Method addMessage

server/src/db/si-db.ts:290–308

(input: AddMessageInput)

  // --------------------------------------------------------------------------

  async addMessage(input: AddMessageInput): Promise<SiSessionMessage> {
    const result = await query(
      `INSERT INTO si_session_messages (session_id, role, content, ui_elements, action_response)
       VALUES ($1, $2, $3, $4, $5)
       RETURNING *`,
      [
        input.session_id,
        input.role,
        input.content,
        input.ui_elements ? JSON.stringify(input.ui_elements) : null,
        input.action_response ? JSON.stringify(input.action_response) : null,
      ]
    );

    // Update session activity
    await this.updateSessionActivity(input.session_id);

    return this.deserializeMessage(result.rows[0]);
  }

  async getSessionMessages(
    sessionId: string,