Декомпозиция монолита: Strangler Fig паттерн и генерация адаптеров

[HTTP Клиенты / Пользователи]
                                              │
                                              ▼
                    [Edge Routing Facade (Next.js Middleware / Envoy)]
                                      │               │
                     (Canary / Path)  │               │ (Legacy Fallback)
                                      ▼               ▼
                        [New Headless App]     [Legacy Monolith (PHP)]
                        (Next.js 15 / RSC)             │
                                │                      │
                                ▼                      │
                    [Anti-Corruption Layer (ACL)] ◄────┘
                    (AI-Generated Data Adapters)
                                │
                                ▼
                       [Unified Data Store]
                     (Outbox / CDC Synchronizer)

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

// Конфигурация маршрутизации Strangler Fig
const LEGACY_BACKEND_URL = process.env.LEGACY_BACKEND_URL || 'https://legacy-monolith.internal';
const MIGRATED_PREFIXES = ['/products', '/catalog', '/api/v2/products'];

export async function middleware(request: NextRequest) {
  const { pathname, search } = request.nextUrl;

  // Проверка: мигрирован ли маршрут на новый Headless стек
  const isMigratedRoute = MIGRATED_PREFIXES.some((prefix) =>
    pathname.startsWith(prefix)
  );

  // Канареечный релиз: процент пользователей, видящих новый сервис
  const canaryCookie = request.cookies.get('canary_opt_in')?.value;
  const isCanaryUser = canaryCookie === 'true' || Math.random() < 0.1; // 10% канарейка

  if (isMigratedRoute && isCanaryUser) {
    // Обслуживание через новый Next.js App Router (локальная обработка)
    const response = NextResponse.next();
    response.headers.set('x-served-by', 'nextjs-headless-strangler');
    return response;
  }

  // Проксирование на legacy PHP-монолит
  const targetUrl = new URL(`${pathname}${search}`, LEGACY_BACKEND_URL);
  
  // Копирование заголовков для сохранения сессий монолита
  const forwardHeaders = new Headers(request.headers);
  forwardHeaders.set('x-forwarded-host', request.headers.get('host') || '');
  forwardHeaders.set('x-strangler-proxy', 'true');

  return NextResponse.rewrite(targetUrl, {
    request: {
      headers: forwardHeaders,
    },
  });
}

export const config = {
  matcher: [
    /*
     * Исключение статических файлов сборки Next.js из проксирования
     */
    '/((?!_next/static|_next/image|favicon.ico).*)',
  ],
};

import { z } from 'zod';

// 1. Схема «грязных» данных монолита (Legacy WordPress Post + Meta)
export const LegacyPostPayloadSchema = z.object({
  ID: z.union([z.string(), z.number()]).transform((val) => String(val)),
  post_title: z.string(),
  post_name: z.string(),
  post_status: z.string(),
  meta: z.record(z.string(), z.unknown()).default({}),
});

export type LegacyPostPayload = z.infer<typeof LegacyPostPayloadSchema>;

// 2. Чистая доменная модель товара (Clean Architecture Domain Entity)
export const DomainProductSchema = z.object({
  id: z.string().uuid().or(z.string().min(1)),
  sku: z.string(),
  title: z.string().min(1),
  slug: z.string(),
  priceCents: z.number().int().nonnegative(),
  isAvailable: z.boolean(),
  tags: z.array(z.string()),
});

export type DomainProduct = z.infer<typeof DomainProductSchema>;

/**
 * Anti-Corruption Layer: безопасная конвертация устаревших метаданных
 * в чистую доменную сущность с защитой от поврежденных данных.
 */
export function adaptLegacyProductToDomain(rawLegacyData: unknown): DomainProduct {
  const legacy = LegacyPostPayloadSchema.parse(rawLegacyData);

  // Извлечение EAV метаполей с проверкой типов
  const rawSku = legacy.meta['_sku'];
  const rawPrice = legacy.meta['_regular_price'];
  const stockStatus = legacy.meta['_stock_status'];

  const sku = typeof rawSku === 'string' && rawSku.trim().length > 0 
    ? rawSku.trim() 
    : `LEGACY-${legacy.ID}`;

  // Преобразование цены: float-строка "199.90" переводится в целые центы (19990)
  const parsedPrice = typeof rawPrice === 'string' ? parseFloat(rawPrice) : 0.0;
  const priceCents = Number.isFinite(parsedPrice) ? Math.round(parsedPrice * 100) : 0;

  const isAvailable = legacy.post_status === 'publish' && stockStatus === 'instock';

  // Формирование чистой сущности
  return DomainProductSchema.parse({
    id: legacy.ID,
    sku,
    title: legacy.post_title,
    slug: legacy.post_name,
    priceCents,
    isAvailable,
    tags: Array.isArray(legacy.meta['_custom_tags']) ? legacy.meta['_custom_tags'] : [],
  });
}

import { generateObject } from 'ai';
import { openai } from '@ai-sdk/openai';
import { z } from 'zod';

const AdapterGeneratorSchema = z.object({
  adapterName: z.string(),
  legacySchemaCode: z.string().describe('Zod-схема для парсинга входных legacy-данных'),
  domainSchemaCode: z.string().describe('Zod-схема для новой доменной сущности'),
  transformFunctionCode: z.string().describe('Функция трансляции с санитизацией EAV-полей'),
  unitTestCode: z.string().describe('Полный набор Vitest тестов с краевыми случаями'),
});

export async function generateAclAdapter(
  legacySqlSchema: string,
  targetDomainRequirements: string
) {
  const prompt = `
    Ты — Principal Software Architect. Спроектируй Anti-Corruption Layer (ACL) адаптер на TypeScript.
    
    Входные структуры монолита (SQL / JSON):
    ${legacySqlSchema}

    Требования к новому доменному интерфейсу:
    ${targetDomainRequirements}

    ПРАВИЛА:
    1. Не допускай просачивания legacy-полей (например, post_author, guid, post_mime_type) в домен.
    2. Цены всегда нормализуй в целые числа (копейки/центы).
    3. Обрабатывай отсутствующие или некорректные типы через fallback-значения.
    4. Генерируй строгий код TypeScript без использования 'any'.
  `;

  const { object } = await generateObject({
    model: openai('gpt-4o', { structuredOutputs: true }),
    schema: AdapterGeneratorSchema,
    prompt,
  });

  return object;
}