Added hover opacity on nav-user for better visibility

apps/mail/actions/ai-reply.ts

@@ -14,7 +14,7 @@ export async function generateAIResponse(
   const session = await auth.api.getSession({ headers: headersList });
 
   if (!session?.user) {
-    return throwUnauthorizedGracefully();
+    return throwUnauthorizedGracefully() as never;
   }
 
   if (!process.env.GROQ_API_KEY) {

apps/mail/actions/brain.ts

@@ -11,7 +11,7 @@ export const EnableBrain = async () => {
   const connection = await getActiveConnection();
 
   if (!connection?.accessToken || !connection.refreshToken) {
-    return throwUnauthorizedGracefully();
+    return throwUnauthorizedGracefully() as never;
   }
 
   return await axios.put(process.env.BRAIN_URL + `/subscribe/${connection.providerId}`, {

apps/mail/actions/connections.ts

@@ -14,13 +14,13 @@ export async function deleteConnection(connectionId: string) {
     const session = await auth.api.getSession({ headers: headersList });
 
     if (!session) {
-      return throwUnauthorizedGracefully();
+      return throwUnauthorizedGracefully() as never;
     }
 
     const userId = session?.user?.id;
 
     if (!userId) {
-      return throwUnauthorizedGracefully();
+      return throwUnauthorizedGracefully() as never;
     }
 
     await db
@@ -46,13 +46,13 @@ export async function putConnection(connectionId: string) {
     const session = await auth.api.getSession({ headers: headersList });
 
     if (!session) {
-      return throwUnauthorizedGracefully();
+      return throwUnauthorizedGracefully() as never;
     }
 
     const userId = session?.user?.id;
 
     if (!userId) {
-      return throwUnauthorizedGracefully();
+      return throwUnauthorizedGracefully() as never;
     }
 
     const [foundConnection] = await db

apps/mail/actions/drafts.ts

@@ -16,9 +16,7 @@ export const getDrafts = async ({
     return await driver.listDrafts(q, max, pageToken);
   } catch (error) {
     console.error('Error getting threads:', error);
-    await throwUnauthorizedGracefully();
-    // throw error;
-    return { messages: [], nextPageToken: null };
+    return throwUnauthorizedGracefully();
   }
 };
 

apps/mail/actions/getSummary.ts

@@ -12,7 +12,7 @@ export const GetSummary = async (threadId: string) => {
   const session = await auth.api.getSession({ headers: headersList });
 
   if (!session || !session.connectionId) {
-    return throwUnauthorizedGracefully();
+    return throwUnauthorizedGracefully() as never;
   }
 
   const [_connection] = await db
@@ -21,7 +21,7 @@ export const GetSummary = async (threadId: string) => {
     .where(and(eq(connection.userId, session.user.id), eq(connection.id, session.connectionId)));
 
   if (!_connection) {
-    return throwUnauthorizedGracefully();
+    return throwUnauthorizedGracefully() as never;
   }
 
   try {

apps/mail/actions/mail.ts

@@ -1,38 +1,9 @@
 'use server';
-import { deleteActiveConnection, FatalErrors, getActiveDriver } from './utils';
 import { throwUnauthorizedGracefully } from '@/app/api/utils';
 import { IGetThreadResponse } from '@/app/api/driver/types';
+import { FatalErrors, getActiveDriver } from './utils';
 import { ParsedMessage } from '@/types';
 
-export const getMails = async ({
-  folder,
-  q,
-  max,
-  labelIds,
-  pageToken,
-}: {
-  folder: string;
-  q?: string;
-  max?: number;
-  labelIds?: string[];
-  pageToken: string | number | undefined;
-}) => {
-  if (!folder) {
-    throw new Error('Missing required fields');
-  }
-
-  try {
-    const driver = await getActiveDriver();
-    return await driver.list(folder, q, max, labelIds, pageToken);
-  } catch (error) {
-    if (FatalErrors.includes((error as Error).message)) await deleteActiveConnection();
-    console.error('Error getting threads:', error);
-    // throw error;
-    await throwUnauthorizedGracefully();
-    return { messages: [], nextPageToken: null };
-  }
-};
-
 export const getMail = async ({ id }: { id: string }): Promise<IGetThreadResponse> => {
   if (!id) {
     throw new Error('Missing required fields');
@@ -47,7 +18,7 @@ export const getMail = async ({ id }: { id: string }): Promise<IGetThreadRespons
 
     return mailData;
   } catch (error) {
-    if (FatalErrors.includes((error as Error).message)) await deleteActiveConnection();
+    if (FatalErrors.includes((error as Error).message)) await throwUnauthorizedGracefully();
     console.error('Error getting mail:', error);
     throw error;
   }
@@ -59,7 +30,7 @@ export const markAsRead = async ({ ids }: { ids: string[] }) => {
     await driver.markAsRead(ids);
     return { success: true };
   } catch (error) {
-    if (FatalErrors.includes((error as Error).message)) await deleteActiveConnection();
+    if (FatalErrors.includes((error as Error).message)) await throwUnauthorizedGracefully();
     console.error('Error marking message as read:', error);
     throw error;
   }
@@ -71,23 +42,12 @@ export const markAsUnread = async ({ ids }: { ids: string[] }) => {
     await driver.markAsUnread(ids);
     return { success: true };
   } catch (error) {
-    if (FatalErrors.includes((error as Error).message)) await deleteActiveConnection();
+    if (FatalErrors.includes((error as Error).message)) await throwUnauthorizedGracefully();
     console.error('Error marking message as unread:', error);
     throw error;
   }
 };
 
-export const mailCount = async () => {
-  try {
-    const driver = await getActiveDriver();
-    return await driver.count();
-  } catch (error) {
-    if (FatalErrors.includes((error as Error).message)) await deleteActiveConnection();
-    console.error('Error getting mail count:', error);
-    throw error;
-  }
-};
-
 export const modifyLabels = async ({
   threadId,
   addLabels = [],
@@ -117,7 +77,7 @@ export const modifyLabels = async ({
     console.log('Server: No label changes specified');
     return { success: false, error: 'No label changes specified' };
   } catch (error) {
-    if (FatalErrors.includes((error as Error).message)) await deleteActiveConnection();
+    if (FatalErrors.includes((error as Error).message)) await throwUnauthorizedGracefully();
     console.error('Error updating thread labels:', error);
     throw error;
   }
@@ -159,7 +119,7 @@ export const toggleStar = async ({ ids }: { ids: string[] }) => {
 
     return { success: true };
   } catch (error) {
-    if (FatalErrors.includes((error as Error).message)) await deleteActiveConnection();
+    if (FatalErrors.includes((error as Error).message)) await throwUnauthorizedGracefully();
     console.error('Error toggling star:', error);
     throw error;
   }

apps/mail/actions/send.ts

@@ -33,7 +33,7 @@ export async function sendEmail({
   const connection = await getActiveConnection();
 
   if (!connection?.accessToken || !connection.refreshToken) {
-    return throwUnauthorizedGracefully();
+    return throwUnauthorizedGracefully() as never;
   }
 
   const driver = await createDriver(connection.providerId, {