feat: triage streams with open, close (#121)

* refactor: use interfaces for function params

* cleanup message retention code

* support open / closed streams

- Tabs for viewing separately
- Context menu to close / open streams
- Update stream particle status field

* ui tweak

* show stream state in stream-view

* ui tweaks

* cleanup message retention from orion api

js/src/lib/firestore-particles.ts

@@ -63,6 +63,7 @@ const particleConverter: FirestoreDataConverter<Particle> = {
             : undefined,
           last_child_created_at: raw.last_child_created_at ? (raw.last_child_created_at as Timestamp).toDate() : undefined,
           huddle_active_participants: raw.huddle_active_participants ?? undefined,
+          status: raw.status ?? undefined,
         });
       case "folder":
         return ParticleSchema.parse({
@@ -128,10 +129,17 @@ export async function getParticle(docPath: string): Promise<Particle | null> {
   return doc.data();
 }
 
+export interface GetParticleChildrenOptions {
+  orderByField: string;
+  orderDirection: "asc" | "desc";
+}
+
 export async function getParticleChildren(
   collectionPath: string,
-  orderByField: string = "created_at",
-  orderDirection: "asc" | "desc" = "asc",
+  {
+    orderByField = "created_at",
+    orderDirection = "asc",
+  }: GetParticleChildrenOptions = { orderByField: "created_at", orderDirection: "asc" },
 ): Promise<Particle[]> {
   const q = query(
     typedCollection(collectionPath),
@@ -141,16 +149,29 @@ export async function getParticleChildren(
   return snap.docs.map((d) => d.data());
 }
 
+export interface SubscribeToParticleChildrenOptions {
+  onData: (children: Particle[]) => void;
+  onError: (error: Error) => void;
+  visibilityScopes?: string[];
+  orderByField?: string;
+  orderDirection?: "asc" | "desc";
+  onAdded?: (child: Particle) => void;
+  onRemoved?: (child: Particle, updatedChildren: Particle[]) => void;
+  whereFilter?: QueryFieldFilterConstraint;
+}
+
 export function subscribeToParticleChildren(
   collectionPath: string,
-  onData: (children: Particle[]) => void,
-  onError: (error: Error) => void,
-  visibilityScopes: string[] = [],
-  orderByField: string = "created_at",
-  orderDirection: "asc" | "desc" = "desc",
-  onAdded?: (child: Particle) => void,
-  onRemoved?: (child: Particle, updatedChildren: Particle[]) => void,
-  whereFilter?: QueryFieldFilterConstraint,
+  {
+    onData,
+    onError,
+    visibilityScopes = [],
+    orderByField = "created_at",
+    orderDirection = "desc",
+    onAdded,
+    onRemoved,
+    whereFilter,
+  }: SubscribeToParticleChildrenOptions
 ): Unsubscribe {
   let q = query(typedCollection(collectionPath), orderBy(orderByField, orderDirection));
   if (visibilityScopes.length > 0) {
@@ -225,6 +246,29 @@ export async function createParticle<T extends ParticleType>(
   return ref.id;
 }
 
+export async function createStreamParticle(
+  collectionPath: string,
+  properties: ParticlePropertiesMap["stream"],
+  createdByHumanId: string,
+  visibleTo?: string[],
+): Promise<string> {
+  if (!visibleTo || visibleTo.length === 0) {
+    throw new Error("visibleTo is required for streams and cannot be empty");
+  }
+
+  const particle: Particle = ParticleSchema.parse({
+    id: "",
+    type: "stream",
+    properties,
+    created_at: new Date(),
+    created_by_human_id: createdByHumanId,
+    visible_to: visibleTo,
+    status: "open",
+  });
+  const ref = await addDoc(typedCollection(collectionPath), particle);
+  return ref.id;
+}
+
 // This allows updating properties without overwriting the entire properties object
 export async function updateParticleProperties<T extends ParticleType>(
   docPath: string,
@@ -278,6 +322,14 @@ export async function updateParticle(
   });
 }
 
+export async function updateStreamStatus(
+  docPath: string,
+  status: "open" | "closed",
+): Promise<void> {
+  const particleRef = typedDoc(docPath);
+  await updateDoc(particleRef, { status, updated_at: serverTimestamp() });
+}
+
 export async function updateStreamPlaybackMarker(
   docPath: string,
   humanId: string,