tr]:last:border-b-0",
+ className
+ )}
+ {...props}
+ />
+ )
+}
+
+function TableRow({ className, ...props }: React.ComponentProps<"tr">) {
+ return (
+ |
+ )
+}
+
+function TableHead({ className, ...props }: React.ComponentProps<"th">) {
+ return (
+ [role=checkbox]]:translate-y-[2px]",
+ className
+ )}
+ {...props}
+ />
+ )
+}
+
+function TableCell({ className, ...props }: React.ComponentProps<"td">) {
+ return (
+ | [role=checkbox]]:translate-y-[2px]",
+ className
+ )}
+ {...props}
+ />
+ )
+}
+
+function TableCaption({
+ className,
+ ...props
+}: React.ComponentProps<"caption">) {
+ return (
+
+ )
+}
+
+export {
+ Table,
+ TableHeader,
+ TableBody,
+ TableFooter,
+ TableHead,
+ TableRow,
+ TableCell,
+ TableCaption,
+}
diff --git a/src/lib/actions/_status.ts b/src/lib/actions/_status.ts
new file mode 100644
index 0000000..48e70e6
--- /dev/null
+++ b/src/lib/actions/_status.ts
@@ -0,0 +1,142 @@
+'use server';
+
+import 'server-only';
+import { createServerClient } from '@/utils/supabase';
+import type { Result } from '.';
+import type { Profile } from '@/utils/supabase';
+
+export type UserStatus = Profile & {
+ status: string;
+ created_at: string;
+ updated_by?: Profile;
+}
+
+export const getRecentUsers = async (): Promise> => {
+ try {
+ const supabase = await createServerClient();
+
+ // Get users who have had status updates in the last week
+ const oneWeekAgo = new Date();
+ oneWeekAgo.setDate(oneWeekAgo.getDate() - 7);
+
+ const { data, error } = await supabase
+ .from('statuses')
+ .select('user_id')
+ .gte('created_at', oneWeekAgo.toISOString())
+ .order('created_at', { ascending: false });
+
+ if (error) throw error;
+
+ // Get unique user IDs
+ const uniqueUserIds = [...new Set(data.map(status => status.user_id))];
+
+ return { success: true, data: uniqueUserIds };
+ } catch (error) {
+ return {
+ success: false,
+ error:
+ error instanceof Error
+ ? error.message
+ : 'Unknown error getting recent users',
+ };
+ }
+};
+
+export const getUserStatuses = async (): Promise> => {
+ try {
+ const supabase = await createServerClient();
+
+ // First get the recent users
+ const recentUsersResult = await getRecentUsers();
+ if (!recentUsersResult.success) {
+ throw new Error(recentUsersResult.error);
+ }
+
+ const userIds = recentUsersResult.data;
+ if (userIds.length === 0) {
+ return { success: true, data: [] };
+ }
+
+ // Get the most recent status for each user
+ const { data: statusData, error: statusError } = await supabase
+ .from('statuses')
+ .select('user_id, status, created_at, updated_by_id')
+ .in('user_id', userIds)
+ .order('created_at', { ascending: false });
+
+ if (statusError) throw statusError;
+
+ if (!statusData) {
+ return { success: true, data: [] };
+ }
+
+ // Group by user_id and get the most recent status for each user
+ const userStatusMap = new Map();
+
+ statusData.forEach(status => {
+ if (!userStatusMap.has(status.user_id)) {
+ userStatusMap.set(status.user_id, status);
+ }
+ });
+
+ // Get all unique user IDs from the status data
+ const statusUserIds = Array.from(userStatusMap.keys());
+
+ // Get profile information for these users
+ const { data: profileData, error: profileError } = await supabase
+ .from('profiles')
+ .select('id, full_name, email, avatar_url, provider, updated_at')
+ .in('id', statusUserIds);
+
+ if (profileError) throw profileError;
+
+ // Get updated_by profile information
+ const updatedByIds = Array.from(userStatusMap.values())
+ .map(status => status.updated_by_id)
+ .filter((id): id is string => id !== null);
+
+ const { data: updatedByData, error: updatedByError } = await supabase
+ .from('profiles')
+ .select('id, full_name, email, avatar_url, provider, updated_at')
+ .in('id', updatedByIds);
+
+ if (updatedByError) throw updatedByError;
+
+ // Create maps for easy lookup
+ const profileMap = new Map(profileData?.map(profile => [profile.id, profile]) ?? []);
+ const updatedByMap = new Map(updatedByData?.map(profile => [profile.id, profile]) ?? []);
+
+ // Transform the data to match UserStatus type
+ const userStatuses: UserStatus[] = [];
+
+ for (const status of userStatusMap.values()) {
+ const profile = profileMap.get(status.user_id);
+ const updatedBy = status.updated_by_id ? updatedByMap.get(status.updated_by_id) : undefined;
+
+ if (!profile) continue; // Skip if no profile found
+
+ userStatuses.push({
+ // Profile fields
+ id: profile.id,
+ full_name: profile.full_name,
+ email: profile.email,
+ avatar_url: profile.avatar_url,
+ provider: profile.provider,
+ updated_at: profile.updated_at,
+ // Status fields
+ status: status.status,
+ created_at: status.created_at,
+ updated_by: updatedBy,
+ });
+ }
+ return { success: true, data: userStatuses };
+ } catch (error) {
+ return {
+ success: false,
+ error:
+ error instanceof Error
+ ? error.message
+ : 'Unknown error getting user statuses',
+ };
+ }
+};
diff --git a/src/lib/actions/index.ts b/src/lib/actions/index.ts
index 13e5fc8..f2f674c 100644
--- a/src/lib/actions/index.ts
+++ b/src/lib/actions/index.ts
@@ -1,6 +1,7 @@
export * from './auth';
-export * from './storage';
export * from './public';
+export * from './status';
+export * from './storage';
export type Result =
| { success: true; data: T }
diff --git a/src/lib/actions/status.ts b/src/lib/actions/status.ts
new file mode 100644
index 0000000..9ad2ebf
--- /dev/null
+++ b/src/lib/actions/status.ts
@@ -0,0 +1,53 @@
+'use server'
+
+import 'server-only';
+import {
+ createServerClient,
+ type Profile,
+ type Result,
+ type Status,
+} from '@/utils/supabase';
+
+type UserWithStatus = {
+ user: Profile;
+ status: string;
+ created_at: string;
+ updated_by: Profile;
+};
+
+type PaginatedHistory = UserWithStatus[] & {
+ meta: {
+ current_page: number;
+ per_page: number;
+ total_pages: number;
+ total_count: number;
+ };
+};
+
+export const getUsersWithStatuses = async () => {
+ try {
+ const supabase = await createServerClient();
+
+ // Get only users with recent statuses (Past 7 days)
+ const oneWeekAgo = new Date();
+ oneWeekAgo.setDate(oneWeekAgo.getDate() - 7);
+
+ const { data: recentStatuses, error } = await supabase
+ .from('statuses')
+ .select(`
+ user:profiles!user_id(*),
+ status,
+ created_at,
+ updated_by:profiles!updated_by_id(*)
+ `)
+ .gte('created_at', oneWeekAgo.toISOString())
+ .order('created_at', { ascending: false });
+
+ if (error) throw error;
+ if (!recentStatuses.length) return { success: true, data: []};
+
+ return { success: true, data: recentStatuses };
+ } catch (error) {
+ return { success: false, error: `Error: ${error as string}` };
+ }
+};
diff --git a/src/lib/hooks/_status.ts b/src/lib/hooks/_status.ts
new file mode 100644
index 0000000..31a144e
--- /dev/null
+++ b/src/lib/hooks/_status.ts
@@ -0,0 +1,401 @@
+'use client';
+import { createClient } from '@/utils/supabase';
+import type { Result } from '.';
+import type { Profile, Status } from '@/utils/supabase';
+
+export type UserStatus = Profile & {
+ status: string;
+ created_at: string;
+ updated_by?: Profile;
+};
+
+export type HistoryEntry = {
+ id: string;
+ status: string;
+ created_at: string;
+ updated_by?: Profile;
+ user_profile: Profile;
+};
+
+export type PaginatedHistory = {
+ data: HistoryEntry[];
+ meta: {
+ current_page: number;
+ per_page: number;
+ total_pages: number;
+ total_count: number;
+ };
+};
+
+export const getUserStatuses = async (): Promise> => {
+ try {
+ const supabase = createClient();
+
+ // Get users with recent activity (last 7 days)
+ const oneWeekAgo = new Date();
+ oneWeekAgo.setDate(oneWeekAgo.getDate() - 7);
+
+ const { data: recentStatuses, error: statusError } = await supabase
+ .from('statuses')
+ .select('*')
+ .gte('created_at', oneWeekAgo.toISOString())
+ .order('created_at', { ascending: false });
+
+ if (statusError) throw statusError;
+ if (!recentStatuses?.length) return { success: true, data: [] };
+
+ // Properly type the status data
+ const typedStatuses: Status[] = recentStatuses;
+
+ // Get most recent status per user
+ const userStatusMap = new Map();
+ typedStatuses.forEach(status => {
+ if (!userStatusMap.has(status.user_id)) {
+ userStatusMap.set(status.user_id, status);
+ }
+ });
+
+ const userIds = Array.from(userStatusMap.keys());
+
+ // Get profiles
+ const { data: profiles, error: profileError } = await supabase
+ .from('profiles')
+ .select('*')
+ .in('id', userIds);
+
+ if (profileError) throw profileError;
+
+ // Get updated_by profiles - filter out nulls properly
+ const updatedByIds = Array.from(userStatusMap.values())
+ .map(s => s.updated_by_id)
+ .filter((id): id is string => id !== null);
+
+ let updatedByProfiles: Profile[] = [];
+ if (updatedByIds.length > 0) {
+ const { data, error } = await supabase
+ .from('profiles')
+ .select('*')
+ .in('id', updatedByIds);
+
+ if (error) throw error;
+ updatedByProfiles = data ?? [];
+ }
+
+ const profileMap = new Map((profiles ?? []).map(p => [p.id, p]));
+ const updatedByMap = new Map(updatedByProfiles.map(p => [p.id, p]));
+
+ const userStatuses: UserStatus[] = [];
+
+ for (const [userId, status] of userStatusMap) {
+ const profile = profileMap.get(userId);
+ if (!profile) continue;
+
+ userStatuses.push({
+ ...profile,
+ status: status.status,
+ created_at: status.created_at,
+ updated_by: status.updated_by_id ? updatedByMap.get(status.updated_by_id) : undefined,
+ });
+ }
+
+ return { success: true, data: userStatuses };
+ } catch (error) {
+ return {
+ success: false,
+ error: error instanceof Error ? error.message : 'Unknown error',
+ };
+ }
+};
+
+export const broadcastStatusUpdate = async (
+ userStatus: UserStatus
+): Promise> => {
+ try {
+ const supabase = createClient();
+
+ const broadcast = await supabase.channel('status_updates').send({
+ type: 'broadcast',
+ event: 'status_updated',
+ payload: {
+ user_status: userStatus,
+ timestamp: new Date().toISOString(),
+ }
+ });
+
+ if (broadcast === 'error') throw new Error('Failed to broadcast status update');
+ if (broadcast === 'ok') return { success: true, data: undefined };
+ else throw new Error('Broadcast timed out!')
+ } catch (error) {
+ return {
+ success: false,
+ error: error instanceof Error ? error.message : 'Unknown error',
+ };
+ }
+};
+
+// Update your existing functions to broadcast after database updates
+export const updateUserStatus = async (
+ userIds: string[],
+ status: string,
+): Promise> => {
+ try {
+ const supabase = createClient();
+ const { data: { user } } = await supabase.auth.getUser();
+
+ if (!user) throw new Error('Not authenticated');
+
+ const inserts = userIds.map(userId => ({
+ user_id: userId,
+ status,
+ updated_by_id: user.id,
+ }));
+
+ const { data: insertedStatuses, error } = await supabase
+ .from('statuses')
+ .insert(inserts)
+ .select();
+
+ if (error) throw error;
+
+ // Broadcast the updates
+ if (insertedStatuses) {
+ for (const insertedStatus of insertedStatuses) {
+ // Get the user profile for broadcasting
+ const { data: profile } = await supabase
+ .from('profiles')
+ .select('*')
+ .eq('id', insertedStatus.user_id)
+ .single();
+
+ if (profile) {
+ const userStatus: UserStatus = {
+ ...profile,
+ status: insertedStatus.status,
+ created_at: insertedStatus.created_at,
+ };
+
+ await broadcastStatusUpdate(userStatus);
+ }
+ }
+ }
+
+ return { success: true, data: undefined };
+ } catch (error) {
+ return {
+ success: false,
+ error: error instanceof Error ? error.message : 'Unknown error',
+ };
+ }
+};
+
+export const updateCurrentUserStatus = async (
+ status: string,
+): Promise> => {
+ try {
+ const supabase = createClient();
+ const { data: { user } } = await supabase.auth.getUser();
+
+ if (!user) throw new Error('Not authenticated');
+
+ const { data: insertedStatus, error } = await supabase
+ .from('statuses')
+ .insert({
+ user_id: user.id,
+ status,
+ updated_by_id: user.id,
+ })
+ .select()
+ .single();
+
+ if (error) throw error;
+
+ // Get the user profile for broadcasting
+ const { data: profile } = await supabase
+ .from('profiles')
+ .select('*')
+ .eq('id', user.id)
+ .single();
+
+ if (profile && insertedStatus) {
+ const userStatus: UserStatus = {
+ ...profile,
+ status: insertedStatus.status,
+ created_at: insertedStatus.created_at,
+ };
+
+ await broadcastStatusUpdate(userStatus);
+ }
+
+ return { success: true, data: undefined };
+ } catch (error) {
+ return {
+ success: false,
+ error: error instanceof Error ? error.message : 'Unknown error',
+ };
+ }
+};
+
+export const getUserHistory = async (
+ userId: string,
+ page = 1,
+ perPage = 50,
+): Promise> => {
+ try {
+ const supabase = createClient();
+ const offset = (page - 1) * perPage;
+
+ // Get count
+ const { count } = await supabase
+ .from('statuses')
+ .select('*', { count: 'exact', head: true })
+ .eq('user_id', userId);
+
+ // Get data
+ const { data: statuses, error } = await supabase
+ .from('statuses')
+ .select('*')
+ .eq('user_id', userId)
+ .order('created_at', { ascending: false })
+ .range(offset, offset + perPage - 1);
+
+ if (error) throw error;
+
+ const typedStatuses: Status[] = statuses ?? [];
+
+ // Get user profile
+ const { data: userProfile, error: userProfileError } = await supabase
+ .from('profiles')
+ .select('*')
+ .eq('id', userId)
+ .single();
+
+ if (userProfileError) throw userProfileError;
+ if (!userProfile) throw new Error('User profile not found');
+
+ // Get updated_by profiles - filter out nulls properly
+ const updatedByIds = typedStatuses
+ .map(s => s.updated_by_id)
+ .filter((id): id is string => id !== null);
+
+ let updatedByProfiles: Profile[] = [];
+ if (updatedByIds.length > 0) {
+ const { data, error: updatedByError } = await supabase
+ .from('profiles')
+ .select('*')
+ .in('id', updatedByIds);
+
+ if (updatedByError) throw updatedByError;
+ updatedByProfiles = data ?? [];
+ }
+
+ const updatedByMap = new Map(updatedByProfiles.map(p => [p.id, p]));
+
+ const historyEntries: HistoryEntry[] = typedStatuses.map(entry => ({
+ id: entry.id,
+ status: entry.status,
+ created_at: entry.created_at,
+ updated_by: entry.updated_by_id ? updatedByMap.get(entry.updated_by_id) : undefined,
+ user_profile: userProfile,
+ }));
+
+ const totalCount = count ?? 0;
+ const totalPages = Math.ceil(totalCount / perPage);
+
+ return {
+ success: true,
+ data: {
+ data: historyEntries,
+ meta: {
+ current_page: page,
+ per_page: perPage,
+ total_pages: totalPages,
+ total_count: totalCount
+ },
+ },
+ };
+ } catch (error) {
+ return {
+ success: false,
+ error: error instanceof Error ? error.message : 'Unknown error',
+ };
+ }
+};
+
+export const getAllHistory = async (
+ page = 1,
+ perPage = 50,
+): Promise> => {
+ try {
+ const supabase = createClient();
+ const offset = (page - 1) * perPage;
+
+ // Get count
+ const { count } = await supabase
+ .from('statuses')
+ .select('*', { count: 'exact', head: true });
+
+ // Get data
+ const { data: statuses, error } = await supabase
+ .from('statuses')
+ .select('*')
+ .order('created_at', { ascending: false })
+ .range(offset, offset + perPage - 1);
+
+ if (error) throw error;
+
+ const typedStatuses: Status[] = statuses ?? [];
+
+ // Get all profiles - filter out nulls properly
+ const userIds = [...new Set(typedStatuses.map(s => s.user_id))];
+ const updatedByIds = typedStatuses
+ .map(s => s.updated_by_id)
+ .filter((id): id is string => id !== null);
+ const allIds = [...new Set([...userIds, ...updatedByIds])];
+
+ const { data: profiles, error: profileError } = await supabase
+ .from('profiles')
+ .select('*')
+ .in('id', allIds);
+
+ if (profileError) throw profileError;
+
+ const profileMap = new Map((profiles ?? []).map(p => [p.id, p]));
+
+ const historyEntries: HistoryEntry[] = typedStatuses.map(entry => {
+ const userProfile = profileMap.get(entry.user_id);
+ if (!userProfile) {
+ throw new Error(`User profile not found for ID: ${entry.user_id}`);
+ }
+
+ return {
+ id: entry.id,
+ status: entry.status,
+ created_at: entry.created_at,
+ updated_by: entry.updated_by_id ? profileMap.get(entry.updated_by_id) : undefined,
+ user_profile: userProfile,
+ };
+ });
+
+ const totalCount = count ?? 0;
+ const totalPages = Math.ceil(totalCount / perPage);
+
+ return {
+ success: true,
+ data: {
+ data: historyEntries,
+ meta: {
+ current_page: page,
+ per_page: perPage,
+ total_pages: totalPages,
+ total_count: totalCount
+ },
+ },
+ };
+ } catch (error) {
+ return {
+ success: false,
+ error: error instanceof Error ? error.message : 'Unknown error',
+ };
+ }
+};
+
diff --git a/src/lib/hooks/index.ts b/src/lib/hooks/index.ts
index e3a9342..a79dac8 100755
--- a/src/lib/hooks/index.ts
+++ b/src/lib/hooks/index.ts
@@ -1,5 +1,6 @@
export * from './auth';
export * from './public';
+export * from './status';
export * from './storage';
export * from './useFileUpload';
diff --git a/src/lib/hooks/status.ts b/src/lib/hooks/status.ts
new file mode 100644
index 0000000..76b4988
--- /dev/null
+++ b/src/lib/hooks/status.ts
@@ -0,0 +1,52 @@
+'use client';
+
+import {
+ createClient,
+ type Profile,
+ type Result,
+ type Status,
+} from '@/utils/supabase';
+
+type UserWithStatus = {
+ user: Profile;
+ status: string;
+ created_at: string;
+ updated_by: Profile;
+};
+
+type PaginatedHistory = UserWithStatus[] & {
+ meta: {
+ current_page: number;
+ per_page: number;
+ total_pages: number;
+ total_count: number;
+ };
+};
+
+export const getUsersWithStatuses = async (): Promise> => {
+ try {
+ const supabase = createClient();
+
+ // Get only users with recent statuses (Past 7 days)
+ const oneWeekAgo = new Date();
+ oneWeekAgo.setDate(oneWeekAgo.getDate() - 7);
+
+ const { data: recentStatuses, error } = await supabase
+ .from('statuses')
+ .select(`
+ user:profiles!user_id(*),
+ status,
+ created_at,
+ updated_by:profiles!updated_by_id(*)
+ `)
+ .gte('created_at', oneWeekAgo.toISOString())
+ .order('created_at', { ascending: false }) as {data: UserWithStatus[], error: unknown};
+
+ if (error) throw error;
+ if (!recentStatuses.length) return { success: true, data: []};
+
+ return { success: true, data: recentStatuses };
+ } catch (error) {
+ return { success: false, error: `Error: ${error as string}` };
+ }
+};
diff --git a/src/server/db/schema.sql b/src/server/db/schema.sql
index d0930b5..d67a532 100644
--- a/src/server/db/schema.sql
+++ b/src/server/db/schema.sql
@@ -64,62 +64,63 @@ create policy "Anyone can update an avatar." on storage.objects
create policy "Anyone can delete an avatar." on storage.objects
for delete using (bucket_id = 'avatars');
--- -- Create a table for public statuses
--- CREATE TABLE statuses (
- -- id uuid DEFAULT gen_random_uuid() PRIMARY KEY,
- -- user_id uuid REFERENCES auth.users ON DELETE CASCADE NOT NULL,
- -- updated_by_id uuid REFERENCES auth.users ON DELETE SET NULL DEFAULT auth.uid(),
- -- created_at timestamp with time zone DEFAULT now() NOT NULL,
- -- status text NOT NULL,
- -- CONSTRAINT status_length CHECK (char_length(status) >= 3 AND char_length(status) <= 80)
--- );
+-- Create a table for public statuses
+CREATE TABLE statuses (
+ id uuid DEFAULT gen_random_uuid() PRIMARY KEY,
+ user_id uuid REFERENCES public.profiles ON DELETE CASCADE NOT NULL,
+ updated_by_id uuid REFERENCES public.profiles ON DELETE SET NULL DEFAULT auth.uid(),
+ created_at timestamp with time zone DEFAULT now() NOT NULL,
+ status text NOT NULL,
+ CONSTRAINT status_length CHECK (char_length(status) >= 3 AND char_length(status) <= 80)
+);
--- -- Set up Row Level Security (RLS)
--- ALTER TABLE statuses
- -- ENABLE ROW LEVEL SECURITY;
+-- Set up Row Level Security (RLS)
+ALTER TABLE statuses
+ ENABLE ROW LEVEL SECURITY;
--- -- Policies
--- CREATE POLICY "Public statuses are viewable by everyone." ON statuses
- -- FOR SELECT USING (true);
+-- Policies
+CREATE POLICY "Public statuses are viewable by everyone." ON statuses
+ FOR SELECT USING (true);
--- -- RECREATE it using the recommended sub-select form
--- CREATE POLICY "Authenticated users can insert statuses for any user."
- -- ON public.statuses
- -- FOR INSERT
- -- WITH CHECK (
- -- (SELECT auth.role()) = 'authenticated'
- -- );
+-- RECREATE it using the recommended sub-select form
+CREATE POLICY "Authenticated users can insert statuses for any user."
+ ON public.statuses
+ FOR INSERT
+ WITH CHECK (
+ (SELECT auth.role()) = 'authenticated'
+ );
--- -- ADD an UPDATE policy so anyone signed-in can update *any* status
--- CREATE POLICY "Authenticated users can update statuses for any user."
- -- ON public.statuses
- -- FOR UPDATE
- -- USING (
- -- (SELECT auth.role()) = 'authenticated'
- -- )
- -- WITH CHECK (
- -- (SELECT auth.role()) = 'authenticated'
- -- );
+-- ADD an UPDATE policy so anyone signed-in can update *any* status
+CREATE POLICY "Authenticated users can update statuses for any user."
+ ON public.statuses
+ FOR UPDATE
+ USING (
+ (SELECT auth.role()) = 'authenticated'
+ )
+ WITH CHECK (
+ (SELECT auth.role()) = 'authenticated'
+ );
--- -- Function to add first status
--- CREATE FUNCTION public.handle_first_status()
--- RETURNS TRIGGER
--- SET search_path = ''
--- AS $$
--- BEGIN
- -- INSERT INTO public.statuses (user_id, updated_by_id, status)
- -- VALUES (
- -- NEW.id,
- -- NEW.id,
- -- 'Just joined!'
- -- );
- -- RETURN NEW;
--- END;
--- $$ LANGUAGE plpgsql SECURITY DEFINER;
+-- Function to add first status
+CREATE FUNCTION public.handle_first_status()
+RETURNS TRIGGER
+SET search_path = ''
+AS $$
+BEGIN
+ INSERT INTO public.statuses (user_id, updated_by_id, status)
+ VALUES (
+ NEW.id,
+ NEW.id,
+ 'Just joined!'
+ );
+ RETURN NEW;
+END;
+$$ LANGUAGE plpgsql SECURITY DEFINER;
--- -- Create a separate trigger for the status
--- CREATE TRIGGER on_auth_user_created_add_status
- -- AFTER INSERT ON auth.users
- -- FOR EACH ROW EXECUTE PROCEDURE public.handle_first_status();
+-- Create a separate trigger for the status
+CREATE TRIGGER on_auth_user_created_add_status
+ AFTER INSERT ON auth.users
+ FOR EACH ROW EXECUTE PROCEDURE public.handle_first_status();
--- alter publication supabase_realtime add table statuses;
+alter publication supabase_realtime add table profiles;
+alter publication supabase_realtime add table statuses;
diff --git a/src/utils/supabase/types.ts b/src/utils/supabase/types.ts
index 3d2165a..6bb7842 100644
--- a/src/utils/supabase/types.ts
+++ b/src/utils/supabase/types.ts
@@ -4,185 +4,200 @@ export type Json =
| boolean
| null
| { [key: string]: Json | undefined }
- | Json[];
+ | Json[]
export type Database = {
public: {
Tables: {
profiles: {
Row: {
- avatar_url: string | null;
- email: string | null;
- full_name: string | null;
- id: string;
- provider: string | null;
- updated_at: string | null;
- };
+ avatar_url: string | null
+ email: string | null
+ full_name: string | null
+ id: string
+ provider: string | null
+ updated_at: string | null
+ }
Insert: {
- avatar_url?: string | null;
- email?: string | null;
- full_name?: string | null;
- id: string;
- provider?: string | null;
- updated_at?: string | null;
- };
+ avatar_url?: string | null
+ email?: string | null
+ full_name?: string | null
+ id: string
+ provider?: string | null
+ updated_at?: string | null
+ }
Update: {
- avatar_url?: string | null;
- email?: string | null;
- full_name?: string | null;
- id?: string;
- provider?: string | null;
- updated_at?: string | null;
- };
- Relationships: [];
- };
+ avatar_url?: string | null
+ email?: string | null
+ full_name?: string | null
+ id?: string
+ provider?: string | null
+ updated_at?: string | null
+ }
+ Relationships: []
+ }
statuses: {
Row: {
- created_at: string;
- id: string;
- status: string;
- updated_by_id: string | null;
- user_id: string;
- };
+ created_at: string
+ id: string
+ status: string
+ updated_by_id: string | null
+ user_id: string
+ }
Insert: {
- created_at?: string;
- id?: string;
- status: string;
- updated_by_id?: string | null;
- user_id: string;
- };
+ created_at?: string
+ id?: string
+ status: string
+ updated_by_id?: string | null
+ user_id: string
+ }
Update: {
- created_at?: string;
- id?: string;
- status?: string;
- updated_by_id?: string | null;
- user_id?: string;
- };
- Relationships: [];
- };
- };
+ created_at?: string
+ id?: string
+ status?: string
+ updated_by_id?: string | null
+ user_id?: string
+ }
+ Relationships: [
+ {
+ foreignKeyName: "statuses_updated_by_id_fkey"
+ columns: ["updated_by_id"]
+ isOneToOne: false
+ referencedRelation: "profiles"
+ referencedColumns: ["id"]
+ },
+ {
+ foreignKeyName: "statuses_user_id_fkey"
+ columns: ["user_id"]
+ isOneToOne: false
+ referencedRelation: "profiles"
+ referencedColumns: ["id"]
+ },
+ ]
+ }
+ }
Views: {
- [_ in never]: never;
- };
+ [_ in never]: never
+ }
Functions: {
- [_ in never]: never;
- };
+ [_ in never]: never
+ }
Enums: {
- [_ in never]: never;
- };
+ [_ in never]: never
+ }
CompositeTypes: {
- [_ in never]: never;
- };
- };
-};
+ [_ in never]: never
+ }
+ }
+}
-type DefaultSchema = Database[Extract];
+type DefaultSchema = Database[Extract]
export type Tables<
DefaultSchemaTableNameOrOptions extends
- | keyof (DefaultSchema['Tables'] & DefaultSchema['Views'])
+ | keyof (DefaultSchema["Tables"] & DefaultSchema["Views"])
| { schema: keyof Database },
TableName extends DefaultSchemaTableNameOrOptions extends {
- schema: keyof Database;
+ schema: keyof Database
}
- ? keyof (Database[DefaultSchemaTableNameOrOptions['schema']]['Tables'] &
- Database[DefaultSchemaTableNameOrOptions['schema']]['Views'])
+ ? keyof (Database[DefaultSchemaTableNameOrOptions["schema"]]["Tables"] &
+ Database[DefaultSchemaTableNameOrOptions["schema"]]["Views"])
: never = never,
> = DefaultSchemaTableNameOrOptions extends { schema: keyof Database }
- ? (Database[DefaultSchemaTableNameOrOptions['schema']]['Tables'] &
- Database[DefaultSchemaTableNameOrOptions['schema']]['Views'])[TableName] extends {
- Row: infer R;
+ ? (Database[DefaultSchemaTableNameOrOptions["schema"]]["Tables"] &
+ Database[DefaultSchemaTableNameOrOptions["schema"]]["Views"])[TableName] extends {
+ Row: infer R
}
? R
: never
- : DefaultSchemaTableNameOrOptions extends keyof (DefaultSchema['Tables'] &
- DefaultSchema['Views'])
- ? (DefaultSchema['Tables'] &
- DefaultSchema['Views'])[DefaultSchemaTableNameOrOptions] extends {
- Row: infer R;
+ : DefaultSchemaTableNameOrOptions extends keyof (DefaultSchema["Tables"] &
+ DefaultSchema["Views"])
+ ? (DefaultSchema["Tables"] &
+ DefaultSchema["Views"])[DefaultSchemaTableNameOrOptions] extends {
+ Row: infer R
}
? R
: never
- : never;
+ : never
export type TablesInsert<
DefaultSchemaTableNameOrOptions extends
- | keyof DefaultSchema['Tables']
+ | keyof DefaultSchema["Tables"]
| { schema: keyof Database },
TableName extends DefaultSchemaTableNameOrOptions extends {
- schema: keyof Database;
+ schema: keyof Database
}
- ? keyof Database[DefaultSchemaTableNameOrOptions['schema']]['Tables']
+ ? keyof Database[DefaultSchemaTableNameOrOptions["schema"]]["Tables"]
: never = never,
> = DefaultSchemaTableNameOrOptions extends { schema: keyof Database }
- ? Database[DefaultSchemaTableNameOrOptions['schema']]['Tables'][TableName] extends {
- Insert: infer I;
+ ? Database[DefaultSchemaTableNameOrOptions["schema"]]["Tables"][TableName] extends {
+ Insert: infer I
}
? I
: never
- : DefaultSchemaTableNameOrOptions extends keyof DefaultSchema['Tables']
- ? DefaultSchema['Tables'][DefaultSchemaTableNameOrOptions] extends {
- Insert: infer I;
+ : DefaultSchemaTableNameOrOptions extends keyof DefaultSchema["Tables"]
+ ? DefaultSchema["Tables"][DefaultSchemaTableNameOrOptions] extends {
+ Insert: infer I
}
? I
: never
- : never;
+ : never
export type TablesUpdate<
DefaultSchemaTableNameOrOptions extends
- | keyof DefaultSchema['Tables']
+ | keyof DefaultSchema["Tables"]
| { schema: keyof Database },
TableName extends DefaultSchemaTableNameOrOptions extends {
- schema: keyof Database;
+ schema: keyof Database
}
- ? keyof Database[DefaultSchemaTableNameOrOptions['schema']]['Tables']
+ ? keyof Database[DefaultSchemaTableNameOrOptions["schema"]]["Tables"]
: never = never,
> = DefaultSchemaTableNameOrOptions extends { schema: keyof Database }
- ? Database[DefaultSchemaTableNameOrOptions['schema']]['Tables'][TableName] extends {
- Update: infer U;
+ ? Database[DefaultSchemaTableNameOrOptions["schema"]]["Tables"][TableName] extends {
+ Update: infer U
}
? U
: never
- : DefaultSchemaTableNameOrOptions extends keyof DefaultSchema['Tables']
- ? DefaultSchema['Tables'][DefaultSchemaTableNameOrOptions] extends {
- Update: infer U;
+ : DefaultSchemaTableNameOrOptions extends keyof DefaultSchema["Tables"]
+ ? DefaultSchema["Tables"][DefaultSchemaTableNameOrOptions] extends {
+ Update: infer U
}
? U
: never
- : never;
+ : never
export type Enums<
DefaultSchemaEnumNameOrOptions extends
- | keyof DefaultSchema['Enums']
+ | keyof DefaultSchema["Enums"]
| { schema: keyof Database },
EnumName extends DefaultSchemaEnumNameOrOptions extends {
- schema: keyof Database;
+ schema: keyof Database
}
- ? keyof Database[DefaultSchemaEnumNameOrOptions['schema']]['Enums']
+ ? keyof Database[DefaultSchemaEnumNameOrOptions["schema"]]["Enums"]
: never = never,
> = DefaultSchemaEnumNameOrOptions extends { schema: keyof Database }
- ? Database[DefaultSchemaEnumNameOrOptions['schema']]['Enums'][EnumName]
- : DefaultSchemaEnumNameOrOptions extends keyof DefaultSchema['Enums']
- ? DefaultSchema['Enums'][DefaultSchemaEnumNameOrOptions]
- : never;
+ ? Database[DefaultSchemaEnumNameOrOptions["schema"]]["Enums"][EnumName]
+ : DefaultSchemaEnumNameOrOptions extends keyof DefaultSchema["Enums"]
+ ? DefaultSchema["Enums"][DefaultSchemaEnumNameOrOptions]
+ : never
export type CompositeTypes<
PublicCompositeTypeNameOrOptions extends
- | keyof DefaultSchema['CompositeTypes']
+ | keyof DefaultSchema["CompositeTypes"]
| { schema: keyof Database },
CompositeTypeName extends PublicCompositeTypeNameOrOptions extends {
- schema: keyof Database;
+ schema: keyof Database
}
- ? keyof Database[PublicCompositeTypeNameOrOptions['schema']]['CompositeTypes']
+ ? keyof Database[PublicCompositeTypeNameOrOptions["schema"]]["CompositeTypes"]
: never = never,
> = PublicCompositeTypeNameOrOptions extends { schema: keyof Database }
- ? Database[PublicCompositeTypeNameOrOptions['schema']]['CompositeTypes'][CompositeTypeName]
- : PublicCompositeTypeNameOrOptions extends keyof DefaultSchema['CompositeTypes']
- ? DefaultSchema['CompositeTypes'][PublicCompositeTypeNameOrOptions]
- : never;
+ ? Database[PublicCompositeTypeNameOrOptions["schema"]]["CompositeTypes"][CompositeTypeName]
+ : PublicCompositeTypeNameOrOptions extends keyof DefaultSchema["CompositeTypes"]
+ ? DefaultSchema["CompositeTypes"][PublicCompositeTypeNameOrOptions]
+ : never
export const Constants = {
public: {
Enums: {},
},
-} as const;
+} as const
diff --git a/src/utils/supabase/utils.ts b/src/utils/supabase/utils.ts
index 150ad65..98952e2 100644
--- a/src/utils/supabase/utils.ts
+++ b/src/utils/supabase/utils.ts
@@ -1,6 +1,11 @@
import type { Database } from '@/utils/supabase/types';
export type { User } from '@supabase/supabase-js';
+// Result type for API calls
+export type Result =
+ | { success: true; data: T }
+ | { success: false; error: string };
+
// Table row types
export type Profile = Database['public']['Tables']['profiles']['Row'];
export type Status = Database['public']['Tables']['statuses']['Row'];
|