Function persistMessage

lib/services/cli/codex.ts:294–345

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

}

async function persistMessage(
  projectId: string,
  payload: {
    id?: string;
    role: Message['role'];
    messageType: Message['messageType'];
    content: string;
    metadata?: Record<string, unknown> | null;
  },
  requestId?: string,
  overrides?: Partial<RealtimeMessage>
) {
  try {
    const saved = await createMessage({
      ...(payload.id ? { id: payload.id } : {}),
      projectId,
      role: payload.role,
      messageType: payload.messageType,
      content: payload.content,
      metadata: payload.metadata ?? null,
      cliSource: 'codex',
      requestId,
    });

    const serializedOverrides = {
      ...(requestId ? { requestId } : {}),
      ...(overrides ?? {}),
    };

    streamManager.publish(projectId, {
      type: 'message',
      data: serializeMessage(saved, serializedOverrides),
    });
  } catch (error) {
    console.error('[CodexService] Failed to persist message. Falling back to realtime emit:', error);
    const fallback = createRealtimeMessage({
      id: payload.id ?? randomUUID(),
      projectId,
      role: payload.role,
      messageType: payload.messageType,
      content: payload.content,
      metadata: payload.metadata ?? null,
      cliSource: 'codex',
      requestId,
      ...(overrides ?? {}),
    });
    streamManager.publish(projectId, {
      type: 'message',
      data: fallback,
    });
  }
}

const encodeHash = (value: string): string =>
  Buffer.from(value, 'utf-8').toString('base64');