113 lines
3.3 KiB
JavaScript
113 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 },
|
|
});
|
|
|
|
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),
|
|
]);
|
|
}
|