Merge pull request #60 from maia-iyer/remove_weather_auth

🐛 Remove auth code in weather agent

Author: mrsabath

a2a/weather_service/src/weather_service/agent.py

@@ -88,38 +88,6 @@ async def emit_event(self, message: str, final: bool = False, failed: bool = Fal
                 ),
             )
 
-def get_token() -> str:
-    keycloak_url = os.getenv("KEYCLOAK_URL", "http://keycloak.localtest.me:8080")
-    client_id = os.getenv("CLIENT_NAME", "NOTSET")
-    realm_name = "master"
-    client_secret = os.getenv("CLIENT_SECRET")
-
-    user_username = "test-user"
-    user_password = "test-password"
-
-    # print(f"client_id: {client_id}")
-    logger.info(
-          f"Using client_id='{client_id}' with realm={realm_name}"
-    )
-
-    try:
-        keycloak_openid = KeycloakOpenID(server_url=keycloak_url,
-                                        client_id=client_id,
-                                        realm_name=realm_name,
-                                        client_secret_key=client_secret)
-    
-        access_token = keycloak_openid.token(
-                username=user_username,
-                password=user_password)
-    except Exception as e:
-        raise Exception(f"Authorization error getting the access token: {e}")    
-
-    logger.info(
-          f"Received access token: {access_token}"
-    )
-    return access_token
-
-
 class WeatherExecutor(AgentExecutor):
     """
     A class to handle weather assistant execution for A2A Agent.
@@ -144,15 +112,6 @@ async def execute(self, context: RequestContext, event_queue: EventQueue):
 
         task_updater = TaskUpdater(event_queue, task.id, task.context_id)
 
-        # demo - if keycloak is enabled, try to acquire token
-        try:
-            if os.getenv("KEYCLOAK_URL"):
-                token = get_token()
-                logger.info(f'received token: {token}')
-        except Exception as e:
-            await event_emitter.emit_event(str(e), failed=True)
-            raise Exception(message=str(e))
-
         try:
             output = None
             # Test MCP connection first