Shared rooms and transcripts

server/reflector/db/rooms.py

@@ -7,7 +7,7 @@ from fastapi import HTTPException
 from pydantic import BaseModel, Field
 from reflector.db import database, metadata
 from reflector.db.transcripts import generate_uuid4
-from sqlalchemy.sql import false
+from sqlalchemy.sql import false, or_
 
 rooms = sqlalchemy.Table(
     "room",
@@ -77,7 +77,9 @@ class RoomController:
         """
         query = rooms.select()
         if user_id is not None:
-            query = query.where(rooms.c.user_id == user_id)
+            query = query.where(or_(rooms.c.user_id == user_id, rooms.c.is_shared))
+        else:
+            query = query.where(rooms.c.is_shared)
 
         if order_by is not None:
             field = getattr(rooms.c, order_by[1:])

server/reflector/db/transcripts.py

@@ -16,7 +16,7 @@ from reflector.processors.types import Word as ProcessorWord
 from reflector.settings import settings
 from reflector.storage import Storage
 from sqlalchemy import Enum
-from sqlalchemy.sql import false
+from sqlalchemy.sql import false, or_
 
 
 class SourceKind(enum.StrEnum):
@@ -334,7 +334,11 @@ class TranscriptController:
         )
 
         if user_id:
-            query = query.where(transcripts.c.user_id == user_id)
+            query = query.where(
+                or_(transcripts.c.user_id == user_id, rooms.c.is_shared)
+            )
+        else:
+            query = query.where(rooms.c.is_shared)
 
         if source_kind:
             query = query.where(transcripts.c.source_kind == source_kind)