From 079db4176581a467ef330ba9d1af135744bcc0a0 Mon Sep 17 00:00:00 2001
From: Erki Aas <erki@veebkolm.ee>
Date: Mon, 23 Mar 2026 16:10:38 +0200
Subject: [PATCH 1/2] Add readPreference option to mongodump

---
 doc/config/source/mongodump.json             |  3 ++-
 doc/config/source/mongodump.xml              |  3 +++
 src/Backup/Source/Mongodump.php              | 12 ++++++++++-
 src/Cli/Executable/Mongodump.php             | 21 ++++++++++++++++++++
 tests/phpbu/Cli/Executable/MongodumpTest.php | 14 +++++++++++++
 5 files changed, 51 insertions(+), 2 deletions(-)

diff --git a/doc/config/source/mongodump.json b/doc/config/source/mongodump.json
index 748f53fb..f9390332 100644
--- a/doc/config/source/mongodump.json
+++ b/doc/config/source/mongodump.json
@@ -10,6 +10,7 @@
     "excludeCollections": "myCollectionToExclude1,myCollectionToExclude2",
     "excludeCollectionsWithPrefix": "myExcludePrefix1,myExcludePrefix2",
     "ipv6": true,
-    "pathToMongodump": "/path/to/custom/bin"
+    "pathToMongodump": "/path/to/custom/bin",
+    "readPreference": "secondary"
   }
 }
diff --git a/doc/config/source/mongodump.xml b/doc/config/source/mongodump.xml
index 429f9e81..58e7979c 100644
--- a/doc/config/source/mongodump.xml
+++ b/doc/config/source/mongodump.xml
@@ -27,6 +27,9 @@
   <!-- optional, default=false -->
   <option name="ipv6" value="true"/>
 
+  <!-- optional, default=none -->
+  <option name="readPreference" value="secondary"/>
+
   <!-- define your custom mongodump executable location -->
   <option name="pathToMongodump" value="/path/to/custom/bin" />
 </source>
diff --git a/src/Backup/Source/Mongodump.php b/src/Backup/Source/Mongodump.php
index 4b4c330a..39d5349f 100644
--- a/src/Backup/Source/Mongodump.php
+++ b/src/Backup/Source/Mongodump.php
@@ -107,6 +107,14 @@ class Mongodump extends SimulatorExecutable implements Simulator
      */
     private $excludeCollectionsWithPrefix;
 
+    /**
+     * Read preference
+     * --readPreference <string>
+     *
+     * @var string
+     */
+    private $readPreference;
+
     /**
      * (No PHPDoc)
      *
@@ -121,6 +129,7 @@ public function setup(array $conf = [])
 
         $this->pathToMongodump = Util\Arr::getValue($conf, 'pathToMongodump', '');
         $this->useIPv6         = Util\Str::toBoolean(Util\Arr::getValue($conf, 'ipv6', ''), false);
+        $this->readPreference  = Util\Arr::getValue($conf, 'readPreference', '');
 
         $this->setupValidation();
     }
@@ -213,7 +222,8 @@ protected function createExecutable(Target $target) : Executable
                    ->dumpDatabases($this->databases)
                    ->dumpCollections($this->collections)
                    ->excludeCollections($this->excludeCollections)
-                   ->excludeCollectionsWithPrefix($this->excludeCollectionsWithPrefix);
+                   ->excludeCollectionsWithPrefix($this->excludeCollectionsWithPrefix)
+                   ->useReadPreference($this->readPreference);
         return $executable;
     }
 
diff --git a/src/Cli/Executable/Mongodump.php b/src/Cli/Executable/Mongodump.php
index 972d09e3..626f9f31 100644
--- a/src/Cli/Executable/Mongodump.php
+++ b/src/Cli/Executable/Mongodump.php
@@ -107,6 +107,14 @@ class Mongodump extends Abstraction
      */
     private $excludeCollectionsWithPrefix = [];
 
+    /**
+     * Read preference
+     * --readPreference <string>
+     *
+     * @var string
+     */
+    private $readPreference;
+
     /**
      * Constructor.
      *
@@ -230,6 +238,18 @@ public function excludeCollectionsWithPrefix(array $prefixes) : Mongodump
         return $this;
     }
 
+    /**
+     * Set read preference.
+     *
+     * @param  string $readPreference
+     * @return Mongodump
+     */
+    public function useReadPreference(string $readPreference) : Mongodump
+    {
+        $this->readPreference = $readPreference;
+        return $this;
+    }
+
     /**
      * Mongodump CommandLine generator.
      *
@@ -252,6 +272,7 @@ protected function createCommandLine() : CommandLine
         $cmd->addOptionIfNotEmpty('--username', $this->user);
         $cmd->addOptionIfNotEmpty('--password', $this->password);
         $cmd->addOptionIfNotEmpty('--authenticationDatabase', $this->authenticationDatabase);
+        $cmd->addOptionIfNotEmpty('--readPreference', $this->readPreference);
 
         foreach ($this->databases as $db) {
             $cmd->addOption('--db', $db);
diff --git a/tests/phpbu/Cli/Executable/MongodumpTest.php b/tests/phpbu/Cli/Executable/MongodumpTest.php
index 6f78cbc5..f3ade470 100644
--- a/tests/phpbu/Cli/Executable/MongodumpTest.php
+++ b/tests/phpbu/Cli/Executable/MongodumpTest.php
@@ -168,4 +168,18 @@ public function testUri()
             $mongo->getCommand()
         );
     }
+
+    /**
+     * Tests Mongodump::createCommandLine
+     */
+    public function testReadPreference()
+    {
+        $mongo = new Mongodump(PHPBU_TEST_BIN);
+        $mongo->dumpToDirectory('./dump')->useReadPreference('secondary');
+
+        $this->assertEquals(
+            '"' . PHPBU_TEST_BIN . '/mongodump" --out=\'./dump\' --readPreference=\'secondary\'',
+            $mongo->getCommand()
+        );
+    }
 }

From 13645b258a073ea8a7e60709c963b7079fc31c27 Mon Sep 17 00:00:00 2001
From: Erki Aas <erki@veebkolm.ee>
Date: Mon, 30 Mar 2026 14:11:04 +0300
Subject: [PATCH 2/2] Add multiPartUploadSize to Amazon S3 sync

---
 doc/config/sync/amazons3.json              |  3 +-
 doc/config/sync/amazons3.xml               |  3 ++
 src/Backup/Sync/AmazonS3.php               | 12 ++++++--
 src/Backup/Sync/AmazonS3v3.php             |  8 ++++--
 tests/phpbu/Backup/Sync/AmazonS3v3Test.php | 33 ++++++++++++++++++++++
 5 files changed, 54 insertions(+), 5 deletions(-)

diff --git a/doc/config/sync/amazons3.json b/doc/config/sync/amazons3.json
index 4e4ccd1d..fcc022b8 100644
--- a/doc/config/sync/amazons3.json
+++ b/doc/config/sync/amazons3.json
@@ -6,6 +6,7 @@
     "bucket": "some-s3-bucket",
     "region": "aws-region",
     "path": "backup",
-    "useMultiPartUpload": false
+    "useMultiPartUpload": false,
+    "multiPartUploadPartSize": 104857600
   }
 }
diff --git a/doc/config/sync/amazons3.xml b/doc/config/sync/amazons3.xml
index a0d2e06c..d3cbe2e7 100644
--- a/doc/config/sync/amazons3.xml
+++ b/doc/config/sync/amazons3.xml
@@ -17,4 +17,7 @@
 
   <!-- optional, default false -->
   <option name="useMultiPartUpload" value="true" />
+
+  <!-- optional, multipart upload part size in bytes, default AWS SDK default (5MB) -->
+  <option name="multiPartUploadPartSize" value="104857600" />
 </sync>
diff --git a/src/Backup/Sync/AmazonS3.php b/src/Backup/Sync/AmazonS3.php
index 15c559bb..dbd6acc9 100644
--- a/src/Backup/Sync/AmazonS3.php
+++ b/src/Backup/Sync/AmazonS3.php
@@ -110,6 +110,13 @@ abstract class AmazonS3 implements Simulator
      */
     protected $signatureVersion;
 
+    /**
+     * Multi part upload part size in bytes
+     *
+     * @var int|null
+     */
+    protected $multiPartUploadSize;
+
     /**
      * Min multi part upload size
      *
@@ -151,8 +158,9 @@ public function setup(array $config)
         $this->path             = Util\Path::replaceDatePlaceholders($pathCleaned, $this->time);
         $this->pathRaw          = $pathCleaned;
         $this->acl              = Util\Arr::getValue($config, 'acl', 'private');
-        $this->multiPartUpload  = Util\Str::toBoolean(Util\Arr::getValue($config, 'useMultiPartUpload'), false);
-        $this->usePathStyle     = Util\Str::toBoolean(Util\Arr::getValue($config, 'usePathStyleEndpoint'), false);
+        $this->multiPartUpload     = Util\Str::toBoolean(Util\Arr::getValue($config, 'useMultiPartUpload'), false);
+        $this->multiPartUploadSize = Util\Arr::getValue($config, 'multiPartUploadPartSize');
+        $this->usePathStyle        = Util\Str::toBoolean(Util\Arr::getValue($config, 'usePathStyleEndpoint'), false);
         $this->endpoint         = Util\Arr::getValue($config, 'endpoint');
         $this->signatureVersion = Util\Arr::getValue($config, 'signatureVersion');
     }
diff --git a/src/Backup/Sync/AmazonS3v3.php b/src/Backup/Sync/AmazonS3v3.php
index 8c42d5f9..7775a2a3 100644
--- a/src/Backup/Sync/AmazonS3v3.php
+++ b/src/Backup/Sync/AmazonS3v3.php
@@ -108,10 +108,14 @@ protected function createClient() : S3Client
      */
     protected function createUploader(Target $target, S3Client $s3) : MultipartUploader
     {
-        return new MultipartUploader($s3, $target->getPathname(), [
+        $options = [
             'bucket' => $this->bucket,
             'key'    => $this->getUploadPath($target),
-        ]);
+        ];
+        if ($this->multiPartUploadSize) {
+            $options['part_size'] = (int) $this->multiPartUploadSize;
+        }
+        return new MultipartUploader($s3, $target->getPathname(), $options);
     }
 
     /**
diff --git a/tests/phpbu/Backup/Sync/AmazonS3v3Test.php b/tests/phpbu/Backup/Sync/AmazonS3v3Test.php
index 746d1a81..3ee6acc1 100644
--- a/tests/phpbu/Backup/Sync/AmazonS3v3Test.php
+++ b/tests/phpbu/Backup/Sync/AmazonS3v3Test.php
@@ -202,6 +202,39 @@ public function testSimulate()
         $amazonS3->simulate($targetStub, $resultStub);
     }
 
+    /**
+     * Tests AmazonS3V3::sync with multiPartUploadPartSize
+     */
+    public function testSyncWithMultiPartUploadPartSize()
+    {
+        $target = $this->createTargetMock('foo.txt', 'foo.txt.gz');
+
+        $result = $this->createMock(Result::class);
+        $result->expects($this->once())->method('debug');
+
+        $clientMock = $this->createAWSS3Mock();
+        $clientMock->expects($this->once())->method('doesBucketExist')->willReturn(true);
+
+        $uploaderMock = $this->createAWSS3UploaderMock();
+        $uploaderMock->expects($this->once())->method('upload');
+
+        $aws = $this->createPartialMock(AmazonS3v3::class, ['createClient', 'createUploader']);
+        $aws->method('createClient')->willReturn($clientMock);
+        $aws->method('createUploader')->willReturn($uploaderMock);
+
+        $aws->setup([
+            'key'                      => 'some-key',
+            'secret'                   => 'some-secret',
+            'bucket'                   => 'backup',
+            'region'                   => 'frankfurt',
+            'path'                     => 'backup',
+            'useMultiPartUpload'       => 'true',
+            'multiPartUploadPartSize'  => '104857600'
+        ]);
+
+        $aws->sync($target, $result);
+    }
+
     /**
      * Tests AmazonS3::setUp
      */