OMS/app/base/lib/package.php

<?php
/**
 * Copyright 2012-2026 ShopeX (https://www.shopex.cn)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */


class base_package implements Iterator{
    
    static function walk($file){
        $obj = new base_package;
        $obj->open($file);
        $obj->filename = $file;
        return $obj;
    }
    
    /**
     * open
     * @param mixed $file file
     * @return mixed 返回值
     */
    public function open($file){
        $this->rs = fopen($file,'rb');
        $this->maxsize = filesize($file);
    }
    
    /**
     * rewind
     * @return mixed 返回值
     */
    public function rewind() {
        $this->offset = 0;
    }

    /**
     * valid
     * @return mixed 返回值
     */
    public function valid() {
        if($this->offset > $this->maxsize){
            return false;
        }
        fseek($this->rs,$this->offset);
        $this->block = fread($this->rs,512);
        if($this->block){
            if($this->block==str_repeat(chr(0),512)){
                return false;
            }else{
                return true;
            }
        }
        return true;
    }

    /**
     * current
     * @return mixed 返回值
     */
    public function current() {
        $data = unpack('a100filename/a8mode/a8uid/a8gid/a12size/a12mtime/a8checksum/a1typeflag/a100link/a6magic/a2version/a32uname/a32gname/a8devmajor/a8devminor', $this->block);
        $file = array();
        $file['name'] = trim($data['filename']); 
        $file['mode'] = OctDec(trim($data['mode'])); 
        $file['uid'] = OctDec(trim($data['uid'])); 
        $file['gid'] = OctDec(trim($data['gid'])); 
        $file['size'] = OctDec(trim($data['size'])); 
        $file['mtime'] = OctDec(trim($data['mtime'])); 
        $file['checksum'] = OctDec(trim($data['checksum']));
        if($file['checksum']!=$this->checksum($this->block)){
            trigger_error('Bad tar format: '.$this->filename,E_USER_ERROR);
            return false;
        }
        
        $file['type'] = $data['typeflag'];
        $file['offset'] = $this->offset+512;
        $file['rs'] = &$this->rs;
        $this->item = $file;
        $this->block = null;
        return $this->item;
    }

    /**
     * key
     * @return mixed 返回值
     */
    public function key() {
        return $this->item['name'];
    }

    /**
     * next
     * @return mixed 返回值
     */
    public function next() {
        $this->offset += 512 + (ceil($this->item['size'] / 512 ) * 512);
        return 1;
    }
    
    private function checksum($bytestring) {
        $unsigned_chksum = 0;
        for($i=0; $i<512; $i++)
            $unsigned_chksum += ord($bytestring[$i]);
        for($i=0; $i<8; $i++)
            $unsigned_chksum -= ord($bytestring[148 + $i]);
        $unsigned_chksum += ord(" ") * 8;

        return $unsigned_chksum;
    }
    
    static function extra($file,$dir){
        $filename = $dir.'/'.$file['name'];
        $dirname = dirname($filename);
        if(!file_exists($dirname)){
            utils::mkdir_p($dirname);
        }
        if($file['type']=='0'){
            fseek($file['rs'],$file['offset']);
            $rs = fopen($filename,'w');
            $output = 0;
            while($output<$file['size']){
                $read = min($file['size']-$output,1024);
                fputs($rs,fread($file['rs'],$read));
                $output+=$read;
            }
            fclose($rs);
            touch($filename,$file['mtime']);
        }
    }
    
}