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 включён всегда
- В 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[]`,
фреймворк автоматически создаёт `Router` и регистрирует его в контейнере
- Загружает `$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) [один раз при старте]
→ Environment::detect() // читает APP_ENV, дефолт 'dev'
→ Config::load($configDir) // config/*.php + config/env/{env}.php + config/env/local.php
→ ContainerFactory::build() // PHP-DI, в prod компилируется в var/cache/prod/
loop (WorkerRunner::run()):
frankenphp_handle_request(fn() =>
loop (WorkerRunner::run($loop)):
$loop(fn() => // адаптер приложения, возвращает keepRunning
HttpApplication::handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER)
→ Request::fromGlobals() // парсит метод, путь, заголовки, JSON body
→ 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/Config.php` | `Config` | Загружает `config/*.php`, deep-merge с env-оверрайдами; `get('a.b.c')` |
| `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/Request.php` | `Request` | Иммутабельный; `body()`, `get(key)`, `withContext()` |
| `src/Http/Response.php` | `Response` | `json()`, `error()`, `withHeader()`, `emit()` |

View File

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

View File

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

View File

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

View File

@@ -4,7 +4,7 @@ Guidance for Claude Code when working with this repository.
## 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)

View File

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

View File

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

View File

@@ -13,13 +13,30 @@ final class ConsoleApplication
public function run(array $argv): int
{
$commandStr = $argv[1] ?? null;
if ($commandStr === null || $commandStr === 'help') {
if (!isset($argv[1]) || $argv[1] === 'help') {
$this->printHelp($argv[2] ?? null);
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);
if (!$match->found) {
@@ -31,7 +48,7 @@ final class ConsoleApplication
$input = ConsoleInput::parse(
$commandStr,
$match->pathParams,
array_slice($argv, 2),
$optionTokens,
$match->definition->options,
);
$output = new ConsoleOutput();

View File

@@ -5,6 +5,10 @@ namespace Pronchev\Pinecore;
use DI\Container;
use DI\ContainerBuilder;
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
{
@@ -20,7 +24,19 @@ class ContainerFactory
$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';
if (file_exists($routesFile)) {

View File

@@ -11,18 +11,19 @@ final class WorkerRunner
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);
for ($n = 0; !$maxRequests || $n < $maxRequests; ++$n) {
$keepRunning = frankenphp_handle_request(function (): void {
try {
$this->app->handleRequest($_GET, $_POST, $_COOKIE, $_FILES, $_SERVER);
} catch (\Throwable $e) {
$this->exceptionHandler->handleException($e);
}
});
$keepRunning = $loop($handler);
$this->app->terminate();
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();
$value = $doc[$key] ?? null;
if ($value instanceof \MongoDB\Model\BSONArray) {
$value = $value->getArrayCopy();
}
$value = $this->normalizeBson($value);
if ($field->isEmbedded && $value !== null) {
$value = $this->hydrate($field->embeddedClass, $this->toArray($value));
@@ -72,6 +70,19 @@ final class MongoHydrator
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
{
if ($doc instanceof BSONDocument) {