chore: wip

Author: glennmichael123

app/Actions/Buddy/BuddyProcessStreamAction.ts

@@ -20,9 +20,9 @@ export default new Action({
 
   async handle(request: RequestInstance) {
     try {
-      const command = request.get<string>('command')
-      const repo = request.get<string>('repo') || request.get<string>('repository')
-      const driver = request.get<string>('driver')
+      const command = request.get('command')
+      const repo = request.get('repo') || request.get('repository')
+      const driver = request.get('driver')
 
       if (!command) {
         return new Response(JSON.stringify({ error: 'Command is required' }), {
@@ -63,15 +63,12 @@ export default new Action({
           const reader = stream.getReader()
 
           try {
-            while (true) {
-              const { done, value } = await reader.read()
-              if (done) break
-
+            let result = await reader.read()
+            while (!result.done) {
               // Convert chunk to text and send as SSE data event
-              const text = decoder.decode(value, { stream: true })
-              // Escape newlines for SSE format
-              const escapedText = text.replace(/\n/g, '\\n')
+              const text = decoder.decode(result.value, { stream: true })
               controller.enqueue(encoder.encode(`event: chunk\ndata: ${JSON.stringify({ text })}\n\n`))
+              result = await reader.read()
             }
 
             // Wait for full response and apply changes

storage/framework/core/realtime/src/emit.ts

@@ -0,0 +1,86 @@
+import type { ChannelType, EmitOptions } from '@stacksjs/types'
+import { config } from '@stacksjs/config'
+import { log } from '@stacksjs/logging'
+import { RealtimeFactory } from './factory'
+
+/**
+ * Emit an event to a channel
+ *
+ * @example
+ * // Simple emit to public channel
+ * emit('orders', 'created', { id: 1, total: 99.99 })
+ *
+ * // Emit to private channel
+ * emit('orders.123', 'updated', { status: 'shipped' }, { private: true })
+ *
+ * // Emit to presence channel
+ * emit('chat.room.1', 'message', { text: 'Hello' }, { presence: true })
+ *
+ * // Exclude specific users
+ * emit('chat.room.1', 'message', { text: 'Hello' }, { exclude: 'user-123' })
+ */
+export function emit<T = unknown>(
+  channel: string,
+  event: string,
+  data?: T,
+  options?: EmitOptions,
+): void {
+  const driverType = options?.driver ?? config.realtime?.driver ?? 'bun'
+  const driver = RealtimeFactory.getInstance().getDriver(driverType)
+
+  // Determine channel type
+  let channelType: ChannelType = 'public'
+  if (options?.presence) {
+    channelType = 'presence'
+  }
+  else if (options?.private) {
+    channelType = 'private'
+  }
+
+  // Build the payload
+  const payload = {
+    data,
+    exclude: options?.exclude
+      ? Array.isArray(options.exclude)
+        ? options.exclude
+        : [options.exclude]
+      : undefined,
+  }
+
+  // Broadcast the event
+  driver.broadcast(channel, event, payload, channelType)
+
+  log.debug(`[realtime] emit "${event}" to ${channelType}:${channel}`)
+}
+
+/**
+ * Emit an event to a specific user
+ *
+ * @example
+ * emitToUser('user-123', 'notification', { message: 'You have a new order!' })
+ */
+export function emitToUser<T = unknown>(
+  userId: string,
+  event: string,
+  data?: T,
+  options?: Omit<EmitOptions, 'private'>,
+): void {
+  emit(`user.${userId}`, event, data, { ...options, private: true })
+}
+
+/**
+ * Emit an event to multiple users
+ *
+ * @example
+ * emitToUsers(['user-1', 'user-2'], 'announcement', { message: 'Server maintenance!' })
+ */
+export function emitToUsers<T = unknown>(
+  userIds: string[],
+  event: string,
+  data?: T,
+  options?: Omit<EmitOptions, 'private'>,
+): void {
+  for (const userId of userIds) {
+    emitToUser(userId, event, data, options)
+  }
+}

storage/framework/core/realtime/src/index.ts

@@ -1,4 +1,5 @@
 export * from './broadcast'
 export * from './channel'
 export * from './drivers'
+export * from './emit'
 export * from './ws'

storage/framework/core/types/src/realtime.ts

@@ -557,3 +557,28 @@ export const RealtimePresets = {
     },
   },
 } as const
+
+/**
+ * Options for the emit function
+ */
+export interface EmitOptions {
+  /**
+   * Make this a private channel (requires authentication)
+   */
+  private?: boolean
+
+  /**
+   * Make this a presence channel (tracks who's online)
+   */
+  presence?: boolean
+
+  /**
+   * Exclude specific user IDs from receiving this event
+   */
+  exclude?: string | string[]
+
+  /**
+   * Specify which driver to use (overrides default)
+   */
+  driver?: DriverType
+}