From 65f2398bdaba7a6b93395a3cbe70f0451e433d44 Mon Sep 17 00:00:00 2001 From: poorva1209 Date: Thu, 8 Jun 2023 10:47:10 -0700 Subject: [PATCH 1/2] added agent pub sub methods --- .../gridappsd/field_interface/agents/agents.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/gridappsd-field-bus-lib/gridappsd/field_interface/agents/agents.py b/gridappsd-field-bus-lib/gridappsd/field_interface/agents/agents.py index ff48e57..d5cbbb0 100644 --- a/gridappsd-field-bus-lib/gridappsd/field_interface/agents/agents.py +++ b/gridappsd-field-bus-lib/gridappsd/field_interface/agents/agents.py @@ -186,7 +186,7 @@ def on_upstream_message(self, headers: Dict, message) -> None: def on_downstream_message(self, headers: Dict, message) -> None: raise NotImplementedError( f"{self.__class__.__name__} must be overriden in child class") - + def on_request_from_uptream(self, headers: Dict, message): self.on_request(self.upstream_message_bus, headers, message) @@ -203,6 +203,12 @@ def get_registration_details(self): self.upstream_message_bus.id, self.downstream_message_bus.id) return dataclasses.asdict(details) + + def publish_downstream(self, message): + self.downstream_message_bus.send(t.field_message_bus_topic(self.downstream_message_bus), message) + + def publish_upstream(self, message): + self.downstream_message_bus.send(t.field_message_bus_topic(self.downstream_message_bus), message) ''' TODO this has not been implemented yet, so we are commented them out for now. From 919e29967a9d1d0690d8208a7dd87f612e00c9e9 Mon Sep 17 00:00:00 2001 From: Craig <3979063+craig8@users.noreply.github.com> Date: Thu, 8 Jun 2023 19:44:45 +0000 Subject: [PATCH 2/2] Remove line --- .../gridappsd/field_interface/agents/agents.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gridappsd-field-bus-lib/gridappsd/field_interface/agents/agents.py b/gridappsd-field-bus-lib/gridappsd/field_interface/agents/agents.py index d5cbbb0..873f2eb 100644 --- a/gridappsd-field-bus-lib/gridappsd/field_interface/agents/agents.py +++ b/gridappsd-field-bus-lib/gridappsd/field_interface/agents/agents.py @@ -186,7 +186,7 @@ def on_upstream_message(self, headers: Dict, message) -> None: def on_downstream_message(self, headers: Dict, message) -> None: raise NotImplementedError( f"{self.__class__.__name__} must be overriden in child class") - + def on_request_from_uptream(self, headers: Dict, message): self.on_request(self.upstream_message_bus, headers, message)