IO v7. Middleware и работа с ними

<?php
namespace IO;

interface Middleware
{
    /**
     * Обработка запроса до выполнения роута
     * 
     * @param App $app Экземпляр приложения
     * @param Route $route Экземпляр роута
     * @param array $params Параметры middleware
     * @return mixed|null Если возвращает не null, выполнение прерывается
     */
    public function handle($app, $route, $params = []);

    /**
     * Обработка после выполнения роута (опционально)
     * 
     * @param App $app Экземпляр приложения
     * @param Route $route Экземпляр роута
     * @param mixed $response Ответ роута
     * @param array $params Параметры middleware
     * @return void
     */
    public function terminate($app, $route, $response, $params = []);
}

// В handle
$route->set('user_id', 123);
$route->set('data', ['key' => 'value']);

// В terminate
$userId = $route->get('user_id');
$data = $route->get('data');

/**
 * Добавить middleware в цепочку
 * 
 * @param string|Middleware $middleware Класс middleware (например, \IO\Middleware\Auth::class) или объект
 * @param array $params Параметры для middleware
 * @return self Возвращает текущий объект роута для цепочечного вызова
 */
protected function addMiddleware($middleware, $params = [])

$app->add_route([
    'url' => '/api/catalog',
    "name" => "app:api:catalog",
    'method' => 'actionCatalog',
    'middleware' => [
        \IO\Middlewares\CacheMiddleware::class => [
            'ttl' => 3600,  // Кэш на 1 час
            'cacheByUser' => false,
            'excludePaths' => ['/api/catalog/search'],
        ],
    ]
]);

// Глобальное применение
$app->add_middleware([
    \IO\Middlewares\CompressionMiddleware::class => [
        'level' => 6,
        'minSize' => 2048,
    ]
]);

if (getenv('CLOUD_ENV') === 'dev')
{
    $app->add_middleware([
        \IO\Middlewares\CorsDebugMiddleware::class => [],
    ]);
}

$app->add_route([
    'url' => '/api/public',
    "name" => "app:api:public",
    'method' => 'actionPublic',
    'middleware' => [
        \IO\Middlewares\CorsMiddleware::class => [
            'project' => 'myproject',
            'extraOrigins' => ['https://example.com', 'https://app.example.com'],
        ],
    ]
]);

$app->add_route([
    'url' => '/api/user/update',
    "name" => "app:api:user:update",
    'method' => 'actionUpdate',
    'middleware' => [
        \IO\Middlewares\CsrfMiddleware::class => [
            'excludeMethods' => ['GET', 'HEAD', 'OPTIONS'],
            'tokenName' => 'csrf_token',
        ],
    ]
]);

if (getenv('CLOUD_ENV') === 'dev')
{
    $app->add_middleware([
        \IO\Middlewares\DebugBarMiddleware::class => [
            'enabled' => true,
            'allowedIps' => ['127.0.0.1', '192.168.1.0/24'],
        ],
    ]);
}

$app->add_route([
    'url' => '/admin',
    "name" => "app:admin",
    'method' => 'actionAdmin',
    'middleware' => [
        \IO\Middlewares\IpWhitelistMiddleware::class => [
            'whitelist' => ['10.0.0.0/8', '192.168.1.100'],
            'blacklist' => ['1.2.3.4'],
            'allowPrivate' => true,
        ],
    ]
]);

$app->add_middleware([
    \IO\Middlewares\LoggingMiddleware::class => [
        'logFile' => '/var/log/myapp/requests.log',
        'logHeaders' => true,
        'logBody' => true,
    ],
]);

// Включение через переменную окружения
$maintenance = getenv('MAINTENANCE_MODE') === 'true';

$app->add_middleware([
    \IO\Middlewares\MaintenanceMiddleware::class => [
        'enabled' => $maintenance,
        'allowedIPs' => ['10.0.0.1', '192.168.1.100'],
        'allowedUsers' => [1, 2, 3],
        'message' => 'Проводим обновление. Вернемся через 15 минут.',
    ],
]);

// Обход режима через токен:
// https://site.com/?maintenance_token=секретный_токен

$app->add_route([
    'url' => '/api/login',
    "name" => "app:api:login",
    'method' => 'actionLogin',
    'middleware' => [
        \IO\Middlewares\RateLimitMiddleware::class => [
            'maxRequests' => 5,     // 5 попыток
            'timeWindow' => 300,    // за 5 минут
        ],
    ],
]);

// Ответ при превышении:
// HTTP/1.1 429 Too Many Requests
// X-RateLimit-Limit: 5
// X-RateLimit-Remaining: 0
// X-RateLimit-Reset: 1700000000

$app->add_middleware([
    \IO\Middlewares\RequestIdMiddleware::class => [
        'headerName' => 'X-Request-Id',
        'generateIfMissing' => true,
    ],
]);

// Использование в коде
$requestId = $this->get('request_id');
error_log("Processing request: $requestId");

$app->add_middleware([
    \IO\Middlewares\SanitizeMiddleware::class => [
        'sanitizeGet' => true,
        'sanitizePost' => true,
        'sanitizeJson' => true,
    ],
]);

// После санитизации:
// - Удаляются HTML теги
// - Экранируются спецсимволы
// - Удаляются пробелы в начале и конце

$app->add_middleware([
    \IO\Middlewares\SecurityHeadersMiddleware::class => [
        'x_frame_options' => 'SAMEORIGIN',
        'content_security_policy' => "default-src 'self' https:; script-src 'self' 'unsafe-inline'",
    ],
]);

$limits = [
    'default' => ['requests' => 100, 'window' => 3600], // 100 запросов в час
    'auth'    => ['requests' => 20,  'window' => 60],   // 20 запросов в минуту
    'api'     => ['requests' => 500, 'window' => 3600], // 500 запросов в час
];

$app->add_middleware([
    \IO\Middlewares\ThrottleMiddleware::class => [
        'limits' => [
            'default' => ['requests' => 50, 'window' => 3600],
            'auth' => ['requests' => 100, 'window' => 3600],
            'api' => ['requests' => 1000, 'window' => 3600],
        ],
    ],
]);

$app->add_route([
    'url' => '/api/user/create',
    "name" => "app:api:user:create",
    'method' => 'actionCreate',
    'middleware' => [
        \IO\Middlewares\ValidationMiddleware::class => [
            'rules' => [
                'name' => ['required' => true, 'min' => 2, 'max' => 50],
                'email' => ['required' => true, 'email' => true],
                'age' => ['numeric' => true, 'min' => 18, 'max' => 120],
                'role' => ['in' => ['admin', 'user', 'guest']],
                'website' => ['url' => true],
                'birth_date' => ['date' => true],
                '_extra' => false,  // Запрещает дополнительные поля
            ],
        ],
    ],
]);

// В роуте
public function actionCreate()
{
    $validated = $this->get('validated_data');
    $name = $validated['name'];
    $email = $validated['email'];
    
    // Создание пользователя...
}

$app->add_route([
    "url" => "/api/data",
    "name" => "app:api:data",
    "method" => "actionData",
    "cors" => [
        'allow_origin' => ['https://client.com', 'https://app.com'],
        'allow_credentials' => true,
        'allow_methods' => ['GET', 'POST'],
        'allow_headers' => ['Content-Type', 'Authorization'],
        'max_age' => 3600,
    ]
]);

/**
 * Получить конфигурацию CORS для проекта
 * 
 * @param string|null $project Имя проекта (например, 'mobi', 'admin')
 * @param array $extraOrigins Дополнительные источники для добавления
 * @return array Конфигурация CORS
 */
protected function getCorsConfig($project = null, $extraOrigins = [])

$this->addMiddleware(MiddlewareA::class);
$this->addMiddleware(MiddlewareB::class);
$this->addMiddleware(MiddlewareC::class);

// Порядок выполнения:
// 1. MiddlewareA::handle()
// 2. MiddlewareB::handle() 
// 3. MiddlewareC::handle()
// 4. Выполнение экшена роута
// 5. MiddlewareC::terminate()
// 6. MiddlewareB::terminate()
// 7. MiddlewareA::terminate()

// Внутренний сервис, вызывается только через /gate/
$app->add_route([
    "url" => "/internal/process",
    "name" => "app:internal:process",
    "method" => "actionProcess",
    "type" => ["post"],
    "nosession" => true,
    // cors отсутствует - CORS заголовки не добавляются
]);

<?php
namespace App\Routes;

use IO\Route;

class DynamicRoute extends Route
{
    public function actionConditional()
    {
        // Добавляем middleware только при определенном условии
        if ($this->input('debug') === 'true')
        {
            $this->addMiddleware(\App\Middleware\DebugLoggerMiddleware::class);
        }
        
        // ... остальной код
    }
}

// В App/Module.php
public static function init($app)
{
    // Глобальные middleware для всех маршрутов
    $app->add_middleware([
        \IO\Middlewares\RequestIdMiddleware::class => [],
        \IO\Middlewares\SecurityHeadersMiddleware::class => [],
        \IO\Middlewares\PerformanceMiddleware::class => ['slowThreshold' => 500],
    ]);
    
    // Регистрация маршрутов
    $app->add_routes([
        \IO\Routes\ApiRoute::class,
        \App\Routes\CustomRoute::class,
    ]);
}

// В Routes/ApiRoute.php
public static function routes($app)
{
    // Публичные API (без авторизации)
    $app->add_route([
        'url' => '/api/public/login',
        "name" => "app:api:public:login",
        'method' => 'actionLogin',
        'middleware' => [
            \IO\Middlewares\RateLimitMiddleware::class => ['maxRequests' => 5, 'timeWindow' => 300],
            \IO\Middlewares\ValidationMiddleware::class => [
                'rules' => [
                    'login' => ['required' => true],
                    'password' => ['required' => true, 'min' => 6],
                ],
            ],
        ],
    ]);
    
    // Защищенные API (с авторизацией)
    $app->add_route([
        'url' => '/api/users',
        "name" => "app:api:users",
        'method' => 'actionUsers',
        'middleware' => [
            \IO\Middlewares\AuthMiddleware::class => ['redirect' => '/login', 'json' => true],
            \IO\Middlewares\ThrottleMiddleware::class => [],
            \IO\Middlewares\CacheMiddleware::class => ['ttl' => 300],
        ],
    ]);
}

$app->add_route([
    'url' => '/admin/users',
    "name" => "app:admin:users",
    'method' => 'actionAdminUsers',
    'middleware' => [
        // Порядок важен! Выполняются сверху вниз
        \IO\Middlewares\IpWhitelistMiddleware::class => [
            'whitelist' => ['10.0.0.0/8', '192.168.1.0/24'],
        ],
        \IO\Middlewares\AuthMiddleware::class => [
            'redirect' => '/admin/login',
        ],
        \IO\Middlewares\RateLimitMiddleware::class => [
            'maxRequests' => 30,
            'timeWindow' => 60,
        ],
        \IO\Middlewares\ValidationMiddleware::class => [
            'rules' => [
                'page' => ['numeric' => true, 'min' => 1],
                'limit' => ['numeric' => true, 'min' => 1, 'max' => 100],
            ],
        ],
    ],
]);

<?php
namespace App\Middlewares;

use IO\Middleware;

/**
 * Проверка подписки пользователя
 */
class SubscriptionMiddleware implements Middleware
{
    public function handle($app, $route, $params = [])
    {
        $userId = $route->get('user_id');
        
        if (!$userId)
        {
            return [
                'error_code' => 401,
                'error_str' => 'User not found'
            ];
        }
        
        // Проверка подписки
        $subscription = $this->checkSubscription($userId);
        
        if (!$subscription || $subscription['expires'] < time())
        {
            return [
                'error_code' => 402,
                'error_str' => 'Subscription required'
            ];
        }
        
        // Сохраняем данные подписки
        $route->set('subscription', $subscription);
        
        return null;
    }
    
    public function terminate($app, $route, $response, $params = [])
    {
        // Логируем использование API
        if ($route->has('subscription'))
        {
            error_log("API called by user with subscription");
        }
    }
    
    private function checkSubscription($userId)
    {
        // Логика проверки подписки
        return ['plan' => 'premium', 'expires' => strtotime('+1 month')];
    }
}

// Применяем middleware только в определенных условиях
$middleware = [];

if (getenv('CLOUD_ENV') === 'production')
{
    $middleware[\IO\Middlewares\SecurityHeadersMiddleware::class] = [];
    $middleware[\IO\Middlewares\RateLimitMiddleware::class] = ['maxRequests' => 60];
}

if (getenv('CLOUD_ENV') === 'dev')
{
    $middleware[\IO\Middlewares\DebugBarMiddleware::class] = ['enabled' => true];
    $middleware[\IO\Middlewares\CorsDebugMiddleware::class] = [];
}

$app->add_middleware($middleware);