X-Git-Url: http://average.org/gitweb/?a=blobdiff_plain;f=gps303%2Fevstore.py;h=2b23e8e92ef98e4c5ff21a584be786df179859ad;hb=f32d7fdd5312dce5b8df09f9a3360a4f9856ad8f;hp=70a3ac6618bec9bd67f53ff7fa9a30a6d92484c4;hpb=623ff0272e0344c26549bbed937d1d33b9822d18;p=loctrkd.git diff --git a/gps303/evstore.py b/gps303/evstore.py index 70a3ac6..2b23e8e 100644 --- a/gps303/evstore.py +++ b/gps303/evstore.py @@ -1,8 +1,9 @@ """ sqlite event store """ -from sqlite3 import connect +from sqlite3 import connect, OperationalError +from typing import Any, List, Tuple -__all__ = "initdb", "stow" +__all__ = "fetch", "initdb", "stow" DB = None @@ -10,22 +11,30 @@ SCHEMA = """create table if not exists events ( tstamp real not null, imei text, peeraddr text not null, + is_incoming int not null default TRUE, proto int not null, packet blob )""" -def initdb(dbname): +def initdb(dbname: str) -> None: global DB DB = connect(dbname) - DB.execute(SCHEMA) + try: + DB.execute( + """alter table events add column + is_incoming int not null default TRUE""" + ) + except OperationalError: + DB.execute(SCHEMA) -def stow(**kwargs): +def stow(**kwargs: Any) -> None: assert DB is not None parms = { k: kwargs[k] if k in kwargs else v for k, v in ( + ("is_incoming", True), ("peeraddr", None), ("when", 0.0), ("imei", None), @@ -36,10 +45,32 @@ def stow(**kwargs): assert len(kwargs) <= len(parms) DB.execute( """insert or ignore into events - (tstamp, imei, peeraddr, proto, packet) + (tstamp, imei, peeraddr, proto, packet, is_incoming) values - (:when, :imei, :peeraddr, :proto, :packet) + (:when, :imei, :peeraddr, :proto, :packet, :is_incoming) """, parms, ) DB.commit() + + +def fetch( + imei: str, matchlist: List[Tuple[bool, int]], backlog: int +) -> List[Tuple[bool, float, bytes]]: + # matchlist is a list of tuples (is_incoming, proto) + # returns a list of tuples (is_incoming, timestamp, packet) + assert DB is not None + selector = " or ".join( + (f"(is_incoming = ? and proto = ?)" for _ in range(len(matchlist))) + ) + cur = DB.cursor() + cur.execute( + f"""select is_incoming, tstamp, packet from events + where ({selector}) and imei = ? + order by tstamp desc limit ?""", + tuple(item for sublist in matchlist for item in sublist) + + (imei, backlog), + ) + result = list(cur) + cur.close() + return list(reversed(result))