Test-1

Author: Coder-philosopher

aws/.aws-sam/build.toml

@@ -1,40 +1,50 @@
 # This file is auto generated by SAM CLI build command
 
-[function_build_definitions.d4cdc4f4-b6a9-48d4-a2ff-19fb9d9e8786]
+[function_build_definitions.1c4c8e46-8650-4c74-9f1f-71edc7117c05]
 packagetype = "Image"
 functions = ["RegisterFunction"]
 
-[function_build_definitions.d4cdc4f4-b6a9-48d4-a2ff-19fb9d9e8786.metadata]
+[function_build_definitions.1c4c8e46-8650-4c74-9f1f-71edc7117c05.metadata]
 DockerTag = "ai-register-lambda"
 DockerContext = "D:\\GOATED\\Zuno - AI Powered Chatbot\\aws"
 Dockerfile = "NodeRegister.Dockerfile"
 DockerCMD = ["handlers/registerHandler.handler"]
 
-[function_build_definitions.7ed0cd8e-4ac1-447a-98f5-5f27de2071db]
+[function_build_definitions.a376c12b-eeb1-4ce3-ba76-2a0665110fc3]
+packagetype = "Image"
+functions = ["ProjectFunction"]
+
+[function_build_definitions.a376c12b-eeb1-4ce3-ba76-2a0665110fc3.metadata]
+DockerTag = "ai-project-lambda"
+DockerContext = "D:\\GOATED\\Zuno - AI Powered Chatbot\\aws"
+Dockerfile = "CreateProject.Dockerfile"
+DockerCMD = ["handlers/CreateProjectHandler.handler"]
+
+[function_build_definitions.d15cc648-6c32-4c83-911c-7cec3f826e32]
 packagetype = "Image"
 functions = ["ChatFunction"]
 
-[function_build_definitions.7ed0cd8e-4ac1-447a-98f5-5f27de2071db.metadata]
+[function_build_definitions.d15cc648-6c32-4c83-911c-7cec3f826e32.metadata]
 DockerTag = "ai-chat-lambda"
 DockerContext = "D:\\GOATED\\Zuno - AI Powered Chatbot\\aws"
 Dockerfile = "NodeChat.Dockerfile"
 DockerCMD = ["handlers/aiChatHandler.handler"]
 
-[function_build_definitions.ea5595d6-5f2e-42af-8cba-5aa26d682af3]
+[function_build_definitions.fd320841-8c10-44bc-aa22-3af3e15bae69]
 packagetype = "Image"
 functions = ["EmbeddingFunction"]
 
-[function_build_definitions.ea5595d6-5f2e-42af-8cba-5aa26d682af3.metadata]
+[function_build_definitions.fd320841-8c10-44bc-aa22-3af3e15bae69.metadata]
 DockerTag = "ai-embedding-lambda"
 DockerContext = "D:\\GOATED\\Zuno - AI Powered Chatbot\\aws"
 Dockerfile = "EmbeddingHandler.Dockerfile"
 DockerCMD = ["handlers/embeddingHandler.handler"]
 
-[function_build_definitions.a8d59e15-5123-4732-b7a3-f394bec8d81f]
+[function_build_definitions.6a9d1400-d6ba-4472-ade4-7f5e5c9262a7]
 packagetype = "Image"
 functions = ["ScrapingFunction"]
 
-[function_build_definitions.a8d59e15-5123-4732-b7a3-f394bec8d81f.metadata]
+[function_build_definitions.6a9d1400-d6ba-4472-ade4-7f5e5c9262a7.metadata]
 DockerTag = "ai-scraper-lambda"
 DockerContext = "D:\\GOATED\\Zuno - AI Powered Chatbot\\aws"
 Dockerfile = "PythonScraper.Dockerfile"

aws/CreateProject.Dockerfile

@@ -0,0 +1,11 @@
+FROM public.ecr.aws/lambda/nodejs:18
+
+WORKDIR /var/task
+
+COPY package*.json ./
+
+RUN npm ci --only=production
+
+COPY . .
+
+CMD ["handlers/createProjectHandler.js"]

aws/EmbeddingHandler.Dockerfile

@@ -11,4 +11,4 @@ RUN npm ci --only=production
 COPY . .
 
 # CMD must be module.function
-CMD ["embeddingHandler.handler"]
+CMD ["handlers/embeddingHandler.handler"]

aws/NodeChat.Dockerfile

@@ -11,4 +11,4 @@ RUN npm ci --only=production
 COPY . .
 
 # CMD must be module.function
-CMD ["aiChatHandler.handler"]
+CMD ["handlers/aiChatHandler.handler"]

aws/NodeRegister.Dockerfile

@@ -11,4 +11,4 @@ RUN npm ci --only=production
 COPY . .
 
 # CMD must be module.function
-CMD ["registerHandler.handler"]
+CMD ["handlers/registerHandler.handler"]

aws/PythonScraper.Dockerfile

@@ -5,4 +5,4 @@ RUN yum install -y gcc gcc-c++ libffi-devel libxml2-devel libxslt-devel python3-
 RUN pip install --upgrade pip && pip install scrapy boto3
 
 COPY . .
-CMD ["scrapingHandler.handler"]
+CMD ["handlers/scrapingHandler.handler"]

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/handlers/createProjectHandler.js

@@ -1,4 +1,5 @@
 // aws/handlers/createProjectHandler.js
+require("dotenv").config();
 
 const { DynamoDBClient } = require('@aws-sdk/client-dynamodb');
 const {

aws/handlers/registerHandler.js

@@ -1,47 +1,72 @@
 // aws/handlers/registerHandler.js
+require("dotenv").config();
 
 const { DynamoDBClient } = require('@aws-sdk/client-dynamodb');
 const { DynamoDBDocumentClient, GetCommand, PutCommand } = require('@aws-sdk/lib-dynamodb');
 
-const isLocal = process.env.IS_OFFLINE === "true";
-
-const ddb = DynamoDBDocumentClient.from(
-  new DynamoDBClient(
-    isLocal
-      ? {
-          region: "local",
-          endpoint: "http://localhost:8000",
-          credentials: {
-            accessKeyId: "dummy",
-            secretAccessKey: "dummy",
-          },
-        }
-      : { region: process.env.AWS_REGION }
-  )
-);
+const isLocal = "true";
+
+console.log("Environment variables:", {
+  USERS_TABLE: process.env.USERS_TABLE,
+  AWS_REGION: process.env.AWS_REGION,
+});
+
+const ddbClientConfig = isLocal
+  ? {
+      region: "local",
+      endpoint: "http://localhost:8000",
+      credentials: {
+        accessKeyId: "dummy",
+        secretAccessKey: "dummy",
+      },
+    }
+  : { region: process.env.AWS_REGION };
+
+console.log("DynamoDB Client Config:", ddbClientConfig);
+
+const ddb = DynamoDBDocumentClient.from(new DynamoDBClient(ddbClientConfig));
 
 exports.handler = async (event) => {
   try {
+    console.log("Received event:", JSON.stringify(event, null, 2));
+
     const body = JSON.parse(event.body || '{}');
+    console.log("Parsed body:", body);
+
     const { userId, fullName, email } = body;
 
     if (!userId || !email || !fullName) {
+      console.warn("Missing required fields in request body");
       return {
         statusCode: 400,
         body: JSON.stringify({ error: 'Missing required user fields: userId, fullName, email' }),
       };
     }
 
+    const tableName = process.env.USERS_TABLE;
+    console.log("Using DynamoDB table:", tableName);
+
+    if (!tableName) {
+      console.error("USERS_TABLE env variable is missing or empty");
+      return {
+        statusCode: 500,
+        body: JSON.stringify({ error: "Server misconfiguration: USERS_TABLE is not set" }),
+      };
+    }
+
     // Check if user already exists
+    console.log(`Checking if user ${userId} exists in table ${tableName}...`);
     const existingUser = await ddb.send(
       new GetCommand({
-        TableName: process.env.USERS_TABLE,
+        TableName: tableName,
         Key: { userId },
       })
     );
 
+    console.log("DynamoDB GetCommand response:", existingUser);
+
     if (existingUser.Item) {
-      // User already registered, return success with existing user info (optional)
+      console.log(`User ${userId} already exists`);
       return {
         statusCode: 200,
         body: JSON.stringify({
@@ -64,13 +89,17 @@ exports.handler = async (event) => {
       createdAt: new Date().toISOString(),
     };
 
-    await ddb.send(
+    console.log("Creating new user:", newUser);
+
+    const putResult = await ddb.send(
       new PutCommand({
-        TableName: process.env.USERS_TABLE,
+        TableName: tableName,
         Item: newUser,
       })
     );
 
+    console.log("DynamoDB PutCommand result:", putResult);
+
     return {
       statusCode: 201,
       body: JSON.stringify({

aws/sample/project.js

@@ -0,0 +1,23 @@
+// testRegister.js
+const { handler } = require("../handlers/createProjectHandler");
+
+const mockEvent = {
+  body: JSON.stringify({
+    userId: "test-user-123",
+    fullName: "Test User",
+    email: "[email protected]",
+    frontendUrl:"thetechshaikh.online",
+    projectName:"project-test"
+  }),
+};
+
+console.log("Invoking handler with event:", mockEvent);
+
+handler(mockEvent)
+  .then((res) => {
+    console.log("Lambda Response:", res);
+  })
+  .catch((err) => {
+    console.error("Lambda Error:", err);
+  });
+