diff --git a/server/db.ts b/server/db.ts
index b703efa..da69035 100644
--- a/server/db.ts
+++ b/server/db.ts
@@ -1227,6 +1227,8 @@ export async function updateWebImportSourceStatus(
  * Used to prevent duplicate file storage during email import
  */
 export async function findSourceFileByFileName(userId: number, fileName: string): Promise<any | null> {
+  const db = await getDb();
+  if (!db) return null;
   const result = await db.select()
     .from(sourceFiles)
     .where(and(