added end points CRUD

Author: Jaime Salas Zancada

01-contenedores/lemoncode-challenge/node-stack/backend/.env.template

@@ -1,3 +1,4 @@
 DATABASE_URL=
+DATABASE_NAME=
 HOST=
 PORT=

01-contenedores/lemoncode-challenge/node-stack/backend/README.md

@@ -12,6 +12,7 @@ The following are environment variables that we can set up:
 
 ```ini
 DATABASE_URL=
+DATABASE_NAME=
 HOST=
 PORT=
 ```

01-contenedores/lemoncode-challenge/node-stack/backend/src/config.ts

@@ -5,6 +5,7 @@ if (process.env.NODE_ENV === 'development') {
 export default {
     database: {
         url: process.env.DATABASE_URL || 'mongodb://localhost:27017',
+        name: process.env.DATABASE_NAME || 'TopicstoreDb'
     },
     app: {
         host: process.env.HOST || 'localhost',

01-contenedores/lemoncode-challenge/node-stack/backend/src/dal/mongo-client.manager.ts

@@ -0,0 +1,31 @@
+// TODO: Move to infrastructure.
+// TODO: Create services.
+import { Collection, Db, Document, MongoClient } from "mongodb";
+import config from '../config';
+
+export type CollectionNames = 'Topics';
+
+const { url } = config.database;
+const client = new MongoClient(url);
+
+export const connect = async () => {
+  try {
+    await client.connect();
+  } catch (error) {
+    console.error();
+  }
+};
+
+export const disconnect = async () => {
+  await client.close();
+};
+
+export const getDatabaseInstance = (databaseName: string): Db =>
+  client.db(databaseName);
+
+export const getCollection = (db: Db, collection: CollectionNames): Collection<Document> => {
+  // TODO: Create schemas.
+  return db.collection(collection);
+};
+
+

01-contenedores/lemoncode-challenge/node-stack/backend/src/dal/topics.contract.dal.ts

@@ -0,0 +1,18 @@
+import { ObjectId, Collection } from 'mongodb';
+import { Topic as TopicEntity } from '../entities';
+
+type Topic = Pick<TopicEntity, 'Name'>;
+
+export interface TopicDatabase extends Topic {
+    _id?: ObjectId
+}
+
+export interface TopicDAL {
+    createTopic(topic: TopicDatabase): Promise<void>;
+    getTopics(): Promise<TopicDatabase[]>;
+    getTopicById(id: string): Promise<TopicDatabase | null>;
+    updateTopic(id: string, topic: Partial<TopicDatabase>): Promise<void>;
+    deleteTopic(id: string): Promise<void>;
+}
+
+export type TopicDALFactory = (collection: Collection) => TopicDAL; 

01-contenedores/lemoncode-challenge/node-stack/backend/src/dal/topics.dal.ts

@@ -0,0 +1,43 @@
+import { Collection } from 'mongodb';
+import { TopicDAL, TopicDALFactory, TopicDatabase} from './topics.contract.dal';
+
+export const topicDALFactory: TopicDALFactory = (collection: Collection): TopicDAL => {
+    return {
+        async createTopic(topic: TopicDatabase): Promise<void> {
+            try {
+                await collection.insertOne(topic);
+            } catch (error) {
+                console.log(error);
+                throw error;
+            }
+        },
+        async getTopics(): Promise<TopicDatabase[]> {
+            try {
+                const topics = await collection.find({}).toArray();
+                return topics as TopicDatabase[];
+            } catch (error) {
+                console.log(error);
+                throw error;
+            }
+        },
+        async getTopicById(id: string): Promise<TopicDatabase | null> {
+            const result = await collection.findOne({
+                _id: id
+            });
+            return result as TopicDatabase;
+        },
+        async updateTopic(id: string, topic: Partial<TopicDatabase>): Promise<void> {
+            delete topic['_id'];
+            await collection.updateOne({
+                _id: id
+            }, {
+                $set: {
+                    ...topic
+                }
+            });
+        },
+        async deleteTopic(id: string): Promise<void> {
+            await collection.deleteOne({ _id: id });
+        }
+    };
+}

01-contenedores/lemoncode-challenge/node-stack/backend/src/entities/index.ts

@@ -1,3 +1,4 @@
-export interface Topics {
+export interface Topic {
+    id?: string;
     Name: string;
 }

01-contenedores/lemoncode-challenge/node-stack/backend/src/routes/topics.route.ts

@@ -1,32 +1,39 @@
 import express from 'express';
+import { Topic } from '../entities';
+import { TopicsService } from '../services';
 
-export const topicsRoutes = (topicsServiceDAL: any) => {
+export const topicsRoutes = (topicsService: TopicsService) => {
     const router = express.Router();
 
-    router.get('/', (_, res) => {
-        // TODO: Use topicsServiceDAL
-        res.json(['topic A', 'topic B']);
+    router.get('/', async (_, res) => {
+        const result = await topicsService.getTopics();
+        res.json(result);
     });
 
-    router.get('/:id', (_, res) => {
-        // TODO: Use topicsServiceDAL
-        res.json('topic A');
+    router.get('/:id', async (req, res) => {
+        const { id } = req.params;
+        const result = await topicsService.getTopicById(id);
+        res.json(result);
     });
 
-    router.post('/', (req, res) => {
-        // TODO: Use topicsServiceDAL
-        const echo = req.body;
-        res.json(echo);
+    router.post('/', async (req, res) => {
+        const topic = req.body as Topic;;
+        await topicsService.createTopic(topic);
+        res.json(topic);
     });
 
-    router.put('/:id', (req, res) => {
-        const echo = req.body;
-        res.json(echo);
+    router.put('/:id', async (req, res) => {
+        const { id } = req.params;
+        const topic = req.body as Topic;
+        await topicsService.updateTopic(id, topic);
+        res.json(topic);
     });
 
-    router.delete('/:id', (req, res) => {
+    router.delete('/:id', async (req, res) => {
+        const { id } = req.params;
+        await topicsService.deleteTopic(id);
         res.json();
     });
 
     return router;
-} 
+}; 

01-contenedores/lemoncode-challenge/node-stack/backend/src/services/index.ts

@@ -0,0 +1,2 @@
+export * from './mappers';
+export * from './topics.service';

01-contenedores/lemoncode-challenge/node-stack/backend/src/services/mappers.ts

@@ -0,0 +1,37 @@
+import { ObjectId } from 'mongodb';
+import { Topic as TopicEntity } from '../entities';
+import { TopicDatabase} from '../dal/topics.contract.dal';
+
+function isTopicDatabase(topic: TopicEntity | TopicDatabase): topic is TopicDatabase {
+    if((topic as TopicDatabase)._id) {
+        return true;
+    }
+    return false;
+} 
+
+function isTopicEntity(topic: TopicEntity | TopicDatabase): topic is TopicEntity {
+    if((topic as TopicEntity).id) {
+        return true;
+    }
+    return false;
+} 
+
+export function mapTopic(topic: TopicEntity | TopicDatabase): TopicEntity | TopicDatabase {
+    if (isTopicDatabase(topic)) {
+        return {
+            ...topic,
+            id: topic._id.toString(),
+        }
+    }
+
+    if(isTopicEntity(topic)) {
+        return {
+            ...topic,
+            _id: new ObjectId(topic.id),  
+        }
+    }
+}
+
+export function mapTopics(topics: TopicEntity[] | TopicDatabase[]): TopicEntity[] | TopicDatabase[] {
+    return topics.map(mapTopic);
+}