#319 - created the insert partiql query

serverless.yml

@@ -48,10 +48,10 @@ resources:
       Properties:
         TableName: ${self:custom.regionTableName}
         AttributeDefinitions:
-          - AttributeName: id
+          - AttributeName: uf
             AttributeType: S
         KeySchema:
-          - AttributeName: id
+          - AttributeName: uf
             KeyType: HASH
         ProvisionedThroughput:
           ReadCapacityUnits: ${self:custom.tableThroughput}

src/components/dynamodb/querys/save-new-region.js

@@ -0,0 +1,19 @@
+import AWS from 'aws-sdk';
+import { stringify } from '../utils/stringify-data-before-save';
+
+const dynamoDB = new AWS.DynamoDB();
+
+async function saveNewRegion(tableName, data) {
+  const insertQuery = `INSERT INTO "${tableName}" VALUE ${stringify(data)}`;
+  try {
+    return dynamoDB
+      .executeStatement({
+        Statement: insertQuery,
+      })
+      .promise();
+  } catch (error) {
+    throw error;
+  }
+}
+
+export { saveNewRegion };

src/components/dynamodb/utils/stringify-data-before-save.js

@@ -0,0 +1,25 @@
+/* eslint-disable max-depth */
+/* eslint-disable complexity */
+/* eslint-disable max-statements */
+function stringify(value) {
+  const lastKey = Object.keys(value).pop();
+  let objString = '';
+  if (typeof value === 'object') {
+    objString += '{';
+    for (const key in value) {
+      objString += `'${key}':${stringify(value[key])}`;
+      if (key !== lastKey) {
+        objString += ',';
+      }
+    }
+    objString += '}';
+  } else if (typeof value === 'string') {
+    objString += `'${value.replace(/'/g, "''")}'`;
+  } else if (typeof value === 'number') {
+    objString += `${value}`;
+  } else if (typeof value === 'boolean') {
+    objString += `${value}`;
+  }
+  return objString;
+}
+export { stringify };

src/functions/create-new-region/config.js

@@ -0,0 +1,5 @@
+const config = {
+  regionTableName: process.env.regionTableName,
+};
+
+export { config };

src/functions/create-new-region/handler.js

@@ -1,17 +1,23 @@
+import { config } from './config';
+import { saveNewRegion } from '../../components/dynamodb/querys/save-new-region';
+import { handlerSuccess } from '../../libs/http/response/handler-success';
+import { handlerResponseError } from '../../libs/http/response/handler-error';
+import { createNewRegion } from './use-case';
+
 async function handlerCreateNewRegion(event) {
-  console.log('regionTableName', process.env.regionTableName);
-  console.log('event.body', event.body);
-  return {
-    statusCode: 200,
-    body: JSON.stringify(
-      {
-        message: 'Go Serverless v1.0! Your function executed successfully!',
-        input: event.body,
-      },
-      null,
-      2,
-    ),
-  };
+  const {
+    body,
+    requestContext: { requestId },
+  } = event;
+  try {
+    const region = createNewRegion(JSON.parse(body), {
+      saveNewRegion,
+      tableName: config.regionTableName,
+    });
+    return handlerSuccess({ body: region }, requestId);
+  } catch (error) {
+    return handlerResponseError({ error }, requestId);
+  }
 }
 
 export { handlerCreateNewRegion };

src/functions/create-new-region/use-case/index.js

@@ -0,0 +1,5 @@
+async function createNewRegion({ uf, label, draft = true }, { saveNewRegion, tableName }) {
+  return saveNewRegion(tableName, { uf: uf, label, draft });
+}
+
+export { createNewRegion };