diff --git a/lib/apiserver/index.js b/lib/apiserver/index.js index 81b9a89..152edc5 100644 --- a/lib/apiserver/index.js +++ b/lib/apiserver/index.js @@ -80,7 +80,7 @@ function onIncomingSms(req, res) { origin_transport: 'SMS', origin_partner: req.query.number, do_not_forward_to_core: req.query.number.indexOf('+') !== 0, - }) + }); } async function pageHistory(req, res) { diff --git a/lib/transport.js b/lib/transport.js index d5bb638..aae2355 100644 --- a/lib/transport.js +++ b/lib/transport.js @@ -8,6 +8,8 @@ const moment = require('moment'); const config = require('komodo-sdk/config'); const logger = require('komodo-sdk/logger'); +const messagingService = require('komodo-center-messaging-client-lib'); + const modemSelect = require('./modemSelect'); const modems = require('./modems2'); const partnerLastSeen = require('./partner-last-seen'); @@ -54,6 +56,18 @@ function _send(destinationNumber, msg, handlerIMSI) { message: msg, }); + messagingService.onIncomingMessage({ + me: modem.name, + partner: destinationNumber, + partner_raw: `+${destinationNumber}`.replace(/^\++/, '+'), + msg: msg, + origin_label: `IMSI_${modem.imsi || 'UNKNOWN'}`, + origin_transport: 'SMS', + origin_partner: destinationNumber, + do_not_forward_to_core: true, + is_outgoing: true, + }); + const requestOptions = { url: url.format({ protocol: 'http',