diff --git a/server/sms/receive.js b/server/sms/receive.js index d05ae725d..d74668728 100644 --- a/server/sms/receive.js +++ b/server/sms/receive.js @@ -78,15 +78,18 @@ exports.receive = async (req, res) => { }); } try { - const r2 = await client.request(queries.RECEIVE_MESSAGE, { - msg: newMessage, - }); if (response.bodyshops[0].conversations[0]) { const r3 = await client.request(queries.INSERT_MESSAGE, { + msg: newMessage, + id: response.bodyshops[0].conversations[0] && response.bodyshops[0].conversations[0].id, }); + } else { + const r2 = await client.request(queries.RECEIVE_MESSAGE, { + msg: newMessage, + }); } logger.log("sms-inbound-success", "DEBUG", "api", null, {