From 1722e9e416ad998fed889c098526a01f76493848 Mon Sep 17 00:00:00 2001
From: Jake Barnby <jakeb994@gmail.com>
Date: Fri, 22 Aug 2025 18:03:10 +1200
Subject: [PATCH] Fix DB read source

---
 src/Appwrite/Platform/Workers/Migrations.php | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/src/Appwrite/Platform/Workers/Migrations.php b/src/Appwrite/Platform/Workers/Migrations.php
index 33af785ab5..ce9b7e2881 100644
--- a/src/Appwrite/Platform/Workers/Migrations.php
+++ b/src/Appwrite/Platform/Workers/Migrations.php
@@ -18,6 +18,7 @@ use Utopia\Migration\Destination;
 use Utopia\Migration\Destinations\Appwrite as DestinationAppwrite;
 use Utopia\Migration\Exception as MigrationException;
 use Utopia\Migration\Source;
+use Utopia\Migration\Sources\Appwrite;
 use Utopia\Migration\Sources\Appwrite as SourceAppwrite;
 use Utopia\Migration\Sources\CSV;
 use Utopia\Migration\Sources\Firebase;
@@ -113,9 +114,17 @@ class Migrations extends Action
     protected function processSource(Document $migration): Source
     {
         $source = $migration->getAttribute('source');
+        $destination = $migration->getAttribute('destination');
         $resourceId = $migration->getAttribute('resourceId');
         $credentials = $migration->getAttribute('credentials');
         $migrationOptions = $migration->getAttribute('options');
+        $dataSource = Appwrite::SOURCE_API;
+        $database = null;
+
+        if ($source === Appwrite::getName() && $destination === DestinationCSV::getName()) {
+            $dataSource = Appwrite::SOURCE_DATABASE;
+            $database = $this->dbForProject;
+        }
 
         $migrationSource = match ($source) {
             Firebase::getName() => new Firebase(
@@ -143,6 +152,8 @@ class Migrations extends Action
                 $credentials['projectId'],
                 $credentials['endpoint'] === 'http://localhost/v1' ? 'http://appwrite/v1' : $credentials['endpoint'],
                 $credentials['apiKey'],
+                $dataSource,
+                $database
             ),
             CSV::getName() => new CSV(
                 $resourceId,
@@ -251,7 +262,9 @@ class Migrations extends Action
                 'functions.write',
                 'databases.read',
                 'collections.read',
+                'collections.write',
                 'tables.read',
+                'tables.write',
                 'documents.read',
                 'documents.write',
                 'rows.read',