Catch transfer failure

Author: abnegate

src/Migration/Sources/CSV.php

@@ -305,6 +305,7 @@ protected function exportGroupFunctions(int $batchSize, array $resources): void
     /**
      * @param callable(resource $stream): void $callback
      * @return void
+     * @throws \Exception
      */
     private function withCsvStream(callable $callback): void
     {
@@ -313,11 +314,19 @@ private function withCsvStream(callable $callback): void
         }
 
         if ($this->device->getType() !== Storage::DEVICE_LOCAL) {
-            $this->device->transfer(
-                $this->filePath,
-                $this->filePath,
-                new Device\Local('/'),
-            );
+            try {
+                $success = $this->device->transfer(
+                    $this->filePath,
+                    $this->filePath,
+                    new Device\Local('/'),
+                );
+            } catch (\Exception) {
+                $success = false;
+            }
+
+            if (!$success) {
+                throw new \Exception('Failed to transfer CSV file from device to local storage.');
+            }
         }
 
         $stream = \fopen($this->filePath, 'r');