Add overwrite and skip options to Appwrite destination

composer.json

@@ -26,7 +26,7 @@
         "ext-curl": "*",
         "ext-openssl": "*",
         "appwrite/appwrite": "19.*",
-        "utopia-php/database": "5.*",
+        "utopia-php/database": "dev-csv-import-upsert-v2 as 5.0.0",
         "utopia-php/storage": "1.0.*",
         "utopia-php/dsn": "0.2.*",
         "halaxa/json-machine": "^1.2"

src/Migration/Destinations/Appwrite.php

@@ -85,6 +85,27 @@ class Appwrite extends Destination
      */
     private array $rowBuffer = [];
 
+    private bool $overwrite = false;
+    private bool $skip = false;
+
+    public function setOverwrite(bool $overwrite): self
+    {
+        if ($overwrite && $this->skip) {
+            throw new \InvalidArgumentException('Cannot set both overwrite and skip to true.');
+        }
+        $this->overwrite = $overwrite;
+        return $this;
+    }
+
+    public function setSkip(bool $skip): self
+    {
+        if ($skip && $this->overwrite) {
+            throw new \InvalidArgumentException('Cannot set both skip and overwrite to true.');
+        }
+        $this->skip = $skip;
+        return $this;
+    }
+
     /**
      * @param string $project
      * @param string $endpoint
@@ -986,7 +1007,7 @@ protected function createRecord(Row $resource, bool $isLast): bool
             $this->cache->get($resource->getName())
         );
 
-        if ($exists) {
+        if ($exists && !$this->overwrite) {
             $resource->setStatus(
                 Resource::STATUS_SKIPPED,
                 'Row has already been created'
@@ -1067,10 +1088,20 @@ protected function createRecord(Row $resource, bool $isLast): bool
                         }
                     }
                 }
-                $dbForDatabases->skipRelationshipsExistCheck(fn () => $dbForDatabases->createDocuments(
-                    'database_' . $databaseInternalId . '_collection_' . $tableInternalId,
-                    $this->rowBuffer
-                ));
+                $collectionName = 'database_' . $databaseInternalId . '_collection_' . $tableInternalId;
+
+                if ($this->overwrite) {
+                    $dbForDatabases->skipRelationshipsExistCheck(fn () => $dbForDatabases->upsertDocuments(
+                        $collectionName,
+                        $this->rowBuffer
+                    ));
+                } else {
+                    $dbForDatabases->skipRelationshipsExistCheck(fn () => $dbForDatabases->createDocuments(
+                        $collectionName,
+                        $this->rowBuffer,
+                        ignore: $this->skip
+                    ));
+                }
 
             } finally {
                 $this->rowBuffer = [];