ticketfrei/db.py

230 lines
8.1 KiB
Python
Raw Normal View History

2018-03-28 15:36:35 +00:00
from config import config
2018-03-22 01:23:31 +00:00
import jwt
2018-03-24 15:26:35 +00:00
import logging
from os import urandom
2018-03-28 15:36:35 +00:00
from pylibscrypt import scrypt_mcf
2018-03-22 01:23:31 +00:00
import sqlite3
2018-03-24 15:26:35 +00:00
logger = logging.getLogger(__name__)
2018-03-22 01:23:31 +00:00
class DB(object):
def __init__(self, dbfile):
2018-03-22 01:23:31 +00:00
self.conn = sqlite3.connect(dbfile)
self.cur = self.conn.cursor()
self.create()
2018-03-22 01:23:31 +00:00
self.secret = urandom(32)
2018-03-28 15:36:35 +00:00
def execute(self, *args, **kwargs):
return self.cur.execute(*args, **kwargs)
def commit(self):
self.conn.commit()
def close(self):
self.conn.close()
2018-03-22 01:23:31 +00:00
def create(self):
# init db
self.cur.executescript('''
CREATE TABLE IF NOT EXISTS user (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
passhash TEXT,
enabled INTEGER DEFAULT 1
);
2018-03-28 15:36:35 +00:00
CREATE TABLE IF NOT EXISTS email (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
2018-03-28 15:36:35 +00:00
user_id INTEGER,
email TEXT,
FOREIGN KEY(user_id) REFERENCES user(id)
);
2018-03-28 15:36:35 +00:00
CREATE TABLE IF NOT EXISTS triggerpatterns (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
patterns TEXT,
FOREIGN KEY(user_id) REFERENCES user(id)
);
2018-03-28 15:36:35 +00:00
CREATE TABLE IF NOT EXISTS badwords (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
words TEXT,
FOREIGN KEY(user_id) REFERENCES user(id)
);
CREATE TABLE IF NOT EXISTS mastodon_instances (
2018-03-28 15:36:35 +00:00
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
instance TEXT,
client_id TEXT,
client_secret TEXT
);
CREATE TABLE IF NOT EXISTS mastodon_accounts (
2018-03-28 15:36:35 +00:00
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
access_token TEXT,
instance_id INTEGER,
active INTEGER,
FOREIGN KEY(user_id) REFERENCES user(id),
FOREIGN KEY(instance_id) REFERENCES mastodon_instances(id)
);
CREATE TABLE IF NOT EXISTS seen_toots (
2018-03-28 15:36:35 +00:00
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
mastodon_accounts_id INTEGER,
2018-03-28 15:36:35 +00:00
toot_id TEXT,
FOREIGN KEY(user_id) REFERENCES user(id),
FOREIGN KEY(mastodon_accounts_id)
REFERENCES mastodon_accounts(id)
);
2018-03-28 15:36:35 +00:00
CREATE TABLE IF NOT EXISTS twitter_request_tokens (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
request_token TEXT,
2018-04-14 15:19:20 +00:00
request_token_secret TEXT,
FOREIGN KEY(user_id) REFERENCES user(id)
);
2018-03-28 15:36:35 +00:00
CREATE TABLE IF NOT EXISTS twitter_accounts (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
client_id TEXT,
client_secret TEXT,
active INTEGER,
FOREIGN KEY(user_id) REFERENCES user(id)
);
2018-06-23 22:00:48 +00:00
CREATE TABLE IF NOT EXISTS telegram_accounts (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
apikey TEXT,
active INTEGER,
FOREIGN KEY(user_id) REFERENCES user(id)
);
CREATE TABLE IF NOT EXISTS seen_tweets (
2018-03-28 15:36:35 +00:00
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
twitter_accounts_id INTEGER,
tweet_id TEXT,
FOREIGN KEY(user_id) REFERENCES user(id)
2018-03-28 22:12:19 +00:00
FOREIGN KEY(twitter_accounts_id)
REFERENCES twitter_accounts(id)
2018-03-28 15:36:35 +00:00
);
2018-04-15 09:58:19 +00:00
CREATE TABLE IF NOT EXISTS seen_dms (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
twitter_accounts_id INTEGER,
message_id TEXT,
FOREIGN KEY(user_id) REFERENCES user(id)
FOREIGN KEY(twitter_accounts_id)
REFERENCES twitter_accounts(id)
);
2018-03-28 22:13:00 +00:00
CREATE TABLE IF NOT EXISTS mailinglist (
2018-03-28 15:36:35 +00:00
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
email TEXT,
active INTEGER,
FOREIGN KEY(user_id) REFERENCES user(id)
);
CREATE TABLE IF NOT EXISTS cities (
id INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
user_id INTEGER,
city TEXT,
markdown TEXT,
masto_link TEXT,
twit_link TEXT,
FOREIGN KEY(user_id) REFERENCES user(id),
UNIQUE(user_id, city) ON CONFLICT IGNORE
);
''')
2018-03-22 01:23:31 +00:00
2018-03-28 15:36:35 +00:00
def user_token(self, email, password):
2018-03-22 01:23:31 +00:00
return jwt.encode({
2018-03-28 15:36:35 +00:00
'email': email,
'passhash': scrypt_mcf(
password.encode('utf-8')
).decode('ascii')
2018-03-22 01:23:31 +00:00
}, self.secret).decode('ascii')
def confirm(self, token, city):
2018-03-28 22:12:19 +00:00
from user import User
2018-03-28 15:36:35 +00:00
try:
json = jwt.decode(token, self.secret)
except jwt.DecodeError:
return None # invalid token
if 'passhash' in json.keys():
# create user
2018-03-28 22:59:13 +00:00
self.execute("INSERT INTO user (passhash) VALUES(?);",
2018-03-28 15:36:35 +00:00
(json['passhash'], ))
uid = self.cur.lastrowid
default_triggerpatterns = """
kontroll?e
konti
db
vgn
vag
zivil
sicherheit
uniform
station
bus
bahn
tram
linie
nuernberg
nürnberg
s\d
u\d\d?
"""
self.execute("""INSERT INTO triggerpatterns (user_id, patterns)
VALUES(?, ?); """, (uid, default_triggerpatterns))
self.execute("INSERT INTO badwords (user_id, words) VALUES(?, ?);",
2018-05-25 14:15:44 +00:00
(uid, "bastard"))
2018-03-28 15:36:35 +00:00
else:
uid = json['uid']
self.execute("INSERT INTO email (user_id, email) VALUES(?, ?);",
(uid, json['email']))
2018-06-23 22:00:48 +00:00
self.execute("""INSERT INTO telegram_accounts (user_id, apikey,
active) VALUES(?, ?, ?);""", (uid, "", 1))
2018-03-28 15:36:35 +00:00
self.commit()
user = User(uid)
user.set_city(city)
return user
2018-03-22 01:23:31 +00:00
def by_email(self, email):
2018-03-28 22:12:19 +00:00
from user import User
2018-03-28 15:36:35 +00:00
self.execute("SELECT user_id FROM email WHERE email=?;", (email, ))
try:
uid, = self.cur.fetchone()
except TypeError:
2018-03-22 01:23:31 +00:00
return None
2018-03-28 15:36:35 +00:00
return User(uid)
2018-03-22 01:23:31 +00:00
def by_city(self, city):
from user import User
self.execute("SELECT user_id FROM cities WHERE city=?", (city, ))
try:
uid, = self.cur.fetchone()
except TypeError:
return None
return User(uid)
def user_facing_properties(self, city):
self.execute("""SELECT city, markdown, masto_link, twit_link
FROM cities
WHERE city=?;""", (city, ))
try:
city, markdown, masto_link, twit_link = self.cur.fetchone()
return dict(city=city,
markdown=markdown,
masto_link=masto_link,
twit_link=twit_link,
mailinglist=city + "@" + config["web"]["host"])
except TypeError:
return None
2018-03-28 15:36:35 +00:00
@property
def active_users(self):
2018-03-28 22:12:19 +00:00
from user import User
2018-03-28 15:36:35 +00:00
self.execute("SELECT id FROM user WHERE enabled=1;")
return [User(uid) for uid, in self.cur.fetchall()]
2018-03-22 01:23:31 +00:00
2018-03-28 15:36:35 +00:00
db = DB(config['database']['db_path'])