happy tests

Author: tschellenbach

docs/ai/instructions/ai-plugin.md

@@ -1,6 +1,15 @@
 
 # Plugin Development Guide
 
+## Example Plugin
+
+An example plugin is located in `plugins/example`. Copying the example is the best way to create a new plugin. After copying the example be sure to:
+
+- Update the folder name "example" to your plugin's name
+- Open `pyproject.toml` and update the name, description etc
+- Update the event types in your `events.py` file
+- Register your events in the plugin's `__init__` method
+
 ## Folder Structure
 
 Every plugin should follow this structure, an example for the plugin named elevenlabs:
@@ -10,6 +19,8 @@ Every plugin should follow this structure, an example for the plugin named eleve
 - pyproject.toml
 - README.md
 - py.typed
+- tests
+- example
 - vision_agents/plugins/
   - elevenlabs/
     - __init__.py
@@ -31,23 +42,13 @@ tts = elevenlabs.TTS()
 llm = anthropic.LLM()
 ```
 
-## Example Plugin
-
-An example plugin is located in `plugins/example`. Copying the example is the best way to create a new plugin. After copying the example be sure to:
-
-- Update the folder name "example" to your plugin's name
-- Open `pyproject.toml` and update the name, description etc
-- Update the event types in your `events.py` file
-- Register your events in the plugin's `__init__` method
-
 ## Guidelines
 
 When building the plugin read these guides:
 
 - **TTS**: [ai-tts.md](ai-tts.md)
 - **STT**: [ai-stt.md](ai-stt.md)  
-- **STS/realtime/LLM**: [ai-llm.md](ai-llm.md)
-- **Video processor**: [ai-video-processor.md](ai-video-processor.md)
+- **STS/realtime/LLM**: [ai-llm.md](ai-llm.md) or [ai-realtime-llm.md](ai-realtime-llm.md)
 
 ## Update pyproject.toml
 

plugins/aws/README.md

@@ -41,3 +41,19 @@ agent = Agent(
 )
 ```
 
+## Running the examples
+
+Create a `.env` file, or cp .env.example to .env and fill in
+
+```
+STREAM_API_KEY=your_stream_api_key_here
+STREAM_API_SECRET=your_stream_api_secret_here
+
+AWS_BEARER_TOKEN_BEDROCK=
+AWS_ACCESS_KEY_ID=
+AWS_SECRET_ACCESS_KEY=
+
+FAL_KEY=
+CARTESIA_API_KEY=
+DEEPGRAM_API_KEY=
+```

plugins/aws/example/.env.example

@@ -1,7 +1,10 @@
-# Stream API credentials
 STREAM_API_KEY=your_stream_api_key_here
 STREAM_API_SECRET=your_stream_api_secret_here
-EXAMPLE_BASE_URL=https://pronto.getstream.io
 
-# Deepgram API credentials
-DEEPGRAM_API_KEY=your_deepgram_api_key_here
+AWS_BEARER_TOKEN_BEDROCK=
+AWS_ACCESS_KEY_ID=
+AWS_SECRET_ACCESS_KEY=
+
+FAL_KEY=
+CARTESIA_API_KEY=
+DEEPGRAM_API_KEY=

plugins/example/example/.env.example

@@ -0,0 +1,8 @@
+# Stream API credentials
+STREAM_API_KEY=your_stream_api_key_here
+STREAM_API_SECRET=your_stream_api_secret_here
+
+AWS_BEARER_TOKEN_BEDROCK=
+AWS_ACCESS_KEY_ID=
+AWS_SECRET_ACCESS_KEY=
+

plugins/example/example/__init__.py

@@ -0,0 +1,40 @@
+import asyncio
+import logging
+from uuid import uuid4
+
+from dotenv import load_dotenv
+
+from vision_agents.core import User
+from vision_agents.core.agents import Agent
+from vision_agents.plugins import aws, getstream, cartesia, deepgram, smart_turn
+
+load_dotenv()
+
+logging.basicConfig(level=logging.INFO, format="%(asctime)s %(levelname)s [call_id=%(call_id)s] %(name)s: %(message)s")
+logger = logging.getLogger(__name__)
+
+
+async def start_agent() -> None:
+    agent = Agent(
+        edge=getstream.Edge(),
+        agent_user=User(name="Friendly AI"),
+        instructions="Be nice to the user",
+        llm=aws.LLM(model="qwen.qwen3-32b-v1:0"),
+        tts=cartesia.TTS(),
+        stt=deepgram.STT(),
+        turn_detection=smart_turn.TurnDetection(buffer_duration=2.0, confidence_threshold=0.5),
+        # Enable turn detection with FAL/ Smart turn
+    )
+    await agent.create_user()
+
+    call = agent.edge.client.video.call("default", str(uuid4()))
+    await agent.edge.open_demo(call)
+
+    with await agent.join(call):
+        await asyncio.sleep(5)
+        await agent.llm.simple_response(text="Say hi")
+        await agent.finish()
+
+
+if __name__ == "__main__":
+    asyncio.run(start_agent())

plugins/example/example/my_example.py

@@ -0,0 +1,22 @@
+[project]
+name = "my-example"
+version = "0.0.0"
+requires-python = ">=3.10"
+
+# put only what this example needs
+dependencies = [
+  "python-dotenv>=1.0",
+  "vision-agents-plugins-gemini",
+  "vision-agents-plugins-getstream",
+  "vision-agents",
+  "google-genai>=1.33.0",
+  "opentelemetry-exporter-otlp>=1.37.0",
+  "opentelemetry-exporter-prometheus>=0.58b0",
+  "prometheus-client>=0.23.1",
+  "opentelemetry-sdk>=1.37.0",
+]
+
+[tool.uv.sources]
+"vision-agents-plugins-getstream" = {path = "../../../plugins/getstream", editable=true}
+"vision-agents-plugins-gemini" = {path = "../../../plugins/gemini", editable=true}
+"vision-agents" = {path = "../../../agents-core", editable=true}

plugins/example/example/pyproject.toml

@@ -270,48 +270,6 @@ async def another_handler(event: AnotherEvent):
     assert not any("Called handler another_handler" in msg for msg in log_messages)
 
 
-@pytest.mark.asyncio
-async def test_silent_suppresses_handler_logging(caplog):
-    """Test that marking an event as silent suppresses the 'Called handler' log message."""
-    import logging
-    
-    manager = EventManager()
-    manager.register(ValidEvent)
-    manager.register(AnotherEvent)
-    
-    handler_called = []
-    
-    @manager.subscribe
-    async def valid_handler(event: ValidEvent):
-        handler_called.append("valid")
-    
-    @manager.subscribe
-    async def another_handler(event: AnotherEvent):
-        handler_called.append("another")
-    
-    # Mark ValidEvent as silent
-    manager.silent(ValidEvent)
-    
-    # Capture logs at INFO level
-    with caplog.at_level(logging.INFO):
-        # Send both events
-        manager.send(ValidEvent(field=42))
-        manager.send(AnotherEvent(value="test"))
-        await manager.wait()
-    
-    # Both handlers should have been called
-    assert handler_called == ["valid", "another"]
-    
-    # Check log messages
-    log_messages = [record.message for record in caplog.records]
-    
-    # Should NOT see "Called handler" for ValidEvent (it's silent)
-    assert not any("Called handler valid_handler" in msg and "custom.validevent" in msg for msg in log_messages)
-    
-    # SHOULD see "Called handler" for AnotherEvent (not silent)
-    assert any("Called handler another_handler" in msg and "custom.anotherevent" in msg for msg in log_messages)
-
-
 @pytest.mark.asyncio
 @pytest.mark.integration
 async def test_protobuf_events_with_base_event():