Финальная архитектура — полный AI-стек бизнеса

┌─────────────────────────────────────────────────────────┐
│                    ПОЛЬЗОВАТЕЛЬ                          │
└────────────────────────┬────────────────────────────────┘
                         │
┌────────────────────────▼────────────────────────────────┐
│               FRONTEND (Слой 1)                         │
│  v0.app / Webflow / Next.js / Telegram Bot              │
│  Что здесь: UI, формы, дашборды, мобильная адаптация   │
└────────────────────────┬────────────────────────────────┘
                         │
┌────────────────────────▼────────────────────────────────┐
│               API GATEWAY (Слой 2)                      │
│  Cloudflare Workers / FastAPI / Express                 │
│  Что здесь: роутинг, auth, rate limiting, логирование   │
└─────────┬──────────────┬──────────────┬─────────────────┘
          │              │              │
┌─────────▼──────┐ ┌─────▼──────┐ ┌────▼──────────────────┐
│  AI (Слой 3)   │ │ DATA (С.4) │ │ PAYMENTS (Слой 5)     │
│  Claude API    │ │ Supabase   │ │ Stripe                │
│  Embeddings   │ │ PostgreSQL │ │ Subscriptions         │
│  Vector DB    │ │ Redis cache│ │ Webhooks              │
└────────────────┘ └────────────┘ └───────────────────────┘
          │
┌─────────▼────────────────────────────────────────────────┐
│           ИНТЕГРАЦИОННЫЙ СЛОЙ (Сквозной)                 │
│  n8n / Zapier — склейка всего со всем                   │
│  CRM → Marketing → Support → Analytics                  │
└──────────────────────────────────────────────────────────┘

// worker.js — базовая структура
export default {
  async fetch(request, env) {
    const url = new URL(request.url);
    
    // Роутинг
    if (url.pathname === '/api/generate') {
      return handleGenerate(request, env);
    }
    
    if (url.pathname === '/api/webhook/stripe') {
      return handleStripeWebhook(request, env);
    }
    
    return new Response('Not found', { status: 404 });
  }
};

async function handleGenerate(request, env) {
  // Auth check
  const apiKey = request.headers.get('X-API-Key');
  if (!await validateKey(apiKey, env)) {
    return new Response('Unauthorized', { status: 401 });
  }
  
  // Rate limiting через KV
  const count = await env.RATE_LIMITS.get(apiKey) || 0;
  if (count > 100) {  // 100 запросов в час
    return new Response('Rate limit exceeded', { status: 429 });
  }
  await env.RATE_LIMITS.put(apiKey, String(parseInt(count) + 1), {expirationTtl: 3600});
  
  // Claude вызов
  const body = await request.json();
  const result = await callClaude(body.prompt, env.ANTHROPIC_API_KEY);
  
  return Response.json({ result });
}

def route_to_model(task_type: str, complexity: str) -> str:
    """
    Оптимизация стоимости через правильную маршрутизацию.
    """
    # Цены за 1 млн токенов (вход / выход) на октябрь 2026; актуальные: ../actual.html
    routing = {
        ("classification", "simple"): "claude-haiku-4-5",      # $1 / $5
        ("summarization", "simple"): "claude-haiku-4-5",
        ("generation", "standard"): "claude-sonnet-5-5",        # $2 / $10
        ("generation", "complex"): "claude-sonnet-5-5",
        ("reasoning", "critical"): "claude-opus-5-5",           # $4 / $20
        ("architecture", "critical"): "claude-opus-5-5",
    }
    return routing.get((task_type, complexity), "claude-sonnet-5-5")

# Пример использования
model = route_to_model("classification", "simple")
# → claude-haiku-4-5 (самая лёгкая и дешёвая из линейки)

Supabase (PostgreSQL) — основное хранилище
├── users (аккаунты, настройки)
├── conversations (история чатов)  
├── documents (загруженные файлы)
└── analytics (события, метрики)

pgvector (векторное расширение Supabase) — семантический поиск
├── embeddings для RAG
└── поиск похожих документов

Redis (Upstash) — быстрый кэш
├── rate limiting
├── сессии
└── результаты частых запросов

Новый клиент в Stripe
        ↓ webhook
      n8n workflow:
        ├── Создать запись в Supabase
        ├── Отправить welcome email (Gmail/SendGrid)
        ├── Добавить в CRM (HubSpot/Notion)
        ├── Уведомление в Telegram (тебе)
        └── Запустить onboarding sequence

import os
import requests

def notify_teams_channel(webhook_url: str, message: str, facts: dict = None):
    """Отправить уведомление в канал Microsoft Teams через вебхук Workflows (Adaptive Card)."""
    body = [{"type": "TextBlock", "text": message, "weight": "Bolder", "wrap": True}]
    if facts:
        body.append({
            "type": "FactSet",
            "facts": [{"title": k, "value": v} for k, v in facts.items()]
        })

    payload = {
        "type": "message",
        "attachments": [{
            "contentType": "application/vnd.microsoft.card.adaptive",
            "content": {
                "$schema": "http://adaptivecards.io/schemas/adaptive-card.json",
                "type": "AdaptiveCard",
                "version": "1.2",
                "body": body
            }
        }]
    }

    response = requests.post(webhook_url, json=payload)
    return response.status_code in (200, 202)

# Пример: уведомление об AI-анализе завершён
notify_teams_channel(
    webhook_url=os.environ["TEAMS_WEBHOOK_URL"],
    message="✅ AI-анализ отчётности завершён",
    facts={"Документов обработано": "47", "Время": "3.2 мин", "Аномалий найдено": "2"}
)

import os
import anthropic
import requests
from msal import ConfidentialClientApplication

def get_sharepoint_documents(site_id: str, folder: str) -> list:
    """Получить документы из SharePoint через Graph API."""
    app = ConfidentialClientApplication(
        client_id=os.environ["AZURE_CLIENT_ID"],
        client_credential=os.environ["AZURE_CLIENT_SECRET"],
        authority=f"https://login.microsoftonline.com/{os.environ['AZURE_TENANT_ID']}"
    )
    
    token = app.acquire_token_for_client(
        scopes=["https://graph.microsoft.com/.default"]
    )
    
    headers = {"Authorization": f"Bearer {token['access_token']}"}
    
    # Получить файлы из папки
    url = f"https://graph.microsoft.com/v1.0/sites/{site_id}/drives/root:/{folder}:/children"
    response = requests.get(url, headers=headers)
    
    files = response.json().get("value", [])
    return [{"name": f["name"], "url": f["@microsoft.graph.downloadUrl"]} 
            for f in files if f.get("file")]

def answer_from_sharepoint(question: str, site_id: str) -> str:
    """Claude отвечает на вопрос используя документы SharePoint."""
    docs = get_sharepoint_documents(site_id, "Knowledge Base")
    
    # Загрузить содержимое документов
    context = ""
    for doc in docs[:5]:  # Топ-5 самых свежих
        content = requests.get(doc["url"]).text[:2000]
        context += f"\n---{doc['name']}---\n{content}"
    
    client = anthropic.Anthropic()
    return "".join(b.text for b in client.messages.create(
        model="claude-sonnet-5-5",
        max_tokens=1000,
        messages=[{
            "role": "user",
            "content": f"Документы компании:\n{context}\n\nВопрос: {question}"
        }]
    ).content if b.type == "text")