refactor: DataFrame Entry contract

Author: norberttech

src/adapter/etl-adapter-elasticsearch/src/Flow/ETL/Adapter/Elasticsearch/ElasticsearchPHP/ElasticsearchLoader.php

@@ -15,6 +15,7 @@
 use Flow\ETL\Row;
 use Flow\ETL\Row\Entry\JsonEntry;
 use Flow\ETL\Rows;
+use Flow\Types\Value\Json;
 use Throwable;
 
 use function class_exists;
@@ -82,7 +83,7 @@ public function load(Rows $rows, FlowContext $context): void
              */
             $dataCollection = $rows->map(static fn(Row $row): Row => Row::create(
                 $factory->create($row),
-                new JsonEntry('body', $row->toArray()),
+                new JsonEntry('body', Json::fromArray($row->toArray())),
             ))->toArray();
 
             foreach ($dataCollection as $data) {

src/adapter/etl-adapter-excel/src/Flow/ETL/Adapter/Excel/RowsNormalizer/ExcelRowsNormalizer.php

@@ -88,6 +88,9 @@ private function normalizeEntry(Entry $entry): bool|float|int|string|null
         };
     }
 
+    /**
+     * @param EnumEntry<\UnitEnum|null> $entry
+     */
     private function normalizeEnumEntry(EnumEntry $entry): ?string
     {
         $value = $entry->value();

src/adapter/etl-adapter-http/src/Flow/ETL/Adapter/Http/RequestEntriesFactory.php

@@ -8,6 +8,7 @@
 use Flow\ETL\Row;
 use Flow\ETL\Row\Entries;
 use Flow\ETL\Row\Entry\JsonEntry;
+use Flow\Types\Value\Json;
 use Psr\Http\Message\RequestInterface;
 
 use function class_exists;
@@ -70,7 +71,7 @@ public function create(RequestInterface $request): Entries
                                 );
                             }
 
-                            $requestBodyEntry = new JsonEntry('request_body', $decodedJson);
+                            $requestBodyEntry = new JsonEntry('request_body', Json::fromArray($decodedJson));
                         } else {
                             $requestBodyEntry = string_entry('request_body', $requestBodyContent);
                         }
@@ -88,7 +89,7 @@ public function create(RequestInterface $request): Entries
         return new Entries(
             $requestBodyEntry,
             string_entry('request_uri', (string) $request->getUri()),
-            new JsonEntry('request_headers', $request->getHeaders()),
+            new JsonEntry('request_headers', Json::fromArray($request->getHeaders())),
             string_entry('request_protocol_version', $request->getProtocolVersion()),
             string_entry('request_method', $request->getMethod()),
         );

src/adapter/etl-adapter-xml/src/Flow/ETL/Adapter/XML/RowsNormalizer/EntryNormalizer.php

@@ -86,7 +86,7 @@ public function normalize(Entry $entry): XMLNode|XMLAttribute
      * It might be possible to use a schema here, if provided we might be able to take a metadata from entry definition and use it to define a node name.
      * However this might be a bit problematic in case of deeply nested lists.
      *
-     * @param ListEntry<mixed> $entry
+     * @param ListEntry<mixed, list<mixed>|null> $entry
      */
     private function listToNode(ListEntry $entry): XMLNode
     {
@@ -143,7 +143,7 @@ private function listToNode(ListEntry $entry): XMLNode
      *
      * Because of that and because Map Values can be other nested structures, the only valid solution is solution from Example 1.
      *
-     * @param MapEntry<array-key, mixed> $entry
+     * @param MapEntry<array-key, mixed, array<array-key, mixed>|null> $entry
      */
     private function mapToNode(MapEntry $entry): XMLNode
     {
@@ -174,7 +174,7 @@ private function mapToNode(MapEntry $entry): XMLNode
     }
 
     /**
-     * @param StructureEntry<array<string, mixed>> $entry
+     * @param StructureEntry<mixed, array<string, mixed>|null> $entry
      */
     private function structureToNode(StructureEntry $entry): XMLNode
     {

src/core/etl/src/Flow/ETL/Constraint/SortedByConstraint.php

@@ -23,7 +23,7 @@ final class SortedByConstraint implements Constraint
     private bool $firstRow = true;
 
     /**
-     * @var array<string, mixed>
+     * @var array<string, null|array<array-key, mixed>|bool|float|int|object|string>
      */
     private array $previousValues = [];
 
@@ -46,9 +46,7 @@ public function isSatisfiedBy(Row $row): bool
         }
 
         foreach ($this->references->all() as $reference) {
-            // @mago-ignore analysis:mixed-assignment
             $currentValue = $row->valueOf($reference);
-            // @mago-ignore analysis:mixed-assignment
             $previousValue = $this->previousValues[$reference->name()];
 
             $direction = $reference->sort();
@@ -120,7 +118,6 @@ public function violation(Row $row): string
 
         foreach ($this->references->all() as $reference) {
             $entry = $row->get($reference);
-            // @mago-ignore analysis:mixed-assignment
             $previousValue = $this->previousValues[$reference->name()] ?? null;
 
             $violations[] = sprintf(