order-to-dynamodb

Author: DHAMODHARABALAJI R

order-manager/src/handlers/createOrder.js

@@ -4,29 +4,67 @@ const Order = require("../models/orderModel");
 // const { sendToQueue } = require("../utils/sqs");
 const { v4: uuidv4 } = require("uuid");
 
+const AWS = require('aws-sdk');
+
+const dynamodb = new AWS.DynamoDB.DocumentClient();
+const ordersTable = "OrdersTable";
+
+
 exports.handler = async (event) => {
+  try {
+
+    console.log('Environment:', process.env);
+
+    const res = await dynamodb.get({
+      TableName: ordersTable,
+      Key: { "id": "3" }
+    }).promise();
+
+    console.log("res from get item:", res);
+    console.log("item from res: ", res.Item);
+
+    const newCount = res.Item.count + 1;
+
+    const res2 = await dynamodb.put({
+      TableName: ordersTable,
+      Item: {
+        "id": "3",
+        "count": newCount
+      }
+    }).promise();
+
+    console.log("res2 after update: ", res2);
+
+
+    // await connectDB();
 
-  // console.log('Environment:', process.env);
+    // const { customerName, items } = JSON.parse(event.body);
 
-  await connectDB();
+    // const totalAmount = items.reduce((sum, item) => sum + item.price * item.quantity, 0);
 
-  const { customerName, items } = JSON.parse(event.body);
-  
-  const totalAmount = items.reduce((sum, item) => sum + item.price * item.quantity, 0);
-  
-  const order = new Order({ orderId: uuidv4(), customerName, items, totalAmount });
-  await order.save();
+    // const order = new Order({ orderId: uuidv4(), customerName, items, totalAmount });
+    // await order.save();
 
-  console.log('order-created:', order);
+    // console.log('order-created:', order);
 
-  // await setCache(`order:${order.orderId}`, order);
+    // await setCache(`order:${order.orderId}`, order);
 
-  // console.log('cache-set:', order);
+    // console.log('cache-set:', order);
 
-  // await sendToQueue({ orderId: order.orderId, status: "Pending" });
+    // await sendToQueue({ orderId: order.orderId, status: "Pending" });
 
-  return {
-    statusCode: 201,
-    body: JSON.stringify({ message: "Order created", orderId: order.orderId }),
-  };
+    return {
+      statusCode: 201,
+      body: JSON.stringify({ message: "Order created", orderId: order.orderId }),
+    };
+  } catch (e) {
+    console.log(e);
+    return {
+      statusCode: 500,
+      body: JSON.stringify({
+        event: event,
+        exception: e.toString()
+      })
+    };
+  }
 };

order-manager/template.yaml

@@ -4,7 +4,7 @@ Transform: AWS::Serverless-2016-10-31
 Globals:
 
   Function:
-    Timeout: 3
+    Timeout: 10
 
 Parameters:
 
@@ -32,10 +32,10 @@ Resources:
       Name: OrderServiceAPI
       StageName: v1
 
-  OrderQueue:
-    Type: AWS::SQS::Queue
-    Properties:
-      QueueName: OrderQueue
+  # OrderQueue:
+  #   Type: AWS::SQS::Queue
+  #   Properties:
+  #     QueueName: OrderQueue
 
   CreateOrderFunction:
     Type: AWS::Serverless::Function
@@ -56,12 +56,12 @@ Resources:
         Variables:
           HOSTING_ENV: !Ref HOSTINGENV
           DB_URI: ""
-          REDIS_HOST: ""
-          SQS_URL: !Ref OrderQueue
-          MONGODB_SECRET_ARN: !Sub "arn:aws:secretsmanager:${AWS::Region}:${AWS::AccountId}:secret:mongodb/credentials"
-      VpcConfig:
-        SecurityGroupIds: !Ref SecurityGroupIds
-        SubnetIds: !Ref SubnetIds
+          # REDIS_HOST: ""
+          # SQS_URL: !Ref OrderQueue
+          # 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
@@ -70,37 +70,37 @@ Resources:
             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:
-        - 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:
+  #       - 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