refactor(github): isolate GitHub domain into dedicated layer

api/languages.ts

@@ -1,7 +1,7 @@
 import { VALID_USERNAME } from "../scripts/utils/validators";
 import { CACHE_DURATION_SECONDS } from "../scripts/utils/constants";
 import type { VercelRequest, VercelResponse } from "../types/vercel";
-import { fetchUserData } from "../scripts/fetchers/fetchLanguages";
+import { fetchUserLanguages } from "../scripts/github/fetchUserLanguages";
 import { renderLanguageCard as renderLangPie } from "../scripts/renderers/renderLangPie";
 import { renderLanguageCard as renderLangPercent } from "../scripts/renderers/renderLangPercent";
 import { renderErrorCard } from "../scripts/renderers/renderErrorCard";
@@ -26,7 +26,7 @@ export default async (req: VercelRequest, res: VercelResponse): Promise<void> =>
     }
 
     try {
-        const data = await fetchUserData(username);
+        const data = await fetchUserLanguages(username);
         res.setHeader("Content-Type", "image/svg+xml");
         res.setHeader("Cache-Control", `public, max-age=${CACHE_DURATION_SECONDS}`);
         if (pie) {

api/stats.ts

@@ -1,7 +1,7 @@
 import { VALID_USERNAME } from "../scripts/utils/validators";
 import { CACHE_DURATION_SECONDS } from "../scripts/utils/constants";
 import type { VercelRequest, VercelResponse } from "../types/vercel";
-import { fetchUserData } from "../scripts/fetchers/fetchUserData";
+import { fetchUserStats } from "../scripts/github/fetchUserStats";
 import { renderStatCard } from "../scripts/renderers/renderStatCard";
 import { renderErrorCard } from "../scripts/renderers/renderErrorCard";
 
@@ -25,7 +25,7 @@ export default async (req: VercelRequest, res: VercelResponse): Promise<void> =>
     }
 
     try {
-        const data = await fetchUserData(username);
+        const data = await fetchUserStats(username);
         res.setHeader("Content-Type", "image/svg+xml");
         res.setHeader("Cache-Control", `public, max-age=${CACHE_DURATION_SECONDS}`);
         res.send(renderStatCard(data, color ?? "", peng));

scripts/github/fetchUserLanguages.ts

@@ -0,0 +1,35 @@
+import {
+	GitHubRepositoryEdge,
+	LanguageData,
+	UserLanguageStats,
+} from "../../types";
+import { makeGraphQLRequest } from "./githubApiClient";
+import { USER_LANGUAGES_QUERY } from "./queries";
+
+const fetchUserLanguages = async (user: string): Promise<UserLanguageStats> => {
+	const countLanguages = (edges: GitHubRepositoryEdge[]): LanguageData[] => {
+		const languageMap = new Map<string, LanguageData>();
+
+		edges.forEach((repoEdge) => {
+			repoEdge.node.languages?.edges.forEach((languageEdge) => {
+				const { name, color } = languageEdge.node;
+				if (languageMap.has(name)) {
+					languageMap.get(name)!.count++;
+				} else {
+					languageMap.set(name, { name, color, count: 1 });
+				}
+			});
+		});
+
+		return Array.from(languageMap.values());
+	};
+
+	const data = await makeGraphQLRequest(USER_LANGUAGES_QUERY(user));
+
+	return {
+		user,
+		languages: countLanguages(data.data.user.repositories.edges),
+	};
+};
+
+export { fetchUserLanguages };

scripts/github/fetchUserStats.ts

@@ -0,0 +1,29 @@
+import { GitHubRepositoryEdge, UserStats } from "../../types";
+import { makeGraphQLRequest } from "./githubApiClient";
+import { USER_STATS_QUERY } from "./queries";
+
+const fetchUserStats = async (user: string): Promise<UserStats> => {
+	const countProperty = (
+		nodes: GitHubRepositoryEdge[],
+		property: "stargazerCount" | "forkCount"
+	): number =>
+		nodes.reduce((t, { node }) => t + (node[property] ?? 0), 0);
+
+	const data = await makeGraphQLRequest(USER_STATS_QUERY(user));
+
+	return {
+		user,
+		amountFollowers: data.data.user.followers?.totalCount ?? 0,
+		amountRepos: data.data.user.repositories.edges.length,
+		amountStars: countProperty(
+			data.data.user.repositories.edges,
+			"stargazerCount"
+		),
+		amountForks: countProperty(data.data.user.repositories.edges, "forkCount"),
+		totalContributions:
+			data.data.user.contributionsCollection?.contributionCalendar
+				.totalContributions ?? 0,
+	};
+};
+
+export { fetchUserStats };

scripts/github/githubApiClient.ts

@@ -0,0 +1,62 @@
+import https from "https";
+import dotenv from "dotenv";
+import { GitHubApiResponse } from "../../types";
+
+dotenv.config();
+
+const createHeaders = (): Record<string, string> => ({
+	"user-agent": "Github-Stats",
+	Authorization: `Bearer ${process.env.GITHUB_TOKEN}`,
+	"Content-Type": "application/json",
+	Accept: "application/json",
+});
+
+const makeGraphQLRequest = (query: string): Promise<GitHubApiResponse> => {
+	const options: https.RequestOptions = {
+		hostname: "api.github.com",
+		path: "/graphql",
+		method: "POST",
+		headers: createHeaders(),
+	};
+
+	return new Promise<GitHubApiResponse>((resolve, reject) => {
+		const req = https.request(options, (res) => {
+			const buffers: Buffer[] = [];
+
+			res.on("data", (d: Buffer) => {
+				buffers.push(d);
+			});
+
+			res.on("end", () => {
+				try {
+					resolve(
+						JSON.parse(
+							Buffer.concat(buffers).toString()
+						) as GitHubApiResponse
+					);
+				} catch (e) {
+					reject(
+						new Error(
+							`Failed to parse GitHub API response: ${(e as Error).message}`
+						)
+					);
+				}
+			});
+		});
+
+		req.on("error", (error: Error) => {
+			console.log(error);
+			reject(error);
+		});
+
+		req.setTimeout(30000, () => {
+			req.destroy();
+			reject(new Error("GitHub API request timed out"));
+		});
+
+		req.write(JSON.stringify({ query }));
+		req.end();
+	});
+};
+
+export { makeGraphQLRequest };