refactor(ts): src/ui/services/repo

Author: jescalada

src/ui/services/repo.js

@@ -0,0 +1,141 @@
+import axios from 'axios';
+import { getAxiosConfig, processAuthError } from './auth.js';
+import { API_BASE } from '../apiBase';
+import { RepositoryData, RepositoryDataWithId } from '../views/RepoList/Components/NewRepo';
+
+const canAddUser = (repoId: string, user: string, action: string) => {
+  const url = new URL(`${API_BASE}/repo/${repoId}`);
+  return axios
+    .get(url.toString(), getAxiosConfig())
+    .then((response) => {
+      const data = response.data;
+      if (action === 'authorise') {
+        return !data.users.canAuthorise.includes(user);
+      } else {
+        return !data.users.canPush.includes(user);
+      }
+    })
+    .catch((error: any) => {
+      throw error;
+    });
+};
+
+class DupUserValidationError extends Error {
+  constructor(message: string) {
+    super(message);
+    this.name = 'The user already has this role...';
+  }
+}
+
+const getRepos = async (
+  setIsLoading: (isLoading: boolean) => void,
+  setData: (data: any) => void,
+  setAuth: (auth: boolean) => void,
+  setIsError: (isError: boolean) => void,
+  setErrorMessage: (errorMessage: string) => void,
+  query: Record<string, boolean> = {},
+): Promise<void> => {
+  const url = new URL(`${API_BASE}/repo`);
+  url.search = new URLSearchParams(query as any).toString();
+  setIsLoading(true);
+  await axios(url.toString(), getAxiosConfig())
+    .then((response) => {
+      const sortedRepos = response.data.sort((a: RepositoryData, b: RepositoryData) =>
+        a.name.localeCompare(b.name),
+      );
+      setData(sortedRepos);
+    })
+    .catch((error: any) => {
+      setIsError(true);
+      if (error.response && error.response.status === 401) {
+        setAuth(false);
+        setErrorMessage(processAuthError(error));
+      } else {
+        setErrorMessage(`Error fetching repos: ${error.response.data.message}`);
+      }
+    })
+    .finally(() => {
+      setIsLoading(false);
+    });
+};
+
+const getRepo = async (
+  setIsLoading: (isLoading: boolean) => void,
+  setData: (data: any) => void,
+  setAuth: (auth: boolean) => void,
+  setIsError: (isError: boolean) => void,
+  id: string,
+): Promise<void> => {
+  const url = new URL(`${API_BASE}/repo/${id}`);
+  setIsLoading(true);
+  await axios(url.toString(), getAxiosConfig())
+    .then((response) => {
+      const data = response.data;
+      setData(data);
+    })
+    .catch((error: any) => {
+      if (error.response && error.response.status === 401) {
+        setAuth(false);
+      } else {
+        setIsError(true);
+      }
+    })
+    .finally(() => {
+      setIsLoading(false);
+    });
+};
+
+const addRepo = async (
+  data: RepositoryData,
+): Promise<{ success: boolean; message?: string; repo: RepositoryDataWithId | null }> => {
+  const url = new URL(`${API_BASE}/repo`);
+
+  try {
+    const response = await axios.post(url.toString(), data, getAxiosConfig());
+    return {
+      success: true,
+      repo: response.data,
+    };
+  } catch (error: any) {
+    return {
+      success: false,
+      message: error.response?.data?.message || error.message,
+      repo: null,
+    };
+  }
+};
+
+const addUser = async (repoId: string, user: string, action: string): Promise<void> => {
+  const canAdd = await canAddUser(repoId, user, action);
+  if (canAdd) {
+    const url = new URL(`${API_BASE}/repo/${repoId}/user/${action}`);
+    const data = { username: user };
+    await axios.patch(url.toString(), data, getAxiosConfig()).catch((error: any) => {
+      console.log(error.response.data.message);
+      throw error;
+    });
+  } else {
+    console.log('Duplicate user can not be added');
+    throw new DupUserValidationError('Duplicate user can not be added');
+  }
+};
+
+const deleteUser = async (user: string, repoId: string, action: string): Promise<void> => {
+  const url = new URL(`${API_BASE}/repo/${repoId}/user/${action}/${user}`);
+
+  await axios.delete(url.toString(), getAxiosConfig()).catch((error: any) => {
+    console.log(error.response.data.message);
+    throw error;
+  });
+};
+
+const deleteRepo = async (repoId: string): Promise<void> => {
+  const url = new URL(`${API_BASE}/repo/${repoId}/delete`);
+
+  await axios.delete(url.toString(), getAxiosConfig()).catch((error: any) => {
+    console.log(error.response.data.message);
+    throw error;
+  });
+};
+
+export { addUser, deleteUser, getRepos, getRepo, addRepo, deleteRepo };

src/ui/services/repo.ts

@@ -96,7 +96,7 @@ const AddRepositoryDialog: React.FC<AddRepositoryDialogProps> = ({ open, onClose
     }
 
     const result = await addRepo(data);
-    if (result.success) {
+    if (result.success && result.repo) {
       handleSuccess(result.repo);
       handleClose();
     } else {