mirror of
https://github.com/supabase/supabase.git
synced 2026-10-17 15:19:08 +03:00
141 lines
5.3 KiB
TypeScript
141 lines
5.3 KiB
TypeScript
import * as Sentry from '@sentry/nextjs'
|
|
import { useRouter } from 'next/router'
|
|
import { PropsWithChildren, useEffect } from 'react'
|
|
|
|
import { useParams, useUser } from 'common'
|
|
import { useSendGroupsIdentifyMutation } from 'data/telemetry/send-groups-identify-mutation'
|
|
import { useSendGroupsResetMutation } from 'data/telemetry/send-groups-reset-mutation'
|
|
import { useSendPageLeaveMutation } from 'data/telemetry/send-page-leave-mutation'
|
|
import { useSendPageMutation } from 'data/telemetry/send-page-mutation'
|
|
import { usePrevious } from 'hooks/deprecated'
|
|
import { useSelectedOrganization } from 'hooks/misc/useSelectedOrganization'
|
|
import { IS_PLATFORM, LOCAL_STORAGE_KEYS } from 'lib/constants'
|
|
import { useAppStateSnapshot } from 'state/app-state'
|
|
import { useConsent } from 'ui-patterns/ConsentToast'
|
|
|
|
const getAnonId = async (id: string) => {
|
|
const encoder = new TextEncoder()
|
|
const data = encoder.encode(id)
|
|
const hashBuffer = await crypto.subtle.digest('SHA-256', data)
|
|
const hashArray = Array.from(new Uint8Array(hashBuffer))
|
|
const base64String = btoa(hashArray.map((byte) => String.fromCharCode(byte)).join(''))
|
|
|
|
return base64String
|
|
}
|
|
|
|
const PageTelemetry = ({ children }: PropsWithChildren<{}>) => {
|
|
const user = useUser()
|
|
const router = useRouter()
|
|
const { ref, slug } = useParams()
|
|
const snap = useAppStateSnapshot()
|
|
const organization = useSelectedOrganization()
|
|
|
|
const { consentValue, hasAcceptedConsent } = useConsent()
|
|
const previousPathname = usePrevious(router.pathname)
|
|
|
|
const trackTelemetryPH = consentValue === 'true'
|
|
const { mutate: sendPage } = useSendPageMutation()
|
|
const { mutateAsync: sendPageLeave } = useSendPageLeaveMutation()
|
|
const { mutate: sendGroupsIdentify } = useSendGroupsIdentifyMutation()
|
|
const { mutate: sendGroupsReset } = useSendGroupsResetMutation()
|
|
|
|
useEffect(() => {
|
|
if (consentValue !== null) {
|
|
snap.setIsOptedInTelemetry(hasAcceptedConsent)
|
|
}
|
|
// eslint-disable-next-line react-hooks/exhaustive-deps
|
|
}, [consentValue])
|
|
|
|
useEffect(() => {
|
|
function handleRouteChange() {
|
|
if (snap.isOptedInTelemetry) handlePageTelemetry(window.location.href)
|
|
}
|
|
|
|
// Listen for page changes after a navigation or when the query changes
|
|
router.events.on('routeChangeComplete', handleRouteChange)
|
|
return () => {
|
|
router.events.off('routeChangeComplete', handleRouteChange)
|
|
}
|
|
// eslint-disable-next-line react-hooks/exhaustive-deps
|
|
}, [router, snap.isOptedInTelemetry])
|
|
|
|
useEffect(() => {
|
|
// Send page telemetry on first page load
|
|
// Waiting for router ready before sending page_view
|
|
// if not the path will be dynamic route instead of the browser url
|
|
if (router.isReady && snap.isOptedInTelemetry) {
|
|
handlePageTelemetry(window.location.href)
|
|
}
|
|
// eslint-disable-next-line react-hooks/exhaustive-deps
|
|
}, [router.isReady, snap.isOptedInTelemetry])
|
|
|
|
useEffect(() => {
|
|
// don't set the sentry user id if the user hasn't logged in (so that Sentry errors show null user id instead of anonymous id)
|
|
if (!user?.id) {
|
|
return
|
|
}
|
|
|
|
const setSentryId = async () => {
|
|
let sentryUserId = localStorage.getItem(LOCAL_STORAGE_KEYS.SENTRY_USER_ID)
|
|
if (!sentryUserId) {
|
|
sentryUserId = await getAnonId(user?.id)
|
|
localStorage.setItem(LOCAL_STORAGE_KEYS.SENTRY_USER_ID, sentryUserId)
|
|
}
|
|
Sentry.setUser({ id: sentryUserId })
|
|
}
|
|
|
|
// if an error happens, continue without setting a sentry id
|
|
setSentryId().catch((e) => console.error(e))
|
|
}, [user?.id])
|
|
|
|
useEffect(() => {
|
|
const isLandingOnProjectRoute =
|
|
router.pathname.includes('[ref]') && previousPathname === router.pathname
|
|
const isEnteringProjectRoute =
|
|
!(previousPathname ?? '').includes('[ref]') && router.pathname.includes('[ref]')
|
|
const isLeavingProjectRoute =
|
|
(previousPathname ?? '').includes('[ref]') && !router.pathname.includes('[ref]')
|
|
|
|
const isLandingOnOrgRoute =
|
|
router.pathname.includes('[slug]') && previousPathname === router.pathname
|
|
const isEnteringOrgRoute =
|
|
!(previousPathname ?? '').includes('[slug]') && router.pathname.includes('[slug]')
|
|
const isLeavingOrgRoute =
|
|
(previousPathname ?? '').includes('[slug]') && !router.pathname.includes('[slug]')
|
|
|
|
if (trackTelemetryPH) {
|
|
if (ref && (isLandingOnProjectRoute || isEnteringProjectRoute)) {
|
|
sendGroupsIdentify({ organization_slug: organization?.slug, project_ref: ref as string })
|
|
} else if (slug && (isLandingOnOrgRoute || isEnteringOrgRoute)) {
|
|
sendGroupsIdentify({ organization_slug: slug, project_ref: undefined })
|
|
} else if (isLeavingProjectRoute || isLeavingOrgRoute) {
|
|
sendGroupsReset({
|
|
reset_organization: isLeavingOrgRoute || isLeavingProjectRoute,
|
|
reset_project: isLeavingProjectRoute,
|
|
})
|
|
}
|
|
}
|
|
|
|
// eslint-disable-next-line react-hooks/exhaustive-deps
|
|
}, [trackTelemetryPH, slug, ref, router.pathname])
|
|
|
|
useEffect(() => {
|
|
const handleBeforeUnload = async () => {
|
|
if (snap.isOptedInTelemetry) await sendPageLeave()
|
|
}
|
|
window.addEventListener('beforeunload', handleBeforeUnload)
|
|
|
|
return () => {
|
|
window.removeEventListener('beforeunload', handleBeforeUnload)
|
|
}
|
|
}, [])
|
|
|
|
const handlePageTelemetry = async (route: string) => {
|
|
if (IS_PLATFORM) sendPage({ url: route })
|
|
}
|
|
|
|
return <>{children}</>
|
|
}
|
|
|
|
export default PageTelemetry
|