Faça de cima para baixo. Não pule etapas.

const MAX_REDIRECTS = 6;

function required(env, key) {
  const value = env[key];
  if (!value) throw new Error(`Missing ${key}`);
  return value;
}

async function getTarget(env) {
  const apiBase = required(env, "FS_DNS_API_URL").replace(/\/$/, "");
  const slug = required(env, "HOST_SLUG");
  const response = await fetch(`${apiBase}/api/worker-state/${encodeURIComponent(slug)}`, {
    headers: { Accept: "application/json" },
    cf: { cacheTtl: 0, cacheEverything: false },
  });
  if (!response.ok) return null;
  const payload = await response.json();
  return payload?.ok && typeof payload.target === "string" && payload.target ? payload.target : null;
}

function upstreamUrl(requestUrl, target) {
  const incoming = new URL(requestUrl);
  const upstream = new URL(target);
  upstream.pathname = incoming.pathname;
  upstream.search = incoming.search;
  return upstream;
}

function isMedia(path) {
  return path.startsWith("/live/") || path.startsWith("/movie/") || path.startsWith("/series/");
}

async function resolveRedirects(url, headers) {
  let current = url;
  for (let i = 0; i < MAX_REDIRECTS; i++) {
    const response = await fetch(current, { method: "HEAD", headers, redirect: "manual" });
    if (response.status < 300 || response.status >= 400) return current;
    const location = response.headers.get("location");
    if (!location) return current;
    current = new URL(location, current).toString();
  }
  return current;
}

async function handle(request, env) {
  const incoming = new URL(request.url);
  const target = await getTarget(env);
  if (!target) return new Response("Host indisponível.", { status: 503 });
  const upstream = upstreamUrl(request.url, target);

  if (incoming.pathname === "/player_api.php") {
    return fetch(new Request(upstream.toString(), request), { redirect: "manual" });
  }
  if (incoming.pathname === "/get.php" || incoming.pathname === "/xmltv.php") {
    const destination = await resolveRedirects(upstream.toString(), request.headers);
    return Response.redirect(destination, 302);
  }
  if (isMedia(incoming.pathname)) return Response.redirect(upstream.toString(), 302);
  const destination = await resolveRedirects(upstream.toString(), request.headers);
  return Response.redirect(destination, 302);
}

export default {
  async fetch(request, env) {
    try { return await handle(request, env); }
    catch (error) {
      console.error("FS DNS Worker error", error instanceof Error ? error.message : error);
      return new Response("FS DNS indisponível.", { status: 503 });
    }
  },
};