Function getDistinctId

packages/sdk/src/utils/observability.ts:82–124

(
  apiKey: string,
  apiUrl: string,
)

}

async function getDistinctId(
  apiKey: string,
  apiUrl: string,
): Promise<{ identity: IdentityInfo; email?: string }> {
  const cached = identityCache.get(apiKey);
  if (cached) return cached;

  try {
    const res = await fetch(`${apiUrl}/users/me`, {
      method: "GET",
      headers: {
        "X-API-Key": apiKey,
        "Content-Type": "application/json",
      },
    });

    if (res.ok) {
      const payload = await res.json();
      if (payload?.id) {
        const result = {
          identity: {
            distinct_id: payload.id,
            distinct_id_source: "database_id",
          },
          email: payload.email || undefined,
        };
        identityCache.set(apiKey, result);
        return result;
      }
    }
  } catch {
    // Fall through to API key hash
  }

  // Don't cache the fallback — a transient /users/me failure should not poison the cache for the entire process lifetime
  const hash = createHash("sha256").update(apiKey).digest("hex").slice(0, 16);
  return {
    identity: {
      distinct_id: `apikey-${hash}`,
      distinct_id_source: "api_key_hash",
    },
  };
}

export function _resetIdentityCache() {
  identityCache.clear();