refactor: split http api function and prevent isolate calls

packages/deployment-service/cdk/lib/cdk-stack.ts

@@ -152,7 +152,7 @@ export const createStack = async () => {
       entrypoint: 'bundle/sns.zip',
     },
     httpApi: {
-      handler: createFileLoc('http', 'handler'),
+      handler: createFileLoc('httpApi', 'handler'),
       policies: [...policies.commonBackendPolicies, policies.cloudFrontPolicy, policies.route53Policy],
       api: {
         routes: [

packages/deployment-service/src/http.ts

@@ -46,7 +46,5 @@ async function bootstrapServer(): Promise<Server> {
 export const handler: Handler = async (event: APIGatewayEvent, context: Context) => {
   cachedServer = await bootstrapServer()
 
-  event.path = event.path?.replace('api/', '')
-
   return proxy(cachedServer, event, context, 'PROMISE').promise
 }

packages/deployment-service/src/httpApi.ts

@@ -0,0 +1,60 @@
+import { NestFactory } from '@nestjs/core'
+import { INestApplication, ValidationPipe } from '@nestjs/common'
+import { AppModule } from './app-module'
+import { ExpressAdapter } from '@nestjs/platform-express'
+import { createServer, proxy } from 'aws-serverless-express'
+import { Handler, Context, APIGatewayEvent } from 'aws-lambda'
+import { eventContext } from 'aws-serverless-express/middleware'
+import { Server } from 'http'
+import express, { Express } from 'express'
+import * as bodyParser from 'body-parser'
+import { CorsHeaderInterceptor } from '@reapit/utils-nest'
+import { APIGatewayProxyResult } from 'aws-lambda/trigger/api-gateway-proxy'
+const crypto = require('crypto')
+
+global.crypto = crypto
+
+export const bootstrapApplication = async (cors: boolean = false): Promise<[INestApplication, Express]> => {
+  const expressApp = express()
+  const app = await NestFactory.create(AppModule, new ExpressAdapter(expressApp), { cors })
+
+  app.useGlobalPipes(new ValidationPipe())
+  app.useGlobalInterceptors(new CorsHeaderInterceptor())
+  app.use(bodyParser.json({ limit: '50mb' }))
+  app.use(bodyParser.urlencoded({ limit: '50mb', extended: true }))
+
+  return [app, expressApp]
+}
+
+const binaryMimeTypes: string[] = []
+
+let cachedServer: Server
+
+async function bootstrapServer(): Promise<Server> {
+  if (!cachedServer) {
+    const [app, express] = await bootstrapApplication()
+
+    app.use(eventContext())
+
+    await app.init()
+
+    cachedServer = createServer(express, undefined, binaryMimeTypes)
+  }
+
+  return cachedServer
+}
+
+export const handler: Handler<APIGatewayEvent, APIGatewayProxyResult> = async (event, context: Context) => {
+  cachedServer = await bootstrapServer()
+
+  if (!event.path.includes('github')) {
+    return {
+      statusCode: 404,
+      body: 'Not Found',
+    }
+  }
+
+  event.path = event.path?.replace('api/', '')
+
+  return proxy(cachedServer, event, context, 'PROMISE').promise
+}

packages/deployment-service/tsup-zip.config.json

@@ -1,3 +1,3 @@
 {
-  "bundleFiles": ["dist/http.js", "dist/sqs.js", "dist/sns.js", "dist/migration-run.js", "dist/dns-eventbridge.js"]
+  "bundleFiles": ["dist/http.js", "dist/httpApi.js", "dist/sqs.js", "dist/sns.js", "dist/migration-run.js", "dist/dns-eventbridge.js"]
 }

packages/deployment-service/tsup.config.js

@@ -7,7 +7,7 @@
 
 export default defineConfig([
   {
-    entry: ['src/http.ts', 'src/sqs.ts', 'src/sns.ts', 'src/migration-run.ts', 'src/dns-eventbridge.ts'],
+    entry: ['src/http.ts', 'src/httpApi.ts', 'src/sqs.ts', 'src/sns.ts', 'src/migration-run.ts', 'src/dns-eventbridge.ts'],
     target: 'node18',
     clean: true,
     minify: config.NODE_ENV === 'production',