fix vari

Author: Alberto Rizzi

README.md

@@ -3,7 +3,7 @@ Il presente progetto ha lo scopo di implementare un prototipo di flusso di un e-
 
 ## Autori
 - Lorenzo Marcolli (mat. 08302A)
-- Alberto Rizzi (mart. 08303A)
+- Alberto Rizzi (mat. 08303A)
 
 ## Diagram flow
 <div align="center">

assets/presentazione_rizzi.pdf

@@ -1,32 +1,88 @@
+import { SQSClient, SendMessageCommand } from "@aws-sdk/client-sqs";
+const sqsClient = new SQSClient({ region: "eu-central-1" });
+
 import { DynamoDBClient, PutItemCommand } from "@aws-sdk/client-dynamodb"; // ES Modules import
 
 const dynamoDBClient = new DynamoDBClient();
 
+
 export const handler = async (event) => {
-    const orderId = event.queryStringParameters.orderId
-    const connectionId = event.requestContext.connectionId
+    let response;
+    let dataSQS;
 
-    console.log(orderId)
-    console.log(connectionId)
+    // check if body is empty
+    if (!event.body) {
+        response = {
+            statusCode: 400,
+            body: JSON.stringify({ "message": "missing_information" }),
+        }
+        return response
+    }
 
-    const params = {
-        TableName: 'CallbackDB',
+    // check if body is valid JSON
+    try {
+        JSON.parse(event.body)
+    }
+    catch (error) {
+        response = {
+            statusCode: 400,
+            body: JSON.stringify({ "message": "invalid_json" }),
+        }
+        return response
+    }
+
+    // check if basket is empty
+    if (!JSON.parse(event.body).basket) {
+        response = {
+            statusCode: 400,
+            body: JSON.stringify({ "message": "empty_basket" }),
+        }
+        return response
+    }
+
+    // check if event has shipping address
+    if (!JSON.parse(event.body).shippingAddress) {
+        response = {
+            statusCode: 400,
+            body: JSON.stringify({ "message": "missing_shipping_address" }),
+        }
+        return response
+    }
+
+    // check if event has paymentDetails
+    if (!JSON.parse(event.body).paymentDetails) {
+        response = {
+            statusCode: 400,
+            body: JSON.stringify({ "message": "missing_payment_details" }),
+        }
+        return response
+    }
+
+    // create random string to identify order
+    const characters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
+    let randomString = '';
+
+    for (let i = 0; i < 20; i++) {
+        const randomIndex = Math.floor(Math.random() * characters.length);
+        randomString += characters.charAt(randomIndex);
+    }
+
+    const basket = JSON.parse(event.body).basket
+
+    const paramsDynamo = {
+        TableName: 'Order',
         Item: {
-            orderId: { S: orderId },
-            connectionId: { S: connectionId }
+            orderId: { S: randomString },
+            basket: { S: JSON.stringify(basket) },
+            orderStatus: { S: "pending" }
         }
     }
 
-    const command = new PutItemCommand(params);
+    const command = new PutItemCommand(paramsDynamo);
 
     try {
         const res = await dynamoDBClient.send(command);
-
         console.log(res)
-        return {
-            statusCode: 200,
-            body: JSON.stringify('Record added successfully')
-        };
     }
     catch (error) {
         console.log(error)
@@ -35,4 +91,57 @@ export const handler = async (event) => {
             body: JSON.stringify('Error adding record')
         };
     }
+
+    dataSQS = JSON.parse(event.body)
+    dataSQS.orderId = randomString
+
+    const params = {
+        DelaySeconds: 0,
+        MessageAttributes: {
+            Author: {
+                DataType: "String",
+                StringValue: "Preeti",
+            }
+        },
+        MessageBody: JSON.stringify(dataSQS),
+        MessageGroupId: randomString,
+        FifoQueue: true,
+        MessageDeduplicationId: randomString,
+        MessageRetentionPeriod: 345600,
+        QueueUrl: "https://sqs.eu-central-1.amazonaws.com/495456954059/OrdersQueueFIFO.fifo"
+    };
+
+    // Send the order to SQS
+    try {
+        const data = await sqsClient.send(new SendMessageCommand(params));
+        if (data) {
+            console.log("Success, message sent. MessageID:", data.MessageId);
+            const bodyMessage = {
+                message: 'Message Send to SQS - MessageId: ' + data.MessageId,
+                orderId: randomString,
+                callbackUrl: "wss://wkr7p95088.execute-api.eu-central-1.amazonaws.com/production/"
+            }
+
+            response = {
+                headers: {
+                    "Access-Control-Allow-Headers": "Content-Type",
+                    "Access-Control-Allow-Origin": "*",
+                    "Access-Control-Allow-Methods": "POST"
+                },
+
+                statusCode: 200,
+                body: JSON.stringify(bodyMessage),
+            };
+        }
+        else {
+            response = {
+                statusCode: 500,
+                body: JSON.stringify({ "message": "error_sending_message_to_SQS" }),
+            };
+        }
+        return response;
+    }
+    catch (err) {
+        console.log("Error", err);
+    }
 };