refactor(streaming): import SSE helpers directly

Author: waleedlatif1

apps/sim/app/api/copilot/chat/stream/route.test.ts

@@ -38,7 +38,6 @@ vi.mock('@/lib/copilot/request/session', () => ({
   }),
   encodeSSEEnvelope: (event: Record<string, unknown>) =>
     new TextEncoder().encode(`data: ${JSON.stringify(event)}\n\n`),
-  encodeSSEComment: (comment: string) => new TextEncoder().encode(`: ${comment}\n\n`),
   SSE_RESPONSE_HEADERS: {
     'Content-Type': 'text/event-stream',
   },

apps/sim/app/api/copilot/chat/stream/route.ts

@@ -22,13 +22,13 @@ import { getCopilotTracer, markSpanForError } from '@/lib/copilot/request/otel'
 import {
   checkForReplayGap,
   createEvent,
-  encodeSSEComment,
   encodeSSEEnvelope,
   readEvents,
   readFilePreviewSessions,
   SSE_RESPONSE_HEADERS,
 } from '@/lib/copilot/request/session'
 import { toStreamBatchEvent } from '@/lib/copilot/request/session/types'
+import { encodeSSEComment } from '@/lib/core/utils/sse'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
 
 export const maxDuration = 3600

apps/sim/lib/copilot/request/session/index.ts

@@ -71,6 +71,6 @@ export {
   isFilePreviewSession,
 } from './file-preview-session-contract'
 export { checkForReplayGap, type ReplayGapResult } from './recovery'
-export { encodeSSEComment, encodeSSEEnvelope, SSE_RESPONSE_HEADERS } from './sse'
+export { encodeSSEEnvelope, SSE_RESPONSE_HEADERS } from './sse'
 export type { StreamBatchEvent } from './types'
 export { StreamWriter, type StreamWriterOptions } from './writer'

apps/sim/lib/copilot/request/session/sse.ts

@@ -1,7 +1,5 @@
 import { SSE_HEADERS } from '@/lib/core/utils/sse'
 
-export { encodeSSEComment } from '@/lib/core/utils/sse'
-
 const encoder = new TextEncoder()
 
 export function encodeSSEEnvelope(envelope: unknown): Uint8Array {

apps/sim/lib/copilot/request/session/writer.ts

@@ -1,10 +1,11 @@
 import { createLogger } from '@sim/logger'
 import { toError } from '@sim/utils/errors'
 import { MothershipStreamV1EventType } from '@/lib/copilot/generated/mothership-stream-v1'
+import { encodeSSEComment } from '@/lib/core/utils/sse'
 import { appendEvents } from './buffer'
 import type { PersistedStreamEventEnvelope } from './contract'
 import { createEvent } from './event'
-import { encodeSSEComment, encodeSSEEnvelope } from './sse'
+import { encodeSSEEnvelope } from './sse'
 import type { StreamEvent } from './types'
 
 const logger = createLogger('StreamWriter')