Set integration with Soket.io

Author: damtaipu

package-lock.json

@@ -44,6 +44,7 @@
   },
   "dependencies": {
     "express": "^4.18.1",
-    "rxjs": "^7.5.5"
+    "rxjs": "^7.5.5",
+    "socket.io": "^4.5.1"
   }
 }

package.json

@@ -1,12 +1,12 @@
 import { NextFunction, Request, Response } from "express";
 
 export default class ExpressAdapter {
-	static create (fn) {
+	static create (fn, io?) {
 		return async function (req: Request, res: Response, next: NextFunction) {
 			res.header("Cache-Control", "no-cache, no-store, must-revalidate");
 			res.header("Pragma", "no-cache");
 
-			const obj = await fn(req.params, req.body, res);
+			const obj = await fn(req.params, req.body, res, io);
 			return obj
 		}
 	}

src/adapter/express.adpter.ts

@@ -3,16 +3,20 @@ import OrderRepositoryMemory from "@infra/repository/order/order-repository.memo
 import GetOrderUseCase from "@usecase/order/get-order.usecase";
 
 export default class OrderController {
-    static getOrder(params, body, res) {
+    static getOrder(params, body, res, io?) {
         let rtn;
         const orderMemory = new OrderRepositoryMemory();
         const getOrder = new GetOrderUseCase(orderMemory);
         const order = getOrder.execute(params.id);
+
         order.subscribe(p => {
             rtn = p;
         }).unsubscribe();
 
         if (!rtn) return BaseData.sendResponse(404, 'nao retornou resultados', [], res);
+        
+        //Dispara evento via Socket.io
+        io.emit('test-message', 'Menssagem eviada via Socket.io para fins de teste');
         return BaseData.sendResponse(200, 'sucesso', Array(rtn), res);
     }
 }

src/controller/order/order.controller.ts

@@ -3,28 +3,51 @@ import express from 'express';
 import VerifyParamMiddleware from './middleware/validate-param.middleware';
 import OrderController from '@controller/order/order.controller';
 import RouteBaseBlock from '@infra/http/route/block-baseurl.route';
+import { createServer, Server } from 'http';
+import SocketIo from '@infra/http/socket.io';
 
 export default class App {
 
     private app: express.Application;
+    private httpServer: Server;
+    private io;
 
-    constructor(){
+    constructor() {
         this.app = express();
+        this.httpServer = createServer(this.app);
+        this.io = SocketIo.serverIo(this.httpServer);
+
+        this.io.on("connection", (socket) => {
+            console.log('Usuário conectado');
+
+            socket.on('disconnect', () => {
+                console.log('usário desconectado');
+            });
+        });
     }
-     
+
     //Root routes
-    blockRootRoutes(){
+    blockRootRoutes() {
         this.app.get(['/', '/teste'], ExpressAdapter.create(RouteBaseBlock.blockUrlBase));
     }
 
     // Order API
-    orderRoutes(){
-        this.app.get('/teste/:id', VerifyParamMiddleware.checkParam, ExpressAdapter.create(OrderController.getOrder));
+    orderRoutes() {
+        this.app.get('/teste/:id', VerifyParamMiddleware.checkParam, ExpressAdapter.create(OrderController.getOrder, this.io));
     }
 
-    listen(port: number){
+    listen(port: number, socket: boolean) {
+
+        // Para iniciar o servidor com Socket.io
+        if (socket) {
+            this.httpServer.listen(port, () => {
+                console.log(`Serve is up in port ${port} with SocketI.io`);
+            });
+            return;
+        }
+
         this.app.listen(port, () => {
-            console.log(`Serve is up in port ${port}`);
+            console.log(`Serve is up in port ${port}, sem Socket.io`);
         });
     }
 }

src/infra/http/express.ts

@@ -1,7 +1,7 @@
 import { BaseData } from "@entity/baseData/base-data.entity";
 
 export default class RouteBaseBlock {
-        static blockUrlBase(params, body, res) {
+        static blockUrlBase(params, body, res, io?) {
                 return BaseData.sendResponse(403, 'Url base com acesso restrito', [], res);
         }
 }

src/infra/http/route/block-baseurl.route.ts

@@ -0,0 +1,12 @@
+import { Server } from "socket.io";
+
+export default class SocketIo {
+  static serverIo(http): Server {
+    return new Server(http, {
+        cors: {
+            origin: '*',
+            credentials: true
+        }
+    });
+  }
+}

src/infra/http/socket.io.ts

@@ -6,7 +6,9 @@ export default class OrderRepositoryMemory implements OrderRepository{
 
     product = [{nome: "Biscoito triunfo", valor: 10.00}];
     pedidos = [
-        new OrderEntity(200, new Date("July 21, 1983 01:15:00"), this.product, 'aberto')
+        new OrderEntity(200, new Date("July 21, 1983 01:15:00"), this.product, 'aberto'),
+        new OrderEntity(100, new Date("July 21, 1983 01:15:00"), this.product, 'fechado'),
+        new OrderEntity(14, new Date("July 21, 1983 01:15:00"), this.product, 'aberto')
     ];
 
     getOrder(id: number): Observable<OrderEntity> { 

src/infra/repository/order/order-repository.memory.ts

@@ -3,6 +3,7 @@ import App from "@infra/http/express";
 const api = new App();
 
 api.blockRootRoutes();
+
 api.orderRoutes();
 
-api.listen(3000);
+api.listen(3000, true);