File size: 1,534 Bytes
8a37e0a
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
import {
  useCancelQueueItemMutation,
  // useCancelByBatchIdsMutation,
  useClearQueueMutation,
  useEnqueueBatchMutation,
  usePauseProcessorMutation,
  usePruneQueueMutation,
  useResumeProcessorMutation,
} from 'services/api/endpoints/queue';

export const useIsQueueMutationInProgress = () => {
  const [_triggerEnqueueBatch, { isLoading: isLoadingEnqueueBatch }] = useEnqueueBatchMutation({
    fixedCacheKey: 'enqueueBatch',
  });
  const [_triggerResumeProcessor, { isLoading: isLoadingResumeProcessor }] = useResumeProcessorMutation({
    fixedCacheKey: 'resumeProcessor',
  });
  const [_triggerPauseProcessor, { isLoading: isLoadingPauseProcessor }] = usePauseProcessorMutation({
    fixedCacheKey: 'pauseProcessor',
  });
  const [_triggerCancelQueue, { isLoading: isLoadingCancelQueue }] = useCancelQueueItemMutation({
    fixedCacheKey: 'cancelQueueItem',
  });
  const [_triggerClearQueue, { isLoading: isLoadingClearQueue }] = useClearQueueMutation({
    fixedCacheKey: 'clearQueue',
  });
  const [_triggerPruneQueue, { isLoading: isLoadingPruneQueue }] = usePruneQueueMutation({
    fixedCacheKey: 'pruneQueue',
  });
  // const [_triggerCancelByBatchIds, { isLoading: isLoadingCancelByBatchIds }] =
  //   useCancelByBatchIdsMutation({
  //     fixedCacheKey: 'cancelByBatchIds',
  //   });
  return (
    isLoadingEnqueueBatch ||
    isLoadingResumeProcessor ||
    isLoadingPauseProcessor ||
    isLoadingCancelQueue ||
    isLoadingClearQueue ||
    isLoadingPruneQueue
    // isLoadingCancelByBatchIds
  );
};