Function createAssistantStreamer

lib/services/cli/cursor.ts:267–368

(projectId: string, requestId: string | undefined, options: AssistantStreamerOptions = {})

};

function createAssistantStreamer(projectId: string, requestId: string | undefined, options: AssistantStreamerOptions = {}) {
  let buffer = '';
  let assistantMessageId: string | null = options.initialMessageId ?? null;
  let lastStreamedPayload: string | null = null;
  let lastChunk: string | null = null;

  const normalizeChunk = (value: string) => value.replace(/\r/g, '');

  const isNoiseChunk = (value: string) => {
    const normalized = normalizeChunk(value);
    const trimmed = normalized.trim();
    if (!trimmed) {
      return true;
    }

    // Ignore spinner characters like / - \ |
    if (trimmed.length <= 3 && /^[\-/\\|]+$/.test(trimmed)) {
      return true;
    }

    // Ignore progress dots or ellipsis
    if (/^[.··…]+$/.test(trimmed)) {
      return true;
    }

    return false;
  };

  const buildPayload = () => buffer.trim();

  const streamDraft = () => {
    const content = buildPayload();
    if (!content || content === lastStreamedPayload) {
      return;
    }
    const id = assistantMessageId ?? (assistantMessageId = randomUUID());
    const realtime = createRealtimeMessage({
      id,
      projectId,
      role: 'assistant',
      messageType: 'chat',
      content,
      metadata: { cli_type: 'cursor' },
      requestId,
      isStreaming: true,
      isFinal: false,
    });
    streamManager.publish(projectId, { type: 'message', data: realtime });
    lastStreamedPayload = content;
  };

  const append = (text: string) => {
    if (!text) return;
    if (isNoiseChunk(text)) {
      return;
    }

    const normalized = normalizeChunk(text);