homeio

1"use client";
2
3import { useMutation, useQueryClient } from "@tanstack/react-query";
4import type {
5  TrashEmptyResponse,
6  TrashDeleteRequest,
7  TrashMoveRequest,
8  TrashMoveResponse,
9  TrashRestoreRequest,
10  TrashRestoreResponse,
11} from "@/lib/shared/contracts/files";
12import { queryKeys } from "@/lib/shared/query-keys";
13
14type TrashMoveApiResponse = {
15  data: TrashMoveResponse;
16};
17
18type TrashRestoreApiResponse = {
19  data: TrashRestoreResponse;
20};
21
22type TrashDeleteApiResponse = {
23  data: {
24    deleted: boolean;
25    path: string;
26  };
27};
28
29type TrashEmptyApiResponse = {
30  data: TrashEmptyResponse;
31};
32
33function mapError(responseStatus: number, errorBody: { error?: string; code?: string }) {
34  return (
35    errorBody.error ??
36    `Request failed (${responseStatus})${errorBody.code ? ` [${errorBody.code}]` : ""}`
37  );
38}
39
40function getParentPath(filePath: string) {
41  const normalized = filePath.trim();
42  if (normalized.length === 0) return "";
43  const separatorIndex = normalized.lastIndexOf("/");
44  if (separatorIndex < 0) return "";
45  return normalized.slice(0, separatorIndex);
46}
47
48function filesListKeyPrefix(filePath: string) {
49  return ["files", "list", filePath] as const;
50}
51
52async function moveToTrash(payload: TrashMoveRequest) {
53  const response = await fetch("/api/v1/files/trash/move", {
54    method: "POST",
55    headers: {
56      "Content-Type": "application/json",
57    },
58    body: JSON.stringify(payload),
59  });
60
61  if (!response.ok) {
62    const errorBody = (await response.json().catch(() => ({}))) as {
63      error?: string;
64      code?: string;
65    };
66    throw new Error(mapError(response.status, errorBody));
67  }
68
69  const json = (await response.json()) as TrashMoveApiResponse;
70  return json.data;
71}
72
73async function restoreFromTrash(payload: TrashRestoreRequest) {
74  const response = await fetch("/api/v1/files/trash/restore", {
75    method: "POST",
76    headers: {
77      "Content-Type": "application/json",
78    },
79    body: JSON.stringify(payload),
80  });
81
82  if (!response.ok) {
83    const errorBody = (await response.json().catch(() => ({}))) as {
84      error?: string;
85      code?: string;
86    };
87    throw new Error(mapError(response.status, errorBody));
88  }
89
90  const json = (await response.json()) as TrashRestoreApiResponse;
91  return json.data;
92}
93
94async function deleteFromTrash(payload: TrashDeleteRequest) {
95  const response = await fetch("/api/v1/files/trash/delete", {
96    method: "POST",
97    headers: {
98      "Content-Type": "application/json",
99    },
100    body: JSON.stringify(payload),
101  });
102
103  if (!response.ok) {
104    const errorBody = (await response.json().catch(() => ({}))) as {
105      error?: string;
106      code?: string;
107    };
108    throw new Error(mapError(response.status, errorBody));
109  }
110
111  const json = (await response.json()) as TrashDeleteApiResponse;
112  return json.data;
113}
114
115async function emptyTrashRequest() {
116  const response = await fetch("/api/v1/files/trash/empty", {
117    method: "POST",
118  });
119
120  if (!response.ok) {
121    const errorBody = (await response.json().catch(() => ({}))) as {
122      error?: string;
123      code?: string;
124    };
125    throw new Error(mapError(response.status, errorBody));
126  }
127
128  const json = (await response.json()) as TrashEmptyApiResponse;
129  return json.data;
130}
131
132export function useMoveToTrash() {
133  const queryClient = useQueryClient();
134
135  return useMutation({
136    mutationFn: moveToTrash,
137    onSuccess: (data, variables) => {
138      void queryClient.invalidateQueries({
139        queryKey: filesListKeyPrefix(getParentPath(variables.path)),
140      });
141      void queryClient.invalidateQueries({
142        queryKey: filesListKeyPrefix("Trash"),
143      });
144      void queryClient.invalidateQueries({
145        queryKey: queryKeys.fileContent(variables.path),
146      });
147      void queryClient.invalidateQueries({
148        queryKey: queryKeys.trashEntries("Trash"),
149      });
150      void queryClient.invalidateQueries({
151        queryKey: filesListKeyPrefix(getParentPath(data.trashPath)),
152      });
153    },
154  });
155}
156
157export function useRestoreFromTrash() {
158  const queryClient = useQueryClient();
159
160  return useMutation({
161    mutationFn: restoreFromTrash,
162    onSuccess: (data, variables) => {
163      void queryClient.invalidateQueries({
164        queryKey: filesListKeyPrefix("Trash"),
165      });
166      void queryClient.invalidateQueries({
167        queryKey: queryKeys.trashEntries("Trash"),
168      });
169      void queryClient.invalidateQueries({
170        queryKey: filesListKeyPrefix(getParentPath(data.restoredPath)),
171      });
172      void queryClient.invalidateQueries({
173        queryKey: queryKeys.fileContent(variables.path),
174      });
175    },
176  });
177}
178
179export function useDeleteFromTrash() {
180  const queryClient = useQueryClient();
181
182  return useMutation({
183    mutationFn: deleteFromTrash,
184    onSuccess: (_data, variables) => {
185      void queryClient.invalidateQueries({
186        queryKey: filesListKeyPrefix(getParentPath(variables.path)),
187      });
188      void queryClient.invalidateQueries({
189        queryKey: queryKeys.trashEntries("Trash"),
190      });
191      void queryClient.invalidateQueries({
192        queryKey: queryKeys.fileContent(variables.path),
193      });
194    },
195  });
196}
197
198export function useEmptyTrash() {
199  const queryClient = useQueryClient();
200
201  return useMutation({
202    mutationFn: emptyTrashRequest,
203    onSuccess: () => {
204      void queryClient.invalidateQueries({
205        queryKey: filesListKeyPrefix("Trash"),
206      });
207      void queryClient.invalidateQueries({
208        queryKey: queryKeys.trashEntries("Trash"),
209      });
210    },
211  });
212}
213