init

src/api/httpClientAdapter.server.ts

@@ -1,70 +1,19 @@
-import { TinyRpcClientAdapter, TinyRpcError } from "@hiogawa/tiny-rpc";
-import { Result } from "@hiogawa/utils";
 import { tryGetContext } from "hono/context-storage";
 
-const GET_PAYLOAD_PARAM = "payload";
-
-export function httpClientAdapter(opts: {
-	url: string;
-	pathsForGET?: string[];
-	headers?: () => Promise<Record<string, string>> | Record<string, string>;
-}): TinyRpcClientAdapter {
-	return {
-		send: async (data) => {
-			const url = [opts.url, data.path].join("/");
-			const payload = JSON.stringify(data.args);
-			const method = opts.pathsForGET?.includes(data.path)
-				? "GET"
-				: "POST";
-			let req: Request;
-			if (method === "GET") {
-				req = new Request(
-					url +
-					"?" +
-					new URLSearchParams({ [GET_PAYLOAD_PARAM]: payload })
-				);
-			} else {
-				req = new Request(url, {
-					method: "POST",
-					body: payload,
-					headers: {
-						"content-type": "application/json; charset=utf-8",
-					},
-					credentials: "include",
-				});
-			}
-			let res: Response;
-			if (import.meta.env.SSR) {
-				const c = tryGetContext<any>();
-				if (!c) {
-					throw new Error("Hono context not found in SSR");
-				}
-				Object.entries(c.req.header()).forEach(([k, v]) => {
-					req.headers.append(k, v);
-				});
-				res = await c.get("fetch")(req);
-			} else {
-				res = await fetch(req);
-			}
-			if (!res.ok) {
-				// throw new Error(`HTTP error: ${res.status}`);
-				throw new Error(
-					JSON.stringify({
-						status: res.status,
-						statusText: res.statusText,
-						data: { message: await res.text() },
-						internal: true,
-					})
-				);
-				// throw TinyRpcError.deserialize(res.status);
-			}
-			const result: Result<unknown, unknown> = JSON.parse(
-				await res.text()
-			);
-			if (!result.ok) {
-				throw TinyRpcError.deserialize(result.value);
-			}
-			return result.value;
-		},
-	};
+export const customFetch = async (url: string, options: RequestInit) => {
+	options.credentials = "include";
+	if (!options.headers) {
+		options.headers = {};
+	}
+	if (import.meta.env.SSR) {
+		const c = tryGetContext<any>();
+		if (!c) {
+			throw new Error("Hono context not found in SSR");
+		}
+		Object.entries(c.req.header()).forEach(([k, v]) => {
+			Object.assign(options.headers!, { [k]: v });
+		});
+		return await c.get("fetch")(url, options);
+	}
+	return fetch(url, options);
 }