import { createClient, type GenericCtx } from "@convex-dev/better-auth";
import { convex } from "@convex-dev/better-auth/plugins";
import { requireRunMutationCtx } from "@convex-dev/better-auth/utils";
import { checkout, polar, portal, webhooks } from "@polar-sh/better-auth";
import { Polar } from "@polar-sh/sdk";
import { components } from "./_generated/api";
import { internal } from "./_generated/api";
import { DataModel } from "./_generated/dataModel";
import { query } from "./_generated/server";
import { betterAuth } from "better-auth/minimal";
import { magicLink } from "better-auth/plugins";
import { Resend } from "resend";
import authConfig from "./auth.config";

const siteUrl = process.env.SITE_URL!;
const appUrl = process.env.APP_URL;

const lemonspaceAppOrigin = "https://app.lemonspace.io";

const polarClient = new Polar({
  accessToken: process.env.POLAR_ACCESS_TOKEN!,
  server: "production",
});

// Component Client — stellt Adapter, Helper und Auth-Methoden bereit
export const authComponent = createClient<DataModel>(components.betterAuth);

// Auth Factory — wird pro Request aufgerufen (Convex ist request-scoped)
export const createAuth = (ctx: GenericCtx<DataModel>) => {
  const authAppUrl = appUrl ?? siteUrl;
  const signInRedirectUrl = `${authAppUrl}/dashboard`;

  return betterAuth({
    baseURL: siteUrl,
    trustedOrigins: [siteUrl, lemonspaceAppOrigin, "http://localhost:3000"],
    database: authComponent.adapter(ctx),
    emailAndPassword: {
      enabled: true,
      requireEmailVerification: true,
      minPasswordLength: 8,
    },
    emailVerification: {
      sendOnSignUp: true,
      sendVerificationEmail: async ({ user, url }) => {
        const verificationUrl = new URL(url);

        if (appUrl) {
          verificationUrl.searchParams.set("callbackURL", `${appUrl}/dashboard`);
        }

        const apiKey = process.env.RESEND_API_KEY;
        if (!apiKey) {
          console.error("RESEND_API_KEY is not set — skipping verification email");
          return;
        }

        const resend = new Resend(apiKey);
        const { error } = await resend.emails.send({
          from: "LemonSpace <noreply@lemonspace.io>",
          to: user.email,
          subject: "Bestätige deine E-Mail-Adresse",
          html: `
            <div style="font-family: sans-serif; max-width: 480px; margin: 0 auto;">
              <h2>Willkommen bei LemonSpace 🍋</h2>
              <p>Hi ${user.name || ""},</p>
              <p>Klicke auf den Button, um deine E-Mail-Adresse zu bestätigen:</p>
              <a href="${verificationUrl.toString()}"
                 style="display: inline-block; background: #facc15; color: #1a1a1a; padding: 12px 24px; border-radius: 8px; text-decoration: none; font-weight: 600; margin: 16px 0;">
                E-Mail bestätigen
              </a>
              <p style="color: #666; font-size: 13px;">
                Falls der Button nicht funktioniert, kopiere diesen Link:<br/>
                <a href="${verificationUrl.toString()}">${verificationUrl.toString()}</a>
              </p>
            </div>
          `,
        });

        if (error) {
          console.error("Failed to send verification email:", error);
        }
      },
    },
    plugins: [
      magicLink({
        disableSignUp: true,
        expiresIn: 60 * 10, // 10 Minuten
        sendMagicLink: async ({ email, url }) => {
          const apiKey = process.env.RESEND_API_KEY;
          if (!apiKey) {
            console.error("RESEND_API_KEY is not set — skipping magic link email");
            return;
          }

          const magicLinkUrl = new URL(url);
          magicLinkUrl.searchParams.set("callbackURL", signInRedirectUrl);
          magicLinkUrl.searchParams.set("errorCallbackURL", `${authAppUrl}/auth/sign-in`);

          const resend = new Resend(apiKey);
          const { error } = await resend.emails.send({
            from: "LemonSpace <noreply@lemonspace.io>",
            to: email,
            subject: "Dein LemonSpace Magic Link",
            html: `
              <div style="font-family: sans-serif; max-width: 480px; margin: 0 auto;">
                <h2>Dein Login-Link für LemonSpace 🍋</h2>
                <p>Klicke auf den Button, um dich anzumelden:</p>
                <a href="${magicLinkUrl.toString()}"
                   style="display: inline-block; background: #facc15; color: #1a1a1a; padding: 12px 24px; border-radius: 8px; text-decoration: none; font-weight: 600; margin: 16px 0;">
                  Jetzt anmelden
                </a>
                <p style="color: #666; font-size: 13px;">
                  Der Link ist 10 Minuten gültig. Falls der Button nicht funktioniert, kopiere diesen Link:<br/>
                  <a href="${magicLinkUrl.toString()}">${magicLinkUrl.toString()}</a>
                </p>
              </div>
            `,
          });

          if (error) {
            console.error("Failed to send magic link email:", error);
          }
        },
      }),
      convex({ authConfig }),
      polar({
        client: polarClient,
        createCustomerOnSignUp: true,
        use: [
          checkout({
            successUrl: `${siteUrl}/dashboard?checkout=success`,
            authenticatedUsersOnly: true,
          }),
          portal(),
          webhooks({
            secret: process.env.POLAR_WEBHOOK_SECRET!,
            onCustomerStateChanged: async (payload) => {
              const runMutationCtx = requireRunMutationCtx(ctx);
              const customerState = payload.data;
              const userId = customerState.externalId;

              if (!userId) {
                console.error("Polar customer.state_changed payload without externalId", {
                  customerId: customerState.id,
                });
                return;
              }

              const subscription = customerState.activeSubscriptions?.[0];

              if (!subscription) {
                await runMutationCtx.runMutation(internal.polar.handleSubscriptionRevoked, {
                  userId,
                });
                return;
              }

              const tierMetadata = subscription.metadata.tier;
              const creditsMetadata = subscription.metadata.credits;
              const tier = tierMetadata === "starter" || tierMetadata === "pro" || tierMetadata === "max"
                ? tierMetadata
                : undefined;
              const monthlyCredits = Number(creditsMetadata);

              if (!tier || !Number.isFinite(monthlyCredits) || monthlyCredits <= 0) {
                console.error("Missing or invalid Polar subscription metadata", {
                  subscriptionId: subscription.id,
                  tier: tierMetadata,
                  credits: creditsMetadata,
                });
                return;
              }

              await runMutationCtx.runMutation(internal.polar.handleSubscriptionActivated, {
                userId,
                tier,
                polarSubscriptionId: subscription.id,
                currentPeriodStart: subscription.currentPeriodStart.getTime(),
                currentPeriodEnd: subscription.currentPeriodEnd.getTime(),
                monthlyCredits,
              });
            },
            onOrderPaid: async (payload) => {
              const runMutationCtx = requireRunMutationCtx(ctx);
              const order = payload.data;
              const metadata = order.product?.metadata;
              const type = metadata?.type;
              const credits = Number(metadata?.credits);

              if (type !== "topup" || !Number.isFinite(credits) || credits <= 0) {
                return;
              }

              const userId = order.customer.externalId;
              if (!userId) {
                console.error("Polar order.paid payload without externalId", {
                  orderId: order.id,
                });
                return;
              }

              await runMutationCtx.runMutation(internal.polar.handleTopUpPaid, {
                userId,
                credits,
                polarOrderId: order.id,
                amountPaidEuroCents: order.totalAmount,
              });
            },
          }),
        ],
      }),
    ],
  });
};

// Helper Query: Aktuellen User abrufen (nutzbar in Frontend via useQuery)
export const getCurrentUser = query({
  args: {},
  handler: async (ctx) => {
    return authComponent.getAuthUser(ctx);
  },
});

export const safeGetAuthUser = query({
  args: {},
  handler: async (ctx) => {
    try {
      return await authComponent.getAuthUser(ctx);
    } catch {
      return null;
    }
  },
});