microsoft-agents-hosting-core

import os from aiohttp.web import Request, Response, Application from microsoft_agents.hosting.core import AgentApplication, AgentAuthConfiguration, TurnContext from microsoft_agents.hosting.aiohttp import ( start_agent_process, jwt_authorization_middleware, CloudAdapter, ) from microsoft_agents.activity import Activity # Define the Echo Agent using AgentApplication agent_app = AgentApplication() @agent_app.activity("message") async def message_activity_handler(turn_context: TurnContext): await turn_context.send_activity(Activity(text=f"Echo: {turn_context.activity.text}")) async def main(): # Example of setting up auth configuration (for non-anonymous hosting) # Use os.environ.get for dynamic configuration auth_config = AgentAuthConfiguration( TENANT_ID=os.environ.get('TENANT_ID', ''), CLIENT_ID=os.environ.get('CLIENT_ID', ''), CLIENT_SECRET=os.environ.get('CLIENT_SECRET', ''), # Add other auth parameters as needed ) # Start the agent using aiohttp, defaulting to anonymous if no client_id is set await start_agent_process( agent_app, CloudAdapter(), auth_config if auth_config.CLIENT_ID else None, # Pass auth_config only if credentials are provided middlewares=[jwt_authorization_middleware] if auth_config.CLIENT_ID else [], port=3978 # Default port for agents ) if __name__ == "__main__": import asyncio asyncio.run(main())