<?php

/* $Id: functions.common.transfer.php 3269 2007-11-11 22:48:00Z b4rt $ */

/*******************************************************************************

 LICENSE

 This program is free software; you can redistribute it and/or
 modify it under the terms of the GNU General Public License (GPL)
 as published by the Free Software Foundation; either version 2
 of the License, or (at your option) any later version.

 This program is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 GNU General Public License for more details.

 To read the license please visit http://www.gnu.org/copyleft/gpl.html

*******************************************************************************/

/**
 * get log of a Transfer
 *
 * @param $transfer
 * @return string
 */
function getTransferLog($transfer) {
	global $cfg;
	$emptyLog = "log empty";
	// sanity-check
	if (!isset($transfer) || (tfb_isValidTransfer($transfer) !== true))
		return "invalid transfer";
	// log-file
	$transferLogFile = $cfg["transfer_file_path"].$transfer.".log";
	// check
	if (!(file_exists($transferLogFile)))
		return $emptyLog;
	// open
	$handle = false;
	$handle = @fopen($transferLogFile, "r");
	if (!$handle)
		return $emptyLog;
	// read
	$data = "";
	while (!@feof($handle))
		$data .= @fgets($handle, 8192);
	@fclose ($handle);
	if ($data == "")
		return $emptyLog;
	// return
	return $data;
}

/**
 * Function to delete saved Settings
 *
 * @param $transfer
 * @return boolean
 */
function deleteTransferSettings($transfer) {
	global $db;
	$sql = "DELETE FROM tf_transfers WHERE transfer = ".$db->qstr($transfer);
	$db->Execute($sql);
	if ($db->ErrorNo() != 0) dbError($sql);
	// set transfers-cache
	cacheTransfersSet();
	return true;
}

/**
 * sets the running flag in the db to stopped.
 *
 * @param $transfer name of the transfer
 */
function stopTransferSettings($transfer) {
	global $db;
	$db->Execute("UPDATE tf_transfers SET running = '0' WHERE transfer = ".$db->qstr($transfer));
	// set transfers-cache
	cacheTransfersSet();
	return true;
}

/**
 * waits until transfer is up/down
 *
 * @param $transfer name of the transfer
 * @param $state : true = start, false = stop
 * @param $maxWait in seconds
 * @return boolean
 */
function waitForTransfer($transfer, $state, $maxWait = 15) {
	$maxLoops = $maxWait * 5;
	$loopCtr = 0;
	for (;;) {
		@clearstatcache();
		if (isTransferRunning($transfer) === $state) {
			return true;
		} else {
		 	$loopCtr++;
		 	if ($loopCtr > $maxLoops)
		 		return false;
		 	else
		 		usleep(200000); // wait for 0.2 seconds
		}
	}
	return true;
}

/**
 * resets totals of a transfer
 *
 * @param $transfer name of the transfer
 * @param $delete boolean if to delete meta-file
 * @return array
 */
function resetTransferTotals($transfer, $delete = false) {
	global $cfg, $db, $transfers;
	$msgs = array();
	$tid = getTransferHash($transfer);
	// delete meta-file
	if ($delete) {
		$ch = ClientHandler::getInstance(getTransferClient($transfer));
		$ch->delete($transfer);
		if (count($ch->messages) > 0)
    		$msgs = array_merge($msgs, $ch->messages);
	} else {
		// reset in stat-file
		$sf = new StatFile($transfer, getOwner($transfer));
		$sf->uptotal = 0;
		$sf->downtotal = 0;
		$sf->write();
	}
	// reset in db
	$sql = "DELETE FROM tf_transfer_totals WHERE tid = ".$db->qstr($tid);
	$db->Execute($sql);
	if ($db->ErrorNo() != 0) dbError($sql);
	// set transfers-cache
	cacheTransfersSet();
	return $msgs;
}

/**
 * deletes data of a transfer
 *
 * @param $transfer name of the transfer
 * @return array
 */
function deleteTransferData($transfer) {
	global $cfg, $transfers;
	$msgs = array();
	if (($cfg['isAdmin']) || (IsOwner($cfg["user"], getOwner($transfer)))) {
		// only torrent
		if (substr($transfer, -8) != ".torrent")
			return $msgs;
		// delete data
		$datapath = getTransferDatapath($transfer);
		if (($datapath != "") && ($datapath != ".")) {
			$targetPath = getTransferSavepath($transfer).$datapath;
			if (tfb_isValidPath($targetPath)) {
				if ((@is_dir($targetPath)) || (@is_file($targetPath))) {
					avddelete($targetPath);
					AuditAction($cfg["constants"]["fm_delete"], $targetPath);
				}
			} else {
				$msg = "ILLEGAL DELETE: ".$cfg["user"]." attempted to delete data of ".$transfer;
				AuditAction($cfg["constants"]["error"], $msg);
				array_push($msgs, $msg);
			}
		}
	} else {
		$msg = "ILLEGAL DELETE: ".$cfg["user"]." attempted to delete data of ".$transfer;
		AuditAction($cfg["constants"]["error"], $msg);
		array_push($msgs, $msg);
	}
	return $msgs;
}

/**
 * gets size of data of a torrent
 *
 * @param $transfer name of the torrent
 * @return int with size of data of torrent.
 *		   -1 if error
 *		   4096 if dir (lol ~)
 */
function getTorrentDataSize($transfer) {
	global $cfg;
	$datapath = getTransferDatapath($transfer);
	return (($datapath != "") && ($datapath != "."))
		? file_size(getTransferSavepath($transfer).$datapath)
		: -1;
}

/**
 * gets datapath of a transfer.
 *
 * @param $transfer name of the torrent
 * @return var with transfer-datapath or empty string
 */
function getTransferDatapath($transfer) {
	global $cfg, $db, $transfers;
	if (isset($transfers['settings'][$transfer]['datapath'])) {
		return $transfers['settings'][$transfer]['datapath'];
	} else {
		$datapath = $db->GetOne("SELECT datapath FROM tf_transfers WHERE transfer = ".$db->qstr($transfer));
		if (empty($datapath)) {
			if (substr($transfer, -8) == ".torrent") {
				// this is a torrent-client
			    require_once('inc/classes/BDecode.php');
			    $ftorrent = $cfg["transfer_file_path"].$transfer;
			    $fd = fopen($ftorrent, "rd");
			    $alltorrent = fread($fd, filesize($ftorrent));
			    $btmeta = @BDecode($alltorrent);
			    $datapath = (empty($btmeta['info']['name']))
			    	? ""
			    	: trim($btmeta['info']['name']);
			} else if (substr($transfer, -5) == ".wget") {
				// this is wget.
				$datapath = ".";
			} else if (substr($transfer, -4) == ".nzb") {
				// This is nzbperl.
				$datapath = ".";
			} else {
				$datapath = "";
			}
		}
		$transfers['settings'][$transfer]['datapath'] = $datapath;
		return $datapath;
	}
}

/**
 * gets savepath of a transfer.
 *
 * @param $transfer name of the torrent
 * @return var with transfer-savepath or empty string
 */
function getTransferSavepath($transfer) {
	global $cfg, $db, $transfers;
	if (isset($transfers['settings'][$transfer]['savepath'])) {
		return $transfers['settings'][$transfer]['savepath'];
	} else {
		$savepath = $db->GetOne("SELECT savepath FROM tf_transfers WHERE transfer = ".$db->qstr($transfer));
		if (empty($savepath))
			$savepath = ($cfg["enable_home_dirs"] != 0)
				? $cfg["path"].getOwner($transfer).'/'
				: $cfg["path"].$cfg["path_incoming"].'/';
				
		/*Origin*/
		//$transfers['settings'][$transfer]['savepath'] = $savepath;
		//return $savepath;
		
		/*Mod*/
		$dir = save_to_folder($transfer);
		if($dir){
			$dirs = $dir;
		} else {
			$dirs = 'Orhers';
		}
		$transfers['settings'][$transfer]['savepath'] = $savepath.$dirs;
		return $savepath.$dirs;
	}
}

/**
 * Save to Folder
 */
function save_to_folder($transfer){
	$path = array(
		'xxx' => 'xXx',
		'Tvs' => 'Sorozatok',	//TVStore special
		'ebook' => 'eBook',	//nCore Special
		'xvidser' => 'Sorozatok',	//nCore Special
		'xvid' => 'Filmek',	//nCore Special
		'game' => 'Game',	//nCore Special
		'iso' => 'Utils',	//nCore Special
		'misc' => 'Utils',	//nCore Special
		'mp3' => 'Zene',	//nCore Special
		'flac' => 'Zene',	//nCore Special
		'va-' => 'Zene',
		'HDTV' => 'Sorozatok',
		'IPTV' => 'Sorozatok',	//BitHUmen Special
		'WEB-DLRip' => 'Sorozatok',	//Other torrent error (Filmek or Sorozatok)
		'BDRip' => 'Filmek',	//Other torrent error (Filmek or Sorozatok)
		'_hd_' => 'Filmek',	//nCore Special
		'HD' => 'Filmek',
		'_dvd9_' => 'Filmek',	//nCore Special
		'DVDRiP' => 'Filmek',
		'DVD' => 'Filmek'
	);

	foreach($path as $a => $b){
		$pos = stripos($transfer, $a);
		if ($pos !== false) {
		return $b;
		}
	}
}

/**
 * set file prio
 *
 * @param $transfer
 */
function setFilePriority($transfer) {
    global $cfg;
    // we will use this to determine if we should create a prio file.
    // if the user passes all 1's then they want the whole thing.
    // so we don't need to create a prio file.
    // if there is a -1 in the array then they are requesting
    // to skip a file. so we will need to create the prio file.
    $okToCreate = false;
    if (!empty($transfer)) {
        $fileName = $cfg["transfer_file_path"].$transfer.".prio";
        $result = array();
        $files = array();
        if (isset($_REQUEST['files'])) {
        	$filesTemp = (is_array($_REQUEST['files']))
        		? $_REQUEST['files']
        		: array($_REQUEST['files']);
        	$files = array_filter($filesTemp, "getFile");
        }
        // if there are files to get then process and create a prio file.
        if (count($files) > 0) {
            for ($i=0; $i <= tfb_getRequestVar('count'); $i++) {
                if (in_array($i,$files)) {
                    array_push($result, 1);
                } else {
                    $okToCreate = true;
                    array_push($result, -1);
                }
            }
            if ($okToCreate) {
                $fp = fopen($fileName, "w");
                fwrite($fp,tfb_getRequestVar('filecount').",");
                fwrite($fp,implode($result,','));
                fclose($fp);
            } else {
                // No files to skip so must be wanting them all.
                // So we will remove the prio file.
                @unlink($fileName);
            }
        } else {
            // No files selected so must be wanting them all.
            // So we will remove the prio file.
            @unlink($fileName);
        }
    }
}

/**
 * gets scrape-info of a torrent as string
 *
 * @param $transfer name of the torrent
 * @return string with torrent-scrape-info
 */
function getTorrentScrapeInfo($transfer) {
	global $cfg;
	$hasClient = false;
	// transmissioncli
	if (is_executable($cfg["btclient_transmission_bin"])) {
		$hasClient = true;
		$retVal = "";
		$retVal = @shell_exec("HOME=".tfb_shellencode($cfg["path"])."; export HOME; ".$cfg["btclient_transmission_bin"] . " -s ".tfb_shellencode($cfg["transfer_file_path"].$transfer));
		if ((isset($retVal)) && ($retVal != "") && (!preg_match('/.*failed.*/i', $retVal)))
			return trim($retVal);
	}
	// ttools.pl
	if (is_executable($cfg["perlCmd"])) {
		$hasClient = true;
		$retVal = "";
		$retVal = @shell_exec($cfg["perlCmd"].' -I '.tfb_shellencode($cfg["docroot"].'bin/ttools').' '.tfb_shellencode($cfg["docroot"].'bin/ttools/ttools.pl').' -s '.tfb_shellencode($cfg["transfer_file_path"].$transfer));
		if ((isset($retVal)) && ($retVal != "") && (!preg_match('/.*failed.*/i', $retVal)))
			return trim($retVal);
	}
	// failed
	return ($hasClient)
		? "Scrape failed"
		: "No Scrape-Client";
}

/**
 * gets ary of running clients (via call to ps)
 *
 * @param $client
 * @return array
 */
function getRunningClientProcesses($client = '') {
	// client-array
	$clients = ($client == '')
		? array('tornado', 'transmission', 'mainline', 'wget', 'nzbperl', 'azureus')
		: array($client);
	// get clients
	$retVal = array();
	foreach ($clients as $client) {
		// client-handler
		$ch = ClientHandler::getInstance($client);
		$procs = $ch->runningProcesses();
		if (!empty($procs))
			$retVal = array_merge($retVal, $procs);
	}
	// return
	return $retVal;
}

/**
 * get info of running clients (via call to ps)
 *
 * @param $client
 * @return string
 */
function getRunningClientProcessInfo($client = '') {
	// client-array
	$clients = ($client == '')
		? array('tornado', 'transmission', 'mainline', 'wget', 'nzbperl', 'azureus')
		: array($client);
	// get clients
	$retVal = "";
	foreach ($clients as $client) {
		// client-handler
		$ch = ClientHandler::getInstance($client);
		$retVal .= $ch->runningProcessInfo();
	}
	// return
	return $retVal;
}

?>