feat: added correct message
ref: N25B-400
This commit is contained in:
@@ -7,6 +7,7 @@ from control_backend.agents import BaseAgent
|
|||||||
from control_backend.agents.bdi.agentspeak_generator import AgentSpeakGenerator
|
from control_backend.agents.bdi.agentspeak_generator import AgentSpeakGenerator
|
||||||
from control_backend.core.agent_system import InternalMessage
|
from control_backend.core.agent_system import InternalMessage
|
||||||
from control_backend.core.config import settings
|
from control_backend.core.config import settings
|
||||||
|
from control_backend.schemas.belief_message import Belief, BeliefMessage
|
||||||
from control_backend.schemas.program import ConditionalNorm, Program
|
from control_backend.schemas.program import ConditionalNorm, Program
|
||||||
from control_backend.schemas.ri_message import (
|
from control_backend.schemas.ri_message import (
|
||||||
GestureCommand,
|
GestureCommand,
|
||||||
@@ -119,7 +120,7 @@ class UserInterruptAgent(BaseAgent):
|
|||||||
event_context,
|
event_context,
|
||||||
)
|
)
|
||||||
elif asl_goal := self._goal_map.get(ui_id):
|
elif asl_goal := self._goal_map.get(ui_id):
|
||||||
await self._send_to_bdi("complete_goal", asl_goal)
|
await self._send_to_bdi_belief(asl_goal)
|
||||||
self.logger.info(
|
self.logger.info(
|
||||||
"Forwarded button press (override) with context '%s' to BDI Core.",
|
"Forwarded button press (override) with context '%s' to BDI Core.",
|
||||||
event_context,
|
event_context,
|
||||||
@@ -134,6 +135,9 @@ class UserInterruptAgent(BaseAgent):
|
|||||||
await self.send(goal_achieve_msg)
|
await self.send(goal_achieve_msg)
|
||||||
else:
|
else:
|
||||||
self.logger.warning("Could not determine which element to override.")
|
self.logger.warning("Could not determine which element to override.")
|
||||||
|
self.logger.warning(self._goal_map)
|
||||||
|
self.loger.warning(ui_id)
|
||||||
|
|
||||||
elif event_type == "pause":
|
elif event_type == "pause":
|
||||||
self.logger.debug(
|
self.logger.debug(
|
||||||
"Received pause/resume button press with context '%s'.", event_context
|
"Received pause/resume button press with context '%s'.", event_context
|
||||||
@@ -305,6 +309,20 @@ class UserInterruptAgent(BaseAgent):
|
|||||||
await self.send(msg)
|
await self.send(msg)
|
||||||
self.logger.info(f"Directly forced {thread} in BDI: {body}")
|
self.logger.info(f"Directly forced {thread} in BDI: {body}")
|
||||||
|
|
||||||
|
async def _send_to_bdi_belief(self, asl_goal: str):
|
||||||
|
"""Send belief to BDI Core"""
|
||||||
|
belief_name = f"achieved_{asl_goal}"
|
||||||
|
belief = Belief(name=belief_name)
|
||||||
|
self.logger.debug(f"Sending belief to BDI Core: {belief_name}")
|
||||||
|
belief_message = BeliefMessage(create=[belief])
|
||||||
|
msg = InternalMessage(
|
||||||
|
to=settings.agent_settings.bdi_core_name,
|
||||||
|
thread="belief_update",
|
||||||
|
body=belief_message.model_dump_json(),
|
||||||
|
)
|
||||||
|
await self.send(msg)
|
||||||
|
self.logger.info(f"Sent belief to BDI Core: {msg}")
|
||||||
|
|
||||||
async def _send_experiment_control_to_bdi_core(self, type):
|
async def _send_experiment_control_to_bdi_core(self, type):
|
||||||
"""
|
"""
|
||||||
method to send experiment control buttons to bdi core.
|
method to send experiment control buttons to bdi core.
|
||||||
|
|||||||
Reference in New Issue
Block a user