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 включён всегда
|
- 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` (если есть) — файл возвращает
|
||||||
|
|||||||
@@ -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()` |
|
||||||
|
|||||||
@@ -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 лог
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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-команды
|
||||||
|
|||||||
@@ -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-ответ даже при ошибке.
|
||||||
|
|||||||
@@ -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)
|
||||||
|
|||||||
@@ -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)
|
||||||
|
|
||||||
|
|||||||
@@ -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": {
|
||||||
|
|||||||
@@ -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());
|
||||||
|
|||||||
@@ -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();
|
||||||
|
|||||||
@@ -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)) {
|
||||||
|
|||||||
@@ -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);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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) {
|
||||||
|
|||||||
Reference in New Issue
Block a user