homeio

1"use client";
2
3import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query";
4import type {
5  StoreCatalogSource,
6  StoreCatalogSourceCreateRequest,
7  StoreCatalogSourceUpdateRequest,
8} from "@/lib/shared/contracts/apps";
9import { queryKeys } from "@/lib/shared/query-keys";
10
11type StoreSourcesResponse = {
12  data: StoreCatalogSource[];
13};
14
15type StoreSourceResponse = {
16  data: StoreCatalogSource;
17};
18
19async function fetchStoreSources() {
20  const response = await fetch("/api/v1/store/sources", {
21    cache: "no-store",
22  });
23
24  if (!response.ok) {
25    throw new Error(`Failed to fetch store sources (${response.status})`);
26  }
27
28  const json = (await response.json()) as StoreSourcesResponse;
29  return json.data;
30}
31
32async function createStoreSource(payload: StoreCatalogSourceCreateRequest) {
33  const response = await fetch("/api/v1/store/sources", {
34    method: "POST",
35    headers: {
36      "Content-Type": "application/json",
37    },
38    body: JSON.stringify(payload),
39  });
40
41  if (!response.ok) {
42    const json = (await response.json().catch(() => ({}))) as { error?: string };
43    throw new Error(json.error ?? `Failed to add store source (${response.status})`);
44  }
45
46  const json = (await response.json()) as StoreSourceResponse;
47  return json.data;
48}
49
50async function updateStoreSource(input: {
51  sourceId: string;
52  payload: StoreCatalogSourceUpdateRequest;
53}) {
54  const response = await fetch(`/api/v1/store/sources/${encodeURIComponent(input.sourceId)}`, {
55    method: "PATCH",
56    headers: {
57      "Content-Type": "application/json",
58    },
59    body: JSON.stringify(input.payload),
60  });
61
62  if (!response.ok) {
63    const json = (await response.json().catch(() => ({}))) as { error?: string };
64    throw new Error(json.error ?? `Failed to update store source (${response.status})`);
65  }
66
67  const json = (await response.json()) as StoreSourceResponse;
68  return json.data;
69}
70
71async function refreshStoreSource(sourceId: string) {
72  const response = await fetch(
73    `/api/v1/store/sources/${encodeURIComponent(sourceId)}/refresh`,
74    {
75      method: "POST",
76    },
77  );
78
79  if (!response.ok) {
80    const json = (await response.json().catch(() => ({}))) as { error?: string };
81    throw new Error(json.error ?? `Failed to refresh store source (${response.status})`);
82  }
83
84  const json = (await response.json()) as StoreSourceResponse;
85  return json.data;
86}
87
88async function deleteStoreSource(sourceId: string) {
89  const response = await fetch(`/api/v1/store/sources/${encodeURIComponent(sourceId)}`, {
90    method: "DELETE",
91  });
92
93  if (!response.ok) {
94    const json = (await response.json().catch(() => ({}))) as { error?: string };
95    throw new Error(json.error ?? `Failed to remove store source (${response.status})`);
96  }
97
98  const json = (await response.json()) as StoreSourceResponse;
99  return json.data;
100}
101
102export function useStoreSources() {
103  return useQuery({
104    queryKey: queryKeys.storeSources,
105    queryFn: fetchStoreSources,
106    staleTime: 60_000,
107    refetchOnMount: false,
108    refetchOnReconnect: false,
109    refetchOnWindowFocus: false,
110    placeholderData: (previousData) => previousData,
111  });
112}
113
114export function useStoreSourceActions() {
115  const queryClient = useQueryClient();
116
117  function invalidateStoreState() {
118    void queryClient.invalidateQueries({ queryKey: queryKeys.storeSources });
119    void queryClient.invalidateQueries({ queryKey: queryKeys.storeCatalog });
120  }
121
122  const addSource = useMutation({
123    mutationFn: createStoreSource,
124    onSuccess: invalidateStoreState,
125  });
126
127  const updateSource = useMutation({
128    mutationFn: updateStoreSource,
129    onSuccess: invalidateStoreState,
130  });
131
132  const refreshSource = useMutation({
133    mutationFn: refreshStoreSource,
134    onSuccess: invalidateStoreState,
135  });
136
137  const removeSource = useMutation({
138    mutationFn: deleteStoreSource,
139    onSuccess: invalidateStoreState,
140  });
141
142  return {
143    addSource,
144    updateSource,
145    refreshSource,
146    removeSource,
147  };
148}
149