Refactor code

Author: minhduc140583

src/config.ts

@@ -3,38 +3,38 @@ export const config = {
   secure: false,
   template: true,
   allow: {
-    origin: "http://localhost:3000",
-    credentials: "true",
-    methods: "GET,PUT,POST,DELETE,OPTIONS,PATCH",
+    origin: 'http://localhost:3000',
+    credentials: 'true',
+    methods: 'GET,PUT,POST,DELETE,OPTIONS,PATCH',
     headers:
-      "Access-Control-Allow-Headers, Authorization, Origin,Accept, X-Requested-With, Content-Type, Access-Control-Request-Method, Access-Control-Request-Headers",
+      'Access-Control-Allow-Headers, Authorization, Origin,Accept, X-Requested-With, Content-Type, Access-Control-Request-Method, Access-Control-Request-Headers',
   },
   log: {
-    level: "debug",
+    level: 'debug',
     map: {
-      time: "@timestamp",
-      msg: "message",
+      time: '@timestamp',
+      msg: 'message',
     },
     db: true,
   },
   middleware: {
     log: true,
-    skips: "health,log",
-    request: "request",
-    status: "status",
-    size: "size",
+    skips: 'health,log',
+    request: 'request',
+    status: 'status',
+    size: 'size',
   },
   db: {
-    uri: "mongodb://localhost:27017",
-    db: "masterdata2",
+    uri: 'mongodb://localhost:27017',
+    db: 'masterdata2',
   },
   amq: {
-    host: "localhost",
+    host: 'localhost',
     port: 61613,
-    username: "admin",
-    password: "admin",
-    destinationName: "topic",
-    subscriptionName: "sub-user",
+    username: 'admin',
+    password: 'admin',
+    destinationName: 'topic',
+    subscriptionName: 'sub-user',
   }
 };
 

src/index.ts

@@ -1,71 +1,48 @@
-import { merge } from 'config-plus';
 import { json } from 'body-parser';
+import { merge } from 'config-plus';
 import dotenv from 'dotenv';
 import express from 'express';
 import http from 'http';
 import { getBody } from 'logger-core';
 import { connectToDb } from 'mongodb-extension';
-import { createContext } from './context';
-import { ActiveMQConnection, Config } from './services/activemq';
 import { config, env } from './config';
+import { createContext } from './context';
+import { ActiveMQConnection } from './services/activemq';
 
 dotenv.config();
 
 const app = express();
 const conf = merge(config, process.env, env, process.env.ENV);
 
-const port = conf.port;
-
-
 app.use(json());
 
 connectToDb(
   `${conf.db.uri}`,
   `${conf.db.db}`
 ).then(async (db) => {
-  if (
-    !conf.amq.host ||
-    !conf.amq.port ||
-    !conf.amq.username ||
-    !conf.amq.password ||
-    !conf.amq.destinationName ||
-    !conf.amq.subscriptionName
-  ) {
-    throw new Error('config wrong!');
-  }
-  const config: Config = {
-    host: conf.amq.host,
-    port: conf.amq.port,
-    username: conf.amq.username,
-    password: conf.amq.password,
-    destinationName: conf.amq.destinationName,
-    subscriptionName: conf.amq.subscriptionName,
-  };
-  const amqConnection = new ActiveMQConnection(config);
+  const amqConnection = new ActiveMQConnection(conf.amq);
   const client = await amqConnection.connect();
-  const ctx = createContext(db, client, config);
+  const ctx = createContext(db, client, conf.amq);
   ctx.read(ctx.handle);
 
-
   http.createServer((req, res) => {
-      if (req.url === '/health') {
-        ctx.health.check(req, res);
-      } else if (req.url === '/send') {
-        getBody(req).then((body: any) => {
-          ctx
-            .write(JSON.parse(body))
-            .then(() => {
-              res.writeHead(200, { 'Content-Type': 'application/json' });
-              res.end(JSON.stringify({ message: 'message was produced' }));
-            })
-            .catch((err) => {
-              res.writeHead(500, { 'Content-Type': 'application/json' });
-              res.end(JSON.stringify({ error: err }));
-            });
-        }).catch((err: any) => console.log(err));
-      }
-    })
-    .listen(port, () => {
-      console.log('Start server at port ' + port);
-    });
+    if (req.url === '/health') {
+      ctx.health.check(req, res);
+    } else if (req.url === '/send') {
+      getBody(req).then((body: any) => {
+        ctx
+          .write(JSON.parse(body))
+          .then(() => {
+            res.writeHead(200, { 'Content-Type': 'application/json' });
+            res.end(JSON.stringify({ message: 'message was produced' }));
+          })
+          .catch((err) => {
+            res.writeHead(500, { 'Content-Type': 'application/json' });
+            res.end(JSON.stringify({ error: err }));
+          });
+      }).catch((err: any) => console.log(err));
+    }
+  }).listen(conf.port, () => {
+    console.log('Start server at port ' + conf.port);
+  });
 });