Merge pull request #2 from Mipmipp/feature/crud

Feature: Add CRUD.

Author: hernandosebastian

.env.dist

@@ -0,0 +1,3 @@
+# DYNAMOOSE
+DYNAMOOSE_ENDPOINT = "http://host.docker.internal:4566"
+DYNAMOOSE_REGION = "us-east-1"

.gitignore

@@ -1,2 +1,5 @@
 # DEPENDENCIES
 /node_modules/*
+
+# ENVIRONMENT VARIABLES
+.env

package-lock.json

@@ -31,6 +31,14 @@
     "localstack"
   ],
   "devDependencies": {
+    "@types/aws-lambda": "^8.10.145",
+    "@types/node": "^22.7.4",
+    "@types/uuid": "^10.0.0",
     "typescript": "^5.6.2"
+  },
+  "dependencies": {
+    "dynamoose": "^4.0.1",
+    "http-status-codes": "^2.3.0",
+    "uuid": "^10.0.0"
   }
 }

package.json

@@ -0,0 +1,4 @@
+import * as ItemController from "./item.controller";
+
+export const { createItem, getItem, getAllItems, updateItem, deleteItem } =
+  ItemController;

src/controller/index.ts

@@ -0,0 +1,65 @@
+import { APIGatewayEvent } from "aws-lambda";
+import { StatusCodes } from "http-status-codes";
+import { createResponse, ErrorMessages } from "../utils";
+import { ItemService } from "../services";
+
+const itemService = new ItemService();
+
+const createItem = async (event: APIGatewayEvent) => {
+  const itemData = JSON.parse(event.body ?? "{}");
+  const newItem = await itemService.create(itemData);
+
+  return createResponse(StatusCodes.CREATED, newItem);
+};
+
+const getItem = async (event: APIGatewayEvent) => {
+  const itemId = event.pathParameters?.id;
+
+  if (!itemId) {
+    return createResponse(StatusCodes.BAD_REQUEST, {
+      message: ErrorMessages.ITEM_ID_REQUIRED,
+    });
+  }
+
+  const item = await itemService.get(itemId);
+
+  return createResponse(StatusCodes.OK, item);
+};
+
+const getAllItems = async () => {
+  const items = await itemService.getAll();
+
+  return createResponse(StatusCodes.OK, items);
+};
+
+const updateItem = async (event: APIGatewayEvent) => {
+  const itemId = event.pathParameters?.id;
+
+  if (!itemId) {
+    return createResponse(StatusCodes.BAD_REQUEST, {
+      message: ErrorMessages.ITEM_ID_REQUIRED,
+    });
+  }
+
+  const itemData = JSON.parse(event.body ?? "{}");
+  const updatedItem = await itemService.update(itemId, itemData);
+
+  return createResponse(StatusCodes.OK, updatedItem);
+};
+
+const deleteItem = async (event: APIGatewayEvent) => {
+  const itemId = event.pathParameters?.id;
+
+  if (!itemId) {
+    return createResponse(StatusCodes.BAD_REQUEST, {
+      message: ErrorMessages.ITEM_ID_REQUIRED,
+    });
+  }
+
+  const itemDeleted = await itemService.get(itemId);
+  await itemService.delete(itemId);
+
+  return createResponse(StatusCodes.NO_CONTENT, itemDeleted);
+};
+
+export { createItem, getItem, getAllItems, updateItem, deleteItem };

src/controller/item.controller.ts

@@ -0,0 +1,33 @@
+import { APIGatewayEvent, APIGatewayProxyResult } from "aws-lambda";
+import { StatusCodes } from "http-status-codes";
+import {
+  createItem,
+  deleteItem,
+  getAllItems,
+  getItem,
+  updateItem,
+} from "./controller";
+import { ErrorMessages } from "./utils";
+
+export const handler = async (
+  event: APIGatewayEvent
+): Promise<APIGatewayProxyResult> => {
+  switch (event.httpMethod) {
+    case "POST":
+      return createItem(event);
+    case "GET":
+      if (event.pathParameters) {
+        return getItem(event);
+      }
+      return getAllItems();
+    case "PUT":
+      return updateItem(event);
+    case "DELETE":
+      return deleteItem(event);
+    default:
+      return {
+        statusCode: StatusCodes.METHOD_NOT_ALLOWED,
+        body: JSON.stringify({ message: ErrorMessages.METHOD_NOT_ALLOWED }),
+      };
+  }
+};

src/index.ts

@@ -0,0 +1,2 @@
+export { default as ItemModel } from "./item.model";
+export type { ItemDTO } from "./item.interface";

src/models/index.ts

@@ -0,0 +1,6 @@
+export interface ItemDTO {
+  name: string;
+  description?: string;
+}
+
+export default ItemDTO;

src/models/item.interface.ts

@@ -0,0 +1,13 @@
+import dynamoose from "dynamoose";
+import { itemSchema } from "../schemas";
+
+const ddb = new dynamoose.aws.ddb.DynamoDB({
+  endpoint: process.env.DYNAMO_ENDPOINT,
+  region: process.env.DYNAMO_REGION,
+});
+
+dynamoose.aws.ddb.set(ddb);
+
+const ItemModel = dynamoose.model("ItemsTable", itemSchema);
+
+export default ItemModel;