fix: gemini async client, events base class for start/finish

Author: yarikdevcom

agents-core/vision_agents/core/agents/events.py

@@ -1,5 +1,5 @@
 from dataclasses import dataclass, field
-from vision_agents.core.events import PluginBaseEvent
+from vision_agents.core.events import PluginBaseEvent, BaseEvent
 from typing import Optional, Any, Dict
 
 

plugins/gemini/vision_agents/plugins/gemini/gemini_llm.py

@@ -2,7 +2,7 @@
 from typing import Optional, List, TYPE_CHECKING, Any, Dict
 
 from google import genai
-from google.genai.client import AsyncClient
+from google.genai.client import AsyncClient, Client
 from google.genai import types
 from google.genai.types import GenerateContentResponse, GenerateContentConfig
 
@@ -55,7 +55,7 @@ def __init__(self, model: str, api_key: Optional[str] = None, client: Optional[A
         if client is not None:
             self.client = client
         else:
-            self.client = AsyncClient(api_key=api_key)
+            self.client = Client(api_key=api_key).aio
 
     async def simple_response(self, text: str, processors: Optional[List[Processor]] = None, participant: Optional[Any] = None) -> LLMResponseEvent[Any]:
         """
@@ -108,7 +108,8 @@ async def send_message(self, *args, **kwargs):
         # Gemini API does not have an item_id, we create it here and add it to all events
         item_id = str(uuid.uuid4())
 
-        for idx, chunk in enumerate(iterator):
+        idx = 0
+        async for chunk in iterator:
             response_chunk: GenerateContentResponse = chunk
             final_chunk = response_chunk
             self._standardize_and_emit_event(response_chunk, text_parts, item_id, idx)
@@ -120,6 +121,8 @@ async def send_message(self, *args, **kwargs):
             except Exception:
                 pass  # Ignore errors in chunk processing
 
+            idx += 1
+
         # Check if there were function calls in the response
         if pending_calls:
             # Multi-hop tool calling loop