diff --git a/apps/server/src/services/integration-service/HttpIntegration.ts b/apps/server/src/services/integration-service/HttpIntegration.ts index f35b7eaf9..ddeb03d74 100644 --- a/apps/server/src/services/integration-service/HttpIntegration.ts +++ b/apps/server/src/services/integration-service/HttpIntegration.ts @@ -87,6 +87,14 @@ export class HttpIntegration implements IIntegration { const templateUrl = parseTemplateNested(url, state || {}); const templateOptions = parseTemplateNested(options, state || {}); try { + const parsedUrl = new globalThis.URL(templateUrl); + // if (parsedUrl.protocol != 'http:') { + // logger.error(LogOrigin.Tx, `HTTP Integration: Only HTTP allowed, got ${parsedUrl.protocol}`); + // return { + // success: false, + // message: `Only HTTP allowed, got ${parsedUrl.protocol}`, + // }; + // } this.emit(templateUrl, templateOptions, method); } catch (err) { logger.error(LogOrigin.Tx, `HTTP Integration: ${err}`); @@ -108,7 +116,6 @@ export class HttpIntegration implements IIntegration { }); } else if (method === 'POST') { await got.post(path, { - body: options, retry: { limit: this.retryCount }, }); }