Merge pull request #6 from Spchdt/new-actions

Fix lint

Author: Spchdt

src/actions/client/echo.py

@@ -1,4 +1,5 @@
-""" Copy text to the user's clipboard. Use this for phone numbers, confirmation codes, addresses, etc. """
+"""Copy text to the user's clipboard. Use this for phone numbers, confirmation codes, addresses, etc."""
+
 from typing import TYPE_CHECKING, Any
 
 from src.actions.base import ServerEventEmitter, register_server_event
@@ -10,7 +11,7 @@
 
 @register_server_event("COPY_TO_CLIPBOARD")
 class CopyToClipboardEmitter(ServerEventEmitter):
-    """ Copy text to the user's clipboard. """
+    """Copy text to the user's clipboard."""
 
     event_type = "COPY_TO_CLIPBOARD"
     description = "Copy text to the user's clipboard. Use this for phone numbers, confirmation codes, addresses, etc."
@@ -23,11 +24,9 @@ class CopyToClipboardEmitter(ServerEventEmitter):
 
     async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:
         text = kwargs.get("text")
-        
+
         return OutboundFrame(
             type="COPY_TO_CLIPBOARD",
-            payload={
-                "text": text
-            },
+            payload={"text": text},
             session_id=ctx.session_id,
-        )
+        )

src/actions/server/copy_to_clipboard.py

@@ -1,4 +1,5 @@
-""" Trigger the client to fetch and share their GPS location. ONLY use this AFTER you have verbally asked for the user's consent and they have explicitly answered Yes. """
+"""Trigger the client to fetch and share their GPS location. ONLY use this AFTER you have verbally asked for the user's consent and they have explicitly answered Yes."""
+
 from typing import TYPE_CHECKING, Any
 
 from src.actions.base import ServerEventEmitter, register_server_event
@@ -10,17 +11,17 @@
 
 @register_server_event("FETCH_LOCATION")
 class FetchLocationEmitter(ServerEventEmitter):
-    """ Trigger the client to fetch and share their GPS location. """
+    """Trigger the client to fetch and share their GPS location."""
 
     event_type = "FETCH_LOCATION"
     description = "Trigger the client to fetch and share their GPS location. ONLY use this AFTER you have verbally asked for the user's consent and they have explicitly answered Yes."
     parameters = {
         # No parameters
     }
 
-    async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:
+    async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:  # noqa: ARG002
         return OutboundFrame(
             type="FETCH_LOCATION",
             payload={},
             session_id=ctx.session_id,
-        )
+        )

src/actions/server/fetch_location.py

@@ -1,4 +1,5 @@
-""" Open a website or Apple Maps link directly on the user's screen. """
+"""Open a website or Apple Maps link directly on the user's screen."""
+
 from typing import TYPE_CHECKING, Any
 
 from src.actions.base import ServerEventEmitter, register_server_event
@@ -10,7 +11,7 @@
 
 @register_server_event("OPEN_URL")
 class OpenUrlEmitter(ServerEventEmitter):
-    """ Open a website or Apple Maps link directly on the user's screen. """
+    """Open a website or Apple Maps link directly on the user's screen."""
 
     event_type = "OPEN_URL"
     description = "Open a website or Apple Maps link directly on the user's screen."
@@ -23,11 +24,9 @@ class OpenUrlEmitter(ServerEventEmitter):
 
     async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:
         url = kwargs.get("url")
-        
+
         return OutboundFrame(
             type="OPEN_URL",
-            payload={
-                "url": url
-            },
+            payload={"url": url},
             session_id=ctx.session_id,
-        )
+        )

src/actions/server/open_url.py

@@ -1,4 +1,5 @@
-""" Trigger the client to temporarily map hardware volume buttons to Yes/No answers. Use this immediately after asking a Yes/No question. """
+"""Trigger the client to temporarily map hardware volume buttons to Yes/No answers. Use this immediately after asking a Yes/No question."""
+
 from typing import TYPE_CHECKING, Any
 
 from src.actions.base import ServerEventEmitter, register_server_event
@@ -10,17 +11,17 @@
 
 @register_server_event("REQUEST_BINARY_INPUT")
 class RequestBinaryInputEmitter(ServerEventEmitter):
-    """ Trigger the client to temporarily map hardware volume buttons to Yes/No answers. """
+    """Trigger the client to temporarily map hardware volume buttons to Yes/No answers."""
 
     event_type = "REQUEST_BINARY_INPUT"
     description = "Trigger the client to temporarily map hardware volume buttons to Yes/No answers. Use this immediately after asking a Yes/No question."
     parameters = {
         # No parameters
     }
 
-    async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:
+    async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:  # noqa: ARG002
         return OutboundFrame(
             type="REQUEST_BINARY_INPUT",
             payload={},
             session_id=ctx.session_id,
-        )
+        )

src/actions/server/request_binary_input.py

@@ -1,4 +1,5 @@
-""" Request the user to take a photo using their camera. Use this when the user asks you to 'look at' something or take a picture. """
+"""Request the user to take a photo using their camera. Use this when the user asks you to 'look at' something or take a picture."""
+
 from typing import TYPE_CHECKING, Any
 
 from src.actions.base import ServerEventEmitter, register_server_event
@@ -10,15 +11,15 @@
 
 @register_server_event("REQUEST_CAMERA_PREVIEW")
 class RequestCameraPreviewEmitter(ServerEventEmitter):
-    """ Request the user to take a photo using their camera. Use this when the user asks you to 'look at' something or take a picture. """
+    """Request the user to take a photo using their camera. Use this when the user asks you to 'look at' something or take a picture."""
 
     event_type = "REQUEST_CAMERA_PREVIEW"
     description = "Request the user to take a photo using their camera. Use this when the user asks you to 'look at' something or take a picture."
     parameters = {
         # No parameters
     }
 
-    async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:
+    async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:  # noqa: ARG002
         # No payload extraction
         return OutboundFrame(
             type="REQUEST_CAMERA_PREVIEW",

src/actions/server/request_camera_preview.py

@@ -1,4 +1,5 @@
-""" Create a local notification/reminder on the user's device. """
+"""Create a local notification/reminder on the user's device."""
+
 from typing import TYPE_CHECKING, Any
 
 from src.actions.base import ServerEventEmitter, register_server_event
@@ -10,7 +11,7 @@
 
 @register_server_event("SET_REMINDER")
 class SetReminderEmitter(ServerEventEmitter):
-    """ Create a local notification/reminder on the user's device. """
+    """Create a local notification/reminder on the user's device."""
 
     event_type = "SET_REMINDER"
     description = "Create a local notification/reminder on the user's device. Parse relative time to an absolute ISO 8601 timestamp."
@@ -22,18 +23,15 @@ class SetReminderEmitter(ServerEventEmitter):
         "time_iso": {
             "type": "string",
             "description": "The exact ISO 8601 timestamp for when the reminder should trigger.",
-        }
+        },
     }
 
     async def tool_fn(self, ctx: "ConnectionContext", **kwargs: Any) -> OutboundFrame:
         message = kwargs.get("message")
         time_iso = kwargs.get("time_iso")
-        
+
         return OutboundFrame(
             type="SET_REMINDER",
-            payload={
-                "message": message,
-                "time_iso": time_iso
-            },
+            payload={"message": message, "time_iso": time_iso},
             session_id=ctx.session_id,
-        )
+        )

src/actions/server/set_reminder.py

@@ -17,21 +17,21 @@
 
 1. **Camera/Photos (REQUEST_CAMERA_PREVIEW)**:
    - When the user asks you to "look at" something, "help me see", or take a picture, say a quick verbal acknowledgment (e.g., "Sure, pull the phone away from your ear and snap a pic"), then IMMEDIATELY invoke the `request_camera_preview` tool.
-   
+
 2. **Location (FETCH_LOCATION)**:
    - **Consent-gated**: Never try to track their location passively. If you need their location (for local recommendations, weather, navigation), you MUST ask them verbally: "Can I use your current location?"
    - Once the user explicitly says "Yes", execute the `fetch_location` tool to retrieve it.
-   
+
 3. **Silent Answers (REQUEST_BINARY_INPUT)**:
    - If you ask a Yes/No question and want to let the user answer silently using their volume buttons, immediately invoke the `request_binary_input` tool right after you ask the question.
    - Example: "Should I book the table? Use your volume up to say yes, volume down for no." -> (Trigger Tool)
-   
+
 4. **Clipboard (COPY_TO_CLIPBOARD)**:
    - If you read out a phone number, address, URL, or confirmation code, ALWAYS use `copy_to_clipboard` to save it to their phone automatically. Let them know you did it: "I've copied that to your clipboard."
-   
+
 5. **Browsing & Navigation (OPEN_URL)**:
    - If you recommend a specific restaurant, location, or website, invoke `open_url` to pop it up straight onto their screen while continuing the chat. Provide standard https:// or maps:// links.
-   
+
 6. **Reminders (SET_REMINDER)**:
    - When asked to remind the user about something later, calculate the absolute ISO 8601 timestamp accurately based on their request and current time, then invoke `set_reminder`. Let them know "Got it, I'll remind you then."
 

src/prompts/jemmie.py

@@ -1,6 +1,7 @@
 import asyncio
 
 import pytest
+from src.actions.client.echo import EchoActionHandler
 
 from src.actions import (
     get_all_client_actions,
@@ -9,7 +10,6 @@
     get_client_handler,
     get_server_event_emitter,
 )
-from src.actions.client.echo import EchoActionHandler
 from src.actions.server.set_timer import SetTimerEmitter
 from src.engine.connection_context import ConnectionContext
 from src.pipelines.action import ActionPipeline