import { NextRequest, NextResponse } from "next/server"
import { IS_PROD } from "~/lib/constants"
import { DISCORD_LINK, IPFS_GATEWAY } from "~/lib/env"

export default async function middleware(req: NextRequest) {
  const { pathname } = req.nextUrl

  if (IS_PROD && req.headers.get("x-forwarded-proto") !== "https") {
    let cfHttps = false
    try {
      if (
        JSON.parse(req.headers.get("cf-visitor") || "{}").scheme === "https"
      ) {
        cfHttps = true
      }
    } catch (error) {}
    if (!cfHttps) {
      return NextResponse.redirect(
        `https://${req.headers.get("host")}${req.nextUrl.pathname}${
          req.nextUrl.search
        }`,
        301,
      )
    }
  }

  if (pathname === "/feed.xml" || pathname === "/atom.xml") {
    return NextResponse.redirect(
      `https://${req.headers.get("host")}/feed/xml`,
      301,
    )
  }

  console.log(`${req.method} ${req.nextUrl.pathname}${req.nextUrl.search}`)

  if (
    pathname.startsWith("/api/") ||
    pathname.startsWith("/dashboard") ||
    pathname.startsWith("/_next/") ||
    pathname.startsWith("/assets/") ||
    pathname.match(/^\/(workbox|worker|fallback)-\w+\.js(\.map)?$/) ||
    pathname === "/sw.js" ||
    pathname === "/sw.js.map"
  ) {
    return NextResponse.next()
  }

  let tenant: {
    subdomain?: string
    redirect?: string
  } = {}
  try {
    tenant = await (
      await fetch(
        new URL(`/api/host2handle?host=${req.headers.get("host")}`, req.url),
      )
    ).json()
  } catch (error) {}

  if (tenant?.redirect && IS_PROD && !pathname.startsWith("/feed")) {
    return NextResponse.redirect(
      `${tenant.redirect}${req.nextUrl.pathname}${req.nextUrl.search}`,
    )
  }

  if (tenant?.subdomain) {
    const url = req.nextUrl.clone()
    url.pathname = `/_site/${tenant?.subdomain}${url.pathname}`
    return NextResponse.rewrite(url)
  }

  if (DISCORD_LINK && pathname === "/discord") {
    return NextResponse.redirect(DISCORD_LINK)
  }

  return NextResponse.next()
}