mutliplr changes but nothing is working as of now

Author: Coder-philosopher

aws/Dockerfile

@@ -0,0 +1,22 @@
+# Use the official AWS Lambda Node.js 18 runtime base image
+FROM public.ecr.aws/lambda/nodejs:18
+
+# Set working directory inside the container
+WORKDIR /var/task
+
+# Copy package.json and package-lock.json first for caching dependencies
+COPY package*.json ./
+
+# Install all production dependencies
+RUN npm install --production
+
+# Copy the full backend source code into container
+COPY . .
+
+# (Optional) Build step if using typescript or transpilers
+# RUN npm run build or tsc
+
+# Set the Lambda handler (adjust path and exported handler function if different)
+# For a single API Lambda serving all routes, this could be main.js exporting handler
+# or an index.js that routes calls internally
+CMD [ "aws/main.handler" ]

aws/controllers/admin.controller.js

@@ -0,0 +1,20 @@
+// aws/controllers/admin.controller.js
+const db = require('../services/db');
+
+async function listAllUsers() {
+  return await db.listUsers();
+}
+
+async function listAllProjects() {
+  return await db.listAllProjects();
+}
+
+async function updateFeatureFlags(userId, flags) {
+  return await db.setUserFeatureFlags(userId, flags);
+}
+
+module.exports = {
+  listAllUsers,
+  listAllProjects,
+  updateFeatureFlags,
+};

aws/controllers/analytics.controller.js

@@ -0,0 +1,15 @@
+// aws/controllers/analytics.controller.js
+const db = require('../services/db');
+
+async function getProjectAnalytics(projectId) {
+  return await db.fetchAnalyticsByProject(projectId);
+}
+
+async function storeFeedback(projectId, userId, feedback) {
+  return await db.saveUserFeedback({ projectId, userId, ...feedback, createdAt: new Date().toISOString() });
+}
+
+module.exports = {
+  getProjectAnalytics,
+  storeFeedback,
+};

aws/controllers/apikeys.controller.js

@@ -0,0 +1,36 @@
+// aws/controllers/apikeys.controller.js
+const { generateApiKey, hashApiKey } = require('../utils/apiKeyManager');
+const { AppError } = require('../utils/errorHandler');
+const db = require('../services/db');
+
+async function listApiKeys(userId) {
+  return await db.getApiKeysByUser(userId);
+}
+
+async function createApiKey(userId, projectId) {
+  const { rawKey, hash } = generateApiKey();
+
+  const saved = await db.createApiKey({
+    userId,
+    projectId,
+    keyHash: hash,
+    createdAt: new Date().toISOString(),
+  });
+
+  if (!saved) throw new AppError("Failed to create API key", 500);
+
+  // Return only rawKey once to user (can't retrieve later)
+  return { apiKey: rawKey };
+}
+
+async function revokeApiKey(keyId, userId) {
+  const deleted = await db.deleteApiKey(keyId, userId);
+  if (!deleted) throw new AppError("Failed to revoke API key", 500);
+  return true;
+}
+
+module.exports = {
+  listApiKeys,
+  createApiKey,
+  revokeApiKey,
+};

aws/controllers/billing.controller.js

@@ -0,0 +1,43 @@
+// aws/controllers/billing.controller.js
+const fetch = require('node-fetch');
+const { AppError } = require('../utils/errorHandler');
+const { stripeKey } = require('../utils/env'); // (replace if using Polar secrets)
+const POLAR_API_BASE = 'https://api.polar.sh/v1';
+
+// Polar Auth token should be added to env vars
+const POLAR_API_KEY = process.env.POLAR_API_KEY;
+
+if (!POLAR_API_KEY) {
+  throw new Error("Missing POLAR_API_KEY in environment variables");
+}
+
+// Example: Create a Checkout Session
+async function createCheckoutSession(userId, planId) {
+  const response = await fetch(`${POLAR_API_BASE}/checkout_sessions`, {
+    method: 'POST',
+    headers: {
+      'Authorization': `Bearer ${POLAR_API_KEY}`,
+      'Content-Type': 'application/json'
+    },
+    body: JSON.stringify({
+      customer: userId,  // your user identifier in Polar
+      plan: planId,
+      success_url: 'https://yourfrontend.com/success',
+      cancel_url: 'https://yourfrontend.com/cancel'
+    })
+  });
+
+  if (!response.ok) {
+    const errStr = await response.text();
+    throw new AppError(`Polar Checkout Session creation failed: ${errStr}`, 500);
+  }
+
+  const data = await response.json();
+  return data;  // Contains session URL or ID to send back to frontend
+}
+
+// Other billing-related functions: webhook handling, subscription status, etc.
+
+module.exports = {
+  createCheckoutSession,
+};

aws/controllers/chat.controller.js

@@ -0,0 +1,24 @@
+// aws/controllers/chat.controller.js
+const { AppError } = require('../utils/errorHandler');
+const aiService = require('../ai/index.js');
+
+async function sendChatQuery(userId, projectId, queryText) {
+  if (!queryText) throw new AppError("Query is required", 400);
+  
+  // Call AI service pipeline/chat with query
+  const response = await aiService.chatPipeline(userId, projectId, queryText);
+  return response;
+}
+
+async function sendChatStream(userId, projectId, queryText) {
+  if (!queryText) throw new AppError("Query is required", 400);
+
+  // Call streaming pipeline
+  const stream = await aiService.chatStreamPipeline(userId, projectId, queryText);
+  return stream;
+}
+
+module.exports = {
+  sendChatQuery,
+  sendChatStream,
+};

aws/controllers/index.js

@@ -0,0 +1,29 @@
+// aws/controllers/index.js
+
+const aiController = require('./ai.controller');
+const authController = require('./auth.controller');
+const billingController = require('./billing.controller');
+const projectsController = require('./projects.controller');
+const scrapingController = require('./scraping.controller');
+
+// Newly added controllers from our plan
+const usersController = require('./users.controller');
+const apikeysController = require('./apikeys.controller');
+const chatController = require('./chat.controller');
+const analyticsController = require('./analytics.controller');
+const supportController = require('./support.controller');
+const adminController = require('./admin.controller');
+
+module.exports = {
+  aiController,
+  authController,
+  billingController,
+  projectsController,
+  scrapingController,
+  usersController,
+  apikeysController,
+  chatController,
+  analyticsController,
+  supportController,
+  adminController
+};

aws/controllers/support.controller.js

@@ -0,0 +1,26 @@
+// aws/controllers/support.controller.js
+const db = require('../services/db');
+const { AppError } = require('../utils/errorHandler');
+
+async function createSupportTicket(userId, subject, description) {
+  if (!subject || !description) throw new AppError("Subject and description required", 400);
+  
+  const ticket = {
+    userId,
+    subject,
+    description,
+    status: 'open',
+    createdAt: new Date().toISOString(),
+  };
+
+  return await db.insertTicket(ticket);
+}
+
+async function listUserTickets(userId) {
+  return await db.getTicketsByUser(userId);
+}
+
+module.exports = {
+  createSupportTicket,
+  listUserTickets
+};

aws/controllers/users.controller.js

@@ -0,0 +1,44 @@
+// aws/controllers/users.controller.js
+const { AppError } = require('../utils/errorHandler');
+const db = require('../services/db'); // Your DB query module here
+const clerkClient = require('@clerk/clerk-sdk-node'); // Clerk SDK
+
+// Fetch user details by userId (Clerk user id)
+async function getUserById(userId) {
+  const userRecord = await db.getUser(userId);
+  if (!userRecord) {
+    // Optionally, fetch from Clerk if not found locally and create local record
+    const clerkUser = await clerkClient.users.getUser(userId);
+    if (!clerkUser) throw new AppError('User not found', 404);
+
+    const newUser = {
+      id: clerkUser.id,
+      email: clerkUser.emailAddresses[0].emailAddress,
+      plan: 'free', // default plan
+      createdAt: new Date().toISOString(),
+      // any other metadata
+    };
+
+    await db.createUser(newUser);
+    return newUser;
+  }
+  return userRecord;
+}
+
+// Update user plan and metadata in DB (called from Clerk webhook handler usually)
+async function updateUserPlan(userId, plan) {
+  const updated = await db.updateUser(userId, { plan });
+  if (!updated) throw new AppError("Failed to update user plan", 500);
+  return updated;
+}
+
+// List all users (for admin)
+async function listUsers() {
+  return await db.listUsers();
+}
+
+module.exports = {
+  getUserById,
+  updateUserPlan,
+  listUsers,
+};

aws/docker/aiChatHandler.Dockerfile

@@ -0,0 +1,6 @@
+FROM public.ecr.aws/lambda/nodejs:18
+WORKDIR /var/task
+COPY package*.json ./
+RUN npm install --production
+COPY . .
+CMD [ "aws/handlers/aiChatHandler.handler" ]