feat: Introduce core scraping types, Google Maps scraper, and dashboard pages for business and task management.

app/api/businesses/route.ts

@@ -37,12 +37,17 @@ export async function GET(request: Request) {
       conditions.push(eq(businesses.emailStatus, status));
     }
 
+    console.log(`🔍 Fetching businesses for UserID: ${userId}`);
+    console.log(`   Filters - Category: ${category}, Status: ${status}, Page: ${page}, Limit: ${limit}`);
+
     // Get total count
     const [{ count }] = await db
       .select({ count: sql<number>`count(*)` })
       .from(businesses)
       .where(and(...conditions));
 
+    console.log(`   Found ${count} total businesses matching criteria`);
+
     const totalPages = Math.ceil(count / limit);
 
     const results = await db

app/dashboard/businesses/page.tsx

@@ -71,7 +71,12 @@ export default function BusinessesPage() {
     const handleSendEmail = async (business: Business) => {
         const toastId = toast.loading(`Sending email to ${business.name}...`);
         try {
-            await sendEmailApi("/api/email/send", { businessId: business.id });
+            const result = await sendEmailApi("/api/email/send", { businessId: business.id });
+
+            if (!result) {
+                throw new Error("Failed to send email");
+            }
+
             toast.success(`Email sent to ${business.email}`, { id: toastId });
 
             // Update local state

app/dashboard/page.tsx

@@ -151,7 +151,12 @@ export default function DashboardPage() {
   const handleSendEmail = async (business: Business) => {
     const toastId = toast.loading(`Sending email to ${business.name}...`);
     try {
-      await sendEmailApi("/api/email/send", { businessId: business.id });
+      const result = await sendEmailApi("/api/email/send", { businessId: business.id });
+
+      if (!result) {
+        throw new Error("Failed to send email");
+      }
+
       toast.success(`Email sent to ${business.email}`, { id: toastId });
 
       setBusinesses(prev => prev.map(b =>

app/dashboard/tasks/page.tsx

@@ -83,6 +83,8 @@ export default function TasksPage() {
       if (result) {
         toast.success(`Task ${action}d successfully`);
         await fetchTasks();
+      } else {
+        throw new Error("API returned null");
       }
     } catch (error) {
       toast.error(`Failed to ${action} task`);
@@ -126,6 +128,8 @@ export default function TasksPage() {
         toast.success(`Priority updated to ${priority}`);
         // No need to fetch if optimistic update matches, but safe to fetch
         // await fetchTasks(); 
+      } else {
+        throw new Error("API returned null");
       }
     } catch (error) {
       toast.error("Failed to update priority");
@@ -143,9 +147,13 @@ export default function TasksPage() {
     if (!confirmDeleteId) return;
 
     try {
-      await deleteTask(`/api/tasks?id=${confirmDeleteId.id}&type=${confirmDeleteId.type}`);
-      toast.success("Task deleted successfully");
-      await fetchTasks();
+      const result = await deleteTask(`/api/tasks?id=${confirmDeleteId.id}&type=${confirmDeleteId.type}`);
+      if (result !== null) {
+        toast.success("Task deleted successfully");
+        await fetchTasks();
+      } else {
+        throw new Error("Failed to delete task");
+      }
     } catch (error) {
       toast.error("Failed to delete task");
       console.error("Error deleting task:", error);

components/active-task-card.tsx

@@ -39,6 +39,8 @@ export function ActiveTaskCard({
       if (result) {
         toast.success(`Task ${action}d successfully`);
         onStatusChange?.();
+      } else {
+        throw new Error("Failed to control task");
       }
     } catch (error) {
       toast.error(`Failed to ${action} task`);

lib/auth.ts

@@ -94,6 +94,8 @@ export const { handlers, signIn, signOut, auth } = NextAuth({
             .set({
               accessToken: account?.access_token,
               refreshToken: account?.refresh_token,
+              name: user.name,
+              image: user.image,
               updatedAt: new Date(),
             })
             .where(eq(users.id, existingUser.id));
@@ -115,21 +117,34 @@ export const { handlers, signIn, signOut, auth } = NextAuth({
       }
     },
     async session({ session, token }) {
-      if (session.user) {
-        if (token.role === "admin") {
-          session.user.role = "admin";
-          session.user.id = "admin-user";
-        } else if (session.user.email) {
+     // console.log("🔐 Session Callback - Token:", JSON.stringify(token, null, 2));
+
+      // Always prioritize DB lookup for logged in users
+      if (session.user && session.user.email) {
+        try {
           const dbUser = await db.query.users.findFirst({
             where: eq(users.email, session.user.email),
           });
 
-          if (dbUser) {
-            session.user.id = dbUser.id;
-            session.user.accessToken = dbUser.accessToken || undefined;
-            session.user.role = "user";
+            console.log("👤 DB User found:", dbUser ? dbUser.id : "null");
+
+            if (dbUser) {
+              // Use Database Truth (which is synced from Google on login)
+              session.user.id = dbUser.id;
+              session.user.name = dbUser.name || session.user.name;
+              session.user.image = dbUser.image || session.user.image;
+              session.user.role = "user"; 
+              session.user.accessToken = dbUser.accessToken || undefined;
+            } else {
+              // Only use admin fallback if NOT found in DB (unlikely for Google login)
+              if (token.role === "admin") {
+                session.user.role = "admin";
+                session.user.id = "admin-user";
+              }
+            }
+          } catch (error) {
+            console.error("Error seeking DB user in session:", error);
           }
-        }
       }
       return session;
     },

lib/queue.ts

@@ -222,15 +222,18 @@ export const scrapingWorker = new Worker(
             ...b,
             userId,
             category: b.category || "Unknown",
-            emailStatus: null,
+            emailStatus: b.emailStatus || null,
           }));
 
           // Use INSERT ON CONFLICT DO NOTHING approach
           try {
             await db.insert(businesses).values(businessesToInsert).onConflictDoNothing();
-          } catch {
+          } catch (e: any) {
+            console.error("  ❌ Failed to insert businesses (onConflictDoNothing):", e.message);
             // Fallback if onConflictDoNothing is not supported by driver or schema setup
-            await db.insert(businesses).values(businessesToInsert).catch(() => { });
+            await db.insert(businesses).values(businessesToInsert).catch((err) => {
+              console.error("  ❌ Fallback insert also failed:", err.message);
+            });
           }
 
           totalFound += results.length;

lib/scrapers/google-maps.ts

@@ -30,6 +30,7 @@ export const googleMapsScraper: ScraperSource = {
         imageUrl: undefined, // Not available from scraper
         source: "google-maps",
         sourceUrl: business.website || undefined,
+        emailStatus: business.emailStatus || "pending",
       }));
 
       console.log(`✅ Google Maps: Found ${businesses.length} businesses`);

lib/scrapers/types.ts

@@ -28,6 +28,7 @@ export interface BusinessData {
   };
   source: string; // Source where this data was found
   sourceUrl?: string; // Original listing URL
+  emailStatus?: string | null;
 }
 
 export interface ScraperSource {