Add a basic agent with gmail tool use

Author: richard-gyiko

.gitignore

@@ -1,2 +1,5 @@
 .aider*
 .env
+
+credentials.json
+token.json

src/.gitignore

@@ -0,0 +1,162 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+*.py,cover
+.hypothesis/
+.pytest_cache/
+cover/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+db.sqlite3-journal
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+.pybuilder/
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# IPython
+profile_default/
+ipython_config.py
+
+# pyenv
+#   For a library or package, you might want to ignore these files since the code is
+#   intended to run in multiple environments; otherwise, check them in:
+# .python-version
+
+# pipenv
+#   According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control.
+#   However, in case of collaboration, if having platform-specific dependencies or dependencies
+#   having no cross-platform support, pipenv may install dependencies that don't work, or not
+#   install all needed dependencies.
+#Pipfile.lock
+
+# poetry
+#   Similar to Pipfile.lock, it is generally recommended to include poetry.lock in version control.
+#   This is especially recommended for binary packages to ensure reproducibility, and is more
+#   commonly ignored for libraries.
+#   https://python-poetry.org/docs/basic-usage/#commit-your-poetrylock-file-to-version-control
+#poetry.lock
+
+# pdm
+#   Similar to Pipfile.lock, it is generally recommended to include pdm.lock in version control.
+#pdm.lock
+#   pdm stores project-wide configurations in .pdm.toml, but it is recommended to not include it
+#   in version control.
+#   https://pdm.fming.dev/latest/usage/project/#working-with-version-control
+.pdm.toml
+.pdm-python
+.pdm-build/
+
+# PEP 582; used by e.g. github.com/David-OConnor/pyflow and github.com/pdm-project/pdm
+__pypackages__/
+
+# Celery stuff
+celerybeat-schedule
+celerybeat.pid
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Pyre type checker
+.pyre/
+
+# pytype static type analyzer
+.pytype/
+
+# Cython debug symbols
+cython_debug/
+
+# PyCharm
+#  JetBrains specific template is maintained in a separate JetBrains.gitignore that can
+#  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore
+#  and can be added to the global gitignore or merged into this file.  For a more nuclear
+#  option (not recommended) you can uncomment the following to ignore the entire idea folder.
+#.idea/

src/agents/tool_use_agent.py

@@ -0,0 +1,51 @@
+from typing import List
+
+from autogen_core.base import AgentId, MessageContext
+from autogen_core.components import RoutedAgent, message_handler
+from autogen_core.components.models import (
+    ChatCompletionClient,
+    LLMMessage,
+    SystemMessage,
+    UserMessage,
+)
+from autogen_core.components.tool_agent import tool_agent_caller_loop
+from autogen_core.components.tools import ToolSchema
+
+from src.contracts.message import Message
+
+
+class ToolUseAgent(RoutedAgent):
+    def __init__(
+        self,
+        model_client: ChatCompletionClient,
+        tool_schema: List[ToolSchema],
+        tool_agent_type: str,
+    ) -> None:
+        super().__init__("An agent with tools")
+        self._system_messages: List[LLMMessage] = [
+            SystemMessage("You are a helpful AI assistant.")
+        ]
+        self._model_client = model_client
+        self._tool_schema = tool_schema
+        self._tool_agent_id = AgentId(tool_agent_type, self.id.key)
+
+    @message_handler
+    async def handle_user_message(
+        self, message: Message, ctx: MessageContext
+    ) -> Message:
+        # Create a session of messages.
+        session: List[LLMMessage] = [
+            UserMessage(content=message.content, source="user")
+        ]
+        # Run the caller loop to handle tool calls.
+        messages = await tool_agent_caller_loop(
+            self,
+            tool_agent_id=self._tool_agent_id,
+            model_client=self._model_client,
+            input_messages=session,
+            tool_schema=self._tool_schema,
+            cancellation_token=ctx.cancellation_token,
+        )
+        # Return the final response.
+        assert isinstance(messages[-1].content, str)
+        return Message(content=messages[-1].content)

src/contracts/message.py

@@ -0,0 +1,5 @@
+from dataclasses import dataclass
+
+@dataclass
+class Message:
+    content: str

src/main.py

@@ -0,0 +1,48 @@
+import asyncio
+
+from .agents.tool_use_agent import ToolUseAgent
+
+from .tools.tool_factory import get_tools
+from autogen_core.application import SingleThreadedAgentRuntime
+from autogen_core.components.tool_agent import ToolAgent
+from autogen_ext.models import OpenAIChatCompletionClient
+from autogen_core.base import AgentId
+from .contracts.message import Message
+
+from dotenv import load_dotenv
+
+
+async def main():
+    load_dotenv()
+
+    tools = get_tools()
+
+    runtime = SingleThreadedAgentRuntime()
+
+    await ToolAgent.register(
+        runtime, "tool_executor_agent", lambda: ToolAgent("tool executor agent", tools)
+    )
+    await ToolUseAgent.register(
+        runtime,
+        "tool_use_agent",
+        lambda: ToolUseAgent(
+            OpenAIChatCompletionClient(model="gpt-4o-mini"),
+            [tool.schema for tool in tools],
+            "tool_executor_agent",
+        ),
+    )
+
+    runtime.start()
+
+    # Send a direct message to the tool agent.
+    tool_use_agent = AgentId("tool_use_agent", "default")
+    response = await runtime.send_message(
+        Message("What's my latest email about?"), tool_use_agent
+    )
+    print(response.content)
+    # Stop processing messages.
+    await runtime.stop()
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

src/requirements.txt

@@ -0,0 +1,9 @@
+# Console utilities
+rich~=13.9.4
+
+# Autogen
+autogen-core==0.4.0.dev4
+autogen-ext[langchain,openai]==0.4.0.dev4
+
+# Toolkits
+langchain-google-community[gmail]

src/tools/tool_factory.py

@@ -0,0 +1,11 @@
+from langchain_google_community import GmailToolkit
+from autogen_ext.tools import LangChainToolAdapter
+
+
+def get_tools():
+    gmailTookit = GmailToolkit()
+    tools = gmailTookit.get_tools()
+
+    autogen_tools = [LangChainToolAdapter(tool) for tool in tools]
+
+    return autogen_tools