Compare commits
8 Commits
5e68f7dd64
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| ac5b5f9246 | |||
| 1d97114915 | |||
| ece0147b3a | |||
| d133898383 | |||
| 9f8c2b1959 | |||
| 404e2089eb | |||
| 58c9b298db | |||
| 72415949e3 |
@@ -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` (если есть) — файл возвращает
|
||||
|
||||
@@ -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()` |
|
||||
|
||||
@@ -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 лог
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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-команды
|
||||
|
||||
@@ -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-ответ даже при ошибке.
|
||||
|
||||
@@ -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)
|
||||
|
||||
@@ -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)
|
||||
|
||||
|
||||
@@ -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": {
|
||||
|
||||
@@ -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());
|
||||
|
||||
@@ -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();
|
||||
|
||||
@@ -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)) {
|
||||
|
||||
@@ -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);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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) {
|
||||
|
||||
Reference in New Issue
Block a user