<?php
class CFACreator {
private $source;
private $pw;
public function __construct($source) {
if (!file_exists($source)) {
throw new Exception($source." not found.");
}
if (!is_dir($source)) {
throw new Exception("There is no need to pack a single file.");
}
if (substr($source, strlen($source)-1)!="\\" && substr($source, strlen($source)-1)!="/") $source.="/";
$this->source=$source;
}
public function setPassword($pw) {
$this->pw=$pw;
}
public function packTo($file, $crypt=false) {
$files=$this->listDir($this->source);
if ($crypt) {
$out_stream=tmpfile();
} else {
$out_stream=fopen($file, "w+");
fwrite($out_stream, "r");
}
foreach ($files as $name=>$size) {
$name=gzcompress($name);
fwrite($out_stream, $this->compress(strlen($name)));
fwrite($out_stream, chr(255));
fwrite($out_stream, $name);
fwrite($out_stream, $this->compress($size));
fwrite($out_stream, chr(255));
}
fwrite($out_stream, chr(255));
foreach ($files as $name=>$size) {
$fp=fopen($this->source.$name, "r+");
while ($size>=100) {
fwrite($out_stream, fread($fp, 100));
$size-=100;
}
if ($size!=0) fwrite($out_stream, fread($fp, $size));
}
if ($crypt) {
rewind($out_stream);
$tmp=$out_stream;
$out_stream=fopen($file, "w+");
fwrite($out_stream, "c");
$iv=$this->pw;
if (strlen($iv)>8) {
$iv=substr($iv, 0, 8);
} elseif (strlen($iv)<8) {
$num=round(8/strlen($iv))+1;
$iv=str_repeat($iv, $num);
$iv=substr($iv, 0, 8);
}
while (!feof($tmp)) {
$part=fread($tmp, 100);
$part=mcrypt_encrypt(MCRYPT_BLOWFISH, $this->pw, $part, "cbc", $iv);
$part=base64_encode($part);
fwrite($out_stream, $part);
}
fclose($tmp);
}
fclose($out_stream);
}
private function listDir($path, $is_root=true, $root=null) {
$files=array();
if (substr($path, strlen($path)-1)!="\\" && substr($path, strlen($path)-1)!="/") $path.="/";
if ($root==null && $is_root) $root=$path;
if ($dir=opendir($path)) {
while ($file=readdir($dir)) {
if ($file!=".." && $file!=".") {
if (is_dir($path.$file)) {
$ar=$this->listDir($path.$file, false, $root);
$files=array_merge($files, $ar);
} else {
if ($is_root) {
$name=$file;
} else {
$name=substr($path.$file, strlen($root));
}
$files[$name]=filesize($path.$file);
}
}
}
closedir($dir);
return $files;
} else {
throw new Exception("Could not open ".$path);
}
}
public static function compress($int) {
$comp="";
$full=0;
while ($int>=253) {
if ($full==253) {
$comp.=chr(253);
$full=0;
}
$full++;
$int-=253;
}
if ($full!=0) $comp.=chr($full);
$comp.=chr(254);
if ($int!=0) $comp.=chr($int);
return $comp;
}
}
class CFAExtractor {
private $path;
private $pw;
public function __construct($path) {
if (!file_exists($path)) {
throw new Exception($path." not found.");
}
$this->path=$path;
}
public function setPassword($pw) {
$this->pw=$pw;
}
public function extractTo($path) {
if (!file_exists($this->path)) {
throw new Exception($path." not found.");
}
if (substr($path, strlen($path)-1)!="\\" && substr($path, strlen($path)-1)!="/") $path.="/";
$in_stream=fopen($this->path, "r");
$mode=fread($in_stream, 1);
if ($mode!="c" && $mode!="r") {
fclose($in_stream);
throw new Exception("Invalid file given.");
}
if ($mode=="c") {
// crypted file
if ($this->pw==null) {
throw new Exception("File encrypted but no password given!");
}
$iv=$this->pw;
if (strlen($iv)>8) {
$iv=substr($iv, 0, 8);
} elseif (strlen($iv)<8) {
$num=round(8/strlen($iv))+1;
$iv=str_repeat($iv, $num);
$iv=substr($iv, 0, 8);
}
$tmp_file=tmpfile();
while (!feof($in_stream)) {
$part=fread($in_stream, 136);
$part=base64_decode($part);
$part=mcrypt_decrypt(MCRYPT_BLOWFISH, $this->pw, $part, "cbc", $iv);
fwrite($tmp_file, $part);
}
fclose($in_stream);
rewind($tmp_file);
$in_stream=$tmp_file;
}
$files=array();
$ci=ord(fread($in_stream, 1));
while ($ci!=255) {
$name_length="";
while ($ci!=255) {
$name_length.=chr($ci);
$ci=ord(fread($in_stream, 1));
}
$name_length=$this->uncompress($name_length);
$name=gzuncompress(fread($in_stream, $name_length));
$size="";
$ci=ord(fread($in_stream, 1));
while ($ci!=255) {
$size.=chr($ci);
$ci=ord(fread($in_stream, 1));
}
$size=$this->uncompress($size);
$files[$name]=$size;
$ci=ord(fread($in_stream, 1));
}
$this->mkdir($path);
foreach ($files as $name=>$size) {
$this->mkdir(dirname($path.$name));
$fp=fopen($path.$name, "w+");
if (!$fp) {
throw new Exception("Could not create ".$path.$name);
}
while ($size>=100) {
fwrite($fp, fread($in_stream, 100));
$size-=100;
}
if ($size!=0) fwrite($fp, fread($in_stream, $size));
fclose($fp);
}
fclose($in_stream);
}
public static function mkdir($path, $rights=0777) {
if (file_exists($path)) return;
$path=str_replace("\\", "/", $path);
if (substr($path, strlen($path)-1)=="/") $path=substr($path, 0, strlen($path)-1);
$prev=strrpos($path, "/");
$prev=substr($path, 0, $prev);
if (!file_exists($prev)) {
self::mkdir($prev, $rights);
}
mkdir($path);
}
public static function uncompress($bytes) {
$j=strlen($bytes)-1;
$full=0;
$c=-1;
$i=0;
$c=ord($bytes[0]);
while ($c!=254 && $i!=$j) {
$full+=$c;
$i++;
$c=ord($bytes[$i]);
}
$size=$full*253;
$i++;
while ($i<=$j) {
$c=$bytes[$i];
$size+=ord($c);
$i++;
}
return $size;
}
}
class CFAFile {
private $filename;
private $filelist=array();
private $passsword;
public function __construct($filename, $pw=null) {
$this->filename=$filename;
$this->password=$pw;
if (file_exists($filename)) {
$in_stream=fopen($filename, "r");
$mode=fread($in_stream, 1);
if ($mode=="c") {
} elseif ($mode!="r") {
throw new Exception("Invalid file given.");
}
$ci=ord(fread($in_stream, 1));
$pos=0;
$files=array();
$buffer_size=2;
while ($ci!=255) {
$name_length="";
while ($ci!=255) {
$name_length.=chr($ci);
$ci=ord(fread($in_stream, 1));
$buffer_size++;
}
$name_length=$this->uncompress($name_length);
$name=gzuncompress(fread($in_stream, $name_length));
$buffer_size+=$name_length;
$size="";
$ci=ord(fread($in_stream, 1));
$buffer_size++;
while ($ci!=255) {
$size.=chr($ci);
$ci=ord(fread($in_stream, 1));
$buffer_size++;
}
$size=$this->uncompress($size);
$files[]=array(
"name"=>$name,
"size"=>$size,
"pos"=>$pos
);
$pos+=$size;
$ci=ord(fread($in_stream, 1));
$buffer_size++;
}
fclose($in_stream);
foreach($files as $info) {
$this->filelist[]=new CFAEntry($info["name"], $filename, $info["size"], $info["pos"]+$buffer_size);
$buffer_size+=$info["size"];
}
}
}
public function getFileList() {
return $this->filelist;
}
public function remove($s_entry) {
$found=false;
foreach ($this->filelist as $k=>$entry) {
if ($entry===$s_entry) {
$found=true;
unset($this->filelist[$k]);
}
}
if ($found) $this->filelist=array_merge($this->filelist, array());
}
public function add($entry) {
if (!$entry instanceof CFAEntry) return;
$this->filelist[]=$entry;
}
public function flushToFile() {
if ($this->password!=null) {
$stream=tmpfile();
} else {
$stream=fopen($this->filename, "w+");
fwrite($stream, "r");
}
foreach ($this->filelist as $entry) {
$name=gzcompress($entry->getName());
fwrite($stream, $this->compress(strlen($name)));
fwrite($stream, chr(255));
fwrite($stream, $name);
fwrite($stream, $this->compress($entry->getSize()));
fwrite($stream, chr(255));
}
fwrite($stream, chr(255));
foreach ($this->filelist as $entry) {
$handle=$entry->getFileHandle();
$POS=ftell($handle);
rewind($handle);
while (!feof($handle)) {
fwrite($stream, fread($handle, 1));
}
fseek($handle, $POS);
}
}
public static function uncompress($bytes) {
$j=strlen($bytes)-1;
$full=0;
$c=-1;
$i=0;
$c=ord($bytes[0]);
while ($c!=254 && $i!=$j) {
$full+=$c;
$i++;
$c=ord($bytes[$i]);
}
$size=$full*253;
$i++;
while ($i<=$j) {
$c=$bytes[$i];
$size+=ord($c);
$i++;
}
return $size;
}
public static function compress($int) {
$comp="";
$full=0;
while ($int>=253) {
if ($full==253) {
$comp.=chr(253);
$full=0;
}
$full++;
$int-=253;
}
if ($full!=0) $comp.=chr($full);
$comp.=chr(254);
if ($int!=0) $comp.=chr($int);
return $comp;
}
}
class CFAEntry {
private $sourcefile="unknown";
private $filename;
private $size=-1;
private $start="unknown";
private $handle;
// 1 - Existiert, 2 - Muss erstellt werden
private $mode=-1;
public function __construct($name, $sourcefile=null, $size=null, $start=null) {
if ($sourcefile==null) {
$this->filename=$name;
$this->mode=2;
} else {
if (!file_exists($sourcefile)) {
throw new Exception($sourcefile." not found.");
}
$this->sourcefile=$sourcefile;
$this->filename=$name;
$this->size=$size;
$this->start=$start;
$this->mode=1;
}
}
public function __destruct() {
if ($this->handle!=null) fclose($this->handle);
}
public function getSize() {
if ($this->handle==null) {
if ($this->size!=-1) return $this->size;
return 0;
} else {
$info=fstat($this->handle);
return $info["size"];
}
}
public function getName() {
return $this->filename;
}
public function getSourcefile() {
return $this->sourcefile;
}
public function getFileHandle() {
if ($this->handle==null) {
$this->handle=tmpfile();
if ($this->mode==1) {
$nsize=(int) "".$this->size;
$sf_stream=fopen($this->sourcefile, "r");
fseek($sf_stream, $this->start);
while ($nsize>=100) {
fwrite($this->handle, fread($sf_stream, 100));
$nsize-=100;
}
if ($nsize!=0) fwrite($this->handle, fread($sf_stream, $nsize));
fclose($sf_stream);
rewind($this->handle);
}
}
return $this->handle;
}
}
?>
|
Download
