Added A2A platform and bug fixes in DB monitoring

Adding A2A platform and bug fixes in DB monitoring

A2A platform.
1. Updated Agent class to include A2A as a platform.
2. Implemented A2A as a platform that depedends on BAF's functionality.
3. Created server, agent-card, message router, agent and method registration.
4. Added a test script in examples to test A2A protocol.

Author: natarajan-chidambaram

README.md

@@ -9,6 +9,7 @@
 [![PyPI - License](https://img.shields.io/pypi/l/besser-agentic-framework)](https://opensource.org/license/MIT)
 [![LinkedIn](https://img.shields.io/badge/-LinkedIn-blue?logo=Linkedin&logoColor=white&link=https://www.linkedin.com/in/pireseduardo/)](https://www.linkedin.com/company/besser-agentic-framework)
 [![GitHub Repo stars](https://img.shields.io/github/stars/besser-pearl/besser-agentic-framework?style=social)](https://star-history.com/#besser-pearl/besser-agentic-framework)
+[![SWH](https://archive.softwareheritage.org/badge/origin/https://github.com/BESSER-PEARL/BESSER-Agentic-Framework/)](https://archive.softwareheritage.org/browse/origin/?origin_url=https://github.com/BESSER-PEARL/BESSER-Agentic-Framework)
 
 The BESSER Agentic Framework (BAF) is part of the [BESSER](https://modeling-languages.com/a-smart-low-code-platform-for-smart-software-in-luxembourg-goodbye-barcelona/) (Building Better Smart Software Faster) project. It aims
 to make the design and implementation of agents, bots and chatbots easier and accessible for everyone.
@@ -69,5 +70,6 @@ Note that if you want to set your agent's language to **Luxembourgish**, you wil
 - [telegram_agent](https://github.com/BESSER-PEARL/BESSER-Agentic-Framework/blob/main/besser/agent/test/examples/telegram_agent.py): Introducing the [TelegramPlatform](https://besser-agentic-framework.readthedocs.io/latest/wiki/platforms/telegram_platform.html)
 - [github_agent](https://github.com/BESSER-PEARL/BESSER-Agentic-Framework/blob/main/besser/agent/test/examples/github_agent.py): Introducing [GitHubPlatform](https://besser-agentic-framework.readthedocs.io/latest/wiki/platforms/github_platform.html)
 - [gitlab_agent](https://github.com/BESSER-PEARL/BESSER-Agentic-Framework/blob/main/besser/agent/test/examples/gitlab_agent.py): Introducing the [GitLabPlatform](https://besser-agentic-framework.readthedocs.io/latest/wiki/platforms/gitlab_platform.html)
+- [a2a_multiagent](https://github.com/BESSER-PEARL/BESSER-Agentic-Framework/blob/main/besser/agent/test/examples/a2a_multiagent.py): Introducing the [A2APlatform](https://besser-agentic-framework.readthedocs.io/latest/wiki/platforms/a2a_platform.html)
 
 For more example agents, check out the [BAF-agent-examples](https://github.com/BESSER-PEARL/BAF-agent-examples) repository!

besser/agent/core/agent.py

@@ -30,6 +30,7 @@
 from besser.agent.platforms.websocket.websocket_platform import WebSocketPlatform
 from besser.agent.platforms.github.github_platform import GitHubPlatform
 from besser.agent.platforms.gitlab.gitlab_platform import GitLabPlatform
+from besser.agent.platforms.a2a.a2a_platform import A2APlatform
 
 
 class Agent:
@@ -528,6 +529,16 @@ def use_gitlab_platform(self) -> GitLabPlatform:
         gitlab_platform = GitLabPlatform(self)
         self._platforms.append(gitlab_platform)
         return gitlab_platform
+    
+    def use_a2a_platform(self) -> A2APlatform:
+        """Use the :class: `~besser.agent.platforms.a2a.a2a_platform.A2APlatform` on this agent.
+
+        Returns:
+            A2APlatform: the A2A platform
+        """
+        a2a_platform = A2APlatform(self)
+        self._platforms.append(a2a_platform)
+        return a2a_platform
 
     def _monitoring_db_insert_session(self, session: Session) -> None:
         """Insert a session record into the monitoring database.

besser/agent/db/monitoring_ui/flow_graph.py

@@ -3,18 +3,24 @@
 from pyvis.network import Network
 
 from besser.agent.db.monitoring_db import MonitoringDB, TABLE_TRANSITION, TABLE_SESSION
-from besser.agent.db.monitoring_ui.home import agent_filter
+from besser.agent.db.monitoring_ui.home import agent_filter, session_filter
 
 
 def flow_graph(monitoring_db: MonitoringDB):
     st.header('Flow Graph')
     agent_names = agent_filter(monitoring_db)
     table_transition = monitoring_db.get_table(TABLE_TRANSITION)
+    table_session = monitoring_db.get_table(TABLE_SESSION)
     if agent_names:
-        table_session = monitoring_db.get_table(TABLE_SESSION)
         # Filter the tables by the specified agents
         table_session = table_session[table_session['agent_name'].isin(agent_names)]
         table_transition = table_transition[table_transition['session_id'].isin(table_session['id'])]
+    
+    session_ids = session_filter(monitoring_db)
+    if session_ids:
+        # Filter the tables by the specified sessions
+        table_session = table_session[table_session['session_id'].isin(session_ids)]
+        table_transition = table_transition[table_transition['session_id'].isin(table_session['id'])]
 
     nt = Network("700px", "100%", notebook=True, directed=True)
     state_set = set()
@@ -37,6 +43,9 @@ def flow_graph(monitoring_db: MonitoringDB):
         if source_state not in state_set:
             state_set.add(source_state)
             nt.add_node(source_state, group=1)
+        if dest_state not in state_set:
+            state_set.add(dest_state)
+            nt.add_node(dest_state, group=1)
         if (source_state, dest_state, event, info) not in transition_dict:
             transition_dict[(source_state, dest_state, event, info)] = 1
         else:

besser/agent/db/monitoring_ui/home.py

@@ -72,6 +72,11 @@ def agent_filter(monitoring_db: MonitoringDB):
     agent_names = st.multiselect(label='Select one or more agents', options=agents, placeholder='All agents')
     return agent_names
 
+def session_filter(monitoring_db: MonitoringDB):
+    sessions = monitoring_db.get_table(TABLE_SESSION)['session_id'].unique()
+    session_ids = st.multiselect(label='Select one or more sessions', options=sessions, placeholder='All sessions')
+    return session_ids
+
 
 def get_matched_intents_ratio(monitoring_db: MonitoringDB, agent_names=[]):
     table_intent_prediction = monitoring_db.get_table(TABLE_INTENT_PREDICTION)

besser/agent/nlp/nlp_engine.py

@@ -232,11 +232,12 @@ def text2speech(self, session: Session, text: str):
 
         Returns:
             dict: the speech synthesis as a dictionary containing 2 keys:
+
                 - audio (np.ndarray): the generated audio waveform as a numpy array with dimensions (nb_channels,
-                audio_length), where nb_channels is the number of audio channels (usually 1 for mono) and audio_length is the number
-                of samples in the audio
+                  audio_length), where nb_channels is the number of audio channels (usually 1 for mono) and audio_length is the number
+                  of samples in the audio
                 - sampling_rate (int): an integer value containing the sampling rate, eg. how many samples correspond to
-                one second of audio
+                  one second of audio
         """
 
         user_language = session.get("user_language", "en")

besser/agent/platforms/a2a/__init__.py

@@ -0,0 +1,16 @@
+"""Definition of the agent properties within the ``A2A_platform`` section:"""
+
+from besser.agent.core.property import Property
+
+SECTION_A2A = 'a2a_platform'
+
+A2A_WEBSOCKET_PORT = Property(SECTION_A2A, 'a2a.port', int, 8000)
+"""
+The server local port. This port should be exposed or proxied to make it visible by other Agents
+
+name: ``a2a.port``
+
+type: ``int``
+
+default value: ``8000``
+"""