diff --git a/lib/models/statement.js b/lib/models/statement.js index b385c56fa0..51116bd804 100644 --- a/lib/models/statement.js +++ b/lib/models/statement.js @@ -233,7 +233,7 @@ schema.statics.aggregateByAuth = function aggregateByAuth( }).catch(cb); }; -const mapDot = (data) => { +export const mapDot = (data) => { if (isPlainObject(data)) { const mappedData = mapKeys(data, (value, key) => decodeDot(key)); return mapValues(mappedData, mapDot); diff --git a/worker/src/handlers/statement/statementForwarding/statementForwardingRequestHandler.js b/worker/src/handlers/statement/statementForwarding/statementForwardingRequestHandler.js index 24462f6083..be805909cc 100644 --- a/worker/src/handlers/statement/statementForwarding/statementForwardingRequestHandler.js +++ b/worker/src/handlers/statement/statementForwarding/statementForwardingRequestHandler.js @@ -2,7 +2,7 @@ import * as popsicle from 'popsicle'; import { assign } from 'lodash'; import { Map } from 'immutable'; import logger from 'lib/logger'; -import Statement from 'lib/models/statement'; +import Statement, { mapDot } from 'lib/models/statement'; import mongoose from 'mongoose'; import StatementForwarding from 'lib/models/statementForwarding'; import ForwardingRequestError from @@ -33,13 +33,15 @@ const sendRequest = async (statement, statementForwarding) => { const urlString = `${statementForwarding.configuration .protocol}://${statementForwarding.configuration.url}`; - const statementContent = JSON.stringify(statement); + const statementContent = JSON.stringify(mapDot( + statement + )); const headers = generateHeaders(statementContent, statementForwarding); const requestOptions = { method: 'POST', - body: statement, + body: mapDot(statement), url: urlString, headers, timeout: 16000,