mirror of
https://github.com/NNTmux/newznab-tmux.git
synced 2026-08-29 17:28:55 +00:00
Darko
1030 lines
39 KiB
PHP
1030 lines
39 KiB
PHP
<?php
|
|
require_once(dirname(__FILE__)."/../bin/config.php");
|
|
require_once(WWW_DIR."lib/framework/db.php");
|
|
require_once(WWW_DIR."lib/category.php");
|
|
require_once(WWW_DIR."lib/groups.php");
|
|
require_once(WWW_DIR."lib/nfo.php");
|
|
require_once(WWW_DIR."lib/site.php");
|
|
require_once("functions.php");
|
|
require_once("consoletools.php");
|
|
require_once("ColorCLI.php");
|
|
require_once("nzbcontents.php");
|
|
require_once("simple_html_dom.php");
|
|
|
|
/*
|
|
* Class for inserting names/categories/md5 etc from predb sources into the DB, also for matching names on files / subjects.
|
|
*/
|
|
// This script is adapted from nZEDb
|
|
Class PreHash
|
|
{
|
|
// If you wish to not get PRE from one of these sources, set it to false.
|
|
const PRE_WOMBLE = true;
|
|
const PRE_OMGWTF = true;
|
|
const PRE_ZENET = true;
|
|
const PRE_PRELIST = true;
|
|
const PRE_ORLYDB = true;
|
|
const PRE_SRRDB = true;
|
|
const PRE_PREDBME = true;
|
|
const PRE_ABGXNET = true;
|
|
const PRE_UCRAWLER = true;
|
|
const PRE_MOOVEE = true;
|
|
const PRE_TEEVEE = true;
|
|
const PRE_EROTICA = true;
|
|
const PRE_FOREIGN = true;
|
|
|
|
function __construct($echooutput=false)
|
|
{
|
|
$s = new Sites();
|
|
$this->site = $s->get();
|
|
$this->echooutput = $echooutput;
|
|
$this->db = new DB();
|
|
$this->c = new ColorCLI;
|
|
}
|
|
|
|
// Retrieve pre info from predb sources and store them in the DB.
|
|
// Returns the quantity of new titles retrieved.
|
|
public function updatePre()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$newNames = 0;
|
|
$newestRel = $this->db->queryOneRow("SELECT value AS adddate FROM tmux WHERE setting = 'lastpretime'");
|
|
if ((int)($newestRel["adddate"] < time()-1200))
|
|
{
|
|
if ($this->echooutput)
|
|
{
|
|
echo $this->c->header("Retrieving titles from preDB sources.");
|
|
}
|
|
if (self::PRE_WOMBLE) {
|
|
$newNames += $newWomble = $this->retrieveWomble();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newWomble . " \tRetrieved from Womble.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_OMGWTF) {
|
|
$newNames += $newOmgWtf = $this->retrieveOmgwtfnzbs();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newOmgWtf . " \tRetrieved from Omgwtfnzbs.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_ZENET) {
|
|
$newNames += $newZenet = $this->retrieveZenet();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newZenet . " \tRetrieved from Zenet.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_PRELIST) {
|
|
$newNames += $newPreList = $this->retrievePrelist();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newPreList . " \tRetrieved from Prelist.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_ORLYDB) {
|
|
$newNames += $newOrly = $this->retrieveOrlydb();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newOrly . " \tRetrieved from Orlydb.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_SRRDB) {
|
|
$newNames += $newSrr = $this->retrieveSrr();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newSrr . " \tRetrieved from Srrdb.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_PREDBME) {
|
|
$newNames += $newPdme = $this->retrievePredbme();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newPdme . " \tRetrieved from Predbme.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_ABGXNET) {
|
|
$newNames += $abgx = $this->retrieveAbgx();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($abgx . " \tRetrieved from abgx.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_UCRAWLER) {
|
|
$newNames += $newUsenetCrawler = $this->retrieveUsenetCrawler();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newUsenetCrawler . " \tRetrieved from Usenet-Crawler.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_MOOVEE) {
|
|
$newNames += $newMoovee = $this->retrieveAllfilledMoovee();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newMoovee . " \tRetrieved from Allfilled Moovee.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_TEEVEE) {
|
|
$newNames += $newTeevee = $this->retrieveAllfilledTeevee();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newTeevee . " \tRetrieved from Allfilled Teevee.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_EROTICA) {
|
|
$newNames += $newErotica = $this->retrieveAllfilledErotica();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newErotica . " \tRetrieved from Allfilled Erotica.");
|
|
}
|
|
}
|
|
|
|
if (self::PRE_FOREIGN) {
|
|
$newNames += $newForeign = $this->retrieveAllfilledForeign();
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newForeign . " \tRetrieved from Allfilled Foreign.\n");
|
|
}
|
|
}
|
|
|
|
if ($this->echooutput) {
|
|
echo $this->c->primary($newNames . " \tRetrieved from all the above sources..");
|
|
}
|
|
|
|
// If we found nothing, update the last added to now to reset the timer.
|
|
$this->db->exec(sprintf("UPDATE tmux SET value = %s WHERE setting = 'lastpretime'", $this->db->escapeString(time())));
|
|
}
|
|
return $newNames;
|
|
}
|
|
|
|
// Attempts to match predb to releases.
|
|
public function checkPre($nntp)
|
|
{
|
|
$matched = $this->matchPredb();
|
|
if ($this->echooutput)
|
|
{
|
|
$count = ($matched > 0) ? $matched : 0;
|
|
echo $this->c->header('Matched ' . number_format($count) . ' prehash titles to release search names.');
|
|
}
|
|
$nfos = $this->matchNfo($nntp);
|
|
if ($this->echooutput)
|
|
{
|
|
$count = ($nfos > 0) ? $nfos : 0;
|
|
echo $this->c->header("\nAdded " . number_format($count) . ' missing NFOs from preDB sources.');
|
|
}
|
|
}
|
|
|
|
public function retrieveWomble()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$newnames = $updated = 0;
|
|
$matches2 = $matches = $match = $m = '';
|
|
|
|
$buffer = $this->fileContents('http://www.newshost.co.za');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match_all('/<tr bgcolor=#[df]{6}>.+?<\/tr>/s', $buffer, $matches))
|
|
{
|
|
foreach ($matches as $match)
|
|
{
|
|
foreach ($match as $m)
|
|
{
|
|
if (preg_match('/<tr bgcolor=#[df]{6}>.+?<td>(?P<date>.+?)<\/td>(.+?right>(?P<size1>.+?) (?P<size2>.+?)<\/td.+?)?<td>(?P<category>.+?)<\/td.+?<a href=.+?(<a href="(?P<nfo>.+?)">nfo<\/a>.+)?<td>(?P<title>.+?)<\/td.+tr>/s', $m, $matches2))
|
|
{
|
|
$md5 = $db->escapeString(md5($matches2['title']));
|
|
$oldname = $db->queryOneRow(sprintf('SELECT md5, source, ID, nfo FROM prehash WHERE md5 = %s', $md5));
|
|
if ($oldname !== false) {
|
|
if ($oldname["nfo"] != NULL)
|
|
continue;
|
|
else
|
|
{
|
|
if (!isset($matches2["size1"]) && empty($matches2["size1"]))
|
|
$size = "NULL";
|
|
else
|
|
$size = $db->escapeString($matches2["size1"].$matches2["size2"]);
|
|
|
|
if ($matches2["nfo"] == "")
|
|
$nfo = "NULL";
|
|
else
|
|
$nfo = $db->escapeString("http://newshost.co.za/".$matches2["nfo"]);
|
|
|
|
$db->exec(sprintf("UPDATE prehash SET nfo = %s, size = %s, category = %s, predate = %s, source = %s where ID = %d", $nfo, $size, $db->escapeString($matches2["category"]), $f->from_unixtime(strtotime($matches2["date"])), $db->escapeString("womble"), $oldname["ID"]));
|
|
$updated++;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!isset($matches2["size1"]) && empty($matches2["size1"]))
|
|
$size = "NULL";
|
|
else
|
|
$size = $db->escapeString($matches2["size1"].$matches2["size2"]);
|
|
|
|
if ($matches2["nfo"] == "")
|
|
$nfo = "NULL";
|
|
else
|
|
$nfo = $db->escapeString("http://newshost.co.za/".$matches2["nfo"]);
|
|
|
|
if (strlen($matches2['title']) > 15) {
|
|
if($db->exec(sprintf("INSERT INTO prehash (title, nfo, size, category, predate, source, md5) VALUES (%s, %s, %s, %s, FROM_UNIXTIME(".strtotime($matches2["date"])."), %s, %s)", $db->escapeString($matches2["title"]), $nfo, $size, $db->escapeString($matches2["category"]), $db->escapeString("womble"), $md5)));{
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
echo $this->c->primary($updated . " \tUpdated from Womble.");
|
|
}
|
|
else
|
|
{
|
|
echo $this->c->error("Update from Womble failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveOmgwtfnzbs()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$newnames = $updated = 0;
|
|
$matches2 = $matches = $match = $m = '';
|
|
|
|
$buffer = $this->fileContents('http://rss.omgwtfnzbs.org/rss-info.php');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match_all('/<item>.+?<\/item>/s', $buffer, $matches))
|
|
{
|
|
foreach ($matches as $match)
|
|
{
|
|
foreach ($match as $m)
|
|
{
|
|
if (preg_match('/<title>(?P<title>.+?)<\/title.+?pubDate>(?P<date>.+?)<\/pubDate.+?gory:<\/b> (?P<category>.+?)<br \/.+?<\/b> (?P<size1>.+?) (?P<size2>[a-zA-Z]+)<b/s', $m, $matches2))
|
|
{
|
|
$title = preg_replace('/\s+- omgwtfnzbs\.org/', '', $matches2['title']);
|
|
$md5 = $db->escapeString(md5($title));
|
|
$oldname = $db->queryOneRow(sprintf('SELECT md5, source, ID FROM prehash WHERE md5 = %s', $md5));
|
|
if ($oldname !== false) {
|
|
if ($oldname['source'] == 'womble' || $oldname['source'] == 'omgwtfnzbs') {
|
|
continue;
|
|
} else {
|
|
$size = $db->escapeString(round($matches2["size1"]).$matches2["size2"]);
|
|
$db->exec(sprintf("UPDATE prehash SET size = %s, category = %s, predate = FROM_UNIXTIME(".strtotime($matches2["date"])."), source = %s where ID = %d", $size, $db->escapeString($matches2["category"]), $db->escapeString("omgwtfnzbs"), $oldname["ID"]));
|
|
$updated++;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
$size = $db->escapeString(round($matches2["size1"]).$matches2["size2"]);
|
|
if (strlen($title) > 15) {
|
|
if($db->exec(sprintf("INSERT INTO prehash (title, size, category, predate, source, md5) VALUES (%s, %s, %s, FROM_UNIXTIME(".strtotime($matches2["date"])."), %s, %s)", $db->escapeString($title), $size, $db->escapeString($matches2["category"]), $db->escapeString("omgwtfnzbs"),$md5))); {
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
echo $this->c->primary($updated . " \tUpdated from Omgwtfnzbs.");
|
|
}
|
|
else
|
|
{
|
|
echo $this->c->error("Update from Omgwtfnzbs failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveZenet()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$newnames = $updated = 0;
|
|
$matches2 = $matches = $match = $m = '';
|
|
|
|
$buffer = $this->fileContents('http://pre.zenet.org/live.php');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match_all('/<div class="mini-layout fluid">((\s+\S+)?\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+\S+\s+(\S+\s+)?(\S+\s+)?(\S+\s+)?(\S+\s+)?(\S+\s+)?(\S+\s+)?(\S+\s+)?<\/div>\s+<\/div>)/s', $buffer, $matches))
|
|
{
|
|
foreach ($matches as $match)
|
|
{
|
|
foreach ($match as $m)
|
|
{
|
|
if (preg_match('/<span class="bold">(?P<predate>\d{4}-\d{2}-\d{2} \d{2}:\d{2})<\/span>.+<a href="\?post=\d+"><b><font color="#\d+">(?P<title>.+)<\/font><\/b><\/a>.+<p><a href="\?cats=.+"><font color="#FF9900">(?P<category>.+)<\/font><\/a> \| (?P<size1>[\d\.,]+)?(?P<size2>[MGK]B)? \/.+<\/div>/s', $m, $matches2))
|
|
{
|
|
$md5 = $db->escapeString(md5($matches2['title']));
|
|
$title = $db->escapeString($matches2['title']);
|
|
$dupeCheck = $db->queryOneRow(sprintf('SELECT md5 FROM prehash WHERE md5 = %s', $md5));
|
|
if ($dupeCheck !== false) {
|
|
continue;
|
|
} else {
|
|
if (!isset($matches2['size1']) && empty($matches2['size1'])) {
|
|
$size = 'NULL';
|
|
} else {
|
|
$size = $db->escapeString(round($matches2['size1']).$matches2['size2']);
|
|
}
|
|
if (isset($matches2['category']) && !empty($matches2['category'])) {
|
|
$category = $db->escapeString($matches2['category']);
|
|
} else {
|
|
$category = 'NULL';
|
|
}
|
|
if (strlen($title) > 15) {
|
|
if ($db->queryInsert(sprintf('INSERT INTO prehash (title, size, category, predate, source, md5) VALUES (%s, %s, %s, %s, %s, %s)', $title, $size, $category, $db->escapeString($matches2['predate']), $db->escapeString('zenet'), $md5)));{
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
echo $this->c->error("Update from Zenet failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrievePrelist()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$newnames = $updated = 0;
|
|
$matches2 = $matches = $match = $m = '';
|
|
|
|
$buffer = $this->fileContents('http://www.prelist.ws/');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match_all('/<small><span.+?<\/span><\/small>/s', $buffer, $matches))
|
|
{
|
|
foreach ($matches as $match)
|
|
{
|
|
foreach ($match as $m)
|
|
{
|
|
if (!preg_match('/NUKED/', $m) && preg_match('/">\[ (?P<date>.+?) U.+?">(?P<category>.+?)<\/a>.+?">(?P<title>.+?)<\/a>.+?(b>\[ (?P<size>.+?) \]<\/b)?/si', $m, $matches2))
|
|
{
|
|
$md5 = $db->escapeString(md5($matches2['title']));
|
|
$oldname = $db->queryOneRow(sprintf('SELECT md5 FROM prehash WHERE md5 = %s', $md5));
|
|
if ($oldname !== false) {
|
|
continue;
|
|
}
|
|
else
|
|
{
|
|
if (!isset($matches2["size"]) && empty($matches2["size"])){
|
|
$size = "NULL";
|
|
} else {
|
|
$size = $db->escapeString(round($matches2["size"]));
|
|
}
|
|
if (strlen($matches2['title']) > 15) {
|
|
if($db->exec(sprintf("INSERT INTO prehash (title, size, category, predate, source, md5) VALUES (%s, %s, %s, FROM_UNIXTIME(".strtotime($matches2["date"])."), %s, %s)", $db->escapeString($matches2["title"]), $size, $db->escapeString($matches2["category"]), $db->escapeString("prelist"), $md5)));{
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else if (preg_match('/">\[ (?P<date>.+?) U.+?">(?P<category>.+?)<\/a>.+?">(?P<category1>.+?)<\/a.+">(?P<title>.+?)<\/a>/si', $m, $matches2))
|
|
{
|
|
$md5 = $db->escapeString(md5($matches2['title']));
|
|
$dupeCheck = $db->queryOneRow(sprintf('SELECT md5 FROM prehash WHERE md5 = %s', $md5));
|
|
if ($dupeCheck !== false) {
|
|
continue;
|
|
}else
|
|
{
|
|
$category = $db->escapeString($matches2["category"].", ".$matches2["category1"]);
|
|
if (strlen($matches2['title']) > 15) {
|
|
if($db->exec(sprintf("INSERT INTO prehash (title, category, predate, source, md5) VALUES (%s, %s, FROM_UNIXTIME(".strtotime($matches2["date"])."), %s, %s)", $db->escapeString($matches2["title"]), $category, $db->escapeString("prelist"), $md5))); {
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
echo $this->c->error("Update from Prelist failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveOrlydb()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$newnames = $updated = 0;
|
|
$matches2 = $matches = $match = $m = '';
|
|
|
|
$buffer = $this->fileContents('http://www.orlydb.com/');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match('/<div id="releases">(.+)<div id="pager">/s', $buffer, $match))
|
|
{
|
|
if (preg_match_all('/<div>.+?<\/div>/s', $match["1"], $matches))
|
|
{
|
|
foreach ($matches as $m1)
|
|
{
|
|
foreach ($m1 as $m)
|
|
{
|
|
if (preg_match('/timestamp">(?P<date>.+?)<\/span>.+?section">.+?">(?P<category>.+?)<\/a>.+?release">(?P<title>.+?)<\/span>(.+info">(?P<size>.+?) )?/s', $m, $matches2))
|
|
{
|
|
$md5 = $db->escapeString(md5($matches2['title']));
|
|
$oldname = $db->queryOneRow(sprintf('SELECT md5 FROM prehash WHERE md5 = %s', $md5));
|
|
if ($oldname !== false) {
|
|
continue;
|
|
} else {
|
|
if (!isset($matches2["size"]) && empty($matches2["size"])) {
|
|
$size = "NULL";
|
|
} else {
|
|
$size = $db->escapeString($matches2["size"]);
|
|
}
|
|
if (strlen($matches2['title']) > 15) {
|
|
if($db->exec(sprintf("INSERT INTO prehash (title, size, category, predate, source, md5) VALUES (%s, %s, %s, FROM_UNIXTIME(".strtotime($matches2["date"])."), %s, %s)", $db->escapeString($matches2["title"]), $size, $db->escapeString($matches2["category"]), $db->escapeString("orlydb"), $md5)));{
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
echo $this->c->error("Update from Orly failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveSrr()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$newnames = 0;
|
|
$url = "http://www.srrdb.com/feed/srrs";
|
|
|
|
$options = array(
|
|
'http'=>array(
|
|
'method'=>"GET",
|
|
'header'=>"Accept-language: en\r\n" .
|
|
"Cookie: foo=bar\r\n" . // check function.stream-context-create on php.net
|
|
"User-Agent: Mozilla/5.0 (iPad; U; CPU OS 3_2 like Mac OS X; en-us) AppleWebKit/531.21.10 (KHTML, like Gecko) Version/4.0.4 Mobile/7B334b Safari/531.21.102011-10-16 20:23:10\r\n" // i.e. An iPad
|
|
)
|
|
);
|
|
|
|
$context = stream_context_create($options);
|
|
$web = $this->fileContents($url, false, $context);
|
|
if ($web !== false)
|
|
{
|
|
$releases = simplexml_load_string($this->fileContents($url, false, $context));
|
|
if ($releases !== false)
|
|
{
|
|
|
|
foreach ($releases->channel->item as $release)
|
|
{
|
|
$md5 = $db->escapeString(md5($release->title));
|
|
$oldname = $db->queryOneRow(sprintf('SELECT md5 FROM prehash WHERE md5 = %s', $md5));
|
|
if ($oldname !== false) {
|
|
continue;
|
|
} else {
|
|
if (strlen($release->title) > 15) {
|
|
if($db->exec(sprintf('INSERT INTO prehash (title, predate, source, md5) VALUES (%s, %s, %s, %s)', $db->escapeString($release->title), $f->from_unixtime(strtotime($release->pubDate)), $db->escapeString('srrdb'),$md5)));{$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
echo $this->c->error("Update from Srr failed.");
|
|
}
|
|
} else {
|
|
echo $this->c->error("Update from Srr failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrievePredbme()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$newnames = $updated = 0;
|
|
|
|
$options = array(
|
|
'http' => array(
|
|
'method' => "GET",
|
|
'header' => "Accept-language: en\r\n" .
|
|
"Cookie: foo=bar\r\n" . // check function.stream-context-create on php.net
|
|
"User-Agent: Mozilla/5.0 (iPad; U; CPU OS 3_2 like Mac OS X; en-us) AppleWebKit/531.21.10 (KHTML, like Gecko) Version/4.0.4 Mobile/7B334b Safari/531.21.102011-10-16 20:23:10\r\n" // i.e. An iPad
|
|
)
|
|
);
|
|
$context = stream_context_create($options);
|
|
$arr = array("http://predb.me/?cats=movies-sd&rss=1", "http://predb.me/?cats=movies-hd&rss=1", "http://predb.me/?cats=movies-discs&rss=1", "http://predb.me/?cats=tv-sd&rss=1", "http://predb.me/?cats=tv-hd&rss=1", "http://predb.me/?cats=tv-discs&rss=1", "http://predb.me/?cats=music-audio&rss=1", "http://predb.me/?cats=music-video&rss=1", "http://predb.me/?cats=music-discs&rss=1", "http://predb.me/?cats=games-pc&rss=1", "http://predb.me/?cats=games-xbox&rss=1", "http://predb.me/?cats=games-playstation&rss=1", "http://predb.me/?cats=games-nintendo&rss=1", "http://predb.me/?cats=apps-windows&rss=1", "http://predb.me/?cats=apps-linux&rss=1", "http://predb.me/?cats=apps-mac&rss=1", "http://predb.me/?cats=apps-mobile&rss=1", "http://predb.me/?cats=books-ebooks&rss=1", "http://predb.me/?cats=books-audio-books&rss=1", "http://predb.me/?cats=xxx-videos&rss=1", "http://predb.me/?cats=xxx-images&rss=1", "http://predb.me/?cats=dox&rss=1", "http://predb.me/?cats=unknown&rss=1");
|
|
foreach ($arr as &$value)
|
|
{
|
|
$releases = @simplexml_load_string($this->fileContents($value, false, $context));
|
|
if ($releases !== false)
|
|
{
|
|
foreach ($releases->channel->item as $release)
|
|
{
|
|
$md5 = $db->escapeString(md5($release->title));
|
|
$oldname = $db->queryOneRow(sprintf('SELECT md5 FROM prehash WHERE md5 = %s', $md5));
|
|
if ($oldname !== false) {
|
|
continue;
|
|
} else
|
|
{
|
|
if (strlen($release->title) > 15) {
|
|
if($db->exec(sprintf("INSERT INTO prehash (title, predate, source, md5) VALUES (%s, now(), %s, %s)", $db->escapeString($release->title), $db->escapeString("predbme"), $md5)));{
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}else
|
|
{
|
|
echo $this->c->error("Update from Predbme failed.");
|
|
}
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveAllfilledMoovee()
|
|
{
|
|
$db = new DB();
|
|
$functions = new Functions();
|
|
$newnames = $updated = 0;
|
|
$groups = new Groups();
|
|
$groupID = $functions->getIDByName('alt.binaries.moovee');
|
|
$buffer = $this->fileContents('http://abmoovee.allfilled.com/reqs.php?fetch=posted&page=1');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match_all('/<tr class="(even|odd)".+?<\/tr>/s', $buffer, $matches))
|
|
{
|
|
foreach ($matches as $match)
|
|
{
|
|
foreach ($match as $m)
|
|
{
|
|
if (preg_match('/<td class="cell_reqid">(?P<requestID>\d+)<\/td>.+<td class="cell_request">(?P<title>.+)<\/td>.+<td class="cell_statuschange">(?P<predate>\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2})<\/td>/s', $m, $matches2))
|
|
{
|
|
if (isset($matches2["requestID"]) && isset($matches2["title"]))
|
|
{
|
|
$title = $db->escapeString($matches2["title"]);
|
|
$md5 = $db->escapeString(md5($matches2["title"]));
|
|
if (strlen($title) > 15) {
|
|
$dupeCheck = $db->queryOneRow(sprintf('SELECT ID, requestID FROM prehash WHERE md5 = %s', $md5));
|
|
if ($dupeCheck === false) {
|
|
$db->exec(sprintf("INSERT INTO prehash (title, predate, source, md5, requestID, groupID, category) VALUES (%s, %s, %s, %s, %s, %d, 'Movies')", $title, $db->escapeString($matches2["predate"]), $db->escapeString('abMooVee'), $md5, $matches2["requestID"], $groupID));
|
|
$newnames++;
|
|
} else {
|
|
$db->exec(sprintf('UPDATE prehash SET requestID = %s, groupID = %d WHERE md5 = %s', $matches2["requestID"], $groupID, $md5));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
else
|
|
echo $this->c->error ("Error: Update from Moovee failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveAllfilledTeevee()
|
|
{
|
|
$db = new DB();
|
|
$functions = new Functions();
|
|
$newnames = $updated = 0;
|
|
$groups = new Groups();
|
|
$groupID = $functions->getIDByName('alt.binaries.teevee');
|
|
$buffer = $this->fileContents('http://abteevee.allfilled.com/reqs.php?fetch=posted&page=1');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match_all('/<tr class="(even|odd)".+?<\/tr>/s', $buffer, $matches))
|
|
{
|
|
foreach ($matches as $match)
|
|
{
|
|
foreach ($match as $m)
|
|
{
|
|
if (preg_match('/<td class="cell_reqid">(?P<requestID>\d+)<\/td>.+<td class="cell_request">(?P<title>.+)<\/td>.+<td class="cell_statuschange">(?P<predate>\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2})<\/td>/s', $m, $matches2))
|
|
{
|
|
if (isset($matches2["requestID"]) && isset($matches2["title"]))
|
|
{
|
|
$title = $db->escapeString($matches2["title"]);
|
|
$md5 = $db->escapeString(md5($matches2["title"]));
|
|
if (strlen($title) > 15) {
|
|
$dupeCheck = $db->queryOneRow(sprintf('SELECT ID, requestID FROM prehash WHERE md5 = %s', $md5));
|
|
if ($dupeCheck === false) {
|
|
$db->exec(sprintf("INSERT INTO prehash (title, predate, source, md5, requestID, groupID, category) VALUES (%s, %s, %s, %s, %s, %d, 'TV')", $title, $db->escapeString($matches2["predate"]), $db->escapeString('abTeeVee'), $md5, $matches2["requestID"], $groupID));
|
|
$newnames++;
|
|
} else {
|
|
$db->exec(sprintf('UPDATE prehash SET requestID = %s, groupID = %d WHERE md5 = %s', $matches2["requestID"], $groupID, $md5));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else
|
|
echo $this->c->error ("Error: Update from Teevee failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveAllfilledErotica()
|
|
{
|
|
$db = new DB();
|
|
$functions = new Functions();
|
|
$newnames = $updated = 0;
|
|
$groups = new Groups();
|
|
$groupID = $functions->getIDByName('alt.binaries.erotica');
|
|
$buffer = $this->fileContents('http://aberotica.allfilled.com/reqs.php?fetch=posted&page=1');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match_all('/<tr class="(even|odd)".+?<\/tr>/s', $buffer, $matches))
|
|
{
|
|
foreach ($matches as $match)
|
|
{
|
|
foreach ($match as $m)
|
|
{
|
|
if (preg_match('/<td class="cell_reqid">(?P<requestID>\d+)<\/td>.+<td class="cell_request">(?P<title>.+)<\/td>.+<td class="cell_statuschange">(?P<predate>\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2})<\/td>/s', $m, $matches2))
|
|
{
|
|
if (isset($matches2["requestID"]) && isset($matches2["title"]))
|
|
{
|
|
$title = $db->escapeString($matches2["title"]);
|
|
$md5 = $db->escapeString(md5($matches2["title"]));
|
|
if (strlen($title) > 15) {
|
|
$dupeCheck = $db->queryOneRow(sprintf('SELECT ID, requestID FROM prehash WHERE md5 = %s', $md5));
|
|
if ($dupeCheck === false) {
|
|
$db->exec(sprintf("INSERT INTO prehash (title, predate, source, md5, requestid, groupid, category) VALUES (%s, %s, %s, %s, %s, %d, 'XXX')", $title, $db->escapeString($matches2["predate"]), $db->escapeString('abErotica'), $md5, $matches2["requestID"], $groupID));
|
|
$newnames++;
|
|
} else {
|
|
$db->exec(sprintf('UPDATE prehash SET requestID = %s, groupID = %d WHERE md5 = %s', $matches2["requestID"], $groupID, $md5));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else
|
|
echo $this->c->error ("Error: Update from Erotica failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveAllfilledForeign()
|
|
{
|
|
$db = new DB();
|
|
$functions = new Functions();
|
|
$newnames = $updated = 0;
|
|
$groups = new Groups();
|
|
$groupID = $functions->getIDByName('alt.binaries.mom');
|
|
$buffer = $this->fileContents('http://abforeign.allfilled.com/reqs.php?fetch=posted&page=1');
|
|
if ($buffer !== false && strlen($buffer))
|
|
{
|
|
if (preg_match_all('/<tr class="(even|odd)".+?<\/tr>/s', $buffer, $matches))
|
|
{
|
|
foreach ($matches as $match)
|
|
{
|
|
foreach ($match as $m)
|
|
{
|
|
if (preg_match('/<td class="cell_reqid">(?P<requestID>\d+)<\/td>.+<td class="cell_request">(?P<title>.+)<\/td>.+<td class="cell_statuschange">(?P<predate>\d{4}-\d{2}-\d{2}( \d{2}:\d{2}:\d{2})?)<\/td>/s', $m, $matches2))
|
|
{
|
|
if (isset($matches2["requestID"]) && isset($matches2["title"]))
|
|
{
|
|
$title = $db->escapeString($matches2["title"]);
|
|
$md5 = $db->escapeString(md5($matches2["title"]));
|
|
if (strlen($title) > 15) {
|
|
$dupeCheck = $db->queryOneRow(sprintf('SELECT ID, requestID FROM prehash WHERE md5 = %s', $md5));
|
|
if ($dupeCheck === false) {
|
|
if($db->exec(sprintf("INSERT INTO prehash (title, predate, source, md5, requestid, groupid) VALUES (%s, %s, %s, %s, %s, %d)", $title, $db->escapeString($matches2["predate"]), $db->escapeString('abForeign'), $md5, $matches2["requestID"], $groupID)));
|
|
$newnames++;
|
|
} else {
|
|
$db->exec(sprintf('UPDATE prehash SET requestID = %s, groupID = %d WHERE md5 = %s', $matches2["requestID"], $groupID, $md5));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else
|
|
echo $this->c->error ("Error: Update from Foreign failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveAbgx()
|
|
{
|
|
$db = new DB();
|
|
$newnames = 0;
|
|
$db = new DB();
|
|
$functions = new Functions();
|
|
$groups = new Groups();
|
|
|
|
$options = array(
|
|
'http'=>array(
|
|
'method'=>"GET",
|
|
'header'=>"Accept-language: en\r\n" .
|
|
"Cookie: foo=bar\r\n" . // check function.stream-context-create on php.net
|
|
"User-Agent: Mozilla/5.0 (iPad; U; CPU OS 3_2 like Mac OS X; en-us) AppleWebKit/531.21.10 (KHTML, like Gecko) Version/4.0.4 Mobile/7B334b Safari/531.21.102011-10-16 20:23:10\r\n" // i.e. An iPad
|
|
)
|
|
);
|
|
$context = stream_context_create($options);
|
|
$arr = array('x360', 'abcp', 'abgw', 'abgwu', 'absp', 'abgn', 'spsv', 'n3ds', 'abgx', 'abg', 'x360');
|
|
foreach ($arr as &$value)
|
|
{
|
|
$releases = simplexml_load_string($this->fileContents('http://www.abgx.net/rss/' . $value . '/posted.rss', false, $context));
|
|
if ($releases !== false)
|
|
{
|
|
preg_match('/^Filled requests in #(\S+)/', $releases->channel->description, $groupname);
|
|
$groupID = ($functions->getIDByName($groupname[1])) ? $functions->getIDByName($groupname[1]) : 0;
|
|
foreach ($releases->channel->item as $release)
|
|
{
|
|
preg_match('/^Req (\d+) - (\S+) .+/', $release->title, $request);
|
|
$requestID = $request[1];
|
|
preg_match('/\(\d+\) (\S+) .+(\d{4}-\d{1,2}-\d{1,2} \d{1,2}:\d{1,2}:\d{1,2})/', $release->description, $title);
|
|
$md5 = md5($title[1]);
|
|
$predate = $title[2];
|
|
|
|
$oldname = $db->queryOneRow(sprintf('SELECT md5, requestID, groupID FROM prehash WHERE md5 = %s', $db->escapeString($md5)));
|
|
if ($oldname !== false)
|
|
{
|
|
$db->exec(sprintf('UPDATE prehash SET requestID = %d, groupID = %d WHERE md5 = %s', max($oldname['requestID'], $requestID), max($oldname['groupID'], $groupID), $db->escapeString($md5)));
|
|
}
|
|
else
|
|
{
|
|
if (strlen($title[1]) > 15) {
|
|
if ($db->exec(sprintf('INSERT INTO prehash (title, predate, source, md5, requestID, groupID) VALUES (%s, %s, %s, %s, %d, %d)', $db->escapeString($title[1]), $functions->from_unixtime(strtotime($predate)), $db->escapeString('abgx'), $db->escapeString($md5), $requestID, $groupID)))
|
|
{
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else
|
|
echo $this->c->error ("Error: Update from ABGX failed.");
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
public function retrieveUsenetCrawler()
|
|
{
|
|
$db = new DB();
|
|
$newnames = 0;
|
|
$functions = new Functions();
|
|
$html = str_get_html($this->getWebPage("http://www.usenet-crawler.com/predb?q=&c=&offset=0#results"));
|
|
$releases = @$html->find('table[id="browsetable"]');
|
|
if (!isset($releases[0])) {
|
|
return $newnames;
|
|
}
|
|
$rows = $releases[0]->find('tr');
|
|
$count = 0;
|
|
foreach ($rows as $post) {
|
|
if ($count == 0) {
|
|
//Skip the table header row
|
|
$count++;
|
|
continue;
|
|
}
|
|
$data = $post->find('td');
|
|
$predate = strtotime($data[0]->innertext);
|
|
|
|
$e = $data[1]->find('a');
|
|
if (isset($e[0])) {
|
|
$title = trim($e[0]->innertext);
|
|
$title = str_ireplace(array('<u>', '</u>'), '', $title);
|
|
} elseif (preg_match('/(.+)<\/br><sub>/', $data[1])) {
|
|
// title is nuked, so skip
|
|
continue;
|
|
} else {
|
|
$title = trim($data[1]->innertext);
|
|
}
|
|
$e = $data[2]->find('a');
|
|
$category = $e[0]->innertext;
|
|
preg_match('/([\d\.]+MB)/', $data[3]->innertext, $match);
|
|
$size = isset($match[1]) ? $match[1] : 'NULL';
|
|
$md5 = md5($title);
|
|
if (strlen($title) > 15 && $category != 'NUKED') {
|
|
if ($db->exec(sprintf('INSERT INTO prehash (title, predate, source, md5, category, size) VALUES (%s, %s, %s, %s, %s, %s)', $db->escapeString($title), $functions->from_unixtime($predate), $db->escapeString('usenet-crawler'), $db->escapeString($md5), $db->escapeString($category), $db->escapeString($size)))) {
|
|
$newnames++;
|
|
}
|
|
}
|
|
}
|
|
return $newnames;
|
|
}
|
|
|
|
// Update a single release as it's created.
|
|
public function matchPre($cleanerName, $releaseID)
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$x = $db->queryOneRow(sprintf('SELECT ID FROM prehash WHERE title = %s', $db->escapeString($cleanerName)));
|
|
if (isset($x['ID'])) {
|
|
$db->exec(sprintf('UPDATE releases SET prehashID = %d WHERE ID = %d', $x['ID'], $releaseID));
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
// When a searchname is the same as the title, tie it to the predb. Try to update the categoryID at the same time.
|
|
public function matchPredb()
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$consoletools = new ConsoleTools();
|
|
$updated = 0;
|
|
if($this->echooutput)
|
|
{
|
|
echo $this->c->header('Querying DB for release searchnames not matched with prehash titles.');
|
|
}
|
|
|
|
$res = $db->queryDirect('SELECT p.ID AS prehashID, r.ID AS releaseID FROM prehash p INNER JOIN releases r ON p.title = r.searchname WHERE r.prehashID = 0');
|
|
$total = $res->rowCount();
|
|
if($total > 0)
|
|
{
|
|
echo "\n";
|
|
foreach ($res as $row)
|
|
{
|
|
$db->exec(sprintf('UPDATE releases SET prehashID = %d WHERE ID = %d', $row['prehashID'], $row['releaseID']));
|
|
if ($this->echooutput)
|
|
{
|
|
$consoletools->overWritePrimary('Matching up prehash titles with release search names: ' . $consoletools->percentString(++$updated, $total));
|
|
}
|
|
}
|
|
echo "\n";
|
|
}
|
|
return $updated;
|
|
}
|
|
// Look if the release is missing an nfo.
|
|
public function matchNfo($nntp)
|
|
{
|
|
$db = new DB();
|
|
$f = new Functions();
|
|
$nfos = 0;
|
|
if($this->echooutput)
|
|
echo $this->c->header ("Matching up prehash NFOs with releases missing an NFO.");
|
|
|
|
$res = $db->query("SELECT r.ID, p.nfo, r.completion, r.guid, r.groupID FROM releases r INNER JOIN prehash p ON r.prehashID = p.ID WHERE r.nfostatus = 0 AND p.nfo IS NOT NULL LIMIT 100");
|
|
$total = count($res);
|
|
if($total > 0)
|
|
{
|
|
$nfo = new Nfo($this->echooutput);
|
|
$nzbcontents = new Nzbcontents($this->echooutput);
|
|
$functions = new Functions($this->echooutput);
|
|
foreach ($res as $row)
|
|
{
|
|
$buffer = getUrl($row["nfo"]);
|
|
if ($buffer !== false)
|
|
{
|
|
if ($functions->addAlternateNfo($db, $buffer, $row, $nntp))
|
|
{
|
|
if($this->echooutput)
|
|
echo '+';
|
|
$nfos++;
|
|
}
|
|
else
|
|
{
|
|
if($this->echooutput)
|
|
echo '-';
|
|
}
|
|
}
|
|
}
|
|
return $nfos;
|
|
}
|
|
}
|
|
|
|
// Matches the MD5 within the prehash table to release files and subjects (names) which are hashed.
|
|
public function parseTitles($time, $echo, $cats, $namestatus, $show)
|
|
{
|
|
$db = new DB();
|
|
$namefixer = new Namefixer();
|
|
$consoletools = new ConsoleTools();
|
|
$updated = $checked = 0;
|
|
$matches = '';
|
|
|
|
$tq = "";
|
|
if ($time == 1)
|
|
$tq = $tq = 'AND r.adddate > (NOW() - INTERVAL 3 HOUR) ORDER BY rf.releaseID, rf.size DESC';
|
|
$ct = "";
|
|
if ($cats == 1)
|
|
$ct = " and r.categoryID in (2020, 5050, 6070, 8010)";
|
|
|
|
if($this->echooutput)
|
|
{
|
|
$te = "";
|
|
if ($time == 1)
|
|
$te = " in the past 3 hours";
|
|
echo $this->c->header ("Fixing search names".$te." using the prehash md5.");
|
|
}
|
|
$regex = "AND (r.ishashed = 1 OR rf.name REGEXP'[a-fA-F0-9]{32}')";
|
|
if ($cats === 3) {
|
|
$query = sprintf('SELECT r.ID AS releaseID, r.name, r.searchname, r.categoryID, r.groupID, '
|
|
. 'dehashstatus, rf.name AS filename FROM releases r '
|
|
. 'LEFT OUTER JOIN releasefiles rf ON r.ID = rf.releaseID '
|
|
. 'WHERE prehashID = 0 %s', $regex);
|
|
} else {
|
|
$query = sprintf('SELECT r.ID AS releaseID, r.name, r.searchname, r.categoryID, r.groupID, '
|
|
. 'dehashstatus, rf.name AS filename FROM releases r '
|
|
. 'LEFT OUTER JOIN releasefiles rf ON r.ID = rf.releaseID '
|
|
. 'WHERE isrenamed = 0 AND dehashstatus BETWEEN -6 AND 0 %s %s %s', $regex, $ct, $tq);
|
|
}
|
|
$res = $db->queryDirect($query);
|
|
$total = $res->rowCount();
|
|
echo $this->c->primary(number_format($total) . " releases to process.");
|
|
if ($total > 0) {
|
|
foreach ($res as $row) {
|
|
if (preg_match('/[a-f0-9]{32}/i', $row['name'], $matches)) {
|
|
$updated = $updated + $namefixer->matchPredbMD5($matches[0], $row, $echo, $namestatus, $this->echooutput, $show);
|
|
} else if (preg_match('/[a-f0-9]{32}/i', $row['filename'], $matches)) {
|
|
$updated = $updated + $namefixer->matchPredbMD5($matches[0], $row, $echo, $namestatus, $this->echooutput, $show);
|
|
}
|
|
if ($show === 2) {
|
|
$consoletools->overWritePrimary("Renamed Releases: [" . number_format($updated) . "] " . $consoletools->percentString( ++$checked, $total));
|
|
}
|
|
}
|
|
}
|
|
if ($echo == 1) {
|
|
echo $this->c->header("\n" . $updated . " releases have had their names changed out of: " . number_format($checked) . " files.");
|
|
} else {
|
|
echo $this->c->header("\n" . $updated . " releases could have their names changed. " . number_format($checked) . " files were checked.");
|
|
}
|
|
|
|
return $updated;
|
|
}
|
|
|
|
/**
|
|
* @param int $offset OFFSET
|
|
* @param int $offset2 LIMIT
|
|
* @param string $search Optional title search.
|
|
*
|
|
* @return array The row count and the query results.
|
|
*/
|
|
public function getAll($offset, $offset2, $search = '')
|
|
{
|
|
$db = new DB();
|
|
if ($search !== '') {
|
|
$search = explode(' ', trim($search));
|
|
if (count($search > 1)) {
|
|
$search = "LIKE '%" . implode("%' AND title LIKE '%", $search) . "%'";
|
|
} else {
|
|
$search = "LIKE '%" . $search . "%'";
|
|
}
|
|
$search = 'WHERE title ' . $search;
|
|
$count = $db->queryOneRow(sprintf('SELECT COUNT(*) AS cnt FROM prehash %s', $search));
|
|
$count = $count['cnt'];
|
|
} else {
|
|
$count = $this->getCount();
|
|
}
|
|
|
|
$parr = $db->query(sprintf('SELECT p.*, r.guid FROM prehash p LEFT OUTER JOIN releases r ON p.ID = r.prehashID %s ORDER BY p.predate DESC LIMIT %d OFFSET %d', $search, $offset2, $offset));
|
|
return array('arr' => $parr, 'count' => $count);
|
|
}
|
|
|
|
// Returns a single row for a release.
|
|
public function getForRelease($prehashID)
|
|
{
|
|
$db = new DB();
|
|
return $db->query(sprintf('SELECT * FROM prehash WHERE ID = %d', $prehashID));
|
|
}
|
|
|
|
public function getCount()
|
|
{
|
|
$db = new DB();
|
|
$count = $db->queryOneRow("SELECT count(*) as cnt from prehash");
|
|
return $count["cnt"];
|
|
}
|
|
|
|
public function getOne($prehashID)
|
|
{
|
|
$db = new DB();
|
|
return $db->queryOneRow(sprintf('SELECT * FROM prehash WHERE ID = %d', $prehashID));
|
|
}
|
|
|
|
public function getWebPage($url)
|
|
{
|
|
$ch = curl_init();
|
|
curl_setopt($ch, CURLOPT_URL, $url);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
|
$output = curl_exec($ch);
|
|
curl_close($ch);
|
|
return $output;
|
|
}
|
|
|
|
function fileContents($path, $use = false, $context = '')
|
|
{
|
|
if ($context === '') {
|
|
$str = @file_get_contents($path);
|
|
} else {
|
|
$str = @file_get_contents($path, $use, $context);
|
|
}
|
|
if ($str === FALSE) {
|
|
return false;
|
|
} else {
|
|
return $str;
|
|
}
|
|
}
|
|
}
|