Method addMessage

server/src/addie/thread-service.ts:435–500

* Add a message to a thread * Automatically assigns sequence_number

(input: CreateMessageInput)

   * Automatically assigns sequence_number
   */
  async addMessage(input: CreateMessageInput): Promise<ThreadMessage> {
    const pool = getPool();
    const client = await pool.connect();

    try {
      await client.query('BEGIN');

      // Get next sequence number
      const seqResult = await client.query<{ next_seq: number }>(
        `SELECT COALESCE(MAX(sequence_number), 0) + 1 as next_seq
         FROM addie_thread_messages WHERE thread_id = $1`,
        [input.thread_id]
      );
      const sequenceNumber = seqResult.rows[0].next_seq;

      // Insert message with enhanced execution metadata
      const result = await client.query<ThreadMessage>(
        `INSERT INTO addie_thread_messages (
          thread_id, role, content, content_sanitized, tools_used, tool_calls,
          knowledge_ids, model, latency_ms, tokens_input, tokens_output,
          flagged, flag_reason, sequence_number,
          timing_system_prompt_ms, timing_total_llm_ms, timing_total_tool_ms,
          processing_iterations, tokens_cache_creation, tokens_cache_read, active_rule_ids,
          router_decision, config_version_id, email_message_id,
          user_id, user_display_name
        ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, $19, $20, $21, $22, $23, $24, $25, $26)
        RETURNING *`,
        [
          input.thread_id,
          input.role,
          stripNullBytesString(input.content),
          input.content_sanitized != null ? stripNullBytesString(input.content_sanitized) : null,
          input.tools_used ? input.tools_used.map(stripNullBytesString) : null,
          input.tool_calls ? stripNullBytesFromJson(JSON.stringify(input.tool_calls)) : null,
          input.knowledge_ids ?? null,
          input.model ?? null,
          input.latency_ms ?? null,
          input.tokens_input ?? null,
          input.tokens_output ?? null,
          input.flagged ?? false,
          input.flag_reason != null ? stripNullBytesString(input.flag_reason) : null,
          sequenceNumber,
          input.timing?.system_prompt_ms ?? null,
          input.timing?.total_llm_ms ?? null,
          input.timing?.total_tool_ms ?? null,
          input.timing?.iterations ?? null,
          input.tokens_cache_creation ?? null,
          input.tokens_cache_read ?? null,
          input.active_rule_ids ?? null,
          input.router_decision ? stripNullBytesFromJson(JSON.stringify(input.router_decision)) : null,
          input.config_version_id ?? null,
          input.email_message_id != null ? stripNullBytesString(input.email_message_id) : null,
          input.user_id ?? null,
          input.user_display_name != null ? stripNullBytesString(input.user_display_name) : null,
        ]
      );

      await client.query('COMMIT');