apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-19 10:11:01 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add push

Browse source
This commit is contained in:
Cyber MacGeddon 2025-04-01 00:08:19 +01:00
parent cbc8e148c1
commit 3f050669b2
1 changed files with 15 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

15
trustgraph-flow/trustgraph/config/service/service.py
View file

@ -175,6 +175,8 @@ class Processor(ConsumerProducer):
) )
await self.send(r, properties={"id": id}) await self.send(r, properties={"id": id})
await self.push()
async def handle_put(self, v): async def handle_put(self, v):
if v.type not in self.config: if v.type not in self.config:
@ -190,6 +192,8 @@ class Processor(ConsumerProducer):
) )
await self.send(r, properties={"id": id}) await self.send(r, properties={"id": id})
await self.push()
async def handle_dump(self, v): async def handle_dump(self, v):
resp = ConfigResponse( resp = ConfigResponse(
@ -201,6 +205,17 @@ class Processor(ConsumerProducer):
) )
await self.send(r, properties={"id": id}) await self.send(r, properties={"id": id})
async def push(self):
resp = ConfigResponse(
value = None,
directory = None,
values = None,
config = self.config,
error = None,
)
self.push_prod.send(r)
async def handle(self, msg): async def handle(self, msg):
v = msg.value() v = msg.value()