23s2s

✏️ Editing: Gzip.php

<?php

namespace JetBackup\Archive;

use JetBackup\DirIterator\DirIteratorFile;
use JetBackup\Exception\GzipException;

if (!defined( '__JETBACKUP__')) die('Direct access is not allowed');

/**
 * Class for compressing files using gzip.
 */
class Gzip {

const DEFAULT_COMPRESS_CHUNK_SIZE = 10485760; // 10MB
	const DEFAULT_DECOMPRESS_CHUNK_SIZE = 1048576; // 1MB
	const DEFAULT_COMPRESSION_LEVEL = -1;

private function __construct() {}

/**
	 * @throws GzipException
	 */
	private static function _getInfo($file) {
		$info = new \stdClass();
		if(file_exists($file)) {
			$info = json_decode(file_get_contents($file));
			if($info === false) throw new GzipException("Failed fetching compress information");
		}
		return $info;
	}

/**
	 * @param $file
	 * @param $data
	 *
	 * @return void
	 * @throws GzipException
	 */
	private static function _putInfo($file, $data) {
		$tempFile = $file . '.tmp';
		$jsonData = json_encode($data);
		if ($jsonData === false) {
			throw new GzipException("Failed to encode compress information");
		}

if (file_put_contents($tempFile, $jsonData) === false) {
			throw new GzipException("Failed to write compress information to temporary file");
		}

if (!rename($tempFile, $file)) {
			throw new GzipException("Failed to atomically write compress information");
		}
	}

/**
	 * @throws GzipException
	 */
	public static function compress($file, $chunkSize=self::DEFAULT_COMPRESS_CHUNK_SIZE, $compressionLevel=self::DEFAULT_COMPRESSION_LEVEL, ?callable $callback=null) {
		if(!file_exists($file) || !is_file($file)) throw new GzipException("Source file not found");

$target = $file . '.gz';

$info_file = $target . '.compress.info';
		$info = self::_getInfo($info_file);

$fd = fopen($file, 'r');
		$gzfd = fopen($target, 'ab');

$read = $write = 0;
		if(isset($info->fdpos) && $info->fdpos) {
			$read = $info->fdpos;
			fseek($fd, $info->fdpos);
		}
		if(isset($info->fdgzpos) && $info->fdgzpos) {
			$write = $info->fdgzpos;
			fseek($gzfd, $info->fdgzpos);
		}

while(!feof($fd)) {
			$write += fwrite($gzfd, gzencode(fread($fd, $chunkSize), $compressionLevel));
			$read += $chunkSize;

self::_putInfo($info_file, [
				'fdpos'         => $read,
				'fdgzpos'       => $write,
			]);

if($callback) $callback($read, DirIteratorFile::safe_filesize($file));
		}

if(feof($fd)) {
			@unlink($file);
			@unlink($info_file);
		}

fclose($fd);
		fclose($gzfd);
	}

/**
	 * @throws GzipException
	 */
	public static function decompress($file, ?callable $callback=null, $chunkSize=self::DEFAULT_DECOMPRESS_CHUNK_SIZE) {
		if(!file_exists($file) || !is_file($file)) throw new GzipException("Source file not found");

$info_file = $file . '.decompress.info';
		$info = self::_getInfo($info_file);

// remove .gz suffix
		$target = substr($file, 0, -3);

$fd = fopen($target, 'a');
		$gzfd = gzopen($file, 'rb');

$read = $write = 0;
		if(isset($info->fdpos) && $info->fdpos) {
			$write = $info->fdpos;
			fseek($fd, $info->fdpos);
		}

if(isset($info->fdgzpos) && $info->fdgzpos) {
			$read = $info->fdgzpos;
			gzseek($gzfd, $info->fdgzpos);
		}

while(!feof($gzfd)) {
			$write += fwrite($fd, gzread($gzfd, $chunkSize));
			$read += $chunkSize;

self::_putInfo($info_file, [
				'fdpos'         => $write,
				'fdgzpos'       => $read,
			]);

if($callback) $callback(
				'Gzip',
				'Decompressing',
				(int) (DirIteratorFile::safe_filesize($file) * 3),  // estimating X3 compression ratio, just for percentage calc
				$read)
			;
		}

if(feof($gzfd)) {
			@unlink($file);
			@unlink($info_file);
		}

fclose($fd);
		gzclose($gzfd);
	}
}

Sid Gifari From Gifari Industries - BD Cyber Security Team