41 lines
1.1 KiB
React
41 lines
1.1 KiB
React
|
import React, { useContext, useEffect } from 'react';
|
||
|
|
import GroupChat from '/imports/api/group-chat';
|
||
|
|
import { GroupChatContext, ACTIONS } from './context';
|
||
|
|
|
||
|
|
|
||
|
|
const Adapter = () => {
|
||
|
|
const usingGroupChatContext = useContext(GroupChatContext);
|
||
|
|
const { dispatch } = usingGroupChatContext;
|
||
|
|
|
||
|
|
|
||
|
|
useEffect(() => {
|
||
|
|
const alreadyDispatched = new Set();
|
||
|
|
const notDispatchedCount = { count: 100 };
|
||
|
|
// TODO: listen to websocket message to avoid full list comparsion
|
||
|
|
const diffAndDispatch = () => {
|
||
|
|
setTimeout(() => {
|
||
|
|
const groupChatCursor = GroupChat.find({}, { reactive: false }).fetch();
|
||
|
|
const notDispatched = groupChatCursor.filter(objMsg => !alreadyDispatched.has(objMsg._id));
|
||
|
|
notDispatchedCount.count = notDispatched.length;
|
||
|
|
|
||
|
|
notDispatched.forEach((groupChat) => {
|
||
|
|
dispatch({
|
||
|
|
type: ACTIONS.ADDED,
|
||
|
|
value: {
|
||
|
|
groupChat,
|
||
|
|
},
|
||
|
|
});
|
||
|
|
|
||
|
|
alreadyDispatched.add(groupChat._id);
|
||
|
|
});
|
||
|
|
diffAndDispatch();
|
||
|
|
}, notDispatchedCount.count >= 10 ? 1000 : 500);
|
||
|
|
};
|
||
|
|
diffAndDispatch();
|
||
|
|
}, []);
|
||
|
|
|
||
|
|
return null;
|
||
|
|
};
|
||
|
|
|
||
|
|
export default Adapter;
|