104 lines
3.3 KiB
JavaScript
104 lines
3.3 KiB
JavaScript
import axios from "axios";
|
|
import parsePhoneNumber from "libphonenumber-js";
|
|
import { all, call, put, select, takeLatest } from "redux-saga/effects";
|
|
import { logImEXEvent } from "../../firebase/firebase.utils";
|
|
import { CONVERSATION_ID_BY_PHONE, CREATE_CONVERSATION } from "../../graphql/conversations.queries";
|
|
import { INSERT_CONVERSATION_TAG } from "../../graphql/job-conversations.queries";
|
|
import client from "../../utils/GraphQLClient";
|
|
import { selectBodyshop } from "../user/user.selectors";
|
|
import { sendMessageFailure, sendMessageSuccess, setSelectedConversation } from "./messaging.actions";
|
|
import MessagingActionTypes from "./messaging.types";
|
|
|
|
export function* onToggleChatVisible() {
|
|
yield takeLatest(MessagingActionTypes.TOGGLE_CHAT_VISIBLE, toggleChatLogging);
|
|
}
|
|
|
|
export function* toggleChatLogging() {
|
|
try {
|
|
yield logImEXEvent("messaging_toggle_popup");
|
|
} catch (error) {
|
|
console.log("Error in sendMessage saga.", error);
|
|
}
|
|
}
|
|
|
|
export function* onOpenChatByPhone() {
|
|
yield takeLatest(MessagingActionTypes.OPEN_CHAT_BY_PHONE, openChatByPhone);
|
|
}
|
|
|
|
export function* openChatByPhone({ payload }) {
|
|
logImEXEvent("messaging_open_by_phone");
|
|
const { phone_num, jobid } = payload;
|
|
|
|
const p = parsePhoneNumber(phone_num, "CA");
|
|
const bodyshop = yield select(selectBodyshop);
|
|
try {
|
|
const {
|
|
data: { conversations }
|
|
} = yield client.query({
|
|
query: CONVERSATION_ID_BY_PHONE,
|
|
variables: { phone: p.number },
|
|
fetchPolicy: 'no-cache'
|
|
});
|
|
|
|
if (conversations.length === 0) {
|
|
const {
|
|
data: {
|
|
insert_conversations: { returning: newConversationsId }
|
|
}
|
|
} = yield client.mutate({
|
|
mutation: CREATE_CONVERSATION,
|
|
variables: {
|
|
conversation: [
|
|
{
|
|
phone_num: p.number,
|
|
bodyshopid: bodyshop.id,
|
|
job_conversations: jobid ? { data: { jobid: jobid } } : null
|
|
}
|
|
]
|
|
}
|
|
});
|
|
yield put(setSelectedConversation(newConversationsId[0].id));
|
|
} else if (conversations.length === 1) {
|
|
//got the ID. Open it.
|
|
yield put(setSelectedConversation(conversations[0].id));
|
|
|
|
//Check to see if this job ID is already a child of it. If not add the tag.
|
|
if (jobid && !conversations[0].job_conversations.find((jc) => jc.jobid === jobid))
|
|
yield client.mutate({
|
|
mutation: INSERT_CONVERSATION_TAG,
|
|
variables: {
|
|
conversationId: conversations[0].id,
|
|
jobId: jobid
|
|
}
|
|
});
|
|
} else {
|
|
console.log("ERROR: Multiple conversations found. ");
|
|
yield put(setSelectedConversation(null));
|
|
}
|
|
} catch (error) {
|
|
console.log("Error in sendMessage saga.", error);
|
|
}
|
|
}
|
|
|
|
export function* onSendMessage() {
|
|
yield takeLatest(MessagingActionTypes.SEND_MESSAGE, sendMessage);
|
|
}
|
|
|
|
export function* sendMessage({ payload }) {
|
|
try {
|
|
const response = yield call(axios.post, "/sms/send", payload);
|
|
if (response.status === 200) {
|
|
yield put(sendMessageSuccess(payload));
|
|
} else {
|
|
yield put(sendMessageFailure(response.data));
|
|
}
|
|
} catch (error) {
|
|
console.log("Error in sendMessage saga.", error);
|
|
yield put(sendMessageFailure(error));
|
|
}
|
|
}
|
|
|
|
export function* messagingSagas() {
|
|
yield all([call(onSendMessage), call(onOpenChatByPhone), call(onToggleChatVisible)]);
|
|
}
|