refactor(projects): enhance getProjects function to handle collaborator projects and improve error handling

Author: DongDuong2001

lib/features/projects/index.ts

@@ -22,10 +22,39 @@ export async function createProject(project: Omit<Project, 'id' | 'created_at' |
 export async function getProjects(userId: string) {
     guard()
     const supabase = createClient()
-    const { data, error } = await supabase
+    const { data: ownedProjects, error: ownedError } = await supabase
         .from('projects').select('*').eq('user_id', userId).order('created_at', { ascending: false })
-    if (error) throw error
-    return data || []
+
+    if (ownedError) throw ownedError
+
+    const { data: collaboratorRows, error: collaboratorError } = await supabase
+        .from('project_collaborators')
+        .select('project_id')
+        .eq('user_id', userId)
+
+    if (collaboratorError) throw collaboratorError
+
+    const ownedIds = new Set((ownedProjects || []).map((project) => project.id))
+    const collaboratorProjectIds = Array.from(
+        new Set((collaboratorRows || []).map((row) => row.project_id).filter(Boolean))
+    ).filter((projectId) => !ownedIds.has(projectId))
+
+    if (collaboratorProjectIds.length === 0) {
+        return ownedProjects || []
+    }
+
+    const { data: collaboratorProjects, error: collaboratorProjectsError } = await supabase
+        .from('projects')
+        .select('*')
+        .in('id', collaboratorProjectIds)
+
+    if (collaboratorProjectsError) throw collaboratorProjectsError
+
+    return [...(ownedProjects || []), ...(collaboratorProjects || [])].sort((a, b) => {
+        const aTime = new Date(a.updated_at || a.created_at || 0).getTime()
+        const bTime = new Date(b.updated_at || b.created_at || 0).getTime()
+        return bTime - aTime
+    })
 }
 
 export async function updateProject(id: string, updates: Partial<Project>) {
@@ -91,12 +120,16 @@ export async function searchUsers(query: string) {
 }
 
 export async function getProfileByEmail(email: string) {
+    guard()
+    const normalizedEmail = email.trim().toLowerCase()
+    if (!normalizedEmail) return null
+
     const supabase = createClient()
     const { data, error } = await supabase
         .from('profiles')
         .select('*')
-        .eq('email', email)
-        .single()
+        .ilike('email', normalizedEmail)
+        .maybeSingle()
     if (error && error.code !== 'PGRST116') throw error
     return data || null
 }