From f3b1b035decbae4b78c9028c3c6ee1e1578c2cdb Mon Sep 17 00:00:00 2001 From: Cyber MacGeddon Date: Mon, 31 Mar 2025 23:49:07 +0100 Subject: [PATCH] Dump operation --- .../trustgraph/config/service/service.py | 24 +++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/trustgraph-flow/trustgraph/config/service/service.py b/trustgraph-flow/trustgraph/config/service/service.py index ce5eb605..5820d347 100644 --- a/trustgraph-flow/trustgraph/config/service/service.py +++ b/trustgraph-flow/trustgraph/config/service/service.py @@ -61,6 +61,7 @@ class Processor(ConsumerProducer): value = self.config[v.type][v.key], directory = None, values = None, + config = None, error = None, ) await self.send(r, properties={"id": id}) @@ -71,6 +72,7 @@ class Processor(ConsumerProducer): value=None, directory=None, values=None, + config = None, error=Error( code="no-such-key", message="No such key" @@ -84,6 +86,7 @@ class Processor(ConsumerProducer): value=None, directory=None, values=None, + config = None, error=Error( code="no-such-type", message="No such type" @@ -99,6 +102,7 @@ class Processor(ConsumerProducer): value = None, directory = list(self.config[v.type].keys()) values = None, + config = None, error = None, ) await self.send(r, properties={"id": id}) @@ -109,6 +113,7 @@ class Processor(ConsumerProducer): value=None, directory=None, values=None, + config = None, error=Error( code="no-such-type", message="No such type" @@ -124,6 +129,7 @@ class Processor(ConsumerProducer): value = None, directory = None, values = self.config[v.type] + config = None, error = None, ) await self.send(r, properties={"id": id}) @@ -134,6 +140,7 @@ class Processor(ConsumerProducer): value=None, directory=None, values=None, + config = None, error=Error( code="no-such-type", message="No such type" @@ -150,6 +157,7 @@ class Processor(ConsumerProducer): value = None, directory = None, values = None, + config = None, error = None, ) await self.send(r, properties={"id": id}) @@ -159,6 +167,7 @@ class Processor(ConsumerProducer): value=None, directory=None, values=None, + config = None, error=Error( code="no-such-object", message="No such object" @@ -181,6 +190,17 @@ class Processor(ConsumerProducer): ) await self.send(r, properties={"id": id}) + async def handle_dump(self, v): + + resp = ConfigResponse( + value = None, + directory = None, + values = None, + config = self.config, + error = None, + ) + await self.send(r, properties={"id": id}) + async def handle(self, msg): v = msg.value() @@ -212,6 +232,10 @@ class Processor(ConsumerProducer): self.handle_put(v, id) + elif v.operation == "dump": + + self.handle_dump(v, id) + else: r = ConfigResponse(