Function getSessionState

web/src/server/free-session/public-api.ts:559–621

(params: {
  userId: string
  accessTier?: FreebuffAccessTier
  userEmail?: string | null | undefined
  userBanned?: boolean
  claimedInstanceId?: string | null | undefined
  deps?: SessionDeps
})

 *   - `queued` / `active` / `ended` otherwise (see `toSessionStateResponse`)
 */
export async function getSessionState(params: {
  userId: string
  accessTier?: FreebuffAccessTier
  userEmail?: string | null | undefined
  userBanned?: boolean
  claimedInstanceId?: string | null | undefined
  deps?: SessionDeps
}): Promise<FreebuffSessionServerResponse> {
  const deps = params.deps ?? defaultDeps
  const accessTier = params.accessTier ?? 'full'
  if (params.userBanned) {
    return { status: 'banned' }
  }
  if (
    !deps.isWaitingRoomEnabled() ||
    isWaitingRoomBypassedForEmail(params.userEmail)
  ) {
    return { status: 'disabled' }
  }
  const row = await deps.getSessionRow(params.userId)

  // Build a `none` response with live queue depths so the CLI's pre-join
  // picker can show "N ahead" hints without first committing the user to a
  // queue, plus per-user quota snapshots so exhausted models are visible
  // before POST.
  const noneResponse = async (): Promise<FreebuffSessionServerResponse> => {
    const [queueDepthByModel, rateLimitsByModel] = await Promise.all([
      deps.queueDepthsByModel(),
      fetchRateLimitsByModel(params.userId, accessTier, deps),
    ])
    return {
      status: 'none',
      accessTier,
      queueDepthByModel,
      ...nonEmptyRateLimitsByModel(
        onlyUsedRateLimitsByModel(rateLimitsByModel),
      ),
    }
  }

  if (!row) return noneResponse()

  if (!isSessionRowCompatibleWithAccessTier(row, accessTier)) {
    await deps.endSession({
      userId: params.userId,
      now: nowOf(deps),
      sessionLengthMs: deps.sessionLengthMs,
    })
    return noneResponse()
  }

  if (
    row.status === 'active' &&
    params.claimedInstanceId &&
    params.claimedInstanceId !== row.active_instance_id
  ) {
    return { status: 'superseded' }
  }