192 lines
4.4 KiB
Python
192 lines
4.4 KiB
Python
import re
|
|
|
|
from util import hook
|
|
|
|
|
|
db_ready = False
|
|
|
|
|
|
def clean_sql(sql):
|
|
return re.sub(r'\s+', " ", sql).strip()
|
|
|
|
|
|
def db_init(db):
|
|
global db_ready
|
|
if db_ready:
|
|
return
|
|
|
|
exists = db.execute("""
|
|
select exists (
|
|
select * from sqlite_master where type = "table" and name = "todos"
|
|
)
|
|
""").fetchone()[0] == 1
|
|
|
|
if not exists:
|
|
db.execute(clean_sql("""
|
|
create virtual table todos using fts4(
|
|
user,
|
|
text,
|
|
added,
|
|
tokenize=porter
|
|
)"""))
|
|
|
|
db.commit()
|
|
|
|
db_ready = True
|
|
|
|
|
|
def db_getall(db, nick, limit=-1):
|
|
return db.execute("""
|
|
select added, text
|
|
from todos
|
|
where lower(user) = lower(?)
|
|
order by added desc
|
|
limit ?
|
|
|
|
""", (nick, limit))
|
|
|
|
|
|
def db_get(db, nick, note_id):
|
|
return db.execute("""
|
|
select added, text from todos
|
|
where lower(user) = lower(?)
|
|
order by added desc
|
|
limit 1
|
|
offset ?
|
|
""", (nick, note_id)).fetchone()
|
|
|
|
|
|
def db_del(db, nick, limit='all'):
|
|
row = db.execute("""
|
|
delete from todos
|
|
where rowid in (
|
|
select rowid from todos
|
|
where lower(user) = lower(?)
|
|
order by added desc
|
|
limit ?
|
|
offset ?)
|
|
""", (nick,
|
|
-1 if limit == 'all' else 1,
|
|
0 if limit == 'all' else limit))
|
|
db.commit()
|
|
return row
|
|
|
|
|
|
def db_add(db, nick, text):
|
|
db.execute("""
|
|
insert into todos (user, text, added)
|
|
values (?, ?, CURRENT_TIMESTAMP)
|
|
""", (nick, text))
|
|
db.commit()
|
|
|
|
|
|
def db_search(db, nick, query):
|
|
return db.execute("""
|
|
select added, text
|
|
from todos
|
|
where todos match ?
|
|
and lower(user) = lower(?)
|
|
order by added desc
|
|
""", (query, nick))
|
|
|
|
|
|
@hook.command("notes")
|
|
@hook.command
|
|
def note(inp, nick='', chan='', db=None, notice=None, bot=None):
|
|
"""note(s) <add|del|list|search> args -- Manipulates your list of notes."""
|
|
|
|
db_init(db)
|
|
|
|
parts = inp.split()
|
|
cmd = parts[0].lower()
|
|
|
|
args = parts[1:]
|
|
|
|
# code to allow users to access each others factoids and a copy of help
|
|
# ".note (add|del|list|search) [@user] args -- Manipulates your list of todos."
|
|
#if len(args) and args[0].startswith("@"):
|
|
# nick = args[0][1:]
|
|
# args = args[1:]
|
|
|
|
if cmd == 'add':
|
|
if not len(args):
|
|
return "no text"
|
|
|
|
text = " ".join(args)
|
|
|
|
db_add(db, nick, text)
|
|
|
|
notice("Note added!")
|
|
return
|
|
elif cmd == 'get':
|
|
if len(args):
|
|
try:
|
|
index = int(args[0])
|
|
except ValueError:
|
|
notice("Invalid number format.")
|
|
return
|
|
else:
|
|
index = 0
|
|
|
|
row = db_get(db, nick, index)
|
|
|
|
if not row:
|
|
notice("No such entry.")
|
|
return
|
|
notice("[{}]: {}: {}".format(index, row[0], row[1]))
|
|
elif cmd == 'del' or cmd == 'delete' or cmd == 'remove':
|
|
if not len(args):
|
|
return "error"
|
|
|
|
if args[0] == 'all':
|
|
index = 'all'
|
|
else:
|
|
try:
|
|
index = int(args[0])
|
|
except ValueError:
|
|
notice("Invalid number.")
|
|
return
|
|
|
|
rows = db_del(db, nick, index)
|
|
|
|
notice("Deleted {} entries".format(rows.rowcount))
|
|
elif cmd == 'list':
|
|
limit = -1
|
|
|
|
if len(args):
|
|
try:
|
|
limit = int(args[0])
|
|
limit = max(-1, limit)
|
|
except ValueError:
|
|
notice("Invalid number.")
|
|
return
|
|
|
|
rows = db_getall(db, nick, limit)
|
|
|
|
found = False
|
|
|
|
for (index, row) in enumerate(rows):
|
|
notice("[{}]: {}: {}".format(index, row[0], row[1]))
|
|
found = True
|
|
|
|
if not found:
|
|
notice("{} has no entries.".format(nick))
|
|
elif cmd == 'search':
|
|
if not len(args):
|
|
notice("No search query given!")
|
|
return
|
|
query = " ".join(args)
|
|
rows = db_search(db, nick, query)
|
|
|
|
found = False
|
|
|
|
for (index, row) in enumerate(rows):
|
|
notice("[{}]: {}: {}".format(index, row[0], row[1]))
|
|
found = True
|
|
|
|
if not found:
|
|
notice("{} has no matching entries for: {}".format(nick, query))
|
|
|
|
else:
|
|
notice("Unknown command: {}".format(cmd))
|