55 lines
1.4 KiB
TypeScript
55 lines
1.4 KiB
TypeScript
import { base64Decode, base64Encode } from "../../plug-api/lib/crypto.ts";
|
|
|
|
export type ProxyFetchRequest64 = {
|
|
method?: string;
|
|
headers?: Record<string, string>;
|
|
base64Body?: string;
|
|
};
|
|
|
|
export type ProxyFetchResponse64 = {
|
|
ok: boolean;
|
|
status: number;
|
|
headers: Record<string, string>;
|
|
// We base64 encode the body because the body can be binary data that we have to push through the worker boundary
|
|
base64Body: string;
|
|
};
|
|
|
|
export type ProxyFetchRequest = {
|
|
method?: string;
|
|
headers?: Record<string, string>;
|
|
responseEncoding?: string;
|
|
body?: Uint8Array | string | any;
|
|
};
|
|
|
|
export type ProxyFetchResponse = {
|
|
ok: boolean;
|
|
status: number;
|
|
headers: Record<string, string>;
|
|
// We base64 encode the body because the body can be binary data that we have to push through the worker boundary
|
|
body: Uint8Array | string | any;
|
|
};
|
|
|
|
export async function performLocalFetch(
|
|
url: string,
|
|
req: ProxyFetchRequest64,
|
|
): Promise<ProxyFetchResponse64> {
|
|
const result = await fetch(
|
|
url,
|
|
req &&
|
|
({
|
|
method: req.method,
|
|
headers: req.headers,
|
|
body: req.base64Body && base64Decode(req.base64Body),
|
|
// Casting to any due to TypeScript fetch type limitations
|
|
} as any),
|
|
);
|
|
return {
|
|
ok: result.ok,
|
|
status: result.status,
|
|
headers: Object.fromEntries(result.headers.entries()),
|
|
base64Body: base64Encode(
|
|
new Uint8Array(await (await result.blob()).arrayBuffer()),
|
|
),
|
|
};
|
|
}
|