Allow skipping the tls check for webhooks (#197)

* fix: throw if configuration is undefined

* feat: add skipTlsCheck option to Webhooks Module

src/modules/messageBrokerPublisher/connectors/MessageBrokerConnector.ts

@@ -4,7 +4,9 @@ export abstract class MessageBrokerConnector<TConfiguration> {
     public constructor(
         protected readonly configuration: TConfiguration,
         protected readonly logger: ILogger
-    ) {}
+    ) {
+        if (!this.configuration) throw new Error("Cannot start the broker, the 'configuration' is not defined.");
+    }
 
     public abstract init(): void | Promise<void>;
     public abstract publish(namespace: string, data: Buffer): void | Promise<void>;

src/modules/webhooks/ConfigModel.ts

@@ -2,7 +2,10 @@ import { Result } from "@js-soft/ts-utils";
 import { WebhooksModuleApplicationErrors } from "./WebhooksModuleApplicationErrors";
 
 export class ConfigModel {
-    public constructor(public readonly webhooks: Webhook[]) {}
+    public constructor(
+        public readonly webhooks: Webhook[],
+        public readonly skipTlsCheck: boolean
+    ) {}
 }
 
 export class Webhook {

src/modules/webhooks/ConfigParser.ts

@@ -14,7 +14,7 @@ export class ConfigParser {
             return Result.fail(webhooks.error);
         }
 
-        const configModel = new ConfigModel(webhooks.value);
+        const configModel = new ConfigModel(webhooks.value, configJson.skipTlsCheck ?? false);
         return Result.ok(configModel);
     }
 

src/modules/webhooks/WebhooksModule.ts

@@ -12,14 +12,14 @@ export default class WebhooksModule extends ConnectorRuntimeModule<WebhooksModul
     private configModel: ConfigModel;
 
     public init(): void {
+        this.configModel = ConfigParser.parse(this.configuration).value;
+
         this.axios = axios.create({
             httpAgent: new agentKeepAlive(),
-            httpsAgent: new AgentKeepAliveHttps(),
+            httpsAgent: new AgentKeepAliveHttps({ rejectUnauthorized: !this.configModel.skipTlsCheck }),
             validateStatus: () => true,
             maxRedirects: 0
         });
-
-        this.configModel = ConfigParser.parse(this.configuration).value;
     }
 
     public start(): void {

src/modules/webhooks/WebhooksModuleConfiguration.ts

@@ -3,6 +3,7 @@ import { ConnectorRuntimeModuleConfiguration } from "../../ConnectorRuntimeModul
 export interface WebhooksModuleConfiguration extends ConnectorRuntimeModuleConfiguration {
     targets?: Record<string, WebhooksModuleConfigurationTarget>;
     webhooks?: WebhooksModuleConfigurationWebhook[];
+    skipTlsCheck?: boolean;
 }
 
 export interface WebhooksModuleConfigurationTarget {