Compare commits

...

8 Commits

Author SHA1 Message Date
ac5b5f9246 Remove FrankenPHP targeting 2026-04-23 17:39:01 +03:00
1d97114915 Fix ConsoleApplication parsing 2026-04-21 14:21:33 +03:00
ece0147b3a Fix MongoHydrator BSON handling 2026-04-12 01:57:12 +03:00
d133898383 Enable PHP DI attributes 2026-04-12 01:50:07 +03:00
9f8c2b1959 Fix missing nbf 2026-04-12 01:40:54 +03:00
404e2089eb Remove deprecated method 2026-04-12 01:24:19 +03:00
58c9b298db Register Logger 2026-04-06 20:38:57 +03:00
72415949e3 Register Config and Environment 2026-04-06 20:30:34 +03:00
13 changed files with 121 additions and 53 deletions

View File

@@ -41,6 +41,10 @@ ContainerFactory::build(Environment $env, Config $config, string $basePath): Con
- Autowiring включён всегда - Autowiring включён всегда
- В prod: `$builder->enableCompilation($basePath . '/var/cache/prod/')` - В prod: `$builder->enableCompilation($basePath . '/var/cache/prod/')`
- Автоматически регистрирует `Config::class`, `Environment::class` и `LoggerInterface::class`
в контейнере — любой класс может получить их через DI без ручного биндинга в `services.php`
- `LoggerInterface` по умолчанию резолвится в `CompositeLogger([StdoutLogger])`;
если задан `log.file` — добавляется `FileLogger`
- Загружает `$basePath/config/routes.php` (если есть) — файл возвращает `RouteDefinition[]`, - Загружает `$basePath/config/routes.php` (если есть) — файл возвращает `RouteDefinition[]`,
фреймворк автоматически создаёт `Router` и регистрирует его в контейнере фреймворк автоматически создаёт `Router` и регистрирует его в контейнере
- Загружает `$basePath/config/services.php` (если есть) — файл возвращает - Загружает `$basePath/config/services.php` (если есть) — файл возвращает

View File

@@ -3,13 +3,13 @@
## Общая схема ## Общая схема
``` ```
HTTP → Caddy (:80) → /worker.php → FrankenPHP worker loop HTTP → /worker.php → worker loop
Kernel::boot($basePath) [один раз при старте] Kernel::boot($basePath) [один раз при старте]
→ Environment::detect() // читает APP_ENV, дефолт 'dev' → Environment::detect() // читает APP_ENV, дефолт 'dev'
→ Config::load($configDir) // config/*.php + config/env/{env}.php + config/env/local.php → Config::load($configDir) // config/*.php + config/env/{env}.php + config/env/local.php
→ ContainerFactory::build() // PHP-DI, в prod компилируется в var/cache/prod/ → ContainerFactory::build() // PHP-DI, в prod компилируется в var/cache/prod/
loop (WorkerRunner::run()): loop (WorkerRunner::run($loop)):
frankenphp_handle_request(fn() => $loop(fn() => // адаптер приложения, возвращает keepRunning
HttpApplication::handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER) HttpApplication::handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER)
→ Request::fromGlobals() // парсит метод, путь, заголовки, JSON body → Request::fromGlobals() // парсит метод, путь, заголовки, JSON body
→ OPTIONS? → CORS headers + 204 // preflight, без роутинга → OPTIONS? → CORS headers + 204 // preflight, без роутинга
@@ -32,7 +32,7 @@ HTTP → Caddy (:80) → /worker.php → FrankenPHP worker loop
| `src/Environment.php` | `Environment` | Читает `APP_ENV`, метод `isProd()` | | `src/Environment.php` | `Environment` | Читает `APP_ENV`, метод `isProd()` |
| `src/Config.php` | `Config` | Загружает `config/*.php`, deep-merge с env-оверрайдами; `get('a.b.c')` | | `src/Config.php` | `Config` | Загружает `config/*.php`, deep-merge с env-оверрайдами; `get('a.b.c')` |
| `src/ContainerFactory.php` | `ContainerFactory` | Строит PHP-DI контейнер; в prod включает compilation | | `src/ContainerFactory.php` | `ContainerFactory` | Строит PHP-DI контейнер; в prod включает compilation |
| `src/Http/WorkerRunner.php` | `WorkerRunner` | Цикл FrankenPHP, MAX_REQUESTS, gc | | `src/Http/WorkerRunner.php` | `WorkerRunner` | Worker-цикл, MAX_REQUESTS, gc |
| `src/Http/HttpApplication.php` | `HttpApplication` | CORS, роутинг, dispatch, обработка исключений | | `src/Http/HttpApplication.php` | `HttpApplication` | CORS, роутинг, dispatch, обработка исключений |
| `src/Http/Request.php` | `Request` | Иммутабельный; `body()`, `get(key)`, `withContext()` | | `src/Http/Request.php` | `Request` | Иммутабельный; `body()`, `get(key)`, `withContext()` |
| `src/Http/Response.php` | `Response` | `json()`, `error()`, `withHeader()`, `emit()` | | `src/Http/Response.php` | `Response` | `json()`, `error()`, `withHeader()`, `emit()` |

View File

@@ -2,7 +2,7 @@
## Entrypoint (`worker.php` приложения) ## Entrypoint (`worker.php` приложения)
FrankenPHP запускается как `frankenphp run --config Caddyfile` и сам стартует PHP-воркеры. Фреймворк запускается удобным для пользователя способом. `WorkerRunner::run()` без аргументов обрабатывает один запрос и завершается (классический SAPI/FPM/CGI). Чтобы крутить worker-петлю, приложение передаёт свой адаптер:
```php ```php
use Pronchev\Pinecore\Kernel; use Pronchev\Pinecore\Kernel;
@@ -11,10 +11,16 @@ use Pronchev\Pinecore\Http\WorkerRunner;
require __DIR__ . '/vendor/autoload.php'; require __DIR__ . '/vendor/autoload.php';
Kernel::boot(__DIR__); Kernel::boot(__DIR__);
Kernel::container()->get(WorkerRunner::class)->run(); $runner = Kernel::container()->get(WorkerRunner::class);
// Один запрос:
$runner->run();
// Или worker-петля (пример для FrankenPHP):
$runner->run(fn ($handler) => frankenphp_handle_request($handler));
``` ```
`WorkerRunner` резолвится через DI autowiring — конфигурировать не нужно. Адаптер получает `callable $handler` (обработать один запрос) и возвращает `bool` — продолжать ли цикл. `MAX_REQUESTS`, `$app->terminate()` и `gc_collect_cycles()` отрабатывает сам `WorkerRunner` между итерациями. `WorkerRunner` резолвится через DI autowiring — конфигурировать не нужно.
## WorkerRunner (`src/Http/WorkerRunner.php`) ## WorkerRunner (`src/Http/WorkerRunner.php`)
@@ -26,23 +32,33 @@ final class WorkerRunner
private readonly ExceptionHandler $exceptionHandler, private readonly ExceptionHandler $exceptionHandler,
) {} ) {}
public function run(): void public function run(?callable $loop = null): void
{ {
if ($loop === null) {
$this->handle();
$this->app->terminate();
return;
}
$handler = fn () => $this->handle();
$maxRequests = (int) ($_SERVER['MAX_REQUESTS'] ?? 0); // 0 = без лимита $maxRequests = (int) ($_SERVER['MAX_REQUESTS'] ?? 0); // 0 = без лимита
for ($n = 0; !$maxRequests || $n < $maxRequests; ++$n) { for ($n = 0; !$maxRequests || $n < $maxRequests; ++$n) {
$keepRunning = frankenphp_handle_request(function (): void { $keepRunning = $loop($handler);
try {
$this->app->handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER);
} catch (\Throwable $e) {
$this->exceptionHandler->handleException($e); // critical лог
}
});
$this->app->terminate(); // хук: закрытие ресурсов (сейчас пустой) $this->app->terminate(); // хук: закрытие ресурсов (сейчас пустой)
gc_collect_cycles(); gc_collect_cycles();
if (!$keepRunning) break; // FrankenPHP сигнализирует об остановке if (!$keepRunning) break;
}
}
private function handle(): void
{
try {
$this->app->handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER);
} catch (\Throwable $e) {
$this->exceptionHandler->handleException($e); // critical лог
} }
} }
} }

View File

@@ -2,20 +2,18 @@
## Запуск worker ## Запуск worker
FrankenPHP стартует PHP-воркеры через Caddyfile: Фреймворк запускается удобным для пользователя способом — способ запуска выбирает само приложение. Воркер-скрипт приложения подключается к фреймворку через `WorkerRunner`:
```bash
frankenphp run --config Caddyfile
```
Воркер-скрипт приложения подключается к фреймворку через `WorkerRunner`:
```php ```php
// worker.php // worker.php — один запрос (классический SAPI)
$runner = new WorkerRunner($kernel);
$runner->run(); $runner->run();
// worker.php — worker-петля, адаптер инжектится приложением
$runner->run(fn ($handler) => frankenphp_handle_request($handler));
``` ```
Адаптер получает `callable $handler` и возвращает `bool` (продолжать ли цикл). `MAX_REQUESTS`, `terminate()` и `gc_collect_cycles()` `WorkerRunner` делает сам между итерациями.
--- ---
## Console-команды ## Console-команды

View File

@@ -105,7 +105,7 @@ $value = Config::get('section.key', $default);
```php ```php
// Внутри worker.php // Внутри worker.php
$runner = new WorkerRunner($kernel); $runner = new WorkerRunner($kernel);
$runner->run(); // FrankenPHP loop: запрос → роутинг → middleware → контроллер → ответ $runner->run(); // worker loop: запрос → роутинг → middleware → контроллер → ответ
``` ```
`WorkerRunner` перехватывает исключения и возвращает корректный HTTP-ответ даже при ошибке. `WorkerRunner` перехватывает исключения и возвращает корректный HTTP-ответ даже при ошибке.

View File

@@ -2,11 +2,7 @@
## Запуск воркера локально ## Запуск воркера локально
```bash Запусти воркер удобным для тебя способом (worker-рантайм, FPM, CLI — по выбору приложения). Убедись, что переменные окружения заданы (`.env` или `environment.php`).
frankenphp run --config Caddyfile
```
Убедись, что переменные окружения заданы (`.env` или `environment.php`).
--- ---
@@ -26,8 +22,7 @@ Config::get('log.level') // DEBUG для максимального вывода
### Воркер не стартует ### Воркер не стартует
- Проверь синтаксис `Caddyfile` и путь до `worker.php` - Проверь конфигурацию выбранного рантайма и путь до `worker.php`
- FrankenPHP требует `FRANKENPHP_CONFIG` или явного указания воркер-скрипта
- Проверь, что `Kernel::init()` вызван до первого запроса - Проверь, что `Kernel::init()` вызван до первого запроса
### Маршрут не найден (404) ### Маршрут не найден (404)

View File

@@ -4,7 +4,7 @@ Guidance for Claude Code when working with this repository.
## Package ## Package
`pronchev/pinecore` — minimal PHP framework for FrankenPHP long-running workers. `pronchev/pinecore` — minimal PHP framework for long-running workers.
**Namespace:** `Pronchev\Pinecore\``src/` (PSR-4) **Namespace:** `Pronchev\Pinecore\``src/` (PSR-4)

View File

@@ -1,6 +1,6 @@
{ {
"name": "pronchev/pinecore", "name": "pronchev/pinecore",
"description": "Minimal PHP framework for FrankenPHP long-running workers", "description": "Minimal PHP framework for long-running workers",
"type": "library", "type": "library",
"license": "MIT", "license": "MIT",
"require": { "require": {

View File

@@ -28,8 +28,8 @@ final class JwtService
$signer = new Sha256(); $signer = new Sha256();
$key = InMemory::plainText($secret); $key = InMemory::plainText($secret);
$this->jwtConfig = Configuration::forSymmetricSigner($signer, $key); $jwtConfig = Configuration::forSymmetricSigner($signer, $key);
$this->jwtConfig->setValidationConstraints( $this->jwtConfig = $jwtConfig->withValidationConstraints(
new SignedWith($signer, $key), new SignedWith($signer, $key),
new StrictValidAt(new class implements ClockInterface { new StrictValidAt(new class implements ClockInterface {
public function now(): DateTimeImmutable public function now(): DateTimeImmutable
@@ -45,6 +45,7 @@ final class JwtService
$now = new DateTimeImmutable(); $now = new DateTimeImmutable();
$token = $this->jwtConfig->builder() $token = $this->jwtConfig->builder()
->issuedAt($now) ->issuedAt($now)
->canOnlyBeUsedAfter($now)
->expiresAt($now->modify("+{$this->accessTtl} seconds")) ->expiresAt($now->modify("+{$this->accessTtl} seconds"))
->relatedTo($userId) ->relatedTo($userId)
->getToken($this->jwtConfig->signer(), $this->jwtConfig->signingKey()); ->getToken($this->jwtConfig->signer(), $this->jwtConfig->signingKey());

View File

@@ -13,13 +13,30 @@ final class ConsoleApplication
public function run(array $argv): int public function run(array $argv): int
{ {
$commandStr = $argv[1] ?? null; if (!isset($argv[1]) || $argv[1] === 'help') {
if ($commandStr === null || $commandStr === 'help') {
$this->printHelp($argv[2] ?? null); $this->printHelp($argv[2] ?? null);
return 0; return 0;
} }
// Split argv (after script name) into positional command tokens and option tokens.
// Positional tokens form the command string matched against command signatures
// (e.g. "users:create admin"). Tokens from the first "--" onwards are options.
$positional = [];
$optionTokens = [];
$inOptions = false;
for ($i = 1, $n = count($argv); $i < $n; $i++) {
$tok = $argv[$i];
if (!$inOptions && str_starts_with($tok, '--')) {
$inOptions = true;
}
if ($inOptions) {
$optionTokens[] = $tok;
} else {
$positional[] = $tok;
}
}
$commandStr = implode(' ', $positional);
$match = $this->router->match($commandStr); $match = $this->router->match($commandStr);
if (!$match->found) { if (!$match->found) {
@@ -31,7 +48,7 @@ final class ConsoleApplication
$input = ConsoleInput::parse( $input = ConsoleInput::parse(
$commandStr, $commandStr,
$match->pathParams, $match->pathParams,
array_slice($argv, 2), $optionTokens,
$match->definition->options, $match->definition->options,
); );
$output = new ConsoleOutput(); $output = new ConsoleOutput();

View File

@@ -5,6 +5,10 @@ namespace Pronchev\Pinecore;
use DI\Container; use DI\Container;
use DI\ContainerBuilder; use DI\ContainerBuilder;
use Pronchev\Pinecore\Http\Router; use Pronchev\Pinecore\Http\Router;
use Pronchev\Pinecore\Log\CompositeLogger;
use Pronchev\Pinecore\Log\FileLogger;
use Pronchev\Pinecore\Log\StdoutLogger;
use Psr\Log\LoggerInterface;
class ContainerFactory class ContainerFactory
{ {
@@ -20,7 +24,19 @@ class ContainerFactory
$builder->enableCompilation($cacheDir); $builder->enableCompilation($cacheDir);
} }
$builder->useAutowiring(true); $builder->useAttributes(true);
$builder->addDefinitions([
Config::class => $config,
Environment::class => $env,
LoggerInterface::class => function ($c) use ($config) {
$loggers = [$c->get(StdoutLogger::class)];
if ($config->get('log.file')) {
$loggers[] = $c->get(FileLogger::class);
}
return new CompositeLogger($loggers);
},
]);
$routesFile = $basePath . '/config/routes.php'; $routesFile = $basePath . '/config/routes.php';
if (file_exists($routesFile)) { if (file_exists($routesFile)) {

View File

@@ -11,18 +11,19 @@ final class WorkerRunner
private readonly ExceptionHandler $exceptionHandler, private readonly ExceptionHandler $exceptionHandler,
) {} ) {}
public function run(): void public function run(?callable $loop = null): void
{ {
if ($loop === null) {
$this->handle();
$this->app->terminate();
return;
}
$handler = fn () => $this->handle();
$maxRequests = (int) ($_SERVER['MAX_REQUESTS'] ?? 0); $maxRequests = (int) ($_SERVER['MAX_REQUESTS'] ?? 0);
for ($n = 0; !$maxRequests || $n < $maxRequests; ++$n) { for ($n = 0; !$maxRequests || $n < $maxRequests; ++$n) {
$keepRunning = frankenphp_handle_request(function (): void { $keepRunning = $loop($handler);
try {
$this->app->handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER);
} catch (\Throwable $e) {
$this->exceptionHandler->handleException($e);
}
});
$this->app->terminate(); $this->app->terminate();
gc_collect_cycles(); gc_collect_cycles();
@@ -32,4 +33,13 @@ final class WorkerRunner
} }
} }
} }
private function handle(): void
{
try {
$this->app->handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER);
} catch (\Throwable $e) {
$this->exceptionHandler->handleException($e);
}
}
} }

View File

@@ -20,9 +20,7 @@ final class MongoHydrator
$propName = $field->property->getName(); $propName = $field->property->getName();
$value = $doc[$key] ?? null; $value = $doc[$key] ?? null;
if ($value instanceof \MongoDB\Model\BSONArray) { $value = $this->normalizeBson($value);
$value = $value->getArrayCopy();
}
if ($field->isEmbedded && $value !== null) { if ($field->isEmbedded && $value !== null) {
$value = $this->hydrate($field->embeddedClass, $this->toArray($value)); $value = $this->hydrate($field->embeddedClass, $this->toArray($value));
@@ -72,6 +70,19 @@ final class MongoHydrator
return $result; return $result;
} }
private function normalizeBson(mixed $value): mixed
{
if ($value instanceof \MongoDB\Model\BSONArray) {
return array_map($this->normalizeBson(...), $value->getArrayCopy());
}
if ($value instanceof BSONDocument) {
return array_map($this->normalizeBson(...), iterator_to_array($value));
}
return $value;
}
private function toArray(array|BSONDocument $doc): array private function toArray(array|BSONDocument $doc): array
{ {
if ($doc instanceof BSONDocument) { if ($doc instanceof BSONDocument) {