From dfa6c7831a05cd37013db5bcd16f3af00a452cdd Mon Sep 17 00:00:00 2001
From: ArnabChatterjee20k <arnabchatterjee.ac.2@gmail.com>
Date: Tue, 5 Aug 2025 17:47:42 +0530
Subject: [PATCH 1/2] Add 'type' property to Database resource and update
 Appwrite source

---
 src/Migration/Destinations/Appwrite.php       | 1 +
 src/Migration/Resources/Database/Database.php | 8 ++++++++
 src/Migration/Sources/Appwrite.php            | 1 +
 3 files changed, 10 insertions(+)

diff --git a/src/Migration/Destinations/Appwrite.php b/src/Migration/Destinations/Appwrite.php
index b63509df..e8b15297 100644
--- a/src/Migration/Destinations/Appwrite.php
+++ b/src/Migration/Destinations/Appwrite.php
@@ -337,6 +337,7 @@ protected function createDatabase(Database $resource): bool
             '$createdAt' => $resource->getCreatedAt(),
             '$updatedAt' => $resource->getUpdatedAt(),
             'originalId' => empty($resource->getOriginalId()) ? null : $resource->getOriginalId(),
+            'type' => empty($resource->getType()) ? null : $resource->getType(),
         ]));
 
         $resource->setSequence($database->getSequence());
diff --git a/src/Migration/Resources/Database/Database.php b/src/Migration/Resources/Database/Database.php
index 0caafeea..bed2cd31 100644
--- a/src/Migration/Resources/Database/Database.php
+++ b/src/Migration/Resources/Database/Database.php
@@ -22,6 +22,7 @@ public function __construct(
         protected string $updatedAt = '',
         protected bool $enabled = true,
         protected string $originalId = '',
+        protected string $type = '',
     ) {
         $this->id = $id;
     }
@@ -45,6 +46,7 @@ public static function fromArray(array $array): self
             updatedAt: $array['updatedAt'] ?? '',
             enabled: $array['enabled'] ?? true,
             originalId: $array['originalId'] ?? '',
+            type: $array['type'] ?? '',
         );
     }
 
@@ -59,6 +61,7 @@ public function jsonSerialize(): array
             'createdAt' => $this->createdAt,
             'updatedAt' => $this->updatedAt,
             'enabled' => $this->enabled,
+            'type' => $this->type,
         ];
     }
 
@@ -81,4 +84,9 @@ public function getEnabled(): bool
     {
         return $this->enabled;
     }
+
+    public function getType(): string
+    {
+        return $this->type;
+    }
 }
diff --git a/src/Migration/Sources/Appwrite.php b/src/Migration/Sources/Appwrite.php
index d4e6a445..31bb1ac2 100644
--- a/src/Migration/Sources/Appwrite.php
+++ b/src/Migration/Sources/Appwrite.php
@@ -725,6 +725,7 @@ private function exportDatabases(int $batchSize): void
                     $database['name'],
                     $database['$createdAt'],
                     $database['$updatedAt'],
+                    type:$database['type']
                 );
 
                 $databases[] = $newDatabase;

From df433b7547b42a4232528354958da9ce78234635 Mon Sep 17 00:00:00 2001
From: ArnabChatterjee20k <arnabchatterjee.ac.2@gmail.com>
Date: Tue, 5 Aug 2025 18:01:26 +0530
Subject: [PATCH 2/2] added fallback to sql

---
 src/Migration/Destinations/Appwrite.php       | 2 +-
 src/Migration/Resources/Database/Database.php | 2 +-
 src/Migration/Sources/Appwrite.php            | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/Migration/Destinations/Appwrite.php b/src/Migration/Destinations/Appwrite.php
index e8b15297..2520acb6 100644
--- a/src/Migration/Destinations/Appwrite.php
+++ b/src/Migration/Destinations/Appwrite.php
@@ -337,7 +337,7 @@ protected function createDatabase(Database $resource): bool
             '$createdAt' => $resource->getCreatedAt(),
             '$updatedAt' => $resource->getUpdatedAt(),
             'originalId' => empty($resource->getOriginalId()) ? null : $resource->getOriginalId(),
-            'type' => empty($resource->getType()) ? null : $resource->getType(),
+            'type' => empty($resource->getType()) ? 'sql' : $resource->getType(),
         ]));
 
         $resource->setSequence($database->getSequence());
diff --git a/src/Migration/Resources/Database/Database.php b/src/Migration/Resources/Database/Database.php
index bed2cd31..f644c5f5 100644
--- a/src/Migration/Resources/Database/Database.php
+++ b/src/Migration/Resources/Database/Database.php
@@ -46,7 +46,7 @@ public static function fromArray(array $array): self
             updatedAt: $array['updatedAt'] ?? '',
             enabled: $array['enabled'] ?? true,
             originalId: $array['originalId'] ?? '',
-            type: $array['type'] ?? '',
+            type: $array['type'] ?? 'sql',
         );
     }
 
diff --git a/src/Migration/Sources/Appwrite.php b/src/Migration/Sources/Appwrite.php
index 31bb1ac2..ba07b941 100644
--- a/src/Migration/Sources/Appwrite.php
+++ b/src/Migration/Sources/Appwrite.php
@@ -725,7 +725,7 @@ private function exportDatabases(int $batchSize): void
                     $database['name'],
                     $database['$createdAt'],
                     $database['$updatedAt'],
-                    type:$database['type']
+                    type: $database['type'] ?? 'sql'
                 );
 
                 $databases[] = $newDatabase;