44 lines
1.2 KiB
React
44 lines
1.2 KiB
React
|
import React, { useEffect } from 'react';
|
||
|
|
import { useMutation, useSubscription } from '@apollo/client';
|
||
|
|
import { CONNECTION_STATUS_SUBSCRIPTION } from './queries';
|
||
|
|
import { UPDATE_CONNECTION_ALIVE_AT, UPDATE_USER_CLIENT_RESPONSE_AT } from './mutations';
|
||
|
|
|
||
|
|
const ConnectionStatus = () => {
|
||
|
|
const [updateUserClientResponseAtToMeAsNow] = useMutation(UPDATE_USER_CLIENT_RESPONSE_AT);
|
||
|
|
|
||
|
|
const handleUpdateUserClientResponseAt = () => {
|
||
|
|
updateUserClientResponseAtToMeAsNow();
|
||
|
|
};
|
||
|
|
|
||
|
|
const [updateConnectionAliveAtToMeAsNow] = useMutation(UPDATE_CONNECTION_ALIVE_AT);
|
||
|
|
|
||
|
|
const handleUpdateConnectionAliveAt = () => {
|
||
|
|
updateConnectionAliveAtToMeAsNow();
|
||
|
|
|
||
|
|
setTimeout(() => {
|
||
|
|
handleUpdateConnectionAliveAt();
|
||
|
|
}, 5000);
|
||
|
|
};
|
||
|
|
|
||
|
|
useEffect(() => {
|
||
|
|
handleUpdateConnectionAliveAt();
|
||
|
|
}, []);
|
||
|
|
|
||
|
|
const { loading, error, data } = useSubscription(CONNECTION_STATUS_SUBSCRIPTION);
|
||
|
|
|
||
|
|
if (!loading && !error && data) {
|
||
|
|
data.user_connectionStatus.forEach((curr) => {
|
||
|
|
if (curr.userClientResponseAt == null) {
|
||
|
|
const delay = 500;
|
||
|
|
setTimeout(() => {
|
||
|
|
handleUpdateUserClientResponseAt();
|
||
|
|
}, delay);
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
return null;
|
||
|
|
};
|
||
|
|
|
||
|
|
export default ConnectionStatus;
|