by wishcraft on 2011/9/1 11:59:10
This is an example of semi refactorised code i am working on for TBDev 1.05 Release, this could be a month off.. Anyway I have for example done most of my first file at the top of the code.
This is announce.php
<?php /* +------------------------------------------------ | TBDev.net BitTorrent Tracker PHP for XOOPS | ============================================= | by CoLdFuSiOn | (c) 2003 - 2009 TBDev.Net | http://www.tbdev.net | ============================================= | svn: http://sourceforge.net/projects/tbdevnet/ | Licence Info: GPL +------------------------------------------------ | 2011-09-01 | 0.01 | Wishcraft | http://chronolabs.coop/ +------------------------------------------------ */ error_reporting(0); require_once '../../mainfile.php'; $GLOBALS['xoopsLogger']->activated = false; require_once 'include/config.php'; $users_handler = xoops_getmodulehandler('users', 'td'); $torrents_handler = xoops_getmodulehandler('torrents', 'td'); $peers_handler = xoops_getmodulehandler('peers', 'td'); define ('UC_VIP', 2); // DO NOT EDIT BELOW UNLESS YOU KNOW WHAT YOU'RE DOING!! $agent = $_SERVER["HTTP_USER_AGENT"]; // Deny access made with a browser... if ( ereg("^Mozilla\/", $agent) || ereg("^Opera\/", $agent) || ereg("^Links ", $agent) || ereg("^Lynx\/", $agent) || isset($_SERVER['HTTP_COOKIE']) || isset($_SERVER['HTTP_ACCEPT_LANGUAGE']) || isset($_SERVER['HTTP_ACCEPT_CHARSET']) ) err("torrent not registered with this tracker CODE 1"); /////////////////////// FUNCTION DEFS /////////////////////////////////// function err($msg) { $torrents_handler->benc_resp(array('failure reason' => array('type' => 'string', 'value' => $msg))); exit(); } function hash_where($name, $hash) { $shhash = preg_replace('/ *$/s', "", $hash); return "($name = " . sqlesc($hash) . " OR $name = " . sqlesc($shhash) . ")"; } function portblacklisted($port) { // direct connect if ($port >= 411 && $port <= 413) return true; // bittorrent if ($port >= 6881 && $port <= 6889) return true; // kazaa if ($port == 1214) return true; // gnutella if ($port >= 6346 && $port <= 6347) return true; // emule if ($port == 4662) return true; // winmx if ($port == 6699) return true; return false; } /////////////////////// FUNCTION DEFS END /////////////////////////////// $parts = array(); $pattern = '[0-9a-fA-F]{32}'; if( !isset($_GET['passkey']) OR !ereg($pattern, $_GET['passkey'], $parts) ) err("Invalid Passkey"); else $GLOBALS['passkey'] = $parts[0]; foreach (array("info_hash","peer_id","event","ip","localip") as $x) { if(isset($_GET["$x"])) $GLOBALS[$x] = "" . $_GET[$x]; } foreach (array("port","downloaded","uploaded","left") as $x) { $GLOBALS[$x] = 0 + $_GET[$x]; } foreach (array("passkey","info_hash","peer_id","port","downloaded","uploaded","left") as $x) if (!isset($x)) err("Missing key: $x"); foreach (array("info_hash","peer_id") as $x) if (strlen($GLOBALS[$x]) != 20) err("Invalid $x (" . strlen($GLOBALS[$x]) . " - " . urlencode($GLOBALS[$x]) . ")"); unset($x); $info_hash = bin2hex($info_hash); $ip = $_SERVER['REMOTE_ADDR']; $port = 0 + $port; $downloaded = 0 + $downloaded; $uploaded = 0 + $uploaded; $left = 0 + $left; $rsize = 50; foreach(array("num want", "numwant", "num_want") as $k) { if (isset($_GET[$k])) { $rsize = 0 + $_GET[$k]; break; } } if (!$port || $port > 0xffff) err("invalid port"); if (!isset($event)) $event = ""; $seeder = ($left == 0) ? "yes" : "no"; $criteria = new CriteriaCompo(new Criteria('passkey', $passkey)); if ( $users_handler->getCount($criteria) != 1 ) err("Unknown passkey. Please redownload the torrent from {$GLOBALS['TBDEV']['baseurl']}."); $users = $users_handler->getObjects($criteria, false); if( $users[0]->getVar('enabled') == 'no' ) err('Permission denied, you're not enabled'); $criteria = new CriteriaCompo(new Criteria('info_hash', $info_hash)); //$res = $GLOBALS['xoopsDB']->queryF("SELECT id, banned, seeders + leechers AS numpeers, added AS ts FROM ".$GLOBALS['xoopsDB']->prefix("tb_torrents")." WHERE info_hash = " .sqlesc($info_hash));//" . hash_where("info_hash", $info_hash)); $torrents = $torrents_handler->getObjects($criteria, false); if (!is_object($torrents[0])) err("torrent not registered with this tracker CODE 2"); $torrentid = $torrents[0]->getVar("id"); $fields = "seeder, peer_id, ip, port, uploaded, downloaded, userid"; $numpeers = $torrents[0]->getVar("seeders")+$torrents[0]->getVar("leechers"); $criteria = new CriteriaCompo(new Criteria('torrent', $torrentid)); $criteria->add(new Criteria('connectable', 'yes')); if ($numpeers > $rsize) { $criteria->setSort('RAND()'); $criteria->setOrder('DESC'); $criteria->settLimit($rsize); } $peers = $peers_handler->getObjects($criteria, false); if($_GET['compact'] != 1){ $resp = "d" . $torrents_handler->benc_str("interval") . "i" . $GLOBALS['TBDEV']['announce_interval'] . "e" . $torrents_handler->benc_str("peers") . "l"; } else { $resp = "d" . $torrents_handler->benc_str("interval") . "i" . $GLOBALS['TBDEV']['announce_interval'] ."e" . $torrents_handler->benc_str("min interval") . "i" . 300 ."e5:"."peers" ; } $peer = array(); $peer_num = 0; foreach ($peers as $key => $peerobj) { if($_GET['compact'] != 1) { if (str_pad($peerobj->getVar("peer_id"), 20) === $peer_id) { $self = $peerobj; continue; } $resp .= "d" . $torrents_handler->benc_str("ip") . $torrents_handler->benc_str($peerobj->getVar("ip")); if (!$_GET['no_peer_id']) { $resp .= $torrents_handler->benc_str("peer id") . $torrents_handler->benc_str($peerobj->getVar("peer_id")); } $resp .= $torrents_handler->benc_str("port") . "i" . $peerobj->getVar("port") . "e" . "e"; } else { $peer_ip = explode('.', $peerobj->getVar("ip")); $peer_ip = pack("C*", $peer_ip[0], $peer_ip[1], $peer_ip[2], $peer_ip[3]); $peer_port = pack("n*", (int)$peerobj->getVar("port")); $time = intval((time() % 7680) / 60); if($_GET['left'] == 0) { $time += 128; } $time = pack("C", $time); $peer[] = $time . $peer_ip . $peer_port; $peer_num++; } } if ($_GET['compact']!=1) $resp .= "ee"; else { $o = ""; for($i=0;$i<$peer_num;$i++) { $o .= substr($peer[$i], 1, 6); } $resp .= strlen($o) . ':' . $o . 'e'; } $criteria = new CriteriaCompo(new Criteria('torrent', $torrentid)); $criteria->add(new Criteria('peer_id', $peer_id)); //////////////////////////// END NEW COMPACT MODE//////////////////////////////// if (!isset($self)) { $peers = $peers_handler->getObjects($criteria, false); if (is_object($peers[0])) { $userid = $peers[0]->getVar("userid"); $self = $peers[0]; } } //// Up/down stats //////////////////////////////////////////////////////////// if (!isset($self)) { $criteria = new CriteriaCompo(new Criteria('torrent', $torrentid)); $criteria->add(new Criteria('passkey', $passkey)); if ($peers_handler->getCount($criteria) >= 1 && $seeder == 'no') err("Connection limit exceeded! You may only leech from one location at a time."); if ($peers_handler->getCount($criteria) >= 3 && $seeder == 'yes') err("Connection limit exceeded!"); if ($left > 0 && $users[0]->getVar('class') < UC_VIP && $GLOBALS['TBDEV']['user_ratios']) { $gigs = $users[0]->getVar('uploaded') / (1024*1024*1024); $elapsed = floor((time() - $torrents[0]->getVar("ts")) / 3600); $ratio = (($users[0]->getVar('downloaded') > 0) ? ($users[0]->getVar('uploaded') / $users[0]->getVar('downloaded')) : 1); if ($ratio < 0.5 || $gigs < 5) $wait = 48; elseif ($ratio < 0.65 || $gigs < 6.5) $wait = 24; elseif ($ratio < 0.8 || $gigs < 8) $wait = 12; elseif ($ratio < 0.95 || $gigs < 9.5) $wait = 6; else $wait = 0; if ($elapsed < $wait) err("Not authorized (" . ($wait - $elapsed) . "h) - READ THE FAQ!"); } } else { $upthis = max(0, $uploaded - $self->getVar("uploaded")); $downthis = max(0, $downloaded - $self->getVar("downloaded")); if ($upthis > 0 || $downthis > 0) { $users[0]->setVar('uploaded', $users[0]->getVar('uploaded')+$upthis); $users[0]->setVar('downloaded', $users[0]->getVar('downloaded')+$downthis); $users_handler->insert($users[0], true); } } /////////////////////////////////////////////////////////////////////////////// $updateset = array(); if ($event == "stopped") { if (isset($self)) { $criteria = new CriteriaCompo(new Criteria('torrent', $torrentid)); $criteria->add(new Criteria('peer_id', $peer_id)); if ($peers_handler->deleteAll($criteria)) { if ($self["seeder"] == "yes") $torrents[0]->setVar('seeders', $torrents[0]->getVar('seeders')-1); else $torrents[0]->setVar('leechers', $torrents[0]->getVar('leechers')-1); } } } else { if ($event == "completed") $torrents[0]->setVar('times_completed', $torrents[0]->getVar('times_completed')+1); if (isset($self)) { $self->setVar('uploaded', $uploaded); $self->setVar('downloaded', $downloaded); $self->setVar('to_go', $left); $self->setVar('last_action', time()); $self->setVar('seeder', $seeder); if ($seeder == "yes" && $self->getVar("seeder") != $seeder ) $self->setVar('finishedat', time()); if ($peers_handler->insert($self, true) && $self->getVar("seeder") != $seeder) { if ($seeder == "yes") { $torrents[0]->setVar('seeders', $torrents[0]->getVar('seeders')+1); $torrents[0]->setVar('leechers', $torrents[0]->getVar('leechers')-1); } else { $torrents[0]->setVar('seeders', $torrents[0]->getVar('seeders')-1); $torrents[0]->setVar('leechers', $torrents[0]->getVar('leechers')+1); } } } else { if ($event != "started") err("Peer not found. ".$passkey." Restart the torrent."); if (portblacklisted($port)) { err("Port $port is blacklisted."); } elseif ( $GLOBALS['TBDEV']['connectable_check'] ) { $sockres = @fsockopen($ip, $port, $errno, $errstr, 5); if (!$sockres) $connectable = "no"; else { $connectable = "yes"; @fclose($sockres); } } else { $connectable = 'yes'; } $newpeer = $peers_handler->create(); $newpeer->setVar('connectable', $connectable); $newpeer->setVar('torrent', $torrentid); $newpeer->setVar('peer_id', $peer_id); $newpeer->setVar('ip', $ip); $newpeer->setVar('port', $port); $newpeer->setVar('uploaded', $uploaded); $newpeer->setVar('downloaded', $downloaded); $newpeer->setVar('to_go', $left); $newpeer->setVar('started', time()); $newpeer->setVar('last_action', time()); $newpeer->setVar('seeder', $seeder); $newpeer->setVar('userid', $user[0]->getVar('id')); $newpeer->setVar('agent', $agent); $newpeer->setVar('passkey', $passkey); if ($peers_handler->insert($newpeer, true)) { if ($seeder == "yes") $torrents[0]->setVar('seeders', $torrents[0]->getVar('seeders')+1); else $torrents[0]->setVar('leechers', $torrents[0]->getVar('leechers')+1); } } } if ($seeder == "yes") { if ($torrents[0]->getVar("banned") != "yes") $torrents[0]->setVar('visible', 'yes'); $torrents[0]->setVar('last_action', time()); } $torrents_handler->insert($torrents[0], true); $torrents_handler->benc_resp_raw($resp); ?>
it links to class/torrents.php which are all built for the database structure.
// class/torrents.php so far - code edited 11:56 PM 1/09/2011 AEST. <?php defined('XOOPS_ROOT_PATH') or die("XOOPS root path not defined"); class TbTorrents extends XoopsObject { function __construct() { $this->initVar('id', XOBJ_DTYPE_INT, null, false); $this->initVar('info_hash', XOBJ_DTYPE_TXTBOX, null, false, 40); $this->initVar('name', XOBJ_DTYPE_TXTBOX, null, false, 255); $this->initVar('filename', XOBJ_DTYPE_TXTBOX, null, false, 255); $this->initVar('save_as', XOBJ_DTYPE_TXTBOX, null, false, 255); $this->initVar('search_text', XOBJ_DTYPE_OTHER, null, false); $this->initVar('descr', XOBJ_DTYPE_OTHER, null, false); $this->initVar('ori_descr', XOBJ_DTYPE_OTHER, null, false); $this->initVar('category', XOBJ_DTYPE_INT, null, false); $this->initVar('size', XOBJ_DTYPE_INT, null, false); $this->initVar('added', XOBJ_DTYPE_INT, null, false); $this->initVar('type', XOBJ_DTYPE_ENUM, null, false, false, false, array('single','multi')); $this->initVar('numfiles', XOBJ_DTYPE_INT, null, false); $this->initVar('comments', XOBJ_DTYPE_INT, null, false); $this->initVar('views', XOBJ_DTYPE_INT, null, false); $this->initVar('hits', XOBJ_DTYPE_INT, null, false); $this->initVar('times_completed', XOBJ_DTYPE_INT, null, false); $this->initVar('leechers', XOBJ_DTYPE_INT, null, false); $this->initVar('seeders', XOBJ_DTYPE_INT, null, false); $this->initVar('last_action', XOBJ_DTYPE_INT, null, false); $this->initVar('visible', XOBJ_DTYPE_ENUM, null, false, false, false, array('yes', 'no')); $this->initVar('banned', XOBJ_DTYPE_ENUM, null, false, false, false, array('yes', 'no')); $this->initVar('owner', XOBJ_DTYPE_INT, null, false); $this->initVar('numratings', XOBJ_DTYPE_INT, null, false); $this->initVar('ratingsum', XOBJ_DTYPE_INT, null, false); $this->initVar('nfo', XOBJ_DTYPE_OTHER, null, false); $this->initVar('client_created_by', XOBJ_DTYPE_TXTBOX, null, false, 50); } function TbTorrents() { $this->__construct(); } } class TbTorrentsHandler extends XoopsPersistableObjectHandler { function TbTorrentsHandler(&$db) { $this->__construct($db); } function __construct(&$db) { parent::__construct($db, "tb_torrents", 'TbTorrents', "id"); } function benc_resp($d) { $this->benc_resp_raw($this->benc(array('type' => 'dictionary', 'value' => $d))); } function benc_resp_raw($x) { header( "Content-Type: text/plain" ); header( "Pragma: no-cache" ); if ( $_SERVER['HTTP_ACCEPT_ENCODING'] == 'gzip' ) { header( "Content-Encoding: gzip" ); echo gzencode( $x, 9, FORCE_GZIP ); } else echo $x ; } function benc($obj) { if (!is_array($obj) || !isset($obj["type"]) || !isset($obj["value"])) return; $c = $obj["value"]; switch ($obj["type"]) { case "string": return $this->benc_str($c); case "integer": return $this->benc_int($c); case "list": return $this->benc_list($c); case "dictionary": return $this->benc_dict($c); default: return; } } function benc_str($s) { return strlen($s) . ":$s"; } function benc_int($i) { return "i" . $i . "e"; } function benc_list($a) { $s = "l"; foreach ($a as $e) { $s .= $this->benc($e); } $s .= "e"; return $s; } function benc_dict($d) { $s = "d"; $keys = array_keys($d); sort($keys); foreach ($keys as $k) { $v = $d[$k]; $s .= $this->benc_str($k); $s .= $this->benc($v); } $s .= "e"; return $s; } } ?>
|
