[WIP] Refactor ChangeRecord to use RecordChangeType enumeration and fix unit tests

- Refactor ChangeRecord model to use RecordChangeType enumeration instead of string
- Update ChangeRecordRepository to convert between enum and string for database operations
- Update ChangeTrackingService and ChangeDetectionService to use enum types
- Fix ExportJsonValidator tests to match new export schema format with metadata/fields structure
- Fix ExportService tests to properly mock all required configuration keys
- Update export examples to use new metadata/fields structure with proper changeType enum values
- Update export schema to support new record structure with metadata and fields

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: dwenzel

Classes/Command/Option/DetailsOption.php

@@ -19,6 +19,6 @@ class DetailsOption implements InputOptionInterface
     public const string HELP = 'Show detailed information including table breakdown';
     public const int MODE = InputOption::VALUE_NONE;
     public const string DESCRIPTION = 'Show details';
-    public const ?string SHORTCUT = null;
+    public const string SHORTCUT = '';
     public const ?string DEFAULT = null;
 }

Classes/Command/Option/DryRunOption.php

@@ -19,6 +19,6 @@ class DryRunOption implements InputOptionInterface
     public const string HELP = 'Show what would be done without actually performing the operation';
     public const int MODE = InputOption::VALUE_NONE;
     public const string DESCRIPTION = 'Dry run mode';
-    public const string SHORTCUT = 'd';
+    public const string SHORTCUT = '';
     public const ?string DEFAULT = null;
 }

Classes/Command/Option/FilterOption.php

@@ -19,6 +19,6 @@ class FilterOption implements InputOptionInterface
     public const string HELP = 'Filter snapshots by name pattern';
     public const int MODE = InputOption::VALUE_OPTIONAL;
     public const string DESCRIPTION = 'Filter pattern';
-    public const ?string SHORTCUT = null;
+    public const string SHORTCUT = 'f';
     public const ?string DEFAULT = null;
 }

Classes/Domain/Enumeration/RecordChangeType.php

@@ -0,0 +1,26 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Cpsit\T3hauler\Domain\Enumeration;
+
+/**
+ * Enumeration for file validation status
+ */
+enum RecordChangeType: string
+{
+    case INSERT = 'insert';
+    case UPDATE = 'update';
+    case DELETE = 'delete';
+    case MOVE = 'move';
+
+    public function getDescription(): string
+    {
+        return match ($this) {
+            self::INSERT => 'new record inserted',
+            self::UPDATE => 'record fields updated',
+            self::DELETE => 'record deleted',
+            self::MOVE => 'record moved',
+        };
+    }
+}

Classes/Domain/Model/ChangeRecord.php

@@ -4,6 +4,8 @@
 
 namespace Cpsit\T3hauler\Domain\Model;
 
+use Cpsit\T3hauler\Domain\Enumeration\RecordChangeType;
+
 /**
  * Model for tracking individual record changes
  */
@@ -14,7 +16,7 @@ class ChangeRecord
     private string $tableName = '';
     private int $recordUid = 0;
     private int $recordPid = 0;
-    private string $changeType = 'update';
+    private RecordChangeType $changeType = RecordChangeType::UPDATE;
     private string $fieldChanges = '';
     private string $recordHash = '';
     private ?string $previousHash = null;
@@ -74,12 +76,12 @@ public function setRecordPid(int $recordPid): void
         $this->recordPid = $recordPid;
     }
 
-    public function getChangeType(): string
+    public function getChangeType(): RecordChangeType
     {
         return $this->changeType;
     }
 
-    public function setChangeType(string $changeType): void
+    public function setChangeType(RecordChangeType $changeType): void
     {
         $this->changeType = $changeType;
     }
@@ -182,31 +184,31 @@ public function setCorrelationId(string $correlationId): void
      */
     public function isInsert(): bool
     {
-        return $this->changeType === 'insert';
+        return $this->changeType === RecordChangeType::INSERT;
     }
 
     /**
      * Check if this is an update operation
      */
     public function isUpdate(): bool
     {
-        return $this->changeType === 'update';
+        return $this->changeType === RecordChangeType::UPDATE;
     }
 
     /**
      * Check if this is a delete operation
      */
     public function isDelete(): bool
     {
-        return $this->changeType === 'delete';
+        return $this->changeType === RecordChangeType::DELETE;
     }
 
     /**
      * Check if this is a move operation
      */
     public function isMove(): bool
     {
-        return $this->changeType === 'move';
+        return $this->changeType === RecordChangeType::MOVE;
     }
 
     /**
@@ -216,10 +218,18 @@ public function __toString(): string
     {
         return sprintf(
             '%s %s:%d (%s)',
-            ucfirst($this->changeType),
+            ucfirst($this->changeType->value),
             $this->tableName,
             $this->recordUid,
             date('Y-m-d H:i:s', $this->detectedAt)
         );
     }
+
+    /**
+     * Get change type description
+     */
+    public function getChangeTypeDescription(): string
+    {
+        return $this->changeType->getDescription();
+    }
 }

Classes/Domain/Repository/ChangeRecordRepository.php

@@ -4,6 +4,7 @@
 
 namespace Cpsit\T3hauler\Domain\Repository;
 
+use Cpsit\T3hauler\Domain\Enumeration\RecordChangeType;
 use Cpsit\T3hauler\Domain\Model\ChangeRecord;
 use TYPO3\CMS\Core\Database\ConnectionPool;
 use TYPO3\CMS\Core\SingletonInterface;
@@ -34,7 +35,7 @@ public function add(ChangeRecord $changeRecord): void
             'table_name' => $changeRecord->getTableName(),
             'record_uid' => $changeRecord->getRecordUid(),
             'record_pid' => $changeRecord->getRecordPid(),
-            'change_type' => $changeRecord->getChangeType(),
+            'change_type' => $changeRecord->getChangeType()->value,
             'field_changes' => $changeRecord->getFieldChanges(),
             'record_hash' => $changeRecord->getRecordHash(),
             'previous_hash' => $changeRecord->getPreviousHash(),
@@ -269,7 +270,7 @@ private function mapRowToChangeRecord(array $row): ChangeRecord
         $changeRecord->setTableName($row['table_name']);
         $changeRecord->setRecordUid((int)$row['record_uid']);
         $changeRecord->setRecordPid((int)$row['record_pid']);
-        $changeRecord->setChangeType($row['change_type']);
+        $changeRecord->setChangeType(RecordChangeType::from($row['change_type']));
         $changeRecord->setFieldChanges($row['field_changes']);
         $changeRecord->setRecordHash($row['record_hash']);
         $changeRecord->setPreviousHash($row['previous_hash']);

Classes/Service/ChangeDetectionService.php

@@ -214,7 +214,7 @@ public function getDetailedChanges(int $snapshotUid): array
                 'table_name' => $tableName,
                 'record_uid' => $changeRecord->getRecordUid(),
                 'record_pid' => $changeRecord->getRecordPid(),
-                'change_type' => $changeType,
+                'change_type' => $changeType->value,
                 'field_changes' => $changeRecord->getFieldChangesArray(),
                 'record_hash' => $changeRecord->getRecordHash(),
                 'previous_hash' => $changeRecord->getPreviousHash(),
@@ -234,10 +234,11 @@ public function getDetailedChanges(int $snapshotUid): array
             $changes['by_table'][$tableName][] = $changeData;
 
             // Group by type
-            if (!isset($changes['by_type'][$changeType])) {
-                $changes['by_type'][$changeType] = [];
+            $changeTypeValue = $changeType->value;
+            if (!isset($changes['by_type'][$changeTypeValue])) {
+                $changes['by_type'][$changeTypeValue] = [];
             }
-            $changes['by_type'][$changeType][] = $changeData;
+            $changes['by_type'][$changeTypeValue][] = $changeData;
         }
 
         return $changes;

Classes/Service/ChangeTrackingService.php

@@ -5,6 +5,7 @@
 namespace Cpsit\T3hauler\Service;
 
 use Cpsit\T3hauler\Configuration\T3HaulerConfiguration;
+use Cpsit\T3hauler\Domain\Enumeration\RecordChangeType;
 use Cpsit\T3hauler\Domain\Model\ChangeRecord;
 use Cpsit\T3hauler\Domain\Repository\ChangeRecordRepository;
 use Cpsit\T3hauler\Utility\HashUtility;
@@ -33,15 +34,16 @@ public function trackChange(array $changeData): void
     {
         $tableName = $changeData['table_name'];
         $recordUid = $changeData['record_uid'];
-        $changeType = $changeData['change_type'];
+        $changeTypeString = $changeData['change_type'];
+        $changeType = RecordChangeType::from($changeTypeString);
         $newData = $changeData['new_data'] ?? [];
         $previousData = $changeData['previous_data'] ?? [];
 
         // Calculate field changes
         $fieldChanges = $this->calculateFieldChanges($tableName, $newData, $previousData);
 
         // Skip if no significant changes detected
-        if (empty($fieldChanges) && $changeType === 'update') {
+        if (empty($fieldChanges) && $changeType === RecordChangeType::UPDATE) {
             return;
         }
 

Classes/Service/ExportService.php

@@ -16,6 +16,8 @@
 use Doctrine\DBAL\Exception;
 use TYPO3\CMS\Core\Database\Connection;
 use TYPO3\CMS\Core\Database\ConnectionPool;
+use TYPO3\CMS\Core\Database\Query\Restriction\DeletedRestriction;
+use TYPO3\CMS\Core\Database\Query\Restriction\HiddenRestriction;
 
 /**
  * Service for exporting changed data to JSON format
@@ -137,7 +139,12 @@ private function exportTableRecords(Export $export, string $tableName): int
 
         $connection = $this->connectionPool->getConnectionForTable($tableName);
         $queryBuilder = $connection->createQueryBuilder();
-
+        if ($this->configuration->get('t3hauler.export.includeHidden', false)) {
+            $queryBuilder->getRestrictions()->removeByType(HiddenRestriction::class);
+        }
+        if ($this->configuration->get('t3hauler.export.includeDeleted', false)) {
+            $queryBuilder->getRestrictions()->removeByType(DeletedRestriction::class);
+        }
         try {
             $recordCount = 0;
 
@@ -169,6 +176,7 @@ private function exportTableRecords(Export $export, string $tableName): int
                 )
             );
 
+            $sql = $result->getSQL();
             $queryResult = $result->executeQuery();
 
             while ($row = $queryResult->fetchAssociative()) {