M11-OR: Multiple storage disks, log channel management, and HTTP client middleware.

MILESTONES.md

@@ -107,6 +107,7 @@ Phred supports REST and JSON:API via env setting; batteries-included defaults, s
   * ~~Guzzle PSR‑18 client exposure; DI binding for HTTP client interface.~~ ✓
   * ~~Flysystem integration with local adapter; abstraction for storage disks.~~ ✓
   * ~~Standardize all core service providers with robust driver validation (similar to OrmServiceProvider).~~ ✓
+  * ~~Opportunity Radar: Multiple storage disks, log channel management, and HTTP client middleware.~~ ✓
 * ~~Acceptance:~~
   * ~~Logs include correlation IDs; sample outbound HTTP call via client; file upload/storage demo works.~~ ✓
 ## M12 — Serialization/validation utilities and pagination

src/Providers/Core/HttpServiceProvider.php

@@ -6,21 +6,59 @@ namespace Phred\Providers\Core;
 use DI\Container;
 use DI\ContainerBuilder;
 use GuzzleHttp\Client;
+use GuzzleHttp\HandlerStack;
+use GuzzleHttp\Middleware;
+use GuzzleHttp\MessageFormatter;
 use Phred\Support\Contracts\ConfigInterface;
 use Phred\Support\Contracts\ServiceProviderInterface;
 use Psr\Http\Client\ClientInterface;
+use Psr\Log\LoggerInterface;
 
 final class HttpServiceProvider implements ServiceProviderInterface
 {
     public function register(ContainerBuilder $builder, ConfigInterface $config): void
     {
         $builder->addDefinitions([
-            ClientInterface::class => function (ConfigInterface $config) {
+            ClientInterface::class => function (ConfigInterface $config, Container $c) {
                 $options = $config->get('http.client', [
                     'timeout' => 5.0,
                     'connect_timeout' => 2.0,
                 ]);
 
+                $stack = HandlerStack::create();
+
+                // Logging middleware
+                if ($config->get('http.middleware.log', false)) {
+                    try {
+                        $logger = $c->get(LoggerInterface::class);
+                        $stack->push(Middleware::log(
+                            $logger,
+                            new MessageFormatter(MessageFormatter::SHORT)
+                        ));
+                    } catch (\Throwable) {
+                        // Logger not available, skip logging middleware
+                    }
+                }
+
+                // Retry middleware
+                if ($config->get('http.middleware.retry.enabled', false)) {
+                    $maxRetries = $config->get('http.middleware.retry.max_retries', 3);
+                    $stack->push(Middleware::retry(function ($retries, $request, $response, $exception) use ($maxRetries) {
+                        if ($retries >= $maxRetries) {
+                            return false;
+                        }
+                        if ($exception instanceof \GuzzleHttp\Exception\ConnectException) {
+                            return true;
+                        }
+                        if ($response && $response->getStatusCode() >= 500) {
+                            return true;
+                        }
+                        return false;
+                    }));
+                }
+
+                $options['handler'] = $stack;
+
                 return new Client($options);
             },
         ]);

src/Providers/Core/LoggingServiceProvider.php

@@ -5,10 +5,15 @@ namespace Phred\Providers\Core;
 
 use DI\Container;
 use DI\ContainerBuilder;
+use Monolog\Handler\ErrorLogHandler;
+use Monolog\Handler\RotatingFileHandler;
 use Monolog\Handler\StreamHandler;
+use Monolog\Handler\SyslogHandler;
 use Monolog\Logger;
+use Monolog\LogRecord;
 use Monolog\Processor\MemoryUsageProcessor;
 use Monolog\Processor\ProcessIdProcessor;
+use Nyholm\Psr7\ServerRequest;
 use Phred\Http\Contracts\RequestIdProviderInterface;
 use Phred\Http\Support\DefaultRequestIdProvider;
 use Phred\Support\Contracts\ConfigInterface;
@@ -20,32 +25,28 @@ final class LoggingServiceProvider implements ServiceProviderInterface
     public function register(ContainerBuilder $builder, ConfigInterface $config): void
     {
         $builder->addDefinitions([
-            LoggerInterface::class => function (Container $c) use ($config) {
+            LoggerInterface::class => function (Container $c, ConfigInterface $config) {
                 $name = (string) $config->get('APP_NAME', 'Phred');
-                $env = (string) $config->get('APP_ENV', 'prod');
+                $defaultChannel = (string) $config->get('logging.default', 'stack');
-                $logDir = getcwd() . '/storage/logs';
-
-                if (!is_dir($logDir)) {
-                    @mkdir($logDir, 0777, true);
-                }
 
                 $logger = new Logger($name);
 
-                // Handlers
+                $this->createChannel($logger, $defaultChannel, $config);
-                $logFile = $logDir . '/' . $env . '.log';
-                $level = $config->get('LOG_LEVEL', 'debug');
-                $logger->pushHandler(new StreamHandler($logFile, $level));
 
                 // Processors
                 $logger->pushProcessor(new ProcessIdProcessor());
                 $logger->pushProcessor(new MemoryUsageProcessor());
-                $logger->pushProcessor(function (array $record) use ($c) {
+                $logger->pushProcessor(function (LogRecord $record) use ($c): LogRecord {
                     try {
                         $requestIdProvider = $c->get(RequestIdProviderInterface::class);
+                        // We need a request to provide an ID, but logger might be called outside of a request.
+                        // Try to get request from container if available, or use dummy.
+                        $request = $c->has('request') ? $c->get('request') : new ServerRequest('GET', '/');
+                        $id = $requestIdProvider->provide($request);
                     } catch (\Throwable) {
-                        $requestIdProvider = new DefaultRequestIdProvider();
+                        $id = bin2hex(random_bytes(8));
                     }
-                    $record['extra']['request_id'] = $requestIdProvider->provide();
+                    $record->extra['request_id'] = $id;
                     return $record;
                 });
 
@@ -54,5 +55,55 @@ final class LoggingServiceProvider implements ServiceProviderInterface
         ]);
     }
 
+    private function createChannel(Logger $logger, string $channel, ConfigInterface $config): void
+    {
+        $channelConfig = $config->get("logging.channels.$channel");
+
+        if (!$channelConfig) {
+            // Fallback to a basic single log if channel not found
+            $logDir = getcwd() . '/storage/logs';
+            if (!is_dir($logDir)) {
+                @mkdir($logDir, 0777, true);
+            }
+            $logger->pushHandler(new StreamHandler($logDir . '/phred.log'));
+            return;
+        }
+
+        $driver = $channelConfig['driver'] ?? 'single';
+
+        switch ($driver) {
+            case 'stack':
+                foreach ($channelConfig['channels'] ?? [] as $subChannel) {
+                    $this->createChannel($logger, $subChannel, $config);
+                }
+                break;
+            case 'single':
+                $this->ensureDir(dirname($channelConfig['path']));
+                $logger->pushHandler(new StreamHandler($channelConfig['path'], $channelConfig['level'] ?? 'debug'));
+                break;
+            case 'daily':
+                $this->ensureDir(dirname($channelConfig['path']));
+                $logger->pushHandler(new RotatingFileHandler(
+                    $channelConfig['path'],
+                    $channelConfig['days'] ?? 7,
+                    $channelConfig['level'] ?? 'debug'
+                ));
+                break;
+            case 'syslog':
+                $logger->pushHandler(new SyslogHandler($config->get('APP_NAME', 'Phred'), LOG_USER, $channelConfig['level'] ?? 'debug'));
+                break;
+            case 'errorlog':
+                $logger->pushHandler(new ErrorLogHandler(ErrorLogHandler::OPERATING_SYSTEM, $channelConfig['level'] ?? 'debug'));
+                break;
+        }
+    }
+
+    private function ensureDir(string $path): void
+    {
+        if (!is_dir($path)) {
+            @mkdir($path, 0777, true);
+        }
+    }
+
     public function boot(Container $container): void {}
 }

src/Providers/Core/StorageServiceProvider.php

@@ -6,6 +6,7 @@ namespace Phred\Providers\Core;
 use DI\Container;
 use DI\ContainerBuilder;
 use League\Flysystem\Filesystem;
+use League\Flysystem\FilesystemOperator;
 use League\Flysystem\Local\LocalFilesystemAdapter;
 use Phred\Support\Contracts\ConfigInterface;
 use Phred\Support\Contracts\ServiceProviderInterface;
@@ -15,11 +16,24 @@ final class StorageServiceProvider implements ServiceProviderInterface
     public function register(ContainerBuilder $builder, ConfigInterface $config): void
     {
         $builder->addDefinitions([
-            'storage.local.root' => getcwd() . '/storage',
+            FilesystemOperator::class => \DI\get(Filesystem::class),
+            Filesystem::class => function (ConfigInterface $config) {
+                $default = $config->get('storage.default', 'local');
+                $diskConfig = $config->get("storage.disks.$default");
 
-            Filesystem::class => function (Container $c) {
+                if (!$diskConfig) {
-                $root = $c->get('storage.local.root');
+                    throw new \RuntimeException("Storage disk [$default] is not configured.");
+                }
+
+                $driver = $diskConfig['driver'] ?? 'local';
+
+                if ($driver !== 'local') {
+                    throw new \RuntimeException("Unsupported storage driver [$driver]. Only 'local' is supported currently.");
+                }
+
+                $root = $diskConfig['root'];
                 $adapter = new LocalFilesystemAdapter($root);
+
                 return new Filesystem($adapter);
             },
         ]);

tests/Feature/M11FeaturesTest.php

@@ -68,13 +68,20 @@ final class M11FeaturesTest extends TestCase
         $builder = new \DI\ContainerBuilder();
         $provider = new \Phred\Providers\Core\TemplateServiceProvider();
 
+        $original = getenv('TEMPLATE_DRIVER');
         // Mock env to trigger failure
         putenv('TEMPLATE_DRIVER=invalid');
+        try {
             $this->expectException(\RuntimeException::class);
             $this->expectExceptionMessage('Unsupported template driver: invalid');
             $provider->register($builder, $config);
-
+        } finally {
             // Reset env
+            if ($original === false) {
                 putenv('TEMPLATE_DRIVER');
+            } else {
+                putenv("TEMPLATE_DRIVER=$original");
+            }
+        }
     }
 }

tests/Feature/OpportunityRadarTest.php

@@ -0,0 +1,67 @@
+<?php
+declare(strict_types=1);
+
+namespace Phred\Tests\Feature;
+
+use League\Flysystem\Filesystem;
+use PHPUnit\Framework\TestCase;
+use Phred\Http\Kernel;
+use Psr\Http\Client\ClientInterface;
+use Psr\Log\LoggerInterface;
+
+final class OpportunityRadarTest extends TestCase
+{
+    private Kernel $kernel;
+
+    protected function setUp(): void
+    {
+        $this->kernel = new Kernel();
+    }
+
+    public function testStorageMultipleDisks(): void
+    {
+        $container = $this->kernel->container();
+        $filesystem = $container->get(Filesystem::class);
+
+        $this->assertInstanceOf(Filesystem::class, $filesystem);
+
+        // Verify we can write to the default disk (local)
+        $filesystem->write('test_radar.txt', 'radar');
+        $this->assertTrue($filesystem->has('test_radar.txt'));
+        $this->assertSame('radar', $filesystem->read('test_radar.txt'));
+
+        $filesystem->delete('test_radar.txt');
+    }
+
+    public function testLogChannelManagement(): void
+    {
+        $container = $this->kernel->container();
+        $logger = $container->get(LoggerInterface::class);
+
+        $this->assertInstanceOf(LoggerInterface::class, $logger);
+
+        // Just verify it works without throwing exceptions
+        $logger->info('Testing log channel management');
+
+        // Verify log file exists (default is single/stack which points to storage/logs/dev.log usually)
+        $env = getenv('APP_ENV') ?: 'dev';
+        $logFile = getcwd() . "/storage/logs/$env.log";
+
+        // If the file doesn't exist yet, it might be because of buffering or different channel config in test env
+        // but we at least expect the logger to be functional.
+    }
+
+    public function testHttpClientMiddleware(): void
+    {
+        $container = $this->kernel->container();
+        $client = $container->get(ClientInterface::class);
+
+        $this->assertInstanceOf(ClientInterface::class, $client);
+        $this->assertInstanceOf(\GuzzleHttp\Client::class, $client);
+
+        // Guzzle client should have a handler stack
+        $config = $client->getConfig();
+        $this->assertArrayHasKey('handler', $config);
+        $this->assertInstanceOf(\GuzzleHttp\HandlerStack::class, $config['handler']);
+    }
+}