diff --git a/app/doorboy-proxy.py b/app/doorboy-proxy.py index 4ef5f45..4dc450a 100755 --- a/app/doorboy-proxy.py +++ b/app/doorboy-proxy.py @@ -146,7 +146,7 @@ async def view_longpoll(request): } ] try: - async with request.app.ctx.db.eventlog.watch(pipeline) as stream: + async with request.app.ctx.db.doorlog.watch(pipeline) as stream: await response.send("data: watch-stream-opened\n\n") async for event in stream: ev = event["fullDocument"] @@ -205,7 +205,6 @@ async def swipe(request): ) event_swipe = { - "component": "doorboy", "method": "card", "timestamp": timestamp, "door": data["door"], @@ -218,7 +217,7 @@ async def swipe(request): }, "uid_hash": data["uid_hash"], } - await request.app.ctx.db.eventlog.insert_one(event_swipe) + await request.app.ctx.db.doorlog.insert_one(event_swipe) return text("ok") diff --git a/app/slack.py b/app/slack.py index a6cb02f..e6ace0e 100644 --- a/app/slack.py +++ b/app/slack.py @@ -48,7 +48,7 @@ async def slack_log_fwd(app, loop): ] while True: try: - async with app.ctx.db.eventlog.watch(pipeline) as stream: + async with app.ctx.db.doorlog.watch(pipeline) as stream: async for event in stream: ev = event["fullDocument"] @@ -120,9 +120,8 @@ async def slack_open(request): doors = ["backdoor", "frontdoor", "grounddoor"] for d in doors: - await request.app.ctx.db.eventlog.insert_one( + await request.app.ctx.db.doorlog.insert_one( { - "component": "doorboy", "method": "slack", "timestamp": datetime.now(timezone.utc), "door": d,