Function persistAssistantMessage

lib/services/cli/glm.ts:117–182

(
  projectId: string,
  payload: {
    role: Message['role'];
    messageType: Message['messageType'];
    content: string;
    metadata?: Record<string, unknown> | null;
  },
  requestId?: string,
  overrides?: Partial<RealtimeMessage>,
)

}

async function persistAssistantMessage(
  projectId: string,
  payload: {
    role: Message['role'];
    messageType: Message['messageType'];
    content: string;
    metadata?: Record<string, unknown> | null;
  },
  requestId?: string,
  overrides?: Partial<RealtimeMessage>,
) {
  let lastError: Error | null = null;

  // Retry logic with exponential backoff
  for (let attempt = 1; attempt <= 3; attempt++) {
    try {
      const saved = await createMessage({
        projectId,
        role: payload.role,
        messageType: payload.messageType,
        content: payload.content,
        metadata: payload.metadata ?? null,
        cliSource: 'glm',
        requestId,
      });

      streamManager.publish(projectId, {
        type: 'message',
        data: serializeMessage(saved, {
          ...(requestId ? { requestId } : {}),
          ...(overrides ?? {}),
        }),
      });

      console.log(`[GLMService] Successfully persisted message on attempt ${attempt}`);
      return; // Success, exit the function
    } catch (error) {
      lastError = error as Error;
      console.error(`[GLMService] Attempt ${attempt} failed to persist assistant message:`, error);

      if (attempt < 3) {
        // Exponential backoff: 1s, 2s
        const delayMs = Math.pow(2, attempt - 1) * 1000;
        console.log(`[GLMService] Retrying in ${delayMs}ms...`);
        await new Promise(resolve => setTimeout(resolve, delayMs));
      }
    }
  }

  // All retries failed, fallback to realtime emit
  console.error('[GLMService] All retry attempts failed. Falling back to realtime emit:', lastError);
  const fallback = createRealtimeMessage({
    projectId,
    role: payload.role,
    messageType: payload.messageType,
    content: payload.content,
    metadata: payload.metadata ?? null,
    cliSource: 'glm',