Method createSession

server/src/db/si-db.ts:171–199

(input: CreateSessionInput)

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

  async createSession(input: CreateSessionInput): Promise<SiSession> {
    const sessionId = `si_${Date.now()}_${uuidv4().slice(0, 8)}`;

    const result = await query(
      `INSERT INTO si_sessions (
        session_id, host_type, host_identifier, member_profile_id, brand_name,
        user_slack_id, user_email, user_name, user_anonymous_id, identity_consent_granted,
        initial_context, campaign_id, offer_id
      ) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13)
      RETURNING *`,
      [
        sessionId,
        input.host_type,
        input.host_identifier,
        input.member_profile_id || null,
        input.brand_name,
        input.user_slack_id || null,
        input.user_email || null,
        input.user_name || null,
        input.user_anonymous_id || null,
        input.identity_consent_granted || false,
        input.initial_context || null,
        input.campaign_id || null,
        input.offer_id || null,
      ]
    );

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

  async getSession(sessionId: string): Promise<SiSession | null> {
    const result = await query(