4f:I[707087,["/_next/static/immutable/chunks/2985g-hklwiee.js","/_next/static/immutable/chunks/0qkc3dps_9x_i.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3thksmxn95rly.js","/_next/static/immutable/chunks/15bpbjna9-vr3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/0agonoz1szsjm.js","/_next/static/immutable/chunks/1ynd3dcge2kn1.js","/_next/static/immutable/chunks/0krdn-21gkgjt.js","/_next/static/immutable/chunks/0n9w9riw96l80.js","/_next/static/immutable/chunks/0w75qangey2ys.js","/_next/static/immutable/chunks/1tge7vcvsb70s.js","/_next/static/immutable/chunks/35ju_ac0ysz07.js"],"RegistryDependencies"] 50:I[512940,["/_next/static/immutable/chunks/2985g-hklwiee.js","/_next/static/immutable/chunks/0qkc3dps_9x_i.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3thksmxn95rly.js","/_next/static/immutable/chunks/15bpbjna9-vr3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/0agonoz1szsjm.js","/_next/static/immutable/chunks/1ynd3dcge2kn1.js","/_next/static/immutable/chunks/0krdn-21gkgjt.js","/_next/static/immutable/chunks/0n9w9riw96l80.js","/_next/static/immutable/chunks/0w75qangey2ys.js","/_next/static/immutable/chunks/1tge7vcvsb70s.js","/_next/static/immutable/chunks/35ju_ac0ysz07.js"],"Installation"] 51:I[314491,["/_next/static/immutable/chunks/2985g-hklwiee.js","/_next/static/immutable/chunks/0qkc3dps_9x_i.js","/_next/static/immutable/chunks/2nvof3-29tvc3.js","/_next/static/immutable/chunks/3thksmxn95rly.js","/_next/static/immutable/chunks/15bpbjna9-vr3.js","/_next/static/immutable/chunks/3tjobt77z_9dj.js","/_next/static/immutable/chunks/0agonoz1szsjm.js","/_next/static/immutable/chunks/1ynd3dcge2kn1.js","/_next/static/immutable/chunks/0krdn-21gkgjt.js","/_next/static/immutable/chunks/0n9w9riw96l80.js","/_next/static/immutable/chunks/0w75qangey2ys.js","/_next/static/immutable/chunks/1tge7vcvsb70s.js","/_next/static/immutable/chunks/35ju_ac0ysz07.js"],"FilesView"] 52:T119f,import { REALTIME_SUBSCRIBE_STATES, RealtimeChannel } from '@supabase/supabase-js' import { useCallback, useEffect, useRef, useState } from 'react' import { createClient } from '@/registry/default/clients/nextjs/lib/supabase/client' /** * Throttle a callback to a certain delay, It will only call the callback if the delay has passed, with the arguments * from the last call */ const useThrottleCallback = ( callback: (...args: Params) => Return, delay: number ) => { const lastCall = useRef(0) const timeout = useRef(null) return useCallback( (...args: Params) => { const now = Date.now() const remainingTime = delay - (now - lastCall.current) if (remainingTime <= 0) { if (timeout.current) { clearTimeout(timeout.current) timeout.current = null } lastCall.current = now callback(...args) } else if (!timeout.current) { timeout.current = setTimeout(() => { lastCall.current = Date.now() timeout.current = null callback(...args) }, remainingTime) } }, [callback, delay] ) } const supabase = createClient() const generateRandomColor = () => `hsl(${Math.floor(Math.random() * 360)}, 100%, 70%)` const generateRandomNumber = () => Math.floor(Math.random() * 100) const EVENT_NAME = 'realtime-cursor-move' type CursorEventPayload = { position: { x: number y: number } user: { id: number name: string } color: string timestamp: number } export const useRealtimeCursors = ({ roomName, username, throttleMs, }: { roomName: string username: string throttleMs: number }) => { const [color] = useState(generateRandomColor()) const [userId] = useState(generateRandomNumber()) const [cursors, setCursors] = useState>({}) const cursorPayload = useRef(null) const channelRef = useRef(null) const callback = useCallback( (event: MouseEvent) => { const { clientX, clientY } = event const payload: CursorEventPayload = { position: { x: clientX, y: clientY, }, user: { id: userId, name: username, }, color: color, timestamp: new Date().getTime(), } cursorPayload.current = payload channelRef.current?.send({ type: 'broadcast', event: EVENT_NAME, payload: payload, }) }, [color, userId, username] ) const handleMouseMove = useThrottleCallback(callback, throttleMs) useEffect(() => { const channel = supabase.channel(roomName) channel .on('presence', { event: 'leave' }, ({ leftPresences }) => { leftPresences.forEach(function (element) { // Remove cursor when user leaves setCursors((prev) => { if (prev[element.key]) { delete prev[element.key] } return { ...prev } }) }) }) .on('presence', { event: 'join' }, () => { if (!cursorPayload.current) return // All cursors broadcast their position when a new cursor joins channelRef.current?.send({ type: 'broadcast', event: EVENT_NAME, payload: cursorPayload.current, }) }) .on('broadcast', { event: EVENT_NAME }, (data: { payload: CursorEventPayload }) => { const { user } = data.payload // Don't render your own cursor if (user.id === userId) return setCursors((prev) => { if (prev[userId]) { delete prev[userId] } return { ...prev, [user.id]: data.payload, } }) }) .subscribe(async (status) => { if (status === REALTIME_SUBSCRIBE_STATES.SUBSCRIBED) { await channel.track({ key: userId }) channelRef.current = channel } else { setCursors({}) channelRef.current = null } }) return () => { channel.unsubscribe() channelRef.current = null } }, []) useEffect(() => { // Add event listener for mousemove window.addEventListener('mousemove', handleMouseMove) // Cleanup on unmount return () => { window.removeEventListener('mousemove', handleMouseMove) } }, [handleMouseMove]) return { cursors } } 53:T94c,import { createServerClient } from '@supabase/ssr' import { NextResponse, type NextRequest } from 'next/server' export async function updateSession(request: NextRequest) { let supabaseResponse = NextResponse.next({ request, }) // With Fluid compute, don't put this client in a global environment // variable. Always create a new one on each request. const supabase = createServerClient( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_PUBLISHABLE_KEY!, { cookies: { getAll() { return request.cookies.getAll() }, setAll(cookiesToSet) { cookiesToSet.forEach(({ name, value }) => request.cookies.set(name, value)) supabaseResponse = NextResponse.next({ request, }) cookiesToSet.forEach(({ name, value, options }) => supabaseResponse.cookies.set(name, value, options) ) }, }, } ) // Do not run code between createServerClient and // supabase.auth.getClaims(). A simple mistake could make it very hard to debug // issues with users being randomly logged out. // IMPORTANT: If you remove getClaims() and you use server-side rendering // with the Supabase client, your users may be randomly logged out. const { data } = await supabase.auth.getClaims() const user = data?.claims if ( !user && !request.nextUrl.pathname.startsWith('/login') && !request.nextUrl.pathname.startsWith('/auth') ) { // no user, potentially respond by redirecting the user to the login page const url = request.nextUrl.clone() url.pathname = '/auth/login' return NextResponse.redirect(url) } // IMPORTANT: You *must* return the supabaseResponse object as it is. // If you're creating a new response object with NextResponse.next() make sure to: // 1. Pass the request in it, like so: // const myNewResponse = NextResponse.next({ request }) // 2. Copy over the cookies, like so: // myNewResponse.cookies.setAll(supabaseResponse.cookies.getAll()) // 3. Change the myNewResponse object to fit your needs, but avoid changing // the cookies! // 4. Finally: // return myNewResponse // If this is not done, you may be causing the browser and server to go out // of sync and terminate the user's session prematurely! return supabaseResponse } 4b:["$","div",null,{"className":"flex flex-col gap-12","children":[["$","div",null,{"className":"pt-10 flex flex-col gap-4","children":[["$","ul",null,{"className":"flex gap-2 flex-wrap","children":[["$","li","lucide-react",{"children":["$","a",null,{"href":"https://www.npmjs.com/package/lucide-react","target":"_blank","rel":"noopener noreferrer","className":"rounded-md border p-2 text-sm flex items-center gap-1 ","children":[["$","svg",null,{"viewBox":"0 0 24 24","className":"size-3","children":["$","path",null,{"d":"M1.763 0C.786 0 0 .786 0 1.763v20.474C0 23.214.786 24 1.763 24h20.474c.977 0 1.763-.786 1.763-1.763V1.763C24 .786 23.214 0 22.237 0zM5.13 5.323l13.837.019-.009 13.836h-3.464l.01-10.382h-3.456L12.04 19.17H5.113z","fill":"currentColor"}]}],["$","span",null,{"className":"text-xs font-medium","children":"lucide-react"}]]}]}],["$","li","@supabase/ssr@latest",{"children":["$","a",null,{"href":"https://www.npmjs.com/package/%40supabase%2Fssr","target":"_blank","rel":"noopener noreferrer","className":"rounded-md border p-2 text-sm flex items-center gap-1 ","children":[["$","svg",null,{"viewBox":"0 0 24 24","className":"size-3","children":["$","path",null,{"d":"M1.763 0C.786 0 0 .786 0 1.763v20.474C0 23.214.786 24 1.763 24h20.474c.977 0 1.763-.786 1.763-1.763V1.763C24 .786 23.214 0 22.237 0zM5.13 5.323l13.837.019-.009 13.836h-3.464l.01-10.382h-3.456L12.04 19.17H5.113z","fill":"currentColor"}]}],["$","span",null,{"className":"text-xs font-medium","children":"@supabase/ssr@latest"}]]}]}],["$","li","@supabase/supabase-js@latest",{"children":["$","a",null,{"href":"https://www.npmjs.com/package/%40supabase%2Fsupabase-js","target":"_blank","rel":"noopener noreferrer","className":"rounded-md border p-2 text-sm flex items-center gap-1 ","children":[["$","svg",null,{"viewBox":"0 0 24 24","className":"size-3","children":["$","path",null,{"d":"M1.763 0C.786 0 0 .786 0 1.763v20.474C0 23.214.786 24 1.763 24h20.474c.977 0 1.763-.786 1.763-1.763V1.763C24 .786 23.214 0 22.237 0zM5.13 5.323l13.837.019-.009 13.836h-3.464l.01-10.382h-3.456L12.04 19.17H5.113z","fill":"currentColor"}]}],["$","span",null,{"className":"text-xs font-medium","children":"@supabase/supabase-js@latest"}]]}]}]]}],["$","$L4f",null,{"registryDependencies":[]}]]}],["$","$L50",null,{"sourceUrl":"https://supabase.com/ui/r/realtime-cursor-nextjs.json","proxyUrl":"https://shadcnregistry.com/r/supabase/realtime-cursor-nextjs","itemId":"@supabase/realtime-cursor-nextjs"}],["$","section",null,{"className":"flex flex-col gap-4","id":"files","children":[["$","h2",null,{"className":"text-lg md:text-2xl font-bold font-mono","children":"Files"}],["$","$L51",null,{"files":[{"path":"registry/default/blocks/realtime-cursor/components/cursor.tsx","content":"import { MousePointer2 } from 'lucide-react'\n\nimport { cn } from '@/lib/utils'\n\nexport const Cursor = ({\n className,\n style,\n color,\n name,\n}: {\n className?: string\n style?: React.CSSProperties\n color: string\n name: string\n}) => {\n return (\n

\n \n\n \n {name}\n

\n \n )\n}\n","type":"registry:component"},{"path":"registry/default/blocks/realtime-cursor/components/realtime-cursors.tsx","content":"'use client'\n\nimport { Cursor } from '@/registry/default/blocks/realtime-cursor/components/cursor'\nimport { useRealtimeCursors } from '@/registry/default/blocks/realtime-cursor/hooks/use-realtime-cursors'\n\nconst THROTTLE_MS = 50\n\nexport const RealtimeCursors = ({ roomName, username }: { roomName: string; username: string }) => {\n const { cursors } = useRealtimeCursors({ roomName, username, throttleMs: THROTTLE_MS })\n\n return (\n

\n {Object.keys(cursors).map((id) => (\n \n ))}\n

\n )\n}\n","type":"registry:component"},{"path":"registry/default/blocks/realtime-cursor/hooks/use-realtime-cursors.ts","content":"$52","type":"registry:hook"},{"path":"registry/default/clients/nextjs/lib/supabase/client.ts","content":"import { createBrowserClient } from '@supabase/ssr'\n\nexport function createClient() {\n return createBrowserClient(\n process.env.NEXT_PUBLIC_SUPABASE_URL!,\n process.env.NEXT_PUBLIC_SUPABASE_PUBLISHABLE_KEY!\n )\n}\n","type":"registry:lib"},{"path":"registry/default/clients/nextjs/lib/supabase/middleware.ts","content":"$53","type":"registry:lib"},{"path":"registry/default/clients/nextjs/lib/supabase/server.ts","content":"import { createServerClient } from '@supabase/ssr'\nimport { cookies } from 'next/headers'\n\n/**\n * If using Fluid compute: Don't put this client in a global variable. Always create a new client within each\n * function when using it.\n */\nexport async function createClient() {\n const cookieStore = await cookies()\n\n return createServerClient(\n process.env.NEXT_PUBLIC_SUPABASE_URL!,\n process.env.NEXT_PUBLIC_SUPABASE_PUBLISHABLE_KEY!,\n {\n cookies: {\n getAll() {\n return cookieStore.getAll()\n },\n setAll(cookiesToSet) {\n try {\n cookiesToSet.forEach(({ name, value, options }) =>\n cookieStore.set(name, value, options)\n )\n } catch {\n // The `setAll` method was called from a Server Component.\n // This can be ignored if you have middleware refreshing\n // user sessions.\n }\n },\n },\n }\n )\n}\n","type":"registry:lib"}]}]]}],"$L54"]}]

Realtime Cursor

Installation

Files

components

hooks

lib

Styles