IO-1551 Include outbound fcm to update timestamps.
This commit is contained in:
@@ -55,6 +55,7 @@ function ChatSendMessageComponent({
|
|||||||
messagingServiceSid: bodyshop.messagingservicesid,
|
messagingServiceSid: bodyshop.messagingservicesid,
|
||||||
conversationid: conversation.id,
|
conversationid: conversation.id,
|
||||||
selectedMedia: selectedImages,
|
selectedMedia: selectedImages,
|
||||||
|
imexshopid: bodyshop.imexshopid,
|
||||||
});
|
});
|
||||||
setSelectedMedia(
|
setSelectedMedia(
|
||||||
selectedMedia.map((i) => {
|
selectedMedia.map((i) => {
|
||||||
|
|||||||
@@ -14,6 +14,22 @@ export default async function FcmHandler({ client, payload }) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
break;
|
break;
|
||||||
|
case "messaging-outbound":
|
||||||
|
client.cache.modify({
|
||||||
|
id: client.cache.identify({
|
||||||
|
__typename: "conversations",
|
||||||
|
id: payload.conversationid,
|
||||||
|
}),
|
||||||
|
fields: {
|
||||||
|
updated_at(oldupdated0) {
|
||||||
|
return new Date();
|
||||||
|
},
|
||||||
|
messages_aggregate(cached) {
|
||||||
|
return { aggregate: { count: cached.aggregate.count + 1 } };
|
||||||
|
},
|
||||||
|
},
|
||||||
|
});
|
||||||
|
break;
|
||||||
case "messaging-mark-conversation-read":
|
case "messaging-mark-conversation-read":
|
||||||
client.cache.modify({
|
client.cache.modify({
|
||||||
id: client.cache.identify({
|
id: client.cache.identify({
|
||||||
|
|||||||
@@ -96,8 +96,6 @@ exports.receive = async (req, res) => {
|
|||||||
type: "messaging-inbound",
|
type: "messaging-inbound",
|
||||||
conversationid: message.conversationid || "",
|
conversationid: message.conversationid || "",
|
||||||
text: message.text || "",
|
text: message.text || "",
|
||||||
image_path: message.image_path || "",
|
|
||||||
image: (message.image && message.image.toString()) || "",
|
|
||||||
messageid: message.id || "",
|
messageid: message.id || "",
|
||||||
phone_num: message.conversation.phone_num || "",
|
phone_num: message.conversation.phone_num || "",
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -13,11 +13,12 @@ const logger = require("../utils/logger");
|
|||||||
const client = twilio(
|
const client = twilio(
|
||||||
process.env.TWILIO_AUTH_TOKEN,
|
process.env.TWILIO_AUTH_TOKEN,
|
||||||
process.env.TWILIO_AUTH_KEY
|
process.env.TWILIO_AUTH_KEY
|
||||||
);
|
);const { admin } = require("../firebase/firebase-handler");
|
||||||
|
|
||||||
const gqlClient = require("../graphql-client/graphql-client").client;
|
const gqlClient = require("../graphql-client/graphql-client").client;
|
||||||
|
|
||||||
exports.send = (req, res) => {
|
exports.send = (req, res) => {
|
||||||
const { to, messagingServiceSid, body, conversationid, selectedMedia } =
|
const { to, messagingServiceSid, body, conversationid, selectedMedia, imexshopid } =
|
||||||
req.body;
|
req.body;
|
||||||
|
|
||||||
logger.log("sms-outbound", "DEBUG", req.user.email, null, {
|
logger.log("sms-outbound", "DEBUG", req.user.email, null, {
|
||||||
@@ -63,6 +64,17 @@ exports.send = (req, res) => {
|
|||||||
conversationid,
|
conversationid,
|
||||||
});
|
});
|
||||||
|
|
||||||
|
const data = {
|
||||||
|
type: "messaging-outbound",
|
||||||
|
conversationid: newMessage.conversationid || "",
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
admin.messaging().send({
|
||||||
|
topic: `${imexshopid}-messaging`,
|
||||||
|
data,
|
||||||
|
});
|
||||||
|
|
||||||
res.sendStatus(200);
|
res.sendStatus(200);
|
||||||
})
|
})
|
||||||
.catch((e2) => {
|
.catch((e2) => {
|
||||||
|
|||||||
Reference in New Issue
Block a user