/admin and with working with db. data is pulling from db

src/app/api/auth/[...nextauth]/route.ts

@@ -1,16 +1,14 @@
 import NextAuth from 'next-auth';
 import GoogleProvider from 'next-auth/providers/google';
 import CredentialsProvider from 'next-auth/providers/credentials';
-
-// In-memory user store (for demo only)
-type User = { email: string; password: string };
-declare global {
-  // eslint-disable-next-line no-var
-  var _users: User[] | undefined;
-}
-const users: User[] = global._users || (global._users = []);
+import { DrizzleAdapter } from '@auth/drizzle-adapter';
+import { db } from '@/db';
+import { users } from '@/db/schema';
+import bcrypt from 'bcryptjs';
 
 const handler = NextAuth({
+  adapter: DrizzleAdapter(db),
+  session: { strategy: 'jwt' },
   providers: [
     GoogleProvider({
       clientId: process.env.GOOGLE_CLIENT_ID ?? '',
@@ -23,25 +21,16 @@ const handler = NextAuth({
         password: { label: "Password", type: "password" }
       },
       async authorize(credentials) {
+        console.log('Credentials received:', credentials);
         if (!credentials?.email || !credentials?.password) return null;
-        // Check in-memory user store
-        const user = users.find(
-          (u) => u.email === credentials.email && u.password === credentials.password
-        );
-        if (user) {
-          return {
-            id: user.email,
-            email: user.email,
-            name: user.email.split('@')[0],
-          };
-        }
-        // For demo, still allow the test user
-        if (credentials.email === "test@example.com" && credentials.password === "password") {
-          return {
-            id: "1",
-            email: credentials.email,
-            name: "Test User",
-          };
+        // Query the real users table using Drizzle
+        const foundUser = await db.query.users.findFirst({
+          where: (u, { eq }) => eq(u.email, credentials.email),
+        });
+        console.log('User found:', foundUser);
+        if (foundUser && foundUser.hashedPassword && await bcrypt.compare(credentials.password, foundUser.hashedPassword)) {
+          console.log('Returning user:', foundUser);
+          return foundUser;
         }
         return null;
       }
@@ -53,17 +42,25 @@ const handler = NextAuth({
     // error: '/account/error', // Uncomment when error page is ready
   },
   callbacks: {
-    async session({ session, token }) {
-      // Add any additional user data to the session here
+    async session({ session, user, token }) {
+      console.log('Session callback - user:', user);
+      console.log('Session callback - token:', token);
+      if (session.user) {
+        (session.user as any).isAdmin = (user as any)?.isAdmin ?? token?.isAdmin ?? false;
+        console.log('Session callback - final isAdmin:', (session.user as any).isAdmin);
+      }
       return session;
     },
     async jwt({ token, user }) {
-      // Add any additional user data to the JWT here
-      if (user) {
-        token.id = user.id;
+      console.log('JWT callback - user:', user);
+      console.log('JWT callback - token before:', token);
+      if (user && typeof user === 'object' && 'isAdmin' in user) {
+        (token as any).isAdmin = (user as any).isAdmin;
+        console.log('JWT callback - setting isAdmin to:', (user as any).isAdmin);
       }
+      console.log('JWT callback - token after:', token);
       return token;
-    },
+    }
   },
 })
 

src/app/api/auth/check-admin/route.ts

@@ -0,0 +1,17 @@
+import { getToken } from 'next-auth/jwt';
+import { NextRequest, NextResponse } from 'next/server';
+
+export async function GET(request: NextRequest) {
+  const token = await getToken({ 
+    req: request,
+    secret: process.env.NEXTAUTH_SECRET 
+  });
+  
+  console.log('Check Admin API - Token:', token);
+  console.log('Check Admin API - isAdmin:', token?.isAdmin);
+  
+  return NextResponse.json({ 
+    isAdmin: token?.isAdmin || false,
+    token: token 
+  });
+} 

src/app/api/categories/route.ts

@@ -1,7 +1,8 @@
-import { db } from "@/db";
-import { componentType } from "@/db/schema";
+import { NextResponse } from 'next/server';
+import { db } from '@/db';
+import { categories } from '@/db/schema';
 
 export async function GET() {
-  const allComponentTypes = await db.select().from(componentType);
-  return Response.json({ success: true, data: allComponentTypes });
+  const allCategories = await db.select().from(categories);
+  return NextResponse.json({ success: true, data: allCategories });
 } 

src/app/api/category-mapping/route.ts

@@ -0,0 +1,66 @@
+import { NextRequest, NextResponse } from 'next/server';
+import { db } from '@/db';
+import { affiliateCategoryMap } from '@/db/schema';
+import { eq } from 'drizzle-orm';
+
+// GET: List all mappings
+export async function GET() {
+  try {
+    const mappings = await db.select().from(affiliateCategoryMap);
+    return NextResponse.json({ success: true, data: mappings });
+  } catch (error: any) {
+    console.error('GET /api/category-mapping error:', error);
+    return NextResponse.json({ success: false, error: error.message || 'Unknown error', data: [] }, { status: 500 });
+  }
+}
+
+// POST: Create a new mapping
+export async function POST(req: NextRequest) {
+  try {
+    const body = await req.json();
+    const { feedname, affiliatecategory, buildercategoryid, notes } = body;
+    if (!feedname || !affiliatecategory || !buildercategoryid) {
+      return NextResponse.json({ success: false, error: 'Missing required fields' }, { status: 400 });
+    }
+    const [inserted] = await db.insert(affiliateCategoryMap).values({ feedname, affiliatecategory, buildercategoryid, notes }).returning();
+    return NextResponse.json({ success: true, data: inserted });
+  } catch (error: any) {
+    console.error('POST /api/category-mapping error:', error);
+    return NextResponse.json({ success: false, error: error.message || 'Unknown error' }, { status: 500 });
+  }
+}
+
+// PUT: Update a mapping
+export async function PUT(req: NextRequest) {
+  try {
+    const body = await req.json();
+    const { id, feedname, affiliatecategory, buildercategoryid, notes } = body;
+    if (!id) {
+      return NextResponse.json({ success: false, error: 'Missing id' }, { status: 400 });
+    }
+    const [updated] = await db.update(affiliateCategoryMap)
+      .set({ feedname, affiliatecategory, buildercategoryid, notes })
+      .where(eq(affiliateCategoryMap.id, id))
+      .returning();
+    return NextResponse.json({ success: true, data: updated });
+  } catch (error: any) {
+    console.error('PUT /api/category-mapping error:', error);
+    return NextResponse.json({ success: false, error: error.message || 'Unknown error' }, { status: 500 });
+  }
+}
+
+// DELETE: Remove a mapping
+export async function DELETE(req: NextRequest) {
+  try {
+    const body = await req.json();
+    const { id } = body;
+    if (!id) {
+      return NextResponse.json({ success: false, error: 'Missing id' }, { status: 400 });
+    }
+    await db.delete(affiliateCategoryMap).where(eq(affiliateCategoryMap.id, id));
+    return NextResponse.json({ success: true });
+  } catch (error: any) {
+    console.error('DELETE /api/category-mapping error:', error);
+    return NextResponse.json({ success: false, error: error.message || 'Unknown error' }, { status: 500 });
+  }
+} 

src/app/api/product-categories/route.ts

@@ -0,0 +1,8 @@
+import { NextResponse } from 'next/server';
+import { db } from '@/db';
+import { product_categories } from '@/db/schema';
+
+export async function GET() {
+  const allCategories = await db.select().from(product_categories);
+  return NextResponse.json({ success: true, data: allCategories });
+}