Add a new HTMLType

Author: stloyd

src/core/etl/src/Flow/ETL/Row/EntryFactory.php

@@ -14,20 +14,23 @@ enum_entry,
     json_object_entry,
     list_entry,
     map_entry,
+    str_entry,
     string_entry,
     struct_entry,
     time_entry,
     uuid_entry,
     xml_element_entry,
     xml_entry};
-use function Flow\Types\DSL\{
+use function Flow\Types\DSL\{type_date,
+    type_datetime,
     type_html,
     type_json,
     type_optional,
     type_string,
+    type_time,
     type_uuid,
-    type_xml
-};
+    type_xml,
+    type_xml_element};
 use Flow\ETL\Exception\{InvalidArgumentException,
     RuntimeException,
     SchemaDefinitionNotFoundException};
@@ -61,6 +64,7 @@ enum_entry,
 };
 use Flow\Types\Type\Native\String\StringTypeChecker;
 use Flow\Types\Type\TypeDetector;
+use Flow\Types\Value\Uuid;
 
 final readonly class EntryFactory
 {
@@ -106,6 +110,30 @@ public function create(string $entryName, mixed $value, Schema|Definition|null $
             }
         }
 
+        if ($valueType instanceof InstanceOfType) {
+            if ($valueType->class === \DOMDocument::class) {
+                $valueType = type_xml();
+            } elseif ($valueType->class === \DOMElement::class) {
+                $valueType = type_xml_element();
+            } elseif ($valueType->class === \DateInterval::class) {
+                $valueType = type_time();
+            } elseif (\in_array($valueType->class, [\DateTimeImmutable::class, \DateTimeInterface::class, \DateTime::class], true)) {
+                if ($value instanceof \DateTimeInterface && $value->format('H:i:s') === '00:00:00') {
+                    $valueType = type_date();
+                } else {
+                    $valueType = type_datetime();
+                }
+            } else {
+                foreach (['Ramsey\Uuid\UuidInterface', Uuid::class, 'Symfony\Component\Uid\Uuid'] as $uuidClass) {
+                    if (\is_a($valueType->class, $uuidClass, true)) {
+                        $valueType = type_uuid();
+
+                        break;
+                    }
+                }
+            }
+        }
+
         return $this->createAs($entryName, $value, $valueType);
     }
 
@@ -128,7 +156,7 @@ public function createAs(string $entryName, mixed $value, Definition|Type $defin
 
         if (null === $value && $type instanceof OptionalType) {
             return match ($type->base()::class) {
-                StringType::class => string_entry($entryName, null, $metadata),
+                StringType::class => str_entry($entryName, null, $metadata),
                 IntegerType::class => int_entry($entryName, null, $metadata),
                 FloatType::class => float_entry($entryName, null, $metadata),
                 BooleanType::class => bool_entry($entryName, null, $metadata),
@@ -158,7 +186,7 @@ public function createAs(string $entryName, mixed $value, Definition|Type $defin
             }
 
             if ($type instanceof StringType) {
-                return string_entry($entryName, type_optional($type)->cast($value), $metadata);
+                return str_entry($entryName, type_optional($type)->cast($value), $metadata);
             }
 
             if ($type instanceof IntegerType) {