got = set()
with connect(self.conf.get("storage", "dbfn")) as db:
for is_incoming, packet in db.execute(
"select is_incoming, packet from events"
):
msg = parse_message(packet, is_incoming=is_incoming)
got = set()
with connect(self.conf.get("storage", "dbfn")) as db:
for is_incoming, packet in db.execute(
"select is_incoming, packet from events"
):
msg = parse_message(packet, is_incoming=is_incoming)