feat: Split SNS webhook server from main HTTP server

package.json

@@ -7,6 +7,7 @@
     "dev:server": "tsnd --respawn --transpile-only --ignore-watch node_modules --exit-child --clear -r tsconfig-paths/register src/infra/http/server.ts",
     "dev:worker": "tsnd --respawn --transpile-only --ignore-watch node_modules --exit-child --clear -r tsconfig-paths/register src/infra/queue/worker.ts",
     "dev:kafka": "tsnd --respawn --transpile-only --ignore-watch node_modules --exit-child --clear -r tsconfig-paths/register src/infra/kafka/app.ts",
+    "dev:webhook": "tsnd --respawn --transpile-only --ignore-watch node_modules --exit-child --clear -r tsconfig-paths/register src/infra/sns-webhook/server.ts",
     "start": "node dist/infra/http/server.js",
     "lint": "eslint src --ext ts,tsx",
     "test": "jest",

scripts/webhook.sh

@@ -0,0 +1,5 @@
+#!/bin/sh
+
+(cd /home/node/app && node_modules/.bin/prisma migrate deploy)
+(cd /home/node/app && node_modules/.bin/prisma generate)
+(cd /home/node/app && node dist/infra/sns-webhook/server.js)

src/infra/http/routes/contacts.routes.ts

@@ -1,7 +1,8 @@
 import express from 'express'
 
-import { adaptMiddleware } from '../adapters/ExpressMiddlewareAdapter'
-import { adaptRoute } from '../adapters/ExpressRouteAdapter'
+import { adaptMiddleware } from '@core/infra/adapters/ExpressMiddlewareAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
+
 import { makeBlockContactController } from '../factories/controllers/BlockContactControllerFactory'
 import { makeCreateContactController } from '../factories/controllers/CreateContactControllerFactory'
 import { makeGetContactDetailsController } from '../factories/controllers/GetContactDetailsControllerFactory'

src/infra/http/routes/index.ts

@@ -1,7 +1,6 @@
 import { Router } from 'express'
 
 import { contactsRouter } from './contacts.routes'
-import { eventsRouter } from './events.routes'
 import { messagesRouter } from './messages.routes'
 import { recipientsRouter } from './recipients.routes'
 import { sendersRouter } from './senders.routes'
@@ -15,7 +14,6 @@ const router = Router()
 router.use('/users', usersRouter)
 router.use('/sessions', sessionsRouter)
 router.use('/messages', messagesRouter)
-router.use('/events', eventsRouter)
 router.use('/contacts', contactsRouter)
 router.use('/senders', sendersRouter)
 router.use('/tags', tagsRouter)

src/infra/http/routes/messages.routes.ts

@@ -1,7 +1,8 @@
 import express from 'express'
 
-import { adaptMiddleware } from '../adapters/ExpressMiddlewareAdapter'
-import { adaptRoute } from '../adapters/ExpressRouteAdapter'
+import { adaptMiddleware } from '@core/infra/adapters/ExpressMiddlewareAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
+
 import { makeCreateMessageController } from '../factories/controllers/CreateMessageControllerFactory'
 import { makeGetMessageDetailsController } from '../factories/controllers/GetMessageDetailsControllerFactory'
 import { makeGetMessageStatsController } from '../factories/controllers/GetMessageStatsControllerFactory'

src/infra/http/routes/recipients.routes.ts

@@ -1,7 +1,8 @@
 import express from 'express'
 
-import { adaptMiddleware } from '../adapters/ExpressMiddlewareAdapter'
-import { adaptRoute } from '../adapters/ExpressRouteAdapter'
+import { adaptMiddleware } from '@core/infra/adapters/ExpressMiddlewareAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
+
 import { makeCountRecipientsFromTagsController } from '../factories/controllers/CountRecipientsFromTagsControllerFactory'
 import { makeEnsureAuthenticatedMiddleware } from '../factories/middlewares/EnsureAuthenticatedMiddlewareFactory'
 

src/infra/http/routes/senders.routes.ts

@@ -1,7 +1,8 @@
 import express from 'express'
 
-import { adaptMiddleware } from '../adapters/ExpressMiddlewareAdapter'
-import { adaptRoute } from '../adapters/ExpressRouteAdapter'
+import { adaptMiddleware } from '@core/infra/adapters/ExpressMiddlewareAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
+
 import { makeCreateSenderController } from '../factories/controllers/CreateSenderControllerFactory'
 import { makeGetAllSendersController } from '../factories/controllers/GetAllSendersControllerFactory'
 import { makeRemoveSenderController } from '../factories/controllers/RemoveSenderControllerFactory'

src/infra/http/routes/sessions.routes.ts

@@ -1,6 +1,7 @@
 import express from 'express'
 
-import { adaptRoute } from '../adapters/ExpressRouteAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
+
 import { makeAuthenticateUserController } from '../factories/controllers/AuthenticateUserControllerFactory'
 
 const sessionsRouter = express.Router()

src/infra/http/routes/tags.routes.ts

@@ -1,7 +1,7 @@
 import express from 'express'
 
-import { adaptMiddleware } from '../adapters/ExpressMiddlewareAdapter'
-import { adaptRoute } from '../adapters/ExpressRouteAdapter'
+import { adaptMiddleware } from '@core/infra/adapters/ExpressMiddlewareAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
 import { makeCreateTagController } from '../factories/controllers/CreateTagControllerFactory'
 import { makeGetAllTagsController } from '../factories/controllers/GetAllTagsControllerFactory'
 import { makeSearchTagsController } from '../factories/controllers/SearchTagsControllerFactory'

src/infra/http/routes/templates.routes.ts

@@ -1,7 +1,7 @@
 import express from 'express'
 
-import { adaptMiddleware } from '../adapters/ExpressMiddlewareAdapter'
-import { adaptRoute } from '../adapters/ExpressRouteAdapter'
+import { adaptMiddleware } from '@core/infra/adapters/ExpressMiddlewareAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
 import { makeCreateTemplateController } from '../factories/controllers/CreateTemplateControllerFactory'
 import { makeGetAllTemplatesController } from '../factories/controllers/GetAllTemplatesControllerFactory'
 import { makePreviewTemplateController } from '../factories/controllers/PreviewTemplateControllerFactory'

src/infra/http/routes/users.routes.ts

@@ -1,7 +1,7 @@
 import express from 'express'
 
-import { adaptMiddleware } from '../adapters/ExpressMiddlewareAdapter'
-import { adaptRoute } from '../adapters/ExpressRouteAdapter'
+import { adaptMiddleware } from '@core/infra/adapters/ExpressMiddlewareAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
 import { makeRegisterUserController } from '../factories/controllers/RegisterUserControllerFactory'
 import { makeEnsureAuthenticatedMiddleware } from '../factories/middlewares/EnsureAuthenticatedMiddlewareFactory'
 

src/infra/sns-webhook/app.ts

@@ -0,0 +1,25 @@
+import cors from 'cors'
+import { config } from 'dotenv-flow'
+import express from 'express'
+
+config({ silent: true })
+
+import { router } from './routes' // eslint-disable-line
+
+const app = express()
+
+app.use(
+  cors({
+    exposedHeaders: ['x-total-count', 'Content-Type', 'Content-Length'],
+  })
+)
+
+app.use(
+  express.json({
+    type: ['application/json', 'text/plain'],
+  })
+)
+
+app.use(router)
+
+export { app }

src/infra/http/factories/middlewares/AmazonSNSValidatorMiddlewareFactory.ts → src/infra/sns-webhook/factories/middlewares/AmazonSNSValidatorMiddlewareFactory.ts

@@ -1,5 +1,5 @@
 import { Middleware } from '@core/infra/Middleware'
-import { AmazonSNSValidatorMiddleware } from '@infra/http/middlewares/AmazonSNSValidatorMiddleware'
+import { AmazonSNSValidatorMiddleware } from '@infra/sns-webhook/middlewares/AmazonSNSValidatorMiddleware'
 
 export function makeAmazonSNSValidatorMiddleware(): Middleware {
   const amazonSNSValidatorMiddleware = new AmazonSNSValidatorMiddleware()

src/infra/sns-webhook/routes.ts

@@ -0,0 +1,17 @@
+import express from 'express'
+
+import { adaptMiddleware } from '@core/infra/adapters/ExpressMiddlewareAdapter'
+import { adaptRoute } from '@core/infra/adapters/ExpressRouteAdapter'
+
+import { makeRegisterEventController } from './factories/controllers/RegisterEventControllerFactory'
+import { makeAmazonSNSValidatorMiddleware } from './factories/middlewares/AmazonSNSValidatorMiddlewareFactory'
+
+const router = express.Router()
+
+router.post(
+  '/events/notifications',
+  adaptMiddleware(makeAmazonSNSValidatorMiddleware()),
+  adaptRoute(makeRegisterEventController())
+)
+
+export { router }

src/infra/sns-webhook/server.ts

@@ -0,0 +1,5 @@
+import { app } from './app'
+
+app.listen(process.env.PORT, () => {
+  console.log(`Server running on http://localhost:${process.env.PORT}`)
+})

src/modules/broadcasting/useCases/RegisterEvent/RegisterEventController.spec.ts

@@ -5,9 +5,9 @@
 import request from 'supertest'
 import { v4 as uuid } from 'uuid'
 
-import { app } from '@infra/http/app'
 import { prisma } from '@infra/prisma/client'
 import { redisConnection } from '@infra/redis/connection'
+import { app } from '@infra/sns-webhook/app'
 
 import { validEventTypes } from '../../domain/event/type'