fix: receiving msg while load shows repeated messages in ticket

This commit is contained in:
canove
2020-08-10 19:05:31 -03:00
parent c3d262648d
commit d747d49881

View File

@@ -221,12 +221,13 @@ const useStyles = makeStyles(theme => ({
}, },
})); }));
const socket = openSocket(process.env.REACT_APP_BACKEND_URL);
const MessagesList = () => { const MessagesList = () => {
const { ticketId } = useParams(); const { ticketId } = useParams();
const history = useHistory(); const history = useHistory();
const classes = useStyles(); const classes = useStyles();
const token = localStorage.getItem("token");
const userId = +localStorage.getItem("userId"); const userId = +localStorage.getItem("userId");
const [loading, setLoading] = useState(true); const [loading, setLoading] = useState(true);
@@ -255,7 +256,6 @@ const MessagesList = () => {
return [...data.messages, ...prevMessages]; return [...data.messages, ...prevMessages];
}); });
setCount(data.count); setCount(data.count);
// setHasMore(res.data.messages.length > 0);
setLoading(false); setLoading(false);
if (pageNumber === 1 && data.messages.length > 1) { if (pageNumber === 1 && data.messages.length > 1) {
scrollToBottom(); scrollToBottom();
@@ -269,15 +269,21 @@ const MessagesList = () => {
fetchMessages(); fetchMessages();
}, 1000); }, 1000);
return () => clearTimeout(delayDebounceFn); return () => clearTimeout(delayDebounceFn);
}, [pageNumber, ticketId, token, history]); }, [pageNumber, ticketId, history]);
useEffect(() => { useEffect(() => {
const socket = openSocket(process.env.REACT_APP_BACKEND_URL);
socket.emit("joinChatBox", ticketId, () => {}); socket.emit("joinChatBox", ticketId, () => {});
return () => {
socket.disconnect();
setPageNumber(1);
setMessagesList([]);
};
}, [ticketId]);
useEffect(() => {
socket.on("appMessage", data => { socket.on("appMessage", data => {
if (data.action === "create") { if (data.action === "create" && !loading) {
addMessage(data.message); addMessage(data.message);
scrollToBottom(); scrollToBottom();
} else if (data.action === "update") { } else if (data.action === "update") {
@@ -286,17 +292,11 @@ const MessagesList = () => {
}); });
socket.on("contact", data => { socket.on("contact", data => {
if (data.action === "update") { if (data.action === "update" && !loading) {
setContact(data.contact); setContact(data.contact);
} }
}); });
}, [loading]);
return () => {
socket.disconnect();
setPageNumber(1);
setMessagesList([]);
};
}, [ticketId]);
const loadMore = () => { const loadMore = () => {
setPageNumber(prevPageNumber => prevPageNumber + 1); setPageNumber(prevPageNumber => prevPageNumber + 1);
@@ -316,14 +316,15 @@ const MessagesList = () => {
}; };
const updateMessageAck = message => { const updateMessageAck = message => {
let id = message.id;
setMessagesList(prevState => { setMessagesList(prevState => {
let aux = [...prevState]; const messageIndex = prevState.findIndex(m => m.id === message.id);
let messageIndex = aux.findIndex(message => message.id === id);
if (messageIndex !== -1) { if (messageIndex !== -1) {
let aux = [...prevState];
aux[messageIndex].ack = message.ack; aux[messageIndex].ack = message.ack;
return aux;
} else {
return prevState;
} }
return aux;
}); });
}; };
@@ -333,6 +334,23 @@ const MessagesList = () => {
} }
}; };
const handleScroll = e => {
if (count === messagesList.length) return;
const { scrollTop } = e.currentTarget;
if (scrollTop === 0) {
document.getElementById("messagesList").scrollTop = 1;
}
if (loading) {
return;
}
if (scrollTop < 50) {
loadMore();
}
};
const checkMessaageMedia = message => { const checkMessaageMedia = message => {
if (message.mediaType === "image") { if (message.mediaType === "image") {
return ( return (
@@ -415,23 +433,6 @@ const MessagesList = () => {
} }
}; };
const handleScroll = e => {
if (count === messagesList.length) return;
const { scrollTop } = e.currentTarget;
if (scrollTop === 0) {
document.getElementById("messagesList").scrollTop = 50;
}
if (loading) {
return;
}
if (scrollTop < 50) {
loadMore();
}
};
const renderDailyTimestamps = (message, index) => { const renderDailyTimestamps = (message, index) => {
if (index === 0) { if (index === 0) {
return ( return (