import {
  createCorsResponse,
  createSuccessResponse,
  errorToResponse,
  validationError,
} from "jsr:@supa-edge-toolkit/errors";

Deno.serve(async (req) => {
  if (req.method === "OPTIONS") return createCorsResponse();

  try {
    const body = await req.json();
    if (!body.email) {
      return validationError("Missing required fields", { email: "Required" });
    }
    return createSuccessResponse({ id: "123", email: body.email });
  } catch (error) {
    return errorToResponse(error);
  }
});

import { AuthError, verifyUserToken } from "jsr:@supa-edge-toolkit/auth";

Deno.serve(async (req) => {
  try {
    const { userId, role } = await verifyUserToken(req);
    return new Response(JSON.stringify({ userId, role }));
  } catch (error) {
    if (error instanceof AuthError) {
      return new Response(error.message, { status: error.statusCode });
    }
    throw error;
  }
});

import { z } from "npm:zod";
import { parseRequestBody } from "jsr:@supa-edge-toolkit/validation";

Deno.serve(async (req) => {
  const schema = z.object({
    email: z.string().email(),
    name: z.string().min(1),
  });

  const body = await parseRequestBody(req, schema);
  // body is typed as { email: string; name: string }
});

import { resilientFetch } from "jsr:@supa-edge-toolkit/resilience";

// Fetch with timeout (5s), retry (3 attempts), and circuit breaker
const response = await resilientFetch("https://api.example.com/data", {
  timeout: { timeoutMs: 5000 },
  retry: { maxAttempts: 3 },
  circuitBreaker: { failureThreshold: 5 },
});

import { createLogger } from "jsr:@supa-edge-toolkit/logger";

const logger = createLogger("my-function");
logger.info("Processing request", { userId: "123", action: "create" });
// => {"timestamp":"...","level":"INFO","function":"my-function","message":"Processing request","userId":"123","action":"create"}

import {
  assertFetchCount,
  createTestContext,
} from "jsr:@supa-edge-toolkit/testing";

Deno.test("my edge function", async () => {
  const ctx = createTestContext({
    dbSeed: { users: [{ id: "u1", name: "Alice" }] },
  });

  try {
    // globalThis.fetch is mocked — Supabase client works against in-memory DB
    const res = await fetch("http://localhost:54321/rest/v1/users?id=eq.u1");
    const data = await res.json();

    assertEquals(data[0].name, "Alice");
    assertFetchCount(ctx.fetchLog, "/rest/v1/users", 1);
  } finally {
    ctx.cleanup();
  }
});

import {
  compilePrompt,
  getLangfusePrompt,
} from "jsr:@supa-edge-toolkit/langfuse";

const config = {
  host: Deno.env.get("LANGFUSE_URL")!,
  publicKey: Deno.env.get("LANGFUSE_PUBLIC_KEY")!,
  secretKey: Deno.env.get("LANGFUSE_SECRET_KEY")!,
};

const promptData = await getLangfusePrompt("my-prompt", config);
const messages = compilePrompt(promptData, { name: "Alice" });