Function set

web/src/server/free-mode-country-access-cache.ts:131–181

({ userId, access, now })

    },

    async set({ userId, access, now }) {
      if (!shouldCacheCountryAccess(access)) return

      const clientIpHash = access.clientIpHash
      if (!clientIpHash) return

      const expiresAt = expiresAtForCountryAccess(access, now)
      const privacyDecision = getFreeModePrivacyDecision(access)
      const privacyProviderDecision = getFreeModePrivacyProviderDecision(access)
      await db
        .insert(schema.freeModeCountryAccessCache)
        .values({
          user_id: userId,
          client_ip_hash: clientIpHash,
          allowed: access.allowed,
          country_code: access.countryCode,
          cf_country: access.cfCountry,
          geoip_country: access.geoipCountry,
          country_block_reason: access.blockReason,
          ip_privacy_signals: access.ipPrivacy?.signals ?? null,
          spur_ip_privacy_signals: access.spurIpPrivacy?.signals ?? null,
          spur_status: access.spurStatus,
          privacy_decision: privacyDecision,
          privacy_provider_decision: privacyProviderDecision,
          checked_at: now,
          expires_at: expiresAt,
          created_at: now,
          updated_at: now,
        })
        .onConflictDoUpdate({
          target: [
            schema.freeModeCountryAccessCache.user_id,
            schema.freeModeCountryAccessCache.client_ip_hash,
          ],
          set: {
            allowed: access.allowed,
            country_code: access.countryCode,
            cf_country: access.cfCountry,
            geoip_country: access.geoipCountry,
            country_block_reason: access.blockReason,
            ip_privacy_signals: access.ipPrivacy?.signals ?? null,
            spur_ip_privacy_signals: access.spurIpPrivacy?.signals ?? null,
            spur_status: access.spurStatus,
            privacy_decision: privacyDecision,
            privacy_provider_decision: privacyProviderDecision,
            checked_at: now,
            expires_at: expiresAt,
            updated_at: now,
          },
        })
    },
  }

export async function getCachedFreeModeCountryAccess(params: {