Executer v2

package.json

@@ -61,23 +61,30 @@
     "@nestjs/schedule": "^3.0.3",
     "@nestjs/swagger": "^7.1.10",
     "@types/cron": "^2.0.1",
+    "@willsoto/nestjs-prometheus": "^6.0.2",
     "axios": "^1.5.0",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.0",
     "cluster": "^0.7.7",
+    "crypto-js": "^4.2.0",
     "expressionparser": "^1.1.5",
     "joi": "^17.10.1",
-    "jwt-decode": "^3.1.2",
+    "jwt-decode": "^4.0.0",
+    "kafkajs": "^2.2.4",
     "lodash": "^4.17.21",
     "moment": "^2.29.4",
     "mongoose": "^7.5.0",
+    "node-sql-parser": "^5.3.6",
     "openai": "^4.6.0",
     "reflect-metadata": "^0.1.13",
     "rimraf": "^5.0.1",
     "rxjs": "^7.8.1",
     "sanitize-filename": "^1.6.3",
+    "soap": "^1.1.7",
     "swagger-ui-express": "^5.0.0",
-    "xml-js": "^1.6.11"
+    "typeorm": "^0.3.20",
+    "xml-js": "^1.6.11",
+    "xml2js": "^0.6.2"
   },
   "devDependencies": {
     "@nestjs/cli": "^10.1.17",
@@ -95,13 +102,15 @@
     "eslint-plugin-prettier": "^5.0.0",
     "jest": "^29.6.4",
     "prettier": "^3.0.3",
+    "run-script-webpack-plugin": "^0.2.2",
     "source-map-support": "^0.5.21",
     "supertest": "^6.3.3",
     "ts-jest": "^29.1.1",
     "ts-loader": "^9.4.4",
     "ts-node": "^10.9.1",
     "tsconfig-paths": "^4.2.0",
-    "typescript": "^5.2.2"
+    "typescript": "^5.2.2",
+    "webpack-cli": "^6.0.1"
   },
   "jest": {
     "moduleFileExtensions": [

src/app.module.ts

@@ -1,14 +1,21 @@
-// require('dotenv').config({ path: `envs/.env.${process.env.NODE_ENV}` })
 
-import { MiddlewareConsumer, Module } from '@nestjs/common'
+import { HttpStatus, MiddlewareConsumer, Module } from '@nestjs/common'
 import { ConfigModule } from '@nestjs/config'
 import { APP_FILTER, APP_INTERCEPTOR } from '@nestjs/core';
 import { AllExceptionsFilter } from './common/exceptions';
-import { HttpRequestHeadersMiddleware } from './common/middlewares';
+import { AppLoggerMiddleware, HttpRequestHeadersMiddleware } from './common/middlewares';
 import { ResponseInterceptor } from './common/interceptors';
-import { HttpModule } from '@nestjs/axios';
-import { ProcessDefinitionsModule, ProcessInstancesModule, TasksModule } from './modules';
-import { HttpConnector } from 'src/shared/connectors';
+import { HttpModule, HttpService } from '@nestjs/axios';
+import { ValidationsModule, ProcessDefinitionsModule, ProcessInstancesModule, TasksModule, WebhooksModule } from './modules';
+import { ScheduleModule } from '@nestjs/schedule';
+import { DataflowConversionModule } from './modules/dataflow-conversion/dataflow-conversion.module';
+import { makeCounterProvider, makeGaugeProvider, makeHistogramProvider, makeSummaryProvider, PrometheusModule } from "@willsoto/nestjs-prometheus";
+import { HttpConnector, GrpcConnector } from 'src/shared/connectors';
+import { MetricsMiddleware } from './common/middlewares/http-status-code.middleware';
+import { ConnectorModule } from './modules/connectors/connectors.module';
+// import { GlobalScheduleProvider } from './common/providers/global-schedule.provider';
+import { ExecutorModule } from './modules/executor/executor.module';
+import { CustomMessages } from './common/const/custom-messages';
 import { MongooseModule } from '@nestjs/mongoose';
 
 // example run command
@@ -29,22 +36,49 @@ const MONGO_PROTOCOL = process.env.MONGO_PROTOCOL, MONGO_HOST = process.env.MONG
     }),
     HttpModule,
     MongooseModule.forRoot(`mongodb://${MONGO_HOST}:${MONGO_PORT}/${MONGO_DBNAME}`),
+    ScheduleModule.forRoot(),
     ProcessDefinitionsModule,
     ProcessInstancesModule,
     TasksModule,
+    WebhooksModule,
+    DataflowConversionModule,
+    PrometheusModule.register(),
+    ExecutorModule,
+    ConnectorModule,
+    ValidationsModule
   ],
   controllers: [],
   providers: [
     { provide: APP_FILTER, useClass: AllExceptionsFilter },
     { provide: APP_INTERCEPTOR, useClass: ResponseInterceptor },
+    makeCounterProvider({
+      name: "metric_Counter",
+      help: "metric_help",
+    }),
+    makeGaugeProvider({
+      name: "metric_gauge",
+      help: "metric_help",
+    }),
+    makeHistogramProvider({
+      name: "metric_histogram",
+      help: "metric_help",
+    }),
+    makeSummaryProvider({
+      name: "metric_summary",
+      help: "metric_help",
+    }),
     HttpConnector,
-    HttpRequestHeadersMiddleware
+    HttpRequestHeadersMiddleware,
+    // GlobalScheduleProvider
   ],
+  // exports: [GlobalScheduleProvider]
 })
 export class AppModule {
   // Global Middleware, Inbound logging
   public configure(consumer: MiddlewareConsumer): void {
     consumer.apply(HttpRequestHeadersMiddleware).forRoutes('*');
     // consumer.apply(AppLoggerMiddleware).forRoutes('*');
+    consumer.apply(MetricsMiddleware).forRoutes('*');
   }
 }
+