Edit File by line

<?php

[0] Fix | Delete

[1] Fix | Delete

if (!defined('ABSPATH')) exit;

[2] Fix | Delete

if (!class_exists('BVFSCallback')) :

[3] Fix | Delete

require_once dirname( __FILE__ ) . '/../streams.php';

[4] Fix | Delete

[5] Fix | Delete

class BVFSCallback extends BVCallbackBase {

[6] Fix | Delete

public $stream;

[7] Fix | Delete

public $account;

[8] Fix | Delete

[9] Fix | Delete

public static $cwAllowedFiles = array(".htaccess", ".user.ini", "malcare-waf.php");

[10] Fix | Delete

const FS_WING_VERSION = 1.2;

[11] Fix | Delete

[12] Fix | Delete

public function __construct($callback_handler) {

[13] Fix | Delete

$this->account = $callback_handler->account;

[14] Fix | Delete

}

[15] Fix | Delete

[16] Fix | Delete

function fileStat($relfile, $md5 = false) {

[17] Fix | Delete

$absfile = ABSPATH.$relfile;

[18] Fix | Delete

$fdata = array();

[19] Fix | Delete

$fdata["filename"] = $relfile;

[20] Fix | Delete

$stats = @stat($absfile);

[21] Fix | Delete

if ($stats) {

[22] Fix | Delete

foreach (preg_grep('#size|uid|gid|mode|mtime#i', array_keys($stats)) as $key ) {

[23] Fix | Delete

$fdata[$key] = $stats[$key];

[24] Fix | Delete

}

[25] Fix | Delete

if (is_link($absfile)) {

[26] Fix | Delete

$fdata["link"] = @readlink($absfile);

[27] Fix | Delete

}

[28] Fix | Delete

if ($md5 === true && !is_dir($absfile)) {

[29] Fix | Delete

$fdata["md5"] = $this->calculateMd5($absfile, array(), 0, 0, 0);

[30] Fix | Delete

}

[31] Fix | Delete

} else {

[32] Fix | Delete

$fdata["failed"] = true;

[33] Fix | Delete

}

[34] Fix | Delete

return $fdata;

[35] Fix | Delete

}

[36] Fix | Delete

[37] Fix | Delete

function scanFilesUsingGlob($initdir = "./", $offset = 0, $limit = 0, $bsize = 512, $recurse = true, $regex = '{.??,}*') {

[38] Fix | Delete

$i = 0;

[39] Fix | Delete

$dirs = array();

[40] Fix | Delete

$dirs[] = $initdir;

[41] Fix | Delete

$bfc = 0;

[42] Fix | Delete

$bfa = array();

[43] Fix | Delete

$current = 0;

[44] Fix | Delete

$abspath = realpath(ABSPATH).'/';

[45] Fix | Delete

$abslen = strlen($abspath);

[46] Fix | Delete

# XNOTE: $recurse cannot be used directly here

[47] Fix | Delete

while ($i < count($dirs)) {

[48] Fix | Delete

$dir = $dirs[$i];

[49] Fix | Delete

[50] Fix | Delete

foreach (glob($abspath.$dir.$regex, GLOB_NOSORT | GLOB_BRACE) as $absfile) {

[51] Fix | Delete

$relfile = substr($absfile, $abslen);

[52] Fix | Delete

if (is_dir($absfile) && !is_link($absfile)) {

[53] Fix | Delete

$dirs[] = $relfile."/";

[54] Fix | Delete

}

[55] Fix | Delete

$current++;

[56] Fix | Delete

if ($offset >= $current)

[57] Fix | Delete

continue;

[58] Fix | Delete

if (($limit != 0) && (($current - $offset) > $limit)) {

[59] Fix | Delete

$i = count($dirs);

[60] Fix | Delete

break;

[61] Fix | Delete

}

[62] Fix | Delete

$bfa[] = $this->fileStat($relfile);

[63] Fix | Delete

$bfc++;

[64] Fix | Delete

if ($bfc == $bsize) {

[65] Fix | Delete

$str = serialize($bfa);

[66] Fix | Delete

$this->stream->writeStream($str);

[67] Fix | Delete

$bfc = 0;

[68] Fix | Delete

$bfa = array();

[69] Fix | Delete

}

[70] Fix | Delete

}

[71] Fix | Delete

$regex = '{.??,}*';

[72] Fix | Delete

$i++;

[73] Fix | Delete

if ($recurse == false)

[74] Fix | Delete

break;

[75] Fix | Delete

}

[76] Fix | Delete

if ($bfc != 0) {

[77] Fix | Delete

$str = serialize($bfa);

[78] Fix | Delete

$this->stream->writeStream($str);

[79] Fix | Delete

}

[80] Fix | Delete

return array("status" => "done");

[81] Fix | Delete

}

[82] Fix | Delete

[83] Fix | Delete

function scanFiles($initdir = "./", $offset = 0, $limit = 0, $bsize = 512, $recurse = true, $md5 = false) {

[84] Fix | Delete

$i = 0;

[85] Fix | Delete

$links = array();

[86] Fix | Delete

$dirs = array();

[87] Fix | Delete

$dirs[] = $initdir;

[88] Fix | Delete

$bfc = 0;

[89] Fix | Delete

$bfa = array();

[90] Fix | Delete

$current = 0;

[91] Fix | Delete

while ($i < count($dirs)) {

[92] Fix | Delete

$dir = $dirs[$i];

[93] Fix | Delete

$d = @opendir(ABSPATH.$dir);

[94] Fix | Delete

if ($d) {

[95] Fix | Delete

while (($file = readdir($d)) !== false) {

[96] Fix | Delete

if ($file == '.' || $file == '..') { continue; }

[97] Fix | Delete

$relfile = $dir.$file;

[98] Fix | Delete

$absfile = ABSPATH.$relfile;

[99] Fix | Delete

if (is_link($absfile)) {

[100] Fix | Delete

$links[] = $relfile;

[101] Fix | Delete

}

[102] Fix | Delete

if (is_dir($absfile) && !is_link($absfile)) {

[103] Fix | Delete

$dirs[] = $relfile."/";

[104] Fix | Delete

}

[105] Fix | Delete

$current++;

[106] Fix | Delete

if ($offset >= $current)

[107] Fix | Delete

continue;

[108] Fix | Delete

if (($limit != 0) && (($current - $offset) > $limit)) {

[109] Fix | Delete

$i = count($dirs);

[110] Fix | Delete

break;

[111] Fix | Delete

}

[112] Fix | Delete

$bfa[] = $this->fileStat($relfile, $md5);

[113] Fix | Delete

$bfc++;

[114] Fix | Delete

if ($bfc == $bsize) {

[115] Fix | Delete

$str = serialize($bfa);

[116] Fix | Delete

$this->stream->writeStream($str);

[117] Fix | Delete

$bfc = 0;

[118] Fix | Delete

$bfa = array();

[119] Fix | Delete

}

[120] Fix | Delete

}

[121] Fix | Delete

closedir($d);

[122] Fix | Delete

}

[123] Fix | Delete

$i++;

[124] Fix | Delete

if ($recurse == false)

[125] Fix | Delete

break;

[126] Fix | Delete

}

[127] Fix | Delete

if ($bfc != 0) {

[128] Fix | Delete

$str = serialize($bfa);

[129] Fix | Delete

$this->stream->writeStream($str);

[130] Fix | Delete

}

[131] Fix | Delete

[132] Fix | Delete

return $links;

[133] Fix | Delete

}

[134] Fix | Delete

[135] Fix | Delete

function calculateMd5($absfile, $fdata, $offset, $limit, $bsize) {

[136] Fix | Delete

if ($offset == 0 && $limit == 0) {

[137] Fix | Delete

$md5 = md5_file($absfile);

[138] Fix | Delete

} else {

[139] Fix | Delete

if ($limit == 0)

[140] Fix | Delete

$limit = $fdata["size"];

[141] Fix | Delete

if ($offset + $limit < $fdata["size"])

[142] Fix | Delete

$limit = $fdata["size"] - $offset;

[143] Fix | Delete

$handle = fopen($absfile, "rb");

[144] Fix | Delete

$ctx = hash_init('md5');

[145] Fix | Delete

fseek($handle, $offset, SEEK_SET);

[146] Fix | Delete

$dlen = 1;

[147] Fix | Delete

while (($limit > 0) && ($dlen > 0)) {

[148] Fix | Delete

if ($bsize > $limit)

[149] Fix | Delete

$bsize = $limit;

[150] Fix | Delete

$d = fread($handle, $bsize);

[151] Fix | Delete

$dlen = strlen($d);

[152] Fix | Delete

hash_update($ctx, $d);

[153] Fix | Delete

$limit -= $dlen;

[154] Fix | Delete

}

[155] Fix | Delete

fclose($handle);

[156] Fix | Delete

$md5 = hash_final($ctx);

[157] Fix | Delete

}

[158] Fix | Delete

return $md5;

[159] Fix | Delete

}

[160] Fix | Delete

[161] Fix | Delete

function getFilesContent($files, $withContent = true) {

[162] Fix | Delete

$result = array();

[163] Fix | Delete

foreach ($files as $file) {

[164] Fix | Delete

$fdata = $this->fileStat($file);

[165] Fix | Delete

$absfile = ABSPATH.$file;

[166] Fix | Delete

[167] Fix | Delete

if (is_dir($absfile) && !is_link($absfile)) {

[168] Fix | Delete

$fdata['is_dir'] = true;

[169] Fix | Delete

} else {

[170] Fix | Delete

if (!is_readable($absfile)) {

[171] Fix | Delete

$fdata['error'] = 'file not readable';

[172] Fix | Delete

} else {

[173] Fix | Delete

if ($withContent === true) {

[174] Fix | Delete

if ($content = file_get_contents($absfile)) {

[175] Fix | Delete

$fdata['content'] = $content;

[176] Fix | Delete

} else {

[177] Fix | Delete

$fdata['error'] = 'unable to read file';

[178] Fix | Delete

}

[179] Fix | Delete

}

[180] Fix | Delete

}

[181] Fix | Delete

}

[182] Fix | Delete

[183] Fix | Delete

$result[$file] = $fdata;

[184] Fix | Delete

}

[185] Fix | Delete

[186] Fix | Delete

return $result;

[187] Fix | Delete

}

[188] Fix | Delete

[189] Fix | Delete

function getFilesStats($files, $offset = 0, $limit = 0, $bsize = 102400, $md5 = false) {

[190] Fix | Delete

$result = array();

[191] Fix | Delete

foreach ($files as $file) {

[192] Fix | Delete

$fdata = $this->fileStat($file);

[193] Fix | Delete

$absfile = ABSPATH.$file;

[194] Fix | Delete

if (!is_readable($absfile)) {

[195] Fix | Delete

$result["missingfiles"][] = $file;

[196] Fix | Delete

continue;

[197] Fix | Delete

}

[198] Fix | Delete

if ($md5 === true && !is_dir($absfile)) {

[199] Fix | Delete

$fdata["md5"] = $this->calculateMd5($absfile, $fdata, $offset, $limit, $bsize);

[200] Fix | Delete

}

[201] Fix | Delete

$result["stats"][] = $fdata;

[202] Fix | Delete

}

[203] Fix | Delete

return $result;

[204] Fix | Delete

}

[205] Fix | Delete

[206] Fix | Delete

function uploadFiles($files, $offset = 0, $limit = 0, $bsize = 102400) {

[207] Fix | Delete

$result = array();

[208] Fix | Delete

foreach ($files as $file) {

[209] Fix | Delete

if (!is_readable(ABSPATH.$file)) {

[210] Fix | Delete

$result["missingfiles"][] = $file;

[211] Fix | Delete

continue;

[212] Fix | Delete

}

[213] Fix | Delete

$handle = fopen(ABSPATH.$file, "rb");

[214] Fix | Delete

if (($handle != null) && is_resource($handle)) {

[215] Fix | Delete

$fdata = $this->fileStat($file);

[216] Fix | Delete

$_limit = $limit;

[217] Fix | Delete

$_bsize = $bsize;

[218] Fix | Delete

if ($_limit == 0)

[219] Fix | Delete

$_limit = $fdata["size"];

[220] Fix | Delete

if ($offset + $_limit > $fdata["size"])

[221] Fix | Delete

$_limit = $fdata["size"] - $offset;

[222] Fix | Delete

$fdata["limit"] = $_limit;

[223] Fix | Delete

$sfdata = serialize($fdata);

[224] Fix | Delete

$this->stream->writeStream($sfdata);

[225] Fix | Delete

fseek($handle, $offset, SEEK_SET);

[226] Fix | Delete

$dlen = 1;

[227] Fix | Delete

while (($_limit > 0) && ($dlen > 0)) {

[228] Fix | Delete

if ($_bsize > $_limit)

[229] Fix | Delete

$_bsize = $_limit;

[230] Fix | Delete

$d = fread($handle, $_bsize);

[231] Fix | Delete

$dlen = strlen($d);

[232] Fix | Delete

$this->stream->writeStream($d);

[233] Fix | Delete

$_limit -= $dlen;

[234] Fix | Delete

}

[235] Fix | Delete

fclose($handle);

[236] Fix | Delete

} else {

[237] Fix | Delete

$result["unreadablefiles"][] = $file;

[238] Fix | Delete

}

[239] Fix | Delete

}

[240] Fix | Delete

$result["status"] = "done";

[241] Fix | Delete

return $result;

[242] Fix | Delete

}

[243] Fix | Delete

[244] Fix | Delete

function process($request) {

[245] Fix | Delete

$params = $request->params;

[246] Fix | Delete

$stream_init_info = BVStream::startStream($this->account, $request);

[247] Fix | Delete

[248] Fix | Delete

if (array_key_exists('stream', $stream_init_info)) {

[249] Fix | Delete

$this->stream = $stream_init_info['stream'];

[250] Fix | Delete

switch ($request->method) {

[251] Fix | Delete

case "scanfilesglob":

[252] Fix | Delete

$initdir = $params['initdir'];

[253] Fix | Delete

$offset = intval($params['offset']);

[254] Fix | Delete

$limit = intval($params['limit']);

[255] Fix | Delete

$bsize = intval($params['bsize']);

[256] Fix | Delete

$regex = $params['regex'];

[257] Fix | Delete

$recurse = true;

[258] Fix | Delete

if (array_key_exists('recurse', $params) && $params["recurse"] == "false") {

[259] Fix | Delete

$recurse = false;

[260] Fix | Delete

}

[261] Fix | Delete

$resp = $this->scanFilesUsingGlob($initdir, $offset, $limit, $bsize, $recurse, $regex);

[262] Fix | Delete

break;

[263] Fix | Delete

case "scanfiles":

[264] Fix | Delete

$links = array();

[265] Fix | Delete

$dir_options = array();

[266] Fix | Delete

if (array_key_exists('dir_options', $params)) {

[267] Fix | Delete

$dir_options = $params['dir_options'];

[268] Fix | Delete

}

[269] Fix | Delete

$bsize = intval($params['bsize']);

[270] Fix | Delete

foreach($dir_options as $option) {

[271] Fix | Delete

$dir = $option['dir'];

[272] Fix | Delete

$offset = intval($option['offset']);

[273] Fix | Delete

$limit = intval($option['limit']);

[274] Fix | Delete

$recurse = true;

[275] Fix | Delete

if (array_key_exists('recurse', $option) && $option["recurse"] == "false") {

[276] Fix | Delete

$recurse = false;

[277] Fix | Delete

}

[278] Fix | Delete

$md5 = true;

[279] Fix | Delete

if (array_key_exists('md5', $option) && $option["md5"] == "false") {

[280] Fix | Delete

$md5 = false;

[281] Fix | Delete

}

[282] Fix | Delete

[283] Fix | Delete

$_links = $this->scanFiles($dir, $offset, $limit, $bsize, $recurse, $md5);

[284] Fix | Delete

$links = array_merge($links, $_links);

[285] Fix | Delete

}

[286] Fix | Delete

$resp = array("status" => "done", "links" => $links);

[287] Fix | Delete

break;

[288] Fix | Delete

case "getfilesstats":

[289] Fix | Delete

$files = $params['files'];

[290] Fix | Delete

$offset = intval($params['offset']);

[291] Fix | Delete

$limit = intval($params['limit']);

[292] Fix | Delete

$bsize = intval($params['bsize']);

[293] Fix | Delete

$md5 = false;

[294] Fix | Delete

if (array_key_exists('md5', $params)) {

[295] Fix | Delete

$md5 = true;

[296] Fix | Delete

}

[297] Fix | Delete

$resp = $this->getFilesStats($files, $offset, $limit, $bsize, $md5);

[298] Fix | Delete

break;

[299] Fix | Delete

case "sendmanyfiles":

[300] Fix | Delete

$files = $params['files'];

[301] Fix | Delete

$offset = intval($params['offset']);

[302] Fix | Delete

$limit = intval($params['limit']);

[303] Fix | Delete

$bsize = intval($params['bsize']);

[304] Fix | Delete

$resp = $this->uploadFiles($files, $offset, $limit, $bsize);

[305] Fix | Delete

break;

[306] Fix | Delete

case "filelist":

[307] Fix | Delete

$dir_options = array();

[308] Fix | Delete

if (array_key_exists('dir_options', $params)) {

[309] Fix | Delete

$dir_options = $params['dir_options'];

[310] Fix | Delete

}

[311] Fix | Delete

if (array_key_exists('chdir', $params)) {

[312] Fix | Delete

chdir(ABSPATH);

[313] Fix | Delete

}

[314] Fix | Delete

$resp = array();

[315] Fix | Delete

foreach($dir_options as $options) {

[316] Fix | Delete

$glob_option = 0;

[317] Fix | Delete

if (array_key_exists('onlydir', $options)) {

[318] Fix | Delete

$glob_option = GLOB_ONLYDIR;

[319] Fix | Delete

}

[320] Fix | Delete

[321] Fix | Delete

$regexes = array("*", ".*");

[322] Fix | Delete

if (array_key_exists('regex', $options)) {

[323] Fix | Delete

$regexes = array($options['regex']);

[324] Fix | Delete

}

[325] Fix | Delete

[326] Fix | Delete

$md5 = false;

[327] Fix | Delete

if (array_key_exists('md5', $options)) {

[328] Fix | Delete

$md5 = $options['md5'];

[329] Fix | Delete

}

[330] Fix | Delete

[331] Fix | Delete

$directoryList = array();

[332] Fix | Delete

[333] Fix | Delete

foreach($regexes as $regex) {

[334] Fix | Delete

$directoryList = array_merge($directoryList, glob($options['dir'].$regex, $glob_option));

[335] Fix | Delete

}

[336] Fix | Delete

$resp[$options['dir']] = $this->getFilesStats($directoryList, 0, 0, 0, $md5);

[337] Fix | Delete

}

[338] Fix | Delete

break;

[339] Fix | Delete

case "dirsexists":

[340] Fix | Delete

$resp = array();

[341] Fix | Delete

$dirs = $params['dirs'];

[342] Fix | Delete

[343] Fix | Delete

foreach ($dirs as $dir) {

[344] Fix | Delete

$path = ABSPATH.$dir;

[345] Fix | Delete

if (file_exists($path) && is_dir($path) && !is_link($path)) {

[346] Fix | Delete

$resp[$dir] = true;

[347] Fix | Delete

} else {

[348] Fix | Delete

$resp[$dir] = false;

[349] Fix | Delete

}

[350] Fix | Delete

}

[351] Fix | Delete

[352] Fix | Delete

$resp["status"] = "Done";

[353] Fix | Delete

break;

[354] Fix | Delete

case "gtfilescntent":

[355] Fix | Delete

$files = $params['files'];

[356] Fix | Delete

$withContent = array_key_exists('withcontent', $params) ? $params['withcontent'] : true;

[357] Fix | Delete

$resp = array("files_content" => $this->getFilesContent($files, $withContent));

[358] Fix | Delete

break;

[359] Fix | Delete

case "gtfls":

[360] Fix | Delete

$resp = array();

[361] Fix | Delete

[362] Fix | Delete

if (array_key_exists('get_files_content', $params)) {

[363] Fix | Delete

$args = $params['get_files_content'];

[364] Fix | Delete

$with_content = array_key_exists('withcontent', $args) ? $args['withcontent'] : true;

[365] Fix | Delete

$resp['get_files_content'] = $this->getFilesContent($args['files'], $with_content);

[366] Fix | Delete

}

[367] Fix | Delete

[368] Fix | Delete

if (array_key_exists('get_files_stats', $params)) {

[369] Fix | Delete

$args = $params['get_files_stats'];

[370] Fix | Delete

$md5 = array_key_exists('md5', $args) ? $args['md5'] : false;

[371] Fix | Delete

$stats = $this->getFilesStats(

[372] Fix | Delete

$args['files'], $args['offset'], $args['limit'], $args['bsize'], $md5

[373] Fix | Delete

);

[374] Fix | Delete

[375] Fix | Delete

$result = array();

[376] Fix | Delete

[377] Fix | Delete

if (array_key_exists('stats', $stats)) {

[378] Fix | Delete

$result['stats'] = array();

[379] Fix | Delete

foreach ($stats['stats'] as $stat) {

[380] Fix | Delete

$result['stats'][$stat['filename']] = $stat;

[381] Fix | Delete

}

[382] Fix | Delete

}

[383] Fix | Delete

[384] Fix | Delete

if (array_key_exists('missingfiles', $stats)) {

[385] Fix | Delete

$result['missingfiles'] = $stats['missingfiles'];

[386] Fix | Delete

}

[387] Fix | Delete

[388] Fix | Delete

$resp['get_files_stats'] = $result;

[389] Fix | Delete

}

[390] Fix | Delete

[391] Fix | Delete

break;

[392] Fix | Delete

default:

[393] Fix | Delete

$resp = false;

[394] Fix | Delete

}

[395] Fix | Delete

$end_stream_info = $this->stream->endStream();

[396] Fix | Delete

if (!empty($end_stream_info) && is_array($resp)) {

[397] Fix | Delete

$resp = array_merge($resp, $end_stream_info);

[398] Fix | Delete

}

[399] Fix | Delete

} else {

[400] Fix | Delete

$resp = $stream_init_info;

[401] Fix | Delete

}

[402] Fix | Delete

return $resp;

[403] Fix | Delete

}

[404] Fix | Delete

}

[405] Fix | Delete

endif;

[406] Fix | Delete