|
|
|
@ -93,8 +93,9 @@ class NodeDbService: |
|
|
|
return await c.to_list() |
|
|
|
|
|
|
|
class PacketDbService: |
|
|
|
def __init__(self, dbStore): |
|
|
|
def __init__(self, dbStore, core): |
|
|
|
self.dbStore:AsyncDatabase = dbStore |
|
|
|
self.core = core |
|
|
|
|
|
|
|
async def findPacketsSignals(self, |
|
|
|
after: float = -1, |
|
|
|
@ -175,7 +176,7 @@ class PacketDbService: |
|
|
|
return [PacketGroup(p, packetsPerNode, packetsSumNode) for p in l] |
|
|
|
|
|
|
|
class DbService(NodeDbService, PacketDbService): |
|
|
|
def __init__(self, dbStore): |
|
|
|
NodeDbService.__init__(self, dbStore) |
|
|
|
PacketDbService.__init__(self, dbStore) |
|
|
|
def __init__(self, dbStore, core): |
|
|
|
NodeDbService.__init__(self, dbStore, core) |
|
|
|
PacketDbService.__init__(self, dbStore, core) |
|
|
|
|