Upload 184 files

src/app/profile/page.tsx

@@ -4,7 +4,7 @@ import Link from 'next/link'
 import { useEffect, useState } from 'react'
 import type { Database } from 'types/database'
 import { isSupabaseBrowserConfigured } from 'lib/supabase/publicEnv'
-import { useAuth } from 'hooks/useAuth'
+import { emitAuthChanged, useAuth } from 'hooks/useAuth'
 
 type ProfileRow = Database['public']['Tables']['users']['Row']
 
@@ -17,12 +17,12 @@ export default function ProfilePage() {
   const [loading, setLoading] = useState(false)
 
   useEffect(() => {
-    const load = async () => {
-      if (!authUser) return
-      setLoading(true)
-      try {
+    const load = async () => {
+      if (!authUser) return
+      setLoading(true)
+      try {
         const res = await fetch('/api/profile', { cache: 'no-store', credentials: 'include' })
-        if (res.ok) {
+        if (res.ok) {
           const json = await res.json()
           setProfile(json.profile || null)
           setRoomsCount(json.roomsCount || 0)
@@ -31,8 +31,8 @@ export default function ProfilePage() {
         setLoading(false)
       }
     }
-    load()
-  }, [authUser])
+    load()
+  }, [authUser])
 
   if (!supabaseConfigured) {
     return (

src/components/forms/LoginForm.tsx

@@ -5,6 +5,7 @@ import { useForm } from 'react-hook-form'
 import { zodResolver } from '@hookform/resolvers/zod'
 import { useRouter } from 'next/navigation'
 import { loginSchema, type LoginForm } from 'lib/validations/auth'
+import { emitAuthChanged } from 'hooks/useAuth'
 import { getSupabaseBrowserConfig, isSupabaseBrowserConfigured } from 'lib/supabase/publicEnv'
 
 export function LoginForm() {
@@ -40,6 +41,7 @@ export function LoginForm() {
         return
       }
 
+      emitAuthChanged()
       router.push('/dashboard')
     } catch (e: any) {
       console.error('Login error:', e)
@@ -116,3 +118,4 @@ export function LoginForm() {
     </form>
   )
 }
+

src/components/layout/Header.tsx

@@ -1,6 +1,6 @@
 'use client'
 
-import { useAuth } from 'hooks/useAuth'
+import { emitAuthChanged, useAuth } from 'hooks/useAuth'
 import { useRouter, usePathname } from 'next/navigation'
 import Link from 'next/link'
 
@@ -11,6 +11,7 @@ export function Header() {
 
   const handleLogout = async () => {
     await fetch('/api/auth/logout', { method: 'POST', credentials: 'include' })
+    emitAuthChanged()
     router.push('/')
   }
 

src/hooks/useAuth.ts

@@ -4,25 +4,39 @@ import { useEffect, useState } from 'react'
 
 type AuthUser = { id: string; email?: string | null }
 
+const AUTH_EVENT = 'letschat-auth-refresh'
+
+export const emitAuthChanged = () => {
+  if (typeof window !== 'undefined') {
+    window.dispatchEvent(new Event(AUTH_EVENT))
+  }
+}
+
 export function useAuth() {
   const [user, setUser] = useState<AuthUser | null>(null)
   const [loading, setLoading] = useState(true)
 
-  useEffect(() => {
-    const init = async () => {
-      try {
-        const res = await fetch('/api/auth/me', { cache: 'no-store', credentials: 'include' })
-        const data = await res.json().catch(() => ({}))
-        setUser(data?.user ? { id: data.user.id, email: data.user.email } as any : null)
-      } catch (e) {
-        setUser(null)
-      } finally {
-        setLoading(false)
-      }
+  const refresh = async () => {
+    try {
+      const res = await fetch('/api/auth/me', { cache: 'no-store', credentials: 'include' })
+      const data = await res.json().catch(() => ({}))
+      setUser(data?.user ? { id: data.user.id, email: data.user.email } : null)
+    } catch {
+      setUser(null)
+    } finally {
+      setLoading(false)
     }
+  }
 
-    init()
+  useEffect(() => {
+    refresh()
+    const listener = () => {
+      setLoading(true)
+      refresh()
+    }
+    window.addEventListener(AUTH_EVENT, listener)
+    return () => window.removeEventListener(AUTH_EVENT, listener)
   }, [])
 
-  return { user, loading }
+  return { user, loading, refresh }
 }

src/lib/persistence.ts

@@ -63,6 +63,14 @@ async function getSupabase(): Promise<SupabaseClient<Database>> {
   return createServerClient()
 }
 
+// Prefer service-role client for write operations to avoid RLS blocks when running on Supabase.
+async function getSupabaseWrite(): Promise<SupabaseClient<Database>> {
+  if (process.env.SUPABASE_SERVICE_ROLE_KEY) {
+    return createServiceClient()
+  }
+  return createServerClient()
+}
+
 function pickFallbackStore() {
   // Prefer file store when enabled; otherwise use in-memory store
   return ENABLE_FILE_STORE ? readFileStore() : Promise.resolve({ codes: inMemory.codes, rooms: inMemory.rooms, room_messages: inMemory.room_messages })
@@ -168,7 +176,7 @@ export async function insertCode(payload: Database['public']['Tables']['codes'][
     await logEvent({ module: 'codes', operation: 'insert', data: res.rows[0] })
     return res.rows[0]
   }
-  const supabase = await getSupabase()
+  const supabase = await getSupabaseWrite()
   try {
     const { data, error } = await supabase.from('codes').insert(normalizedPayload).select().single()
     if (error) {
@@ -256,7 +264,7 @@ export async function updateCode(id: string, payload: Partial<Database['public']
     await logEvent({ module: 'codes', operation: 'update', data: res.rows[0] })
     return res.rows[0]
   }
-  const supabase = await getSupabase()
+  const supabase = await getSupabaseWrite()
   try {
     const { data, error } = await supabase.from('codes').update(payload).eq('id', id).select().single()
     if (error) {
@@ -300,7 +308,7 @@ export async function insertRoom(payload: Partial<Database['public']['Tables']['
     return res.rows[0]
   }
   try {
-    const supabase = await getSupabase()
+    const supabase = await getSupabaseWrite()
     const { data, error } = await supabase.from('rooms').insert(payload).select().single()
     if (error) {
       console.error('[persistence.insertRoom] supabase error:', error)