aboutsummaryrefslogtreecommitdiff
blob: 37b8c010868825b3e17757774efb1d1c9f778df6 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
from peewee import *

db = SqliteDatabase("checkinbot.db")
db.connect(reuse_if_open=True)


class BaseModel(Model):
    class Meta:
        database = db


class User(BaseModel):
    telegram_user_id = CharField(unique=True, primary_key=True)
    access_key = CharField(max_length=64)
    home_instance = CharField(max_length=128)
    state = CharField(max_length=128)
    client_id = CharField(max_length=128)
    client_secret = CharField(max_length=128)


class Location(BaseModel):
    fsq_id = CharField(unique=True, primary_key=True)
    name = CharField(max_length=128)
    locality = CharField(max_length=128)
    region = CharField(max_length=128)
    latitude = CharField(max_length=128)
    longitude = CharField(max_length=128)


with db.connection_context():
    db.create_tables([User, Location])


def get_poi_by_fsq_id(fsq_id) -> dict:
    with db.connection_context():
        try:
            poi = Location.get(Location.fsq_id == fsq_id)
            return {
                "name": poi.name,
                "locality": poi.locality,
                "region": poi.region,
                "latitude": poi.latitude,
                "longitude": poi.longitude,
            }
        except DoesNotExist:
            return {}


def create_poi(poi: dict):
    with db.connection_context():
        poi = Location.create(
            fsq_id=poi["fsq_id"],
            name=poi["name"],
            locality=poi["locality"],
            region=poi["region"],
            latitude=poi["latitude"],
            longitude=poi["longitude"],
        )
        poi.save()
Powered by cgit v1.2.3 (git 2.41.0)