Method getSessionMessages

server/src/db/si-db.ts:310–333

(
    sessionId: string,
    limit?: number
  )

  }

  async getSessionMessages(
    sessionId: string,
    limit?: number
  ): Promise<SiSessionMessage[]> {
    let sql =
      "SELECT * FROM si_session_messages WHERE session_id = $1 ORDER BY created_at ASC";
    const params: (string | number)[] = [sessionId];

    if (limit) {
      sql =
        "SELECT * FROM si_session_messages WHERE session_id = $1 ORDER BY created_at DESC LIMIT $2";
      params.push(limit);
    }

    const result = await query(sql, params);
    const messages = result.rows.map((row) => this.deserializeMessage(row));

    // If we limited, reverse to get chronological order
    if (limit) {
      messages.reverse();
    }

    return messages;
  }

  // --------------------------------------------------------------------------
  // Relationship Memory