Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 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 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 | 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 5x 5x 5x 5x 5x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x 1x | import { useInfiniteQuery, useQueries, useQuery, useQueryClient } from '@tanstack/react-query';
import { isNil, uniq } from 'lodash-es';
import { useMemo } from 'react';
import { useIntl } from 'react-intl';
import { useSnackbars } from '@allshares/studio-design-system';
import { useMutation } from '@amalia/ext/react-query';
import { type KeysOfUserWithStringValues, type UsersMap } from '@amalia/tenants/users/types';
import { NotificationsApiClient } from './api-client/notifications.api-client';
import { UserApiClient } from './api-client/user.api-client';
import { notificationsQueryKeys, userInformationQueryKeys } from './queries.keys';
export const useUsersInformations = (
usersToFetch: [property: KeysOfUserWithStringValues, value: string][],
enabled: boolean = true,
) =>
useQueries({
queries: usersToFetch.map(([property, value]) => ({
queryKey: userInformationQueryKeys.byProperty(property, value),
queryFn: () => UserApiClient.bufferedFetchUserBy(property, value),
enabled,
})),
});
export const useUsersById = (userIds: string[], enabled: boolean = true) =>
useUsersInformations(
userIds.map((id) => ['id', id]),
enabled,
);
export const useUsersMap = (userIds: string[], enabled: boolean = true) => {
const queries = useUsersById(uniq(userIds), enabled);
return useMemo(
() =>
queries.reduce<UsersMap>((acc, query) => {
if (query.data) {
acc[query.data.id] = query.data;
}
return acc;
}, {}),
[queries],
);
};
export const useUserInformations = (property: KeysOfUserWithStringValues, value?: string) =>
useQuery({
queryKey: userInformationQueryKeys.byProperty(property, value!),
queryFn: () => UserApiClient.bufferedFetchUserBy(property, value!),
refetchOnWindowFocus: false,
enabled: !!value,
});
export const useGetUserManagers = (queryArgs: Parameters<(typeof UserApiClient)['getUserManagers']>[0]) =>
useQuery({
queryKey: userInformationQueryKeys.ofUser.managers(queryArgs),
queryFn: () => UserApiClient.getUserManagers(queryArgs),
});
const authzContextQueryKeys = {
all: () => ['authenticated-context'] as const,
currentUser: () => [...authzContextQueryKeys.all(), 'current-user'] as const,
} as const;
const authzContextMutationKeys = {
all: () => ['authenticated-context'] as const,
updateSettings: () => [...authzContextMutationKeys.all(), 'update-settings'] as const,
} as const;
export const useUpdateUserSettings = () => {
const { snackSuccess } = useSnackbars();
const queryClient = useQueryClient();
const { formatMessage } = useIntl();
return useMutation({
mutationKey: authzContextMutationKeys.updateSettings(),
mutationFn: UserApiClient.updateSettings,
onSuccess: async () => {
await queryClient.invalidateQueries({ queryKey: authzContextQueryKeys.all() });
snackSuccess(formatMessage({ defaultMessage: 'Settings successfully updated!' }));
},
});
};
export const useInfiniteNotifications = () => {
const { data, ...rest } = useInfiniteQuery({
queryKey: notificationsQueryKeys.pages(),
queryFn: ({ pageParam = 1 }: { pageParam?: number }) => NotificationsApiClient.fetchNotifications(pageParam),
getNextPageParam: (lastPage, allPages) =>
!isNil(lastPage.paginatedNotifications.pageCount) && allPages.length < lastPage.paginatedNotifications.pageCount
? allPages.length + 1
: undefined,
initialPageParam: 1,
});
const notifications = useMemo(
() => data?.pages.flatMap((page) => page.paginatedNotifications.items) ?? [],
[data?.pages],
);
return {
data: notifications,
...rest,
};
};
export const useUnreadNotificationsCount = () =>
useQuery({
queryKey: notificationsQueryKeys.unreadCount(),
queryFn: () => NotificationsApiClient.fetchUnreadCount(),
refetchInterval: 15_000,
});
export const useMarkNotificationsAsRead = () => {
const queryClient = useQueryClient();
return useMutation({
mutationFn: async (args: Parameters<(typeof NotificationsApiClient)['markAsRead']>) => {
await NotificationsApiClient.markAsRead(...args);
},
onSuccess: async () => {
await queryClient.invalidateQueries({ queryKey: notificationsQueryKeys.all() });
},
});
};
|