get orders

Author: DHAMODHARABALAJI R

order-manager/src/handlers/createOrder.js

@@ -1,5 +1,3 @@
-const connectDB = require("../utils/db");
-const Order = require("../models/orderModel");
 // const { setCache } = require("../utils/cache");
 // const { sendToQueue } = require("../utils/sqs");
 const { v4: uuidv4 } = require("uuid");
@@ -19,10 +17,8 @@ exports.handler = async (event) => {
       throw 'Items not configured in the payload'
     }
 
-    console.log('Processing Order Id:', id, ', Item Count: ', items.length);
-
     const order = {
-      id,
+      id: uuidv4(),
       items
     };
 
@@ -35,6 +31,7 @@ exports.handler = async (event) => {
     console.log('order-created:', order, response);
 
     // Payload Sample
+
     // {
     //   "id": "2",
     //   "items": [

order-manager/src/handlers/getMyOrders.js

@@ -1,14 +1,23 @@
-const connectDB = require("../utils/db");
-const Order = require("../models/orderModel");
+const { DynamoDBClient } = require("@aws-sdk/client-dynamodb");
+const { ScanCommand, DynamoDBDocumentClient } = require("@aws-sdk/lib-dynamodb");
+const client = new DynamoDBClient({});
+const docClient = DynamoDBDocumentClient.from(client);
+const ordersTable = "OrdersTable";
 
 exports.handler = async (event) => {
-  await connectDB();
 
-  order = await Order.find({});
-  if (!order) return { statusCode: 404, body: "Order not found" };
+  const body = await dynamo.send(
+    new ScanCommand({
+      TableName: ordersTable,
+    })
+  );
+
+  console.log('items: ', body.Items)
+
+  if (!body || !body.Items) return { statusCode: 404, body: "Orders not found" };
 
   return {
     statusCode: 200,
-    body: JSON.stringify(order),
+    body: JSON.stringify(body.Items),
   };
 };

order-manager/template.yaml

@@ -84,37 +84,34 @@ Resources:
         AppGroup: OrdersLambda
         AppType: Serverless
 
-  # GetMyOrdersFunction:
-  #   Type: AWS::Serverless::Function
-  #   Properties:
-  #     CodeUri: src/
-  #     Handler: handlers/getMyOrders.handler
-  #     Runtime: nodejs22.x
-  #     MemorySize: 128
-  #     Timeout: 10
-  #     Policies:
-  #       - AWSLambdaVPCAccessExecutionRole
-  #       - AmazonDynamoDBFullAccess
-  #       - AWSLambdaSQSQueueExecutionRole
-  #       - AWSLambdaBasicExecutionRole
-  #       - AWSSecretsManagerGetSecretValuePolicy:
-  #           SecretArn: !Sub "arn:aws:secretsmanager:${AWS::Region}:${AWS::AccountId}:secret:mongodb/credentials-*"
-  #     Environment:
-  #       Variables:
-  #         HOSTING_ENV: !Ref HOSTINGENV
-  #         DB_URI: ""
-  #         REDIS_HOST: ""
-  #         MONGODB_SECRET_ARN: !Sub "arn:aws:secretsmanager:${AWS::Region}:${AWS::AccountId}:secret:mongodb/credentials"
-  #     VpcConfig:
-  #       SecurityGroupIds: !Ref SecurityGroupIds
-  #       SubnetIds: !Ref SubnetIds
-  #     Events:
-  #       ApiEvent:
-  #         Type: Api
-  #         Properties:
-  #           Path: /myorders
-  #           Method: post
-  #           RestApiId: !Ref OrderApi
+  GetMyOrdersFunction:
+    Type: AWS::Serverless::Function
+    Properties:
+      CodeUri: src/
+      Handler: handlers/getMyOrders.handler
+      Runtime: nodejs22.x
+      MemorySize: 128
+      Timeout: 10
+      Policies:
+        - DynamoDBCrudPolicy:
+            TableName: 
+              !Ref DynamoDBOrdersTable
+        - AWSLambdaVPCAccessExecutionRole
+        - AmazonDynamoDBFullAccess
+        - AWSLambdaSQSQueueExecutionRole
+        - AWSLambdaBasicExecutionRole
+        - AWSSecretsManagerGetSecretValuePolicy:
+            SecretArn: !Sub "arn:aws:secretsmanager:${AWS::Region}:${AWS::AccountId}:secret:mongodb/credentials-*"
+      Environment:
+        Variables:
+          HOSTING_ENV: !Ref HOSTINGENV
+      Events:
+        ApiEvent:
+          Type: Api
+          Properties:
+            Path: /myorders
+            Method: get
+            RestApiId: !Ref OrderApi
 
 Outputs:
   # ServerlessRestApi is an implicit API created out of Events key under Serverless::Function