mirror of
https://github.com/cpvalente/ontime.git
synced 2026-08-12 19:03:47 +00:00
3f8c6f1192
- fetch to useFetch hook - refetch every 10s - sync browser tabs with experimental broadcastQueryClient
188 lines
5.5 KiB
React
188 lines
5.5 KiB
React
import { useMutation, useQueryClient } from 'react-query';
|
|
import { useEffect } from 'react';
|
|
import {
|
|
eventsNamespace,
|
|
fetchAllEvents,
|
|
requestPatch,
|
|
requestPost,
|
|
requestPut,
|
|
requestDelete,
|
|
} from '../../../app/api/eventsApi.js';
|
|
import EventList from './EventList';
|
|
import EventListMenu from '../../menu/EventListMenu.jsx';
|
|
import { showErrorToast } from '../../../common/helpers/toastManager';
|
|
import { Skeleton } from '@chakra-ui/skeleton';
|
|
import style from './List.module.css';
|
|
import { useFetch } from '../../../app/hooks/useFetch.js';
|
|
|
|
export default function EventListWrapper() {
|
|
const queryClient = useQueryClient();
|
|
const { data, status, isError, refetch } = useFetch(
|
|
eventsNamespace,
|
|
fetchAllEvents
|
|
);
|
|
const addEvent = useMutation(requestPost, {
|
|
// we optimistically update here
|
|
onMutate: async (newEvent) => {
|
|
// cancel ongoing queries
|
|
queryClient.cancelQueries(eventsNamespace, { exact: true });
|
|
|
|
// Snapshot the previous value
|
|
let previousEvents = queryClient.getQueryData(eventsNamespace);
|
|
if (previousEvents == null) {
|
|
await queryClient.refetchQueries();
|
|
previousEvents = queryClient.getQueryData(eventsNamespace);
|
|
}
|
|
// optimistically update object, temp ID until refetch
|
|
let optimistic = [...previousEvents];
|
|
optimistic.splice(newEvent.order, 0, {
|
|
...newEvent,
|
|
id: new Date().toISOString(),
|
|
});
|
|
queryClient.setQueryData(eventsNamespace, optimistic);
|
|
|
|
// Return a context with the previous and new todo
|
|
return { previousEvents };
|
|
},
|
|
|
|
// Mutation fails, rollback undos optimist update
|
|
onError: (error, newEvent, context) => {
|
|
queryClient.setQueryData(eventsNamespace, context.previousEvents);
|
|
},
|
|
// Mutation finished, failed or successful
|
|
// Fetch anyway, just to be sure
|
|
onSettled: () => {
|
|
queryClient.invalidateQueries(eventsNamespace);
|
|
},
|
|
});
|
|
const updateEvent = useMutation(requestPut, {
|
|
// we optimistically update here
|
|
onMutate: async (newEvent) => {
|
|
// cancel ongoing queries
|
|
queryClient.cancelQueries([eventsNamespace, newEvent.id]);
|
|
|
|
// Snapshot the previous value
|
|
const previousEvent = queryClient.getQueryData([
|
|
eventsNamespace,
|
|
newEvent.id,
|
|
]);
|
|
|
|
// optimistically update object
|
|
queryClient.setQueryData([eventsNamespace, newEvent.id], newEvent);
|
|
|
|
// Return a context with the previous and new todo
|
|
return { previousEvent, newEvent };
|
|
},
|
|
|
|
// Mutation fails, rollback undos optimist update
|
|
onError: (error, newEvent, context) => {
|
|
queryClient.setQueryData(
|
|
[eventsNamespace, context.newEvent.id],
|
|
context.previousEvent
|
|
);
|
|
},
|
|
// Mutation finished, failed or successful
|
|
// Fetch anyway, just to be sure
|
|
onSettled: (newEvent) => {
|
|
queryClient.invalidateQueries([eventsNamespace, newEvent.id]);
|
|
},
|
|
});
|
|
|
|
const patchEvent = useMutation(requestPatch, {
|
|
// we optimistically update here
|
|
onMutate: async (newEvent) => {
|
|
// cancel ongoing queries
|
|
queryClient.cancelQueries([eventsNamespace, newEvent.id]);
|
|
|
|
// Snapshot the previous value
|
|
const previousEvent = queryClient.getQueryData([
|
|
eventsNamespace,
|
|
newEvent.id,
|
|
]);
|
|
|
|
// optimistically update object
|
|
queryClient.setQueryData([eventsNamespace, newEvent.id], newEvent);
|
|
|
|
// Return a context with the previous and new todo
|
|
return { previousEvent, newEvent };
|
|
},
|
|
|
|
// Mutation fails, rollback undos optimist update
|
|
onError: (error, newEvent, context) => {
|
|
queryClient.setQueryData(
|
|
[eventsNamespace, context.newEvent.id],
|
|
context.previousEvent
|
|
);
|
|
},
|
|
// Mutation finished, failed or successful
|
|
// Fetch anyway, just to be sure
|
|
onSettled: (newEvent) => {
|
|
queryClient.invalidateQueries([eventsNamespace, newEvent.id]);
|
|
},
|
|
});
|
|
|
|
const deleteEvent = useMutation(requestDelete);
|
|
|
|
// Show toasts on errors
|
|
useEffect(() => {
|
|
if (isError) {
|
|
showErrorToast('Error fetching data');
|
|
}
|
|
}, [isError]);
|
|
|
|
// Events API
|
|
const eventsHandler = async (action, payload) => {
|
|
let needsRefetch = false;
|
|
switch (action) {
|
|
case 'add':
|
|
try {
|
|
await addEvent.mutateAsync(payload);
|
|
} catch (error) {
|
|
showErrorToast('Error creating event', error.message);
|
|
}
|
|
break;
|
|
case 'update':
|
|
try {
|
|
await updateEvent.mutateAsync(payload);
|
|
} catch (error) {
|
|
showErrorToast('Error updating event', error.message);
|
|
}
|
|
break;
|
|
case 'patch':
|
|
try {
|
|
await patchEvent.mutateAsync(payload);
|
|
} catch (error) {
|
|
showErrorToast('Error updating event', error.message);
|
|
}
|
|
break;
|
|
case 'delete':
|
|
// TODO: could do optimistic update here?
|
|
try {
|
|
await deleteEvent.mutateAsync(payload).then((needsRefetch = true));
|
|
} catch (error) {
|
|
showErrorToast('Error deleting event', error.message);
|
|
}
|
|
break;
|
|
default:
|
|
showErrorToast('Unrecognised request', action);
|
|
break;
|
|
}
|
|
if (needsRefetch) {
|
|
refetch();
|
|
}
|
|
};
|
|
|
|
return (
|
|
<>
|
|
<EventListMenu eventsHandler={eventsHandler} />
|
|
{status === 'success' ? (
|
|
<EventList events={data} eventsHandler={eventsHandler} />
|
|
) : (
|
|
<div className={style.eventContainer}>
|
|
<Skeleton height='50vh' />
|
|
</div>
|
|
)}
|
|
</>
|
|
);
|
|
}
|