..

Author: DHAMODHARABALAJI R

order-manager/src/handlers/createOrder.js

@@ -4,7 +4,10 @@ const Order = require("../models/orderModel");
 // const { sendToQueue } = require("../utils/sqs");
 const { v4: uuidv4 } = require("uuid");
 
-const AWS = require('aws-sdk');
+const DynamoDBClient = require('@aws-sdk/client-dynamodb');
+const client = new DynamoDBClient({});
+const docClient = DynamoDBDocumentClient.from(client);
+
 
 const dynamodb = new AWS.DynamoDB.DocumentClient();
 const ordersTable = "OrdersTable";
@@ -15,26 +18,16 @@ exports.handler = async (event) => {
 
     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({
+    const command = new PutCommand({
       TableName: ordersTable,
       Item: {
-        "id": "3",
-        "count": newCount
-      }
-    }).promise();
-
-    console.log("res2 after update: ", res2);
+        id: uuidv4(),
+        name: "test1"
+      },
+    });
 
+    const order = await docClient.send(command);
+    console.log(order);
 
     // await connectDB();
 

order-manager/src/package.json

@@ -10,6 +10,7 @@
       "deploy": "sam build && sam deploy --guided"
     },
     "dependencies": {
+      "@aws-sdk/lib-dynamodb": "^3.321.1",
       "@aws-sdk/client-apigatewaymanagementapi": "^3.428.0",
       "@aws-sdk/client-sqs": "^3.428.0",
       "@aws-sdk/client-dynamodb": "^3.428.0",

order-manager/template.yaml

@@ -1,18 +1,16 @@
-AWSTemplateFormatVersion: '2010-09-09'
+AWSTemplateFormatVersion: "2010-09-09"
 Transform: AWS::Serverless-2016-10-31
 
 Globals:
-
   Function:
     Timeout: 10
 
 Parameters:
-
   HOSTINGENV:
     Type: String
     Description: "Ex: Development, Staging, Production"
     Default: "Production"
-  
+
   # VpcId:
   #   Type: AWS::EC2::VPC::Id
   #   Description: "The VPC ID where resources will be created"
@@ -23,9 +21,7 @@ Parameters:
   #   Type: List<AWS::EC2::SecurityGroup::Id>
   #   Description: "The security group IDs within the VPC"
 
-
 Resources:
-
   OrderApi:
     Type: AWS::Serverless::Api
     Properties:
@@ -69,7 +65,7 @@ Resources:
             Path: /orders
             Method: post
             RestApiId: !Ref OrderApi
-          
+
   # GetMyOrdersFunction:
   #   Type: AWS::Serverless::Function
   #   Properties:
@@ -102,6 +98,13 @@ Resources:
   #           Method: post
   #           RestApiId: !Ref OrderApi
 
-
-
-
+Outputs:
+  # ServerlessRestApi is an implicit API created out of Events key under Serverless::Function
+  # Find out more about other implicit resources you can reference within SAM
+  # https://github.com/awslabs/serverless-application-model/blob/master/docs/internals/generated_resources.rst#api
+  HelloWorldApi:
+    Description: "API Gateway endpoint URL for Prod stage for Create Order function"
+    Value: !Sub "https://${ServerlessRestApi}.execute-api.${AWS::Region}.amazonaws.com/Prod/orders"
+  HelloWorldFunction:
+    Description: "Create Order Lambda Function ARN"
+    Value: !GetAtt CreateOrderFunction.Arn