import { NextResponse } from 'next/server';
import { db } from '@/lib/db/drizzle';
import { twilioConfigs, teams } from '@/lib/db/schema';
import { eq } from 'drizzle-orm';
import { getUser, getUserWithTeam } from '@/lib/db/queries';
import { enforceFeature } from '@/lib/limits';
import { getGatewayById } from '@/lib/payments';
import { checkRateLimit, getClientIp, RATE_LIMITS } from '@/lib/rate-limit';

export async function POST(request: Request) {
  try {
    const limited = checkRateLimit(`purchase:${getClientIp(request)}`, RATE_LIMITS.purchase);
    if (limited) return limited;

    const user = await getUser();
    if (!user) {
      return NextResponse.json({ error: 'Not authenticated' }, { status: 401 });
    }

    const userWithTeam = await getUserWithTeam(user.id);
    if (!userWithTeam?.teamId) {
      return NextResponse.json({ error: 'No team found' }, { status: 403 });
    }

    const teamId = userWithTeam.teamId;
    await enforceFeature(teamId, 'isVoiceCallsEnabled');

    const body = await request.json();
    const { phoneNumber } = body;

    if (!phoneNumber || typeof phoneNumber !== 'string') {
      return NextResponse.json({ error: 'phoneNumber is required' }, { status: 400 });
    }

    const config = await db.query.twilioConfigs.findFirst({
      where: eq(twilioConfigs.isActive, true),
    });

    if (!config) {
      return NextResponse.json({ error: 'Voice calling is not configured.' }, { status: 400 });
    }

    if (!config.paymentGatewayId) {
      return NextResponse.json({ error: 'No payment gateway configured for voice calls.' }, { status: 400 });
    }

    const currency = config.currency || 'usd';
    const baseUrl = process.env.BASE_URL || 'http://localhost:3000';
    const team = await db.query.teams.findFirst({ where: eq(teams.id, teamId) });
    const adapter = await getGatewayById(config.paymentGatewayId);

    const result = await adapter.createCheckout({
      planId: 0,
      planName: `Phone Number: ${phoneNumber}`,
      amount: config.pricePerNumber,
      currency,
      interval: 'month',
      teamId,
      userId: user.id,
      successUrl: `${baseUrl}/settings/voice?purchased=true`,
      cancelUrl: `${baseUrl}/settings/voice?canceled=true`,
      existingCustomerId: adapter.type === 'stripe' ? (team?.stripeCustomerId || undefined) : undefined,
    });

    return NextResponse.json({ url: result.url });
  } catch (error: any) {
    console.error('[Number Purchase]', error.message, error);
    if (error.message?.includes('does not allow access')) {
      return NextResponse.json({ error: 'Feature not available on your plan' }, { status: 403 });
    }
    return NextResponse.json({ error: 'Internal server error' }, { status: 500 });
  }
}