refactor: cover core static analysis with mago

Author: norberttech

Justfile

@@ -60,7 +60,8 @@ analyze-mago *args:
         src/lib/azure-sdk \
         src/lib/doctrine-dbal-bulk \
         src/lib/snappy \
-        src/lib/parquet
+        src/lib/parquet \
+        src/core/etl
 
 # Auto-fix code style with Mago (format + lint --fix).
 fix:

composer.lock

@@ -43,6 +43,8 @@ ignore = [
         "src/lib/types/tests/Flow/Types/Tests/Unit/Type/Logical/HTMLTypeTest.php",
         "src/lib/types/tests/Flow/Types/Tests/Unit/Type/Native/StringTypeTest.php",
         "src/lib/types/tests/Flow/Types/Tests/Unit/Type/TypeDetectorTest.php",
+        "src/core/etl/src/Flow/ETL/Row/Entry/HTMLEntry.php",
+        "src/core/etl/src/Flow/ETL/Row/Entry/HTMLElementEntry.php",
     ] },
 ]
 

mago.toml

@@ -19,8 +19,8 @@ assert (!(with-c && with-pg-query-ext)) || builtins.throw "Cannot use --arg with
 
 let
     nixpkgs = fetchTarball {
-        url = "https://github.com/NixOS/nixpkgs/archive/03158cb739fc4a09babe7949900bfc221871d642.tar.gz";
-        sha256 = "0vl4iwqcpbczhzb3xbckjb86brcsxkcz4wcbqzidia2fyhm9llmx";
+        url = "https://github.com/NixOS/nixpkgs/archive/0c4e77908e1204498184d81cda8716e1ba4c47af.tar.gz";
+        sha256 = "0mbr776gj2qk9klvara4zlww3g0da4nfbnrmi114nnmmayx3pyj4";
     };
 
     pkgs = import nixpkgs {

shell.nix

@@ -474,10 +474,7 @@ private function registerCatalogProviders(array $catalogProviders, ContainerBuil
                 $providerDef = new Definition(ArrayCatalogProvider::class, [$providerConfig['catalog']]);
                 $providerDef->addTag('flow.postgresql.catalog_provider');
                 $container->setDefinition("flow.postgresql.catalog_provider.{$i}", $providerDef);
-            } elseif (
-                array_key_exists('catalog_provider_id', $providerConfig)
-                && $providerConfig['catalog_provider_id'] !== null
-            ) {
+            } elseif ($providerConfig['catalog_provider_id'] !== null) {
                 $configProviderServiceIds[] = type_string()->assert($providerConfig['catalog_provider_id']);
             }
         }

src/bridge/symfony/postgresql-bundle/src/Flow/Bridge/Symfony/PostgreSqlBundle/FlowPostgreSqlBundle.php

@@ -55,6 +55,7 @@ private function valueEquals($a, $b): bool
             return false;
         }
 
+        // @mago-ignore analysis:mixed-assignment
         foreach ($b as $key => $value) {
             if (!array_key_exists($key, $a)) {
                 return false;

src/core/etl/src/Flow/ArrayComparison/ArrayComparison.php

@@ -56,18 +56,29 @@ public function divide(
             $useNewNaming = defined('Brick\Math\RoundingMode::Up');
 
             $brickMode = match ($rounding) {
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::UP => $useNewNaming ? RoundingMode::Up : RoundingMode::UP,
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::DOWN => $useNewNaming ? RoundingMode::Down : RoundingMode::DOWN,
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::CEILING => $useNewNaming ? RoundingMode::Ceiling : RoundingMode::CEILING,
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::FLOOR => $useNewNaming ? RoundingMode::Floor : RoundingMode::FLOOR,
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::HALF_UP => $useNewNaming ? RoundingMode::HalfUp : RoundingMode::HALF_UP,
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::HALF_DOWN => $useNewNaming ? RoundingMode::HalfDown : RoundingMode::HALF_DOWN,
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::HALF_CEILING => $useNewNaming ? RoundingMode::HalfCeiling : RoundingMode::HALF_CEILING,
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::HALF_FLOOR => $useNewNaming ? RoundingMode::HalfFloor : RoundingMode::HALF_FLOOR,
+                // @mago-ignore analysis:non-existent-class-constant
                 Rounding::HALF_EVEN => $useNewNaming ? RoundingMode::HalfEven : RoundingMode::HALF_EVEN,
+                // @mago-ignore analysis:non-existent-class-constant
                 default => $useNewNaming ? RoundingMode::Unnecessary : RoundingMode::UNNECESSARY,
             };
 
+            // @mago-ignore analysis:possibly-invalid-argument
             $result = $aDecimal->dividedBy(BigDecimal::of((string) $b), $effectiveScale, $brickMode);
 
             if (!self::hasNonZeroFractionalPart($result)) {
@@ -76,9 +87,9 @@ public function divide(
 
             return $result->toFloat();
         } catch (DivisionByZeroException $e) {
-            throw new DivisionByZeroError('Division by zero.', $e->getCode(), $e);
+            throw new DivisionByZeroError('Division by zero.', (int) $e->getCode(), $e);
         } catch (RoundingNecessaryException $e) {
-            throw new Exception\RoundingNecessaryException($e->getMessage(), $e->getCode(), $e);
+            throw new Exception\RoundingNecessaryException($e->getMessage(), (int) $e->getCode(), $e);
         }
     }
 
@@ -112,6 +123,7 @@ public function multiply(int|float|string $a, int|float|string $b): int|float
      */
     public function power(int|float|string $a, int|string $b): int|float
     {
+        // @mago-ignore analysis:possibly-invalid-argument
         $result = BigDecimal::of((string) $a)->power(BigInteger::of((string) $b)->toInt());
 
         if (!self::hasNonZeroFractionalPart($result)) {
@@ -139,6 +151,7 @@ public function subtract(int|float|string $a, int|float|string $b): int|float
     private static function hasNonZeroFractionalPart(BigDecimal $result): bool
     {
         if (method_exists($result, 'hasNonZeroFractionalPart')) {
+            // @mago-ignore analysis:mixed-return-statement
             return $result->hasNonZeroFractionalPart();
         }
 

src/core/etl/src/Flow/Calculator/Calculator.php

@@ -24,6 +24,7 @@ final class NumberNormalizer
      */
     public static function toNumber(string $number): float|int
     {
+        // @mago-ignore analysis:impossible-condition,redundant-type-comparison
         if (!is_numeric($number)) {
             throw new NonNumericValueException((string) $number);
         }
@@ -33,6 +34,7 @@ public static function toNumber(string $number): float|int
         }
 
         if (str_contains($number, '.')) {
+            // @mago-ignore analysis:invalid-type-cast
             return (float) $number;
         }
 
@@ -50,6 +52,7 @@ public static function toString(string|float|int $number, int $scale): string
             throw new InvalidScaleException($scale);
         }
 
+        // @mago-ignore analysis:impossible-condition,redundant-type-comparison
         if (!is_numeric($number)) {
             throw new NonNumericValueException((string) $number);
         }

src/core/etl/src/Flow/Calculator/NumberNormalizer.php

@@ -37,6 +37,7 @@ public function delete(string $key): void
 
     public function get(string $key): Row|Rows|CacheIndex
     {
+        // @mago-ignore analysis:mixed-assignment
         $serializedValue = $this->cache->get($key);
 
         if (!$serializedValue) {

src/core/etl/src/Flow/ETL/Cache/Implementation/PSRSimpleCache.php

@@ -66,6 +66,7 @@ public function cache(Cache $cache): self
      */
     public function externalSortBucketsCount(int $externalSortBucketsCount): self
     {
+        // @mago-ignore analysis:impossible-condition,redundant-comparison
         if ($externalSortBucketsCount < 1) {
             throw new InvalidArgumentException('External sort buckets count must be greater than 0');
         }