recursive file quee folder changed from "exec(rm -fr /folder)" to

RecursiveDirectoryIterator

Author: 2tvenom

examples/file_example.php

@@ -12,8 +12,29 @@
 
 $driver = new FileDriver('file_queue');
 
-/* TRUNCATE */
-exec('rm -fr file_queue/*');
+function delete($path)
+{
+    $it = new RecursiveIteratorIterator(
+        new RecursiveDirectoryIterator($path),
+        RecursiveIteratorIterator::CHILD_FIRST
+    );
+
+    /**
+     * @var \SplFileInfo[] $it
+     */
+    foreach ($it as $file) {
+        if (in_array($file->getBasename(), array('.', '..'))) {
+            continue;
+        } elseif ($file->isDir()) {
+            rmdir($file->getPathname());
+        } elseif ($file->isFile() || $file->isLink()) {
+            unlink($file->getPathname());
+        }
+    }
+}
+
+
+delete(__DIR__ . '/file_queue');
 
 $queue = new Queue($driver);
 

tests/PhpQueueFileTest.php

@@ -7,9 +7,30 @@ class PhpQueueFileTest extends \PhpQueueTestDriver
 {
     private static $connection = 'file_queue';
 
+    private static function delete($path)
+    {
+        $it = new \RecursiveIteratorIterator(
+            new \RecursiveDirectoryIterator($path),
+            \RecursiveIteratorIterator::CHILD_FIRST
+        );
+        /**
+         * @var \SplFileInfo[] $it
+         */
+        foreach ($it as $file) {
+
+            if (in_array($file->getBasename(), array('.', '..'))) {
+                continue;
+            } elseif ($file->isDir()) {
+                rmdir($file->getPathname());
+            } elseif ($file->isFile() || $file->isLink()) {
+                unlink($file->getPathname());
+            }
+        }
+    }
+
     public static function prepareTestExecution()
     {
-        exec('rm -fr ' . self::$connection . '/*');
+        self::delete(self::$connection);
     }
 
     /**
@@ -22,6 +43,6 @@ public static function getQueueDriver()
 
     public static function tearDownAfterClass()
     {
-        exec('rm -fr ' . self::$connection . '/*');
+        self::delete(self::$connection);
     }
 }