import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import { authorizeWith } from "../HttpClientUtils.ts";
import { makeHttpBucketBinding, type R2Auth } from "./BucketHttp.ts";
import { makeReadR2HttpClient } from "./ReadBucketHttp.ts";
import {
  ReadWriteBucket,
  type ReadWriteBucketClient,
} from "./ReadWriteBucket.ts";
import { makeWriteR2HttpClient } from "./WriteBucketHttp.ts";

/**
 * HTTP-backed implementation of the {@link ReadWriteBucket} binding.
 *
 * It creates a scoped {@link AccountApiToken} with the `Workers R2 Storage Read` and `Workers R2 Storage Write` permissions.
 */
export const ReadWriteBucketHttp = Layer.effect(
  ReadWriteBucket,
  Effect.suspend(() =>
    makeHttpBucketBinding({
      permissionGroups: ["Workers R2 Storage Read", "Workers R2 Storage Write"],
      makeClient: (token, bucketName, jurisdiction) =>
        makeReadWriteR2HttpClient(
          { authorize: authorizeWith(token), accountId: token.accountId },
          bucketName,
          jurisdiction,
        ),
    }),
  ),
);

/** Build the HTTP-backed {@link ReadWrite} over a bound token + bucket. */
export const makeReadWriteR2HttpClient = (
  auth: R2Auth,
  bucketName: Effect.Effect<string>,
  jurisdiction: Effect.Effect<string>,
): ReadWriteBucketClient =>
  ({
    ...makeReadR2HttpClient(auth, bucketName, jurisdiction),
    ...makeWriteR2HttpClient(auth, bucketName, jurisdiction),
  }) satisfies ReadWriteBucketClient;