Multi-Tenant SaaS: Dynamic Subdomain Routing, Custom Domains, and Edge Middleware

Входящий HTTP-запрос:
  Host: portal.acme-corp.com
  Path: /dashboard/analytics
           │
           ▼
┌────────────────────────────────────────────────────────┐
│ Edge Proxy Layer (proxy.ts / пограничный роутер)       │
│ 1. Извлечение Host: portal.acme-corp.com              │
│ 2. Резолв в Tenant ID: tenant_984f2                    │
│ 3. Внутренний Rewrite: /[domain]/dashboard/analytics   │
│ 4. Инъекция заголовка: x-tenant-id: tenant_984f2       │
└────────────────────────────────────────────────────────┘
           │
           ▼
Внутренний роутер Next.js 16 (App Router):
  app/[domain]/dashboard/analytics/page.tsx
           │
           ▼
Data Access Layer (DAL) & Cache:
  - Cache Tag: `tenant:tenant_984f2`
  - Database: WHERE tenant_id = 'tenant_984f2' (RLS)

Схема маршрутизации доменов
                                
  Пользователь А                        Пользователь Б                      Пользователь В
(acme.platform.io)                  (custom-corp.com)                     (platform.io/login)
        │                                   │                                      │
        └─────────────────────────┬─────────┴──────────────────────────────────────┘
                                  ▼
                    ┌───────────────────────────┐
                    │  Пограничный шлюз         │
                    │  (Edge Proxy / proxy.ts)  │
                    └─────────────┬─────────────┘
                                  │
         ┌────────────────────────┼────────────────────────┐
         │ Rewrite                │ Rewrite                │ Pass-through
         ▼                        ▼                        ▼
┌──────────────────┐    ┌──────────────────┐    ┌──────────────────┐
│ app/[domain]/... │    │ app/[domain]/... │    │ app/(main)/...   │
│ domain = "acme"  │    │ domain = "custom"│    │ Корневой сайт    │
└──────────────────┘    └──────────────────┘    └──────────────────┘

import { NextRequest, NextResponse } from 'next/server';

// Регулярное выражение для исключения статических ресурсов и внутренних API
const PUBLIC_FILE = /\.(.*)$/;

// Базовый домен платформы из переменных окружения
const ROOT_DOMAIN = process.env.NEXT_PUBLIC_ROOT_DOMAIN || 'platform.io';

export async function proxy(req: NextRequest) {
  const url = req.nextUrl;
  const hostname = req.headers.get('host') || ROOT_DOMAIN;

  // Очистка имени хоста от порта (актуально для локальной разработки localhost:3000)
  const currentHost = hostname.replace(/:\d+$/, '').toLowerCase();

  // Игнорируем внутренние пути Next.js, API вебхуков и статические файлы
  if (
    url.pathname.startsWith('/_next') ||
    url.pathname.startsWith('/api/webhooks') ||
    PUBLIC_FILE.test(url.pathname)
  ) {
    return NextResponse.next();
  }

  // 1. Сценарий: Локальная разработка или корневой домен платформы
  if (currentHost === ROOT_DOMAIN || currentHost === 'localhost') {
    // URL вида platform.io/pricing -> рендерится из app/(marketing)/...
    return NextResponse.rewrite(new URL(`/marketing${url.pathname}`, req.url));
  }

  // 2. Сценарий: Системный поддомен (например, acme.platform.io)
  let detectedTenantDomain: string;

  if (currentHost.endsWith(`.${ROOT_DOMAIN}`)) {
    const subdomain = currentHost.replace(`.${ROOT_DOMAIN}`, '');
    detectedTenantDomain = subdomain;
  } else {
    // 3. Сценарий: Кастомный домен клиента (например, portal.customer.com)
    detectedTenantDomain = currentHost;
  }

  // Перезаписываем внутренний путь на app/[domain]/...
  // Браузер видит исходный URL, Next.js направляет запрос в сегмент [domain]
  const rewriteUrl = new URL(`/${detectedTenantDomain}${url.pathname}${url.search}`, req.url);

  // Создаем ответ с перезаписью и пробрасываем служебный заголовок x-tenant-host
  const response = NextResponse.rewrite(rewriteUrl);
  response.headers.set('x-tenant-host', detectedTenantDomain);

  return response;
}

export const config = {
  matcher: [
    /*
     * Применяем прокси ко всем маршрутам, кроме служебных путей
     */
    '/((?!api/health|_next/static|_next/image|favicon.ico).*)',
  ],
};

app/
├── (marketing)/                # Публичный сайт платформы (platform.io)
│   ├── page.tsx                # Главная страница платформы
│   └── pricing/
│       └── page.tsx
├── [domain]/                   # Виртуализированное пространство тенантов
│   ├── layout.tsx              # Мультитенантный макет (темы, навигация арендатора)
│   ├── page.tsx                # Домашняя страница тенанта
│   ├── settings/
│   │   └── page.tsx
│   └── api/
│       └── data/
│           └── route.ts
└── api/
    └── domains/
        └── verify/             # Проверка владения доменом (DNS verification)
            └── route.ts

import { notFound } from 'next/navigation';
import { getTenantByDomain } from '@/lib/dal/tenant';
import { TenantProvider } from '@/components/tenant-provider';

interface TenantLayoutProps {
  children: React.ReactNode;
  params: Promise<{ domain: string }>;
}

export async function generateMetadata(props: TenantLayoutProps) {
  const { domain } = await props.params;
  const tenant = await getTenantByDomain(domain);

  if (!tenant) {
    return { title: 'Tenant Not Found' };
  }

  return {
    title: `${tenant.name} | Портал управления`,
    description: tenant.description,
    icons: [{ rel: 'icon', url: tenant.faviconUrl || '/default-favicon.ico' }],
  };
}

export default async function TenantLayout(props: TenantLayoutProps) {
  const { domain } = await props.params;
  const tenant = await getTenantByDomain(domain);

  // Если домен не привязан ни к одному арендатору, возвращаем 404
  if (!tenant) {
    notFound();
  }

  return (
    <div 
      className="min-h-screen flex flex-col"
      style={{
        // Динамическая инъекция корпоративных цветов арендатора
        ['--primary-color' as string]: tenant.theme.primaryColor,
        ['--font-family' as string]: tenant.theme.fontFamily,
      }}
    >
      <header className="border-b border-border px-6 py-4 flex items-center justify-between">
        <div className="flex items-center gap-3">
          <img 
            src={tenant.logoUrl} 
            alt={tenant.name} 
            className="h-8 w-auto object-contain"
          />
          <span className="font-semibold text-lg text-text-primary">{tenant.name}</span>
        </div>
        <div className="text-xs text-text-muted font-mono">
          Tenant ID: {tenant.id}
        </div>
      </header>

      <main className="flex-1 p-6">
        <TenantProvider tenantId={tenant.id} domain={domain}>
          {props.children}
        </TenantProvider>
      </main>
    </div>
  );
}

import { unstable_cacheTag as cacheTag, unstable_cacheLife as cacheLife } from 'next/cache';
import { db } from '@/lib/db';

export interface AnalyticsSummary {
  activeUsers: number;
  monthlyRevenue: number;
  churnRate: number;
}

/**
 * Извлечение аналитических метрик с жесткой изоляцией кэша
 */
export async function getTenantAnalytics(tenantId: string): Promise<AnalyticsSummary> {
  'use cache';
  // Устанавливаем профиль жизненного цикла кэша
  cacheLife('hours');
  
  // КРИТИЧЕСКИ ВАЖНО: Тегируем кэш уникальным идентификатором арендатора.
  // Это исключает вероятность того, что Tenant B получит в ответе кэш Tenant A.
  cacheTag(`tenant:${tenantId}`, `tenant:${tenantId}:analytics`);

  // Запрос в базу данных с обязательным предикатом по tenant_id
  const metrics = await db.analytics.aggregate({
    where: {
      tenantId: tenantId,
      timestamp: {
        gte: new Date(Date.now() - 30 * 24 * 60 * 60 * 1000), // последние 30 дней
      },
    },
    _sum: { revenue: true },
    _count: { userId: true },
  });

  return {
    activeUsers: metrics._count.userId,
    monthlyRevenue: metrics._sum.revenue || 0,
    churnRate: 1.2,
  };
}

import { revalidateTag } from 'next/cache';
import { NextRequest, NextResponse } from 'next/server';
import { verifySystemAdminAuth } from '@/lib/auth/admin';

export async function POST(
  req: NextRequest,
  { params }: { params: Promise<{ tenantId: string }> }
) {
  const { tenantId } = await params;

  // Авторизация сервисного вызова
  const isAuthorized = await verifySystemAdminAuth(req);
  if (!isAuthorized) {
    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
  }

  // Инвалидируем кэш строго в рамках одного тенанта
  revalidateTag(`tenant:${tenantId}`, 'hard');

  return NextResponse.json({
    status: 'success',
    revalidatedTenant: tenantId,
    timestamp: Date.now(),
  });
}