Method byId

packages/db/src/services/session.service.ts:428–456

(sessionId: string, projectId: string)

  }

  async byId(sessionId: string, projectId: string) {
    const [sessionRows, hasReplayRows] = await Promise.all([
      clix(this.client)
        .select<IClickhouseSession>(['*'])
        .from(TABLE_NAMES.sessions, true)
        .where('id', '=', sessionId)
        .where('project_id', '=', projectId)
        .where('sign', '=', 1)
        .execute(),
      chQuery<{ n: number }>(
        `SELECT 1 AS n
         FROM ${TABLE_NAMES.session_replay_chunks}
         WHERE session_id = ${sqlstring.escape(sessionId)}
           AND project_id = ${sqlstring.escape(projectId)}
         LIMIT 1`
      ),
    ]);

    if (!sessionRows[0]) {
      throw new Error('Session not found');
    }

    const session = transformSession(sessionRows[0]);

    return {
      ...session,
      hasReplay: hasReplayRows.length > 0,
    };
  }
}

export const sessionService = new SessionService(ch);