diff --git a/src/helpers/app-helper.js b/src/helpers/app-helper.js index 5cb30d3a1..0fb7dda37 100644 --- a/src/helpers/app-helper.js +++ b/src/helpers/app-helper.js @@ -157,6 +157,12 @@ function handleCLIError(error) { } } +function trimCertificate(cert) { + let result = cert.replace(/(^[\s\S]*-{3,}BEGIN CERTIFICATE-{3,}[\s]*)/, ""); + result = result.replace(/([\s]*-{3,}END CERTIFICATE-{3,}[\s\S]*$)/, ""); + return result; +} + module.exports = { encryptText, decryptText, @@ -173,5 +179,6 @@ module.exports = { findAvailablePort, stringifyCliJsonSchema, isValidPublicIP, - handleCLIError + handleCLIError, + trimCertificate }; diff --git a/src/services/microservices-service.js b/src/services/microservices-service.js index 8fd62b5b6..ccb069f97 100644 --- a/src/services/microservices-service.js +++ b/src/services/microservices-service.js @@ -31,6 +31,7 @@ const FlowService = require('../services/flow-service'); const CatalogService = require('../services/catalog-service'); const RoutingManager = require('../sequelize/managers/routing-manager'); const Op = require('sequelize').Op; +const fs = require('fs'); const _listMicroservices = async function (flowId, user, isCLI, transaction) { if (!isCLI) { @@ -602,7 +603,7 @@ async function _createPortMappingOverConnector(microservice, portMappingData, us const netwMsConfig = { 'mode': 'public', 'host': connector.domain, - 'cert': connector.cert, + 'cert': AppHelper.trimCertificate(fs.readFileSync(connector.cert, "utf-8")), 'port': ports.port1, 'passcode': ports.passcode1, 'connectioncount': 60,