From 1762ecaf904ef9c793e402587fa70d83622e5181 Mon Sep 17 00:00:00 2001
From: Cyber MacGeddon <cybermaggedon@gmail.com>
Date: Tue, 1 Apr 2025 16:45:22 +0100
Subject: [PATCH] Add missing file

---
 trustgraph-flow/trustgraph/gateway/config.py | 51 ++++++++++++++++++++
 1 file changed, 51 insertions(+)
 create mode 100644 trustgraph-flow/trustgraph/gateway/config.py

diff --git a/trustgraph-flow/trustgraph/gateway/config.py b/trustgraph-flow/trustgraph/gateway/config.py
new file mode 100644
index 00000000..40b35461
--- /dev/null
+++ b/trustgraph-flow/trustgraph/gateway/config.py
@@ -0,0 +1,51 @@
+
+from .. schema import ConfigRequest, ConfigResponse
+from .. schema import config_request_queue
+from .. schema import config_response_queue
+
+from . endpoint import ServiceEndpoint
+from . requestor import ServiceRequestor
+
+class ConfigRequestor(ServiceRequestor):
+    def __init__(self, pulsar_client, timeout, auth):
+
+        super(ConfigRequestor, self).__init__(
+            pulsar_client=pulsar_client,
+            request_queue=config_request_queue,
+            response_queue=config_response_queue,
+            request_schema=ConfigRequest,
+            response_schema=ConfigResponse,
+            timeout=timeout,
+        )
+
+    def to_request(self, body):
+
+        return ConfigRequest(
+            operation = body.get("operation", None),
+            type = body.get("type", None),
+            key = body.get("key", None),
+            value = body.get("value", None),
+        )
+
+    def from_response(self, message):
+
+        response = {
+        }
+
+        if message.version:
+            response["version"] = message.version
+
+        if message.value:
+            response["value"] = message.value
+
+        if message.directory:
+            response["directory"] = message.directory
+
+        if message.values:
+            response["values"] = message.values
+
+        if message.config:
+            response["config"] = message.config
+
+        return response, True
+