From 8c79f4060c050de7e1d866b0e45922ffa2f67558 Mon Sep 17 00:00:00 2001 From: Moishe Lettvin Date: Thu, 21 Mar 2024 16:26:28 -0400 Subject: [PATCH] clean up errant files --- .../websocket-server/frames.proto | 25 ------------------- src/dailyai/transport/abstract_transport.py | 20 --------------- 2 files changed, 45 deletions(-) delete mode 100644 examples/foundational/websocket-server/frames.proto delete mode 100644 src/dailyai/transport/abstract_transport.py diff --git a/examples/foundational/websocket-server/frames.proto b/examples/foundational/websocket-server/frames.proto deleted file mode 100644 index 7ecea6d25..000000000 --- a/examples/foundational/websocket-server/frames.proto +++ /dev/null @@ -1,25 +0,0 @@ -syntax = "proto3"; - -package dailyai_proto; - -message TextFrame { - string text = 1; -} - -message AudioFrame { - bytes audio = 1; -} - -message TranscriptionFrame { - string text = 1; - string participant_id = 2; - string timestamp = 3; -} - -message Frame { - oneof frame { - TextFrame text = 1; - AudioFrame audio = 2; - TranscriptionFrame transcription = 3; - } -} diff --git a/src/dailyai/transport/abstract_transport.py b/src/dailyai/transport/abstract_transport.py deleted file mode 100644 index 6303d4cdf..000000000 --- a/src/dailyai/transport/abstract_transport.py +++ /dev/null @@ -1,20 +0,0 @@ -import asyncio -from dailyai.pipeline.pipeline import Pipeline - - -class AbstractTransport: - def __init__(self, *args, **kwargs): - self.send_queue: asyncio.Queue = asyncio.Queue() - self.recieve_queue: asyncio.Queue = asyncio.Queue() - - self._mic_enabled = kwargs.get("mic_enabled") or False - self._mic_sample_rate = kwargs.get("mic_sample_rate") or 16000 - self._camera_enabled = kwargs.get("camera_enabled") or False - self._camera_width = kwargs.get("camera_width") or 1024 - self._camera_height = kwargs.get("camera_height") or 768 - self._speaker_enabled = kwargs.get("speaker_enabled") or False - self._speaker_sample_rate = kwargs.get("speaker_sample_rate") or 16000 - self._fps = kwargs.get("fps") or 8 - - async def run(self, pipeline: Pipeline | None = None, override_pipeline_source_queue=True): - pass