diff --git a/compose.yml b/compose.yml new file mode 100644 index 00000000..2ba58fa0 --- /dev/null +++ b/compose.yml @@ -0,0 +1,38 @@ +services: + server: + build: + context: server + ports: + - 1250:1250 + volumes: + - ./server/data/:/app/data/ + env_file: + - ./server/.env + environment: + ENTRYPOINT: server + + worker: + build: + context: server + volumes: + - ./server/data/:/app/data/ + env_file: + - ./server/.env + environment: + ENTRYPOINT: worker + + redis: + image: redis:7.2 + ports: + - 6379:6379 + web: + image: node:18 + ports: + - "3000:3000" + command: sh -c "yarn install && yarn dev" + restart: unless-stopped + working_dir: /app + volumes: + - ./www:/app/ + env_file: + - ./www/.env.local diff --git a/docker-compose.yml b/docker-compose.yml deleted file mode 100644 index 9e6519af..00000000 --- a/docker-compose.yml +++ /dev/null @@ -1,28 +0,0 @@ -version: "3.9" -services: - server: - build: - context: server - ports: - - 1250:1250 - volumes: - - model-cache:/root/.cache - environment: ENTRYPOINT=server - worker: - build: - context: server - volumes: - - model-cache:/root/.cache - environment: ENTRYPOINT=worker - redis: - image: redis:7.2 - ports: - - 6379:6379 - web: - build: - context: www - ports: - - 3000:3000 - -volumes: - model-cache: diff --git a/server/docker-compose.yml b/server/docker-compose.yml deleted file mode 100644 index c8432816..00000000 --- a/server/docker-compose.yml +++ /dev/null @@ -1,27 +0,0 @@ -version: "3.9" -services: - server: - build: - context: . - ports: - - 1250:1250 - volumes: - - model-cache:/root/.cache - environment: - ENTRYPOINT: server - REDIS_HOST: redis - worker: - build: - context: . - volumes: - - model-cache:/root/.cache - environment: - ENTRYPOINT: worker - REDIS_HOST: redis - redis: - image: redis:7.2 - ports: - - 6379:6379 - -volumes: - model-cache: diff --git a/server/reflector/pipelines/main_live_pipeline.py b/server/reflector/pipelines/main_live_pipeline.py index f81e37b7..d54ebac0 100644 --- a/server/reflector/pipelines/main_live_pipeline.py +++ b/server/reflector/pipelines/main_live_pipeline.py @@ -53,7 +53,11 @@ from reflector.processors.types import ( from reflector.processors.types import Transcript as TranscriptProcessorType from reflector.settings import settings from reflector.ws_manager import WebsocketManager, get_ws_manager -from reflector.zulip import get_zulip_message, send_message_to_zulip +from reflector.zulip import ( + get_zulip_message, + send_message_to_zulip, + update_zulip_message, +) from structlog import BoundLogger as Logger @@ -573,10 +577,27 @@ async def pipeline_post_to_zulip(transcript: Transcript, logger: Logger): if room.zulip_auto_post: message = get_zulip_message(transcript=transcript, include_topics=True) - response = send_message_to_zulip(room.zulip_stream, room.zulip_topic, message) - await transcripts_controller.update( - transcript, {"zulip_message_id": response["id"]} - ) + message_updated = False + if transcript.zulip_message_id: + try: + update_zulip_message( + transcript.zulip_message_id, + room.zulip_stream, + room.zulip_topic, + message, + ) + message_updated = True + except Exception: + logger.error( + f"Failed to update zulip message with id {transcript.zulip_message_id}" + ) + if not message_updated: + response = send_message_to_zulip( + room.zulip_stream, room.zulip_topic, message + ) + await transcripts_controller.update( + transcript, {"zulip_message_id": response["id"]} + ) logger.info("Posted to zulip") @@ -665,6 +686,13 @@ async def pipeline_process(transcript: Transcript, logger: Logger): try: if transcript.audio_location == "storage": await transcripts_controller.download_mp3_from_storage(transcript) + transcript.audio_waveform_filename.unlink(missing_ok=True) + await transcripts_controller.update( + transcript, + { + "topics": [], + }, + ) # open audio audio_filename = next(transcript.data_path.glob("upload.*"), None) diff --git a/www/docker-compose.yml b/www/docker-compose.yml deleted file mode 100644 index 18a4f860..00000000 --- a/www/docker-compose.yml +++ /dev/null @@ -1,11 +0,0 @@ -version: "3.9" -services: - server: - build: - context: . - ports: - - 80:80 - environment: - LLM_URL: "${LLM_URL}" - volumes: - - model-cache:/root/.cache