run formatter

packages/opencode/src/bus/index.ts

@@ -1,22 +1,22 @@
-import { z, type ZodType } from "zod";
-import { App } from "../app/app";
-import { Log } from "../util/log";
+import { z, type ZodType } from "zod"
+import { App } from "../app/app"
+import { Log } from "../util/log"
 
 export namespace Bus {
-  const log = Log.create({ service: "bus" });
-  type Subscription = (event: any) => void;
+  const log = Log.create({ service: "bus" })
+  type Subscription = (event: any) => void
 
   const state = App.state("bus", () => {
-    const subscriptions = new Map<any, Subscription[]>();
+    const subscriptions = new Map<any, Subscription[]>()
 
     return {
       subscriptions,
-    };
-  });
+    }
+  })
 
-  export type EventDefinition = ReturnType<typeof event>;
+  export type EventDefinition = ReturnType<typeof event>
 
-  const registry = new Map<string, EventDefinition>();
+  const registry = new Map<string, EventDefinition>()
 
   export function event<Type extends string, Properties extends ZodType>(
     type: Type,
@@ -25,9 +25,9 @@ export namespace Bus {
     const result = {
       type,
       properties,
-    };
-    registry.set(type, result);
-    return result;
+    }
+    registry.set(type, result)
+    return result
   }
 
   export function payloads() {
@@ -46,7 +46,7 @@ export namespace Bus {
             }),
         )
         .toArray() as any,
-    );
+    )
   }
 
   export function publish<Definition extends EventDefinition>(
@@ -56,14 +56,14 @@ export namespace Bus {
     const payload = {
       type: def.type,
       properties,
-    };
+    }
     log.info("publishing", {
       type: def.type,
-    });
+    })
     for (const key of [def.type, "*"]) {
-      const match = state().subscriptions.get(key);
+      const match = state().subscriptions.get(key)
       for (const sub of match ?? []) {
-        sub(payload);
+        sub(payload)
       }
     }
   }
@@ -71,31 +71,31 @@ export namespace Bus {
   export function subscribe<Definition extends EventDefinition>(
     def: Definition,
     callback: (event: {
-      type: Definition["type"];
-      properties: z.infer<Definition["properties"]>;
+      type: Definition["type"]
+      properties: z.infer<Definition["properties"]>
     }) => void,
   ) {
-    return raw(def.type, callback);
+    return raw(def.type, callback)
   }
 
   export function subscribeAll(callback: (event: any) => void) {
-    return raw("*", callback);
+    return raw("*", callback)
   }
 
   function raw(type: string, callback: (event: any) => void) {
-    log.info("subscribing", { type });
-    const subscriptions = state().subscriptions;
-    let match = subscriptions.get(type) ?? [];
-    match.push(callback);
-    subscriptions.set(type, match);
+    log.info("subscribing", { type })
+    const subscriptions = state().subscriptions
+    let match = subscriptions.get(type) ?? []
+    match.push(callback)
+    subscriptions.set(type, match)
 
     return () => {
-      log.info("unsubscribing", { type });
-      const match = subscriptions.get(type);
-      if (!match) return;
-      const index = match.indexOf(callback);
-      if (index === -1) return;
-      match.splice(index, 1);
-    };
+      log.info("unsubscribing", { type })
+      const match = subscriptions.get(type)
+      if (!match) return
+      const index = match.indexOf(callback)
+      if (index === -1) return
+      match.splice(index, 1)
+    }
   }
 }