One way sync code

Author: DivineOmega

src/FileListing/FileListingFactory.php

@@ -2,12 +2,19 @@
 
 namespace DivineOmega\FileSync\FileListing;
 
+use League\Flysystem\Filesystem;
+
 abstract class FileListingFactory
 {
     public static function createFromFilesystems(array $filesystems)
     {
-        return array_map(function($filesystem) {
-            return new FileListing($filesystem);
+        return array_map(function(FileSystem $filesystem) {
+            return self::createFromFilesystem($filesystem);
         }, $filesystems);
     }
+
+    public static function createFromFilesystem(Filesystem $filesystem)
+    {
+        return new FileListing($filesystem);
+    }
 }

src/FileSyncStrategies/MultiDirectional.php

@@ -30,7 +30,7 @@ public function begin(): void
         if ($this->showProgressBar) {
             $maxProgress = 1;
             $progressBar = new ProgressBar();
-            $progressBar->setMaxProgress(1);
+            $progressBar->setMaxProgress($maxProgress);
             $progressBar->setMessage('Getting file listings...');
             $progressBar->display();
         }

src/FileSyncStrategies/OneWay.php

@@ -2,12 +2,82 @@
 
 namespace DivineOmega\FileSync\FileSyncStrategies;
 
+use DivineOmega\CliProgressBar\ProgressBar;
+use DivineOmega\FileSync\FileListing\FileListingFactory;
+use DivineOmega\FileSync\FileListing\TransferActionFactory;
 use DivineOmega\FileSync\Interfaces\FileSyncStrategyInterface;
+use League\Flysystem\Filesystem;
 
 class OneWay implements FileSyncStrategyInterface
 {
+    private $fromFilesystem;
+    private $toFilesystem;
+    private $showProgressBar = false;
+
+    public function from(Filesystem $filesystem)
+    {
+        $this->fromFilesystem = $filesystem;
+        return $this;
+    }
+
+    public function to(Filesystem $filesystem)
+    {
+        $this->toFilesystem = $filesystem;
+        return $this;
+    }
+
+    public function withProgressBar(): self
+    {
+        $this->showProgressBar = true;
+        return $this;
+    }
+
     public function begin(): void
     {
-        // TODO: Implement begin() method.
+        if ($this->showProgressBar) {
+            $maxProgress = 3;
+            $progressBar = new ProgressBar();
+            $progressBar->setMaxProgress($maxProgress);
+            $progressBar->setMessage('Getting file listings...');
+            $progressBar->display();
+        }
+
+        $fromFileListing = FileListingFactory::createFromFilesystem($this->fromFilesystem);
+
+        if ($this->showProgressBar) {
+            $progressBar->advance();
+            $progressBar->display();
+        }
+
+        $toFileListing = FileListingFactory::createFromFilesystem($this->toFilesystem);
+
+        if ($this->showProgressBar) {
+            $progressBar->advance();
+            $progressBar->setMessage('Determining differences...');
+            $progressBar->display();
+        }
+
+        $files = $fromFileListing->getFilesToTransferTo($toFileListing);
+        $transferActions = TransferActionFactory::createFromFiles($files, $this->fromFilesystem, $this->toFilesystem);
+
+        if ($this->showProgressBar) {
+            $maxProgress += count($transferActions);
+            $progressBar->setMaxProgress($maxProgress);
+            $progressBar->setMessage('Transferring files...');
+            $progressBar->display();
+        }
+
+        foreach($transferActions as $transferAction) {
+            $transferAction->transfer();
+
+            if ($this->showProgressBar) {
+                $progressBar->advance();
+                $progressBar->display();
+            }
+        }
+
+        if ($this->showProgressBar) {
+            $progressBar->complete();
+        }
     }
 }

tests/Integration/OneWayFileSyncTest.php

@@ -0,0 +1,69 @@
+<?php
+
+use DivineOmega\FileSync\FileSync;
+use League\Flysystem\Adapter\Local;
+use League\Flysystem\Filesystem;
+use PHPUnit\Framework\TestCase;
+
+final class OneWayFileSystemTest extends TestCase
+{
+    public function setupDirectory($name, $fillWithFiles = true)
+    {
+        $path = __DIR__.'/Data/'.$name.'/';
+
+        if (is_dir($path)) {
+
+            $files = glob($path.'*.txt');
+
+            foreach($files as $file) {
+                unlink($file);
+            }
+        } else {
+            mkdir($path, 0777, true);
+        }
+
+        if ($fillWithFiles)
+        {
+            $numFiles = rand(1, 100);
+
+            $faker = Faker\Factory::create();
+
+            $monthInSeconds = 2592000;
+
+            for ($i=0; $i < $numFiles; $i++) {
+                $filename = $faker->word().'.txt';
+                $content  = $faker->text(rand(5, 1000));
+                file_put_contents($path.$filename, $content);
+                touch($path.$filename, time() - rand(0, $monthInSeconds));
+            }
+        }
+
+        $adapter = new Local($path);
+        return new Filesystem($adapter);
+    }
+
+    public function testMultiDirectionalFileSync()
+    {
+        $directoryA = $this->setupDirectory('oneway-a');
+        $directoryB = $this->setupDirectory('oneway-b', false);
+
+        (new FileSync())
+            ->oneWay()
+            ->from($directoryA)
+            ->to($directoryB)
+            ->begin();
+
+        $filesA = glob(__DIR__.'/Data/oneway-a/*.txt');
+        $filesB = glob(__DIR__.'/Data/oneway-b/*.txt');
+
+        $this->assertSameSize($filesA, $filesB);
+
+        foreach($filesA as $fileA) {
+            $fileB = __DIR__.'/Data/oneway-b/'.basename($fileA);
+
+            $this->assertFileExists($fileB);
+
+            $this->assertFileEquals($fileA, $fileB);
+        }
+    }
+}