1import "server-only";
2
3import { toQueryString } from "@/util";
4import {
5  type CreateRepositoryRequest,
6  type CreateRepositoryResponse,
7  CreateRepositoryResponseSchema,
8  type RepositoryCommitDiffs,
9  RepositoryCommitDiffsSchema,
10  type RepositoryCommits,
11  type RepositoryCommitsQuery,
12  RepositoryCommitsSchema,
13  type RepositoryFile,
14  type RepositoryFileCommitsQuery,
15  type RepositoryFileQuery,
16  RepositoryFileSchema,
17  type RepositoryPreview,
18  type RepositoryPreviewQuery,
19  RepositoryPreviewSchema,
20  type RepositoryTree,
21  type RepositoryTreeQuery,
22  RepositoryTreeSchema,
23} from "../dto";
24import {
25  authFetch,
26  authPost,
27  GITDOT_SERVER_URL,
28  handleResponse,
29  NotFound,
30} from "./util";
31
32export async function createRepository(
33  owner: string,
34  repo: string,
35  request: CreateRepositoryRequest,
36): Promise<CreateRepositoryResponse | null> {
37  const response = await authPost(
38    `${GITDOT_SERVER_URL}/repository/${owner}/${repo}`,
39    request,
40  );
41
42  return await handleResponse(response, CreateRepositoryResponseSchema);
43}
44
45export async function getRepositoryFile(
46  owner: string,
47  repo: string,
48  query: RepositoryFileQuery,
49): Promise<RepositoryFile | NotFound | null> {
50  const queryString = toQueryString(query);
51  const response = await authFetch(
52    `${GITDOT_SERVER_URL}/repository/${owner}/${repo}/file?${queryString}`,
53  );
54  if (response.status === 404) return NotFound;
55
56  return await handleResponse(response, RepositoryFileSchema);
57}
58
59export async function getRepositoryTree(
60  owner: string,
61  repo: string,
62  query?: RepositoryTreeQuery,
63): Promise<RepositoryTree | NotFound | null> {
64  const queryString = toQueryString(query);
65  const response = await authFetch(
66    `${GITDOT_SERVER_URL}/repository/${owner}/${repo}/tree?${queryString}`,
67  );
68  if (response.status === 404) return NotFound;
69
70  return await handleResponse(response, RepositoryTreeSchema);
71}
72
73export async function getRepositoryCommits(
74  owner: string,
75  repo: string,
76  query?: RepositoryCommitsQuery,
77): Promise<RepositoryCommits | NotFound | null> {
78  const queryString = toQueryString(query);
79  const response = await authFetch(
80    `${GITDOT_SERVER_URL}/repository/${owner}/${repo}/commits?${queryString}`,
81  );
82  if (response.status === 404) return NotFound;
83
84  return await handleResponse(response, RepositoryCommitsSchema);
85}
86
87export async function getRepositoryFileCommits(
88  owner: string,
89  repo: string,
90  query: RepositoryFileCommitsQuery,
91): Promise<RepositoryCommits | null> {
92  const queryString = toQueryString(query);
93  const response = await authFetch(
94    `${GITDOT_SERVER_URL}/repository/${owner}/${repo}/file/commits?${queryString}`,
95  );
96
97  return await handleResponse(response, RepositoryCommitsSchema);
98}
99
100export async function getRepositoryCommitStats(
101  owner: string,
102  repo: string,
103  sha: string,
104): Promise<RepositoryCommitDiffs | null> {
105  const response = await authFetch(
106    `${GITDOT_SERVER_URL}/repository/${owner}/${repo}/commits/${sha}/stats`,
107  );
108
109  return await handleResponse(response, RepositoryCommitDiffsSchema);
110}
111
112export async function getRepositoryCommitDiffs(
113  owner: string,
114  repo: string,
115  sha: string,
116): Promise<RepositoryCommitDiffs | null> {
117  const response = await authFetch(
118    `${GITDOT_SERVER_URL}/repository/${owner}/${repo}/commits/${sha}/diffs`,
119  );
120
121  return await handleResponse(response, RepositoryCommitDiffsSchema);
122}
123
124export async function getRepositoryPreview(
125  owner: string,
126  repo: string,
127  query?: RepositoryPreviewQuery,
128): Promise<RepositoryPreview | NotFound | null> {
129  const queryString = toQueryString(query);
130  const response = await authFetch(
131    `${GITDOT_SERVER_URL}/repository/${owner}/${repo}/preview?${queryString}`,
132  );
133  if (response.status === 404) return NotFound;
134
135  return await handleResponse(response, RepositoryPreviewSchema);
136}
137