#6265 - Zip todo

Erdogan Furkan
1 parent 8a8df0ca
Showing 7 changed files with 247 additions and 0 deletions Show diff stats
src/FunctionTypeEnumClass.php
src/InputOutput/IHMImpl/DownloadObject/IHMInputOutputDownloadObjectClass.php
src/InputOutput/IHMImpl/IHMInputOutputClass.php
src/Request/DownloadObjectRequestClass.php
src/Request/DownloadObjectRequestDataClass.php
src/RequestManagerClass.php
src/amdaintegration_autoload.php
@@ -18,6 +18,7 @@ abstract class FunctionTypeEnumClass
 	const TTMERGE            = "tt_merge";
 	const TTUNION            = "tt_union";
 	const TTCONVERT          = "tt_convert";
+	const DLOBJECT           = "download_object";
 	const PARAMINFO          = "param_info";
         const USERWSINIT         = "user_init";
 }
@@ -0,0 +1,49 @@
+<?php
+
+/**
+ * @class IHMInputOutputDownloadObjectClass
+ * @brief Class that's implement an InputOutputInterface used to treat a get download object request
+ * @details
+ */
+class IHMInputOutputDownloadObjectClass implements InputOutputInterface
+{
+    public function getInputData($input, $function, $requestId = ""){
+
+        $this->downloadObjectData = new DownloadObjectRequestDataClass();
+
+        if($input->nodeType == "download" && $input->downloadSrc == "2")
+        {
+            // Set type
+            $this->downloadObjectData->setType(DownloadObjectTypeEnumClass::ASTROIMG);
+
+            // Set tmp directory
+            $this->downloadObjectData->setTmpDir(IHMConfigClass::getRequestPath());
+
+            // Set compression format
+            if($input->compression == DownloadObjectFormatEnumClass::ZIP)
+                $this->downloadObjectData->setCompressionFormat(DownloadObjectFormatEnumClass::ZIP);
+
+             // Set list of links to download   
+            if(sizeof($input->list) > 0){
+                $this->downloadObjectData->setList($input->list);
+            }
+            
+        }
+        return $this->downloadObjectData;
+        
+    }
+    public function getOutput($data)
+	{
+        $result = NULL;
+        if($data->getResult() != NULL){
+            if($data->getType() == DownloadObjectTypeEnumClass::ASTROIMG && $data->getCompression() == DownloadObjectFormatEnumClass::ZIP){
+
+                $result = array(
+                    "success" => true,
+                    "download" => $data->getResult()
+                );
+            }
+        }
+        return $result;
+    }
+}
 \ No newline at end of file
@@ -111,6 +111,9 @@ class IHMInputOutputClass implements InputOutputInterface
 			case FunctionTypeEnumClass::PARAMINFO :
 				$this->inputOutput = new IHMInputOutputParamInfoClass();
 				break;
+			case FunctionTypeEnumClass::DLOBJECT :
+				$this->inputOutput = new IHMInputOutputDownloadObjectClass();
+				break;
 			case FunctionTypeEnumClass::USERWSINIT :
 				return $this->userWSMgr->init();
 			default :
@@ -0,0 +1,101 @@
+<?php
+
+/**
+ * @class DownloadObjectRequestClass
+ * @brief Class used for a download request 
+ * @details
+ */
+class DownloadObjectRequestClass extends RequestAbstractClass
+{
+
+    /*
+	 * @brief Init a donwload object request
+	*/
+    public function init(){ 
+        if (!isset($this->requestData))
+			return false;
+        return true;
+    }
+
+    public function run(){ 
+
+        // Create a temporary directory to store the files
+
+        $tempDir = $this->requestData->getTmpDir().'/curl_files_'. uniqid();
+        mkdir($tempDir);
+
+        // Array to hold the paths of the downloaded files
+        $filePaths = array();
+
+        $fileList = $this->requestData->getList();
+        foreach($fileList as $fileData){
+
+            $filePaths[] = $this->curlFile($fileData, $tempDir);
+        }
+        $zipFilePath = $filePaths[0]; // $this->zipFiles($filePaths, $tempDir); // fonctionne pas pour le moment.
+
+        $basePath = '/home/amda_admin/AMDA/AMDA_IHM/';
+
+        $zipFilePath = str_replace($basePath, '', $zipFilePath);
+        $this->requestData->setResult($zipFilePath);
+        $this->requestData->setSuccess(true);
+
+        return  $this->requestData->getSuccess();
+    }
+
+    public function curlFile($fileData, $tempDir){
+         // Initialize cURL session
+        $ch = curl_init($fileData->url);
+        // Set cURL options
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
+        
+        // Execute cURL request
+        $content = curl_exec($ch);
+
+         // Check for cURL errors
+         if (curl_errno($ch)) {
+            echo 'cURL error: ' . curl_error($ch);
+            curl_close($ch);
+            return false;
+        }
+
+         // Close cURL session
+         curl_close($ch);
+        // Define the file path
+        $filePath = $tempDir . '/' . basename($fileData->name);
+        file_put_contents($filePath, $content);
+        
+        // Store the file path
+        return $filePath;
+    }
+
+    public function zipFiles($filePaths, $tempDir){
+    
+        // Create a zip file
+    
+    $zipFilePath = IHMConfigClass::getRequestPath().'/curl_files_'.uniqid() . '.zip';
+    $zip = new ZipArchive();
+    
+    if ($zip->open($zipFilePath, ZipArchive::CREATE) !== TRUE) {
+        exit("Cannot open <$zipFilePath>\n");
+    }
+
+    // Add files to the zip archive
+    foreach ($filePaths as $filePath) {
+        $zip->addFile($filePath, basename($filePath));
+    }
+
+    // Close the zip archive
+    $zip->close();
+
+    // Clean up the temporary files
+    foreach ($filePaths as $filePath) {
+        unlink($filePath);
+    }
+    rmdir($tempDir);
+
+    // Return the path of the zip file
+    return $zipFilePath;
+    }
+}
 \ No newline at end of file
@@ -0,0 +1,90 @@
+<?php
+
+/**
+ * @class DownloadObjectTypeEnumClass
+ * @brief Enumerate for download request type
+ * @details
+ */
+abstract class DownloadObjectTypeEnumClass
+{
+	const UNKNOWN  = "";
+    const ASTROIMG = "astro_image";
+}
+
+/**
+ * @class DownloadObjectFormatEnumClass
+ * @brief Enumerate for download extention request type
+ * @details
+ */
+abstract class DownloadObjectFormatEnumClass
+{
+	const UNKNOWN  = "";
+    const ZIP = "zip";
+}
+
+
+/**
+ * @class DownloadObjectRequestDataClass
+ * @brief Data for a download request
+ * @details
+ */
+class DownloadObjectRequestDataClass extends RequestDataClass
+{
+    private $type    = DownloadObjectTypeEnumClass::UNKNOWN;
+    private $list = NULL;
+    private $compression = DownloadObjectFormatEnumClass::ZIP;
+	private $tmpDir = "";
+	private $result = NULL;
+
+
+    public function getType()
+	{
+		return $this->type;
+	}
+
+	public function setType($type)
+	{
+		$this->type = $type;
+	}
+
+    public function getList()
+	{
+		return $this->list;
+	}
+
+	public function setList($list)
+	{
+		$this->list = $list;
+	}
+
+	public function getTmpDir()
+	{
+		return $this->tmpDir;
+	}
+
+	public function setTmpDir($tmpDir)
+	{
+		$this->tmpDir = $tmpDir;
+	}
+
+	public function getResult()
+	{
+		return $this->result;
+	}
+
+	public function setResult($result)
+	{
+		$this->result = $result;
+	}
+
+    public function getCompressionFormat()
+	{
+		return $this->compression;
+	}
+
+	public function setCompressionFormat($compression)
+	{
+		$this->compression = $compression;
+	}
+
+}
 \ No newline at end of file
@@ -84,6 +84,8 @@ Class RequestManagerClass
 				return new ParamInfoRequestClass($user, $userHost);
 			case FunctionTypeEnumClass::USERWSINIT :
 				return new UserRequestClass($user, $userHost);
+			case FunctionTypeEnumClass::DLOBJECT :
+				return new DownloadObjectRequestClass($user, $userHost);
 			default :
 				throw new Exception('Request '.$function.' not implemented.');
 		}
@@ -23,6 +23,7 @@ class AutoloadData {
 				'InputOutput/IHMImpl/Params/GenInfoParamImpl',
 				'InputOutput/IHMImpl/Process',
 				'InputOutput/IHMImpl/ParamInfo',
+				'InputOutput/IHMImpl/DownloadObject',
 				'InputOutput/IHMImpl/Tools',
 				'InputOutput/IHMImpl/TimeTables',
 				'InputOutput/TestImpl',