import {
  type CompleteLinkedIdentityProviderIntentRequest,
  type CompleteLinkedIdentityProviderIntentResponse,
  CompleteLinkedIdentityProviderIntentResponseSchema,
  type CreateLinkedIdentityProviderIntentRequest,
  type CreateLinkedIdentityProviderIntentResponse,
  CreateLinkedIdentityProviderIntentResponseSchema,
  LINKED_IDP_AUTH_COMPLETE_ENDPOINT,
  LINKED_IDP_AUTH_INTENT_ENDPOINT,
} from "@archestra/shared";

export async function createLinkedIdentityProviderIntent(
  params: CreateLinkedIdentityProviderIntentRequest,
): Promise<CreateLinkedIdentityProviderIntentResponse> {
  const response = await fetch(LINKED_IDP_AUTH_INTENT_ENDPOINT, {
    method: "POST",
    credentials: "include",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify(params),
  });

  if (!response.ok) {
    throw new Error("Failed to create identity provider link request");
  }

  return CreateLinkedIdentityProviderIntentResponseSchema.parse(
    await response.json(),
  );
}

export async function completeLinkedIdentityProviderIntent(
  intentId: string,
): Promise<CompleteLinkedIdentityProviderIntentResponse> {
  const body = {
    intentId,
  } satisfies CompleteLinkedIdentityProviderIntentRequest;

  const response = await fetch(LINKED_IDP_AUTH_COMPLETE_ENDPOINT, {
    method: "POST",
    credentials: "include",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify(body),
  });

  if (!response.ok) {
    throw new Error("Failed to complete identity provider link request");
  }

  return CompleteLinkedIdentityProviderIntentResponseSchema.parse(
    await response.json(),
  );
}
