Tests: Improve coverage (#18)

composer.json

@@ -13,6 +13,7 @@
     "doctrine/orm": "^2.16",
     "friendsofphp/php-cs-fixer": "^3.35",
     "mockery/mockery": "^1.6",
+    "monolog/monolog": "^3.5",
     "pestphp/pest": "^2.24",
     "phpstan/phpstan": "^1.10",
     "phpstan/phpstan-mockery": "^1.1",

phpstan.dist.neon

@@ -3,5 +3,9 @@ parameters:
     paths:
         - src/
         - tests/
+    ignoreErrors:
+        -
+          message: "#Access to an undefined property#"
+          path: "tests/Unit/Recipe/LoggerRecipeTest.php"
 includes:
     - vendor/phpstan/phpstan-mockery/extension.neon

src/Recipe/LoggerRecipe.php

@@ -22,9 +22,6 @@
 use Psr\Log\NullLogger;
 use Stringable;
 
-/**
- * @codeCoverageIgnore
- */
 final class LoggerRecipe extends Recipe
 {
     /**

tests/Unit/Recipe/LoggerRecipeTest.php

@@ -0,0 +1,41 @@
+<?php
+
+declare(strict_types=1);
+
+namespace BenTools\ETL\Tests\Unit\Recipe;
+
+use Bentools\ETL\EtlConfiguration;
+use Bentools\ETL\EtlExecutor;
+use Bentools\ETL\Recipe\LoggerRecipe;
+use Monolog\Handler\TestHandler;
+use Monolog\Level;
+use Monolog\Logger;
+
+it('logs messages during ETL process', function () {
+    // Given
+    $handler = new TestHandler();
+    $logger = new Logger('test', [$handler]);
+    $loggerRecipe = new LoggerRecipe($logger);
+    $executor = new EtlExecutor(options: new EtlConfiguration(flushEvery: 1));
+    $executor = $executor->withRecipe($loggerRecipe);
+
+    // When
+    $executor->process(['foo', 'bar']);
+
+    // Then
+    $records = $handler->getRecords();
+    expect($records)->toHaveCount(12)->and($records)->sequence(
+        fn ($record) => $record->message->toEqual('Initializing ETL...')->and($record->level->toBe(Level::Debug)),
+        fn ($record) => $record->message->toEqual('Starting ETL...')->and($record->level->toBe(Level::Info)),
+        fn ($record) => $record->message->toContain('Extracting item')->and($record->level->toBe(Level::Debug)),
+        fn ($record) => $record->message->toContain('Transformed item')->and($record->level->toBe(Level::Debug)),
+        fn ($record) => $record->message->toContain('Loaded item')->and($record->level->toBe(Level::Debug)),
+        fn ($record) => $record->message->toContain('Flushing items (partial)...')->and($record->level->toBe(Level::Info)),
+        fn ($record) => $record->message->toContain('Extracting item')->and($record->level->toBe(Level::Debug)),
+        fn ($record) => $record->message->toContain('Transformed item')->and($record->level->toBe(Level::Debug)),
+        fn ($record) => $record->message->toContain('Loaded item')->and($record->level->toBe(Level::Debug)),
+        fn ($record) => $record->message->toContain('Flushing items (partial)...')->and($record->level->toBe(Level::Info)),
+        fn ($record) => $record->message->toContain('Flushing items...')->and($record->level->toBe(Level::Info)),
+        fn ($record) => $record->message->toContain('ETL complete.')->and($record->level->toBe(Level::Info)),
+    );
+});