v3 preparations

2025-11-16 13:08:01 +00:00 · 2025-05-06 14:18:36 +02:00
parent 815895a524
commit 956368e444
1099 changed files with 82590 additions and 10 deletions
--- a/src/storage-controllers/ftp.controller.php
+++ b/src/storage-controllers/ftp.controller.php
@@ -0,0 +1,145 @@
+<?php 
+
+class FTPStorage implements StorageController
+{
+    private $connection;
+    private $login;
+
+    function __destruct()
+    {
+        if($this->connection)
+        ftp_close($this->connection);
+    }
+
+    function connect()
+    {
+        if(!$this->connection)
+        {
+            if(defined('FTP_SSL') && FTP_SSL === true)
+                $this->connection = ftp_ssl_connect(FTP_SERVER, ((defined('FTP_SSL') && is_numeric(FTP_PORT))?FTP_PORT:21) );
+            else
+                $this->connection = ftp_connect(FTP_SERVER, ((defined('FTP_SSL') && is_numeric(FTP_PORT))?FTP_PORT:21) );
+        }
+        if($this->connection && !$this->login)
+        {
+            $this->login = ftp_login($this->connection, FTP_USER, FTP_PASS);
+
+            if( (defined('FTP_PASSIVEMODE') && FTP_PASSIVEMODE === true) || !defined('FTP_PASSIVEMODE') )
+            {
+                ftp_set_option($this->connection, FTP_USEPASVADDRESS, false);
+                ftp_pasv($this->connection, TRUE);
+            }
+            else 
+                ftp_pasv($this->connection, false);
+            
+        }
+
+        // Was the connection successful?
+        if ((!$this->connection) || (!$this->login)) {
+            $this->connection = false;
+            return false;
+        }
+        return true;
+    }
+
+    function isEnabled()
+    {
+        return (defined('FTP_SERVER') && FTP_SERVER &&
+        defined('FTP_USER') && FTP_USER &&
+        defined('FTP_PASS') && FTP_PASS);
+    }
+    
+    function hashExists($hash)
+    {
+        if(!$this->connect()) return null;
+        $subdir = $this->hashToDir($hash);
+        $ftpfilepath = FTP_BASEDIR.$subdir.'/'.$hash;
+        if(@ftp_chdir($this->connection, FTP_BASEDIR.$subdir))
+            return (ftp_size($this->connection,$ftpfilepath)>0?true:false);
+        return false;
+    }
+
+    function getItems($dev=false)
+    {
+        if(!$this->connect()) return false;
+        return $this->ftp_list_files_recursive(FTP_BASEDIR,$dev);
+    }
+
+    function pullFile($hash,$location)
+    {
+        if(!$this->connect()) return false;
+        $subdir = $this->hashToDir($hash);
+        $ftpfilepath = FTP_BASEDIR.$subdir.'/'.$hash;
+        return ftp_get($this->connection, $location, $ftpfilepath, FTP_BINARY);
+    }
+
+    function pushFile($source,$hash)
+    {
+        if(!$this->connect()) return false;
+        $subdir = $this->hashToDir($hash);
+        $ftpfilepath = FTP_BASEDIR.$subdir.'/'.$hash;
+        $this->ftp_mksubdirs($subdir);
+
+        return ftp_put($this->connection, $ftpfilepath, $source, FTP_BINARY);
+    }
+
+    function deleteFile($hash) 
+    {
+        if(!$this->connect()) return false;
+        $subdir = $this->hashToDir($hash);
+        $ftpfilepath = FTP_BASEDIR.$subdir.'/'.$hash;
+        return (ftp_delete($this->connection,$ftpfilepath)?true:false);
+    }
+
+    function hashToDir($hash)
+    {
+        $md5 = md5($hash);
+        $dir = $md5[0].'/'.$md5[1].'/'.$md5[2];
+
+        return $dir;
+    }
+
+    function ftp_mksubdirs($ftpath)
+    {
+        if(!$this->connect()) return false;
+        @ftp_chdir($this->connection, FTP_BASEDIR); 
+        $parts = array_filter(explode('/',$ftpath), function($value) {
+            return ($value !== null && $value !== false && $value !== ''); 
+        });
+        foreach($parts as $part){
+            $part = strval($part);
+        if(!@ftp_chdir($this->connection, $part)){
+            ftp_mkdir($this->connection, $part);
+            ftp_chdir($this->connection, $part);
+        }
+        }
+    }
+
+    function ftp_list_files_recursive($path,$dev=false)
+    {
+        if(!$this->connect()) return false;
+        $items = ftp_mlsd($this->connection, $path);
+        $result = array();
+
+        if(is_array($items))
+        foreach ($items as $item)
+        {
+            $name = $item['name'];
+            $type = $item['type'];
+            $filepath = $path.'/'. $name;
+
+            if ($type == 'dir')
+            {
+                $result =
+                    array_merge($result, $this->ftp_list_files_recursive($filepath,$dev));
+            }
+            else if(mightBeAHash($name) || endswith($name,'.enc'))
+            {
+                $result[] = $name;
+                if($dev===true) echo "      Got $name                  \r";
+            }
+        }
+        
+        return $result;
+    }
+}