http-client.ts

import fetch_, { RequestInfo, RequestInit, Response } from "node-fetch";
import * as T from "@effect-ts/core/Effect"
import { Tagged } from "@effect-ts/core/Case";

export class HttpError extends Tagged("http-error")<{
    readonly error: unknown;
}> { }

export const fetch = (url: RequestInfo, opts?: Omit<RequestInit, "signal">) =>
    T.effectAsyncInterrupt<unknown, HttpError, Response>((cb) => {
        const { signal, abort } = new AbortController();

        fetch_(url, { ...opts, signal }).then(
            (response) => cb(T.succeed(response)),
            (error) => cb(T.fail(HttpError.make({ error })))
        );

        return T.succeedWith(() => {
            abort();
        });
    });

export class JsonError extends Tagged("json-error")<{
    readonly error: unknown;
}> { }

export const json = (resp: Response) =>
    T.tryCatchPromise(
        () => resp.json(),
        (error) => JsonError.make({ error })
    );