mirror of
https://github.com/NNTmux/newznab-tmux.git
synced 2026-08-30 09:48:55 +00:00
jonnyboy
234 lines
11 KiB
PHP
Executable File
234 lines
11 KiB
PHP
Executable File
<?php
|
|
|
|
require_once("config.php");
|
|
require_once(WWW_DIR."/lib/postprocess.php");
|
|
|
|
$db = new DB();
|
|
|
|
//initial queries
|
|
$book_query = "SELECT COUNT(*) AS cnt from releases where bookinfoID IS NULL and categoryID = 7020;";
|
|
$book_query2 = "SELECT COUNT(*) AS cnt from releases where categoryID = 7020;";
|
|
$console_query = "SELECT COUNT(*) AS cnt from releases where consoleinfoID IS NULL and categoryID in ( select ID from category where parentID = 1000 );";
|
|
$console_query2 = "SELECT COUNT(*) AS cnt from releases where categoryID in ( select ID from category where parentID = 1000 );";
|
|
$movie_query = "SELECT COUNT(*) AS cnt from releases where imdbID IS NULL and categoryID in ( select ID from category where parentID = 2000 );";
|
|
$movie_query2 = "SELECT COUNT(*) AS cnt from releases where categoryID in ( select ID from category where parentID = 2000 );";
|
|
$music_query = "SELECT COUNT(*) AS cnt from releases where musicinfoID IS NULL and categoryID in ( select ID from category where parentID = 3000 );";
|
|
$music_query2 = "SELECT COUNT(*) AS cnt from releases where categoryID in ( select ID from category where parentID = 3000 );";
|
|
$pc_query = "SELECT COUNT(*) AS cnt from releases r left join category c on c.ID = r.categoryID where (categoryID in ( select ID from category where parentID = 4000)) and ((r.passwordstatus between -6 and -1) or (r.haspreview = -1 and c.disablepreview = 0));";
|
|
$pc_query2 = "SELECT COUNT(*) AS cnt from releases where categoryID in ( select ID from category where parentID = 4000 );";
|
|
$tvrage_query = "SELECT COUNT(*) AS cnt, ID from releases where rageID = -1 and categoryID in ( select ID from category where parentID = 5000 );";
|
|
$tvrage_query2 = "SELECT COUNT(*) AS cnt, ID from releases where categoryID in ( select ID from category where parentID = 5000 );";
|
|
$releases_query = "SELECT COUNT(*) AS cnt from releases";
|
|
$work_remaining_query = "SELECT COUNT(*) AS cnt from releases r left join category c on c.ID = r.categoryID where (r.passwordstatus between -6 and -1) or (r.haspreview = -1 and c.disablepreview = 0);";
|
|
$nfo_remaining_query = "SELECT COUNT(*) AS cnt from releasenfo rn left outer join releases r ON r.ID = rn.releaseID WHERE rn.nfo IS NULL AND rn.attempts < 5;";
|
|
$_maxdays = getenv('MAXDAYS');
|
|
$backfill_increment = "UPDATE groups set backfill_target=backfill_target+1 where active=1 and backfill_target<$_maxdays;";
|
|
|
|
//initial counts
|
|
$releases_start = $db->query($releases_query);
|
|
$releases_start = $releases_start[0]['cnt'];
|
|
|
|
//functions
|
|
function games()
|
|
{
|
|
$postprocess = new PostProcess(true);
|
|
$postprocess->processGames();
|
|
}
|
|
|
|
|
|
$time = TIME();
|
|
$time2 = TIME();
|
|
$time3 = TIME();
|
|
$time4 = TIME();
|
|
|
|
$i=1;
|
|
while($i>0)
|
|
{
|
|
$secs = TIME() - $time;
|
|
$mins = floor($secs / 60);
|
|
$hrs = floor($mins / 60);
|
|
$days = floor($hrs / 24);
|
|
$sec = floor($secs % 60);
|
|
$min = ($mins % 60);
|
|
$hr = ($hrs % 60);
|
|
$day = ($days % 24);
|
|
|
|
//loop counts
|
|
$releases_loop = $db->query($releases_query);
|
|
$releases_loop = $releases_loop[0]['cnt'];
|
|
|
|
|
|
$sleeptime = getenv('MONITOR_UPDATE');
|
|
if ($i!=1) {
|
|
sleep($sleeptime);
|
|
}
|
|
$short_sleep = $sleeptime;
|
|
|
|
//get totals inside loop
|
|
$nfo_remaining_now = $db->query($nfo_remaining_query);
|
|
$nfo_remaining_now = $nfo_remaining_now[0]['cnt'];
|
|
$book_releases_proc = $db->query($book_query);
|
|
$book_releases_proc = $book_releases_proc[0]['cnt'];
|
|
$book_releases_now = $db->query($book_query2);
|
|
$book_releases_now = $book_releases_now[0]['cnt'];
|
|
$console_releases_proc = $db->query($console_query);
|
|
$console_releases_proc = $console_releases_proc[0]['cnt'];
|
|
$console_releases_now = $db->query($console_query2);
|
|
$console_releases_now = $console_releases_now[0]['cnt'];
|
|
$movie_releases_proc = $db->query($movie_query);
|
|
$movie_releases_proc = $movie_releases_proc[0]['cnt'];
|
|
$movie_releases_now = $db->query($movie_query2);
|
|
$movie_releases_now = $movie_releases_now[0]['cnt'];
|
|
$music_releases_proc = $db->query($music_query);
|
|
$music_releases_proc = $music_releases_proc[0]['cnt'];
|
|
$music_releases_now = $db->query($music_query2);
|
|
$music_releases_now = $music_releases_now[0]['cnt'];
|
|
$pc_releases_proc = $db->query($pc_query);
|
|
$pc_releases_proc = $pc_releases_proc[0]['cnt'];
|
|
$pc_releases_now = $db->query($pc_query2);
|
|
$pc_releases_now = $pc_releases_now[0]['cnt'];
|
|
$tvrage_releases_proc = $db->query($tvrage_query);
|
|
$tvrage_releases_proc = $tvrage_releases_proc[0]['cnt'];
|
|
$tvrage_releases_now = $db->query($tvrage_query2);
|
|
$tvrage_releases_now = $tvrage_releases_now[0]['cnt'];
|
|
$releases_now = $db->query($releases_query);
|
|
$releases_now = $releases_now[0]['cnt'];
|
|
$work_remaining_now = $db->query($work_remaining_query);
|
|
$work_remaining_now = $work_remaining_now[0]['cnt'];
|
|
$releases_since_start = $releases_now - $releases_start;
|
|
$releases_since_loop = $releases_now - $releases_loop;
|
|
$additional_releases_now = $releases_now - $book_releases_now - $console_releases_now - $movie_releases_now - $music_releases_now - $pc_releases_now - $tvrage_releases_now;
|
|
$total_work_now = $work_remaining_now + $tvrage_releases_proc + $music_releases_proc + $movie_releases_proc + $console_releases_proc + $book_releases_proc;
|
|
|
|
passthru('clear');
|
|
printf("\033[1;34mMonitor\033[0m has been running for: \033[38;5;160m$day\033[0m");printf(" days, ");
|
|
printf("\033[38;5;208m$hr\033[0m");printf(" hrs, ");
|
|
printf("\033[38;5;020m$min\033[0m");printf(" min\n");
|
|
printf("The script updates every $sleeptime seconds.\n");
|
|
printf("$releases_since_loop releases added since last update.\n\n");
|
|
|
|
printf("$releases_now releases in your database.\n");
|
|
printf("$releases_since_start releases have been added.\n\n");
|
|
|
|
$mask = "%16s %10s %10s \n";
|
|
printf($mask, "Category", "In Process", "In Database");
|
|
printf($mask, "===============", "==========", "==========");
|
|
printf($mask, "Books(7020)","$book_releases_proc","$book_releases_now");
|
|
printf($mask, "Console(1000)","$console_releases_proc","$console_releases_now");
|
|
printf($mask, "Movie(2000)","$movie_releases_proc","$movie_releases_now");
|
|
printf($mask, "Audio(3000)","$music_releases_proc","$music_releases_now");
|
|
printf($mask, "PC(4000)","$pc_releases_proc","$pc_releases_now");
|
|
printf($mask, "TVShows(5000)","$tvrage_releases_proc","$tvrage_releases_now");
|
|
printf($mask, "Additional Proc","$work_remaining_now","$additional_releases_now");
|
|
|
|
printf("Pane is dead = dormant, no work to be done");
|
|
|
|
//environment
|
|
$_DB_USER = getenv('DB_USER');
|
|
$_DB_HOST = getenv('DB_HOST');
|
|
$_DB_PASSWORD = getenv('DB_PASSWORD');
|
|
$_DB_NAME = getenv('DB_NAME');
|
|
$_backfill = getenv('BACKFILL');
|
|
$_binaries = getenv('BINARIES');
|
|
$_import = getenv('IMPORT');
|
|
$_cleanup = getenv('CLEANUP');
|
|
|
|
$_innodb_path = getenv('INNODB_PATH');
|
|
$_admin_path = getenv('ADMIN_PATH');
|
|
$_max_releases = getenv('MAX_RELEASES');
|
|
$_nzbs = getenv('NZBS');
|
|
$_newznab_path = getenv('NEWZNAB_PATH');
|
|
$_testing_path = getenv('TESTING_PATH');
|
|
$_mysql = getenv('MYSQL');
|
|
$_php = getenv('PHP');
|
|
|
|
|
|
if ((TIME() - $time2) >= 900 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:1.0 'cd $_newznab_path && $_php update_predb.php true' 2>&1 1> /dev/null");
|
|
$time2 = TIME();
|
|
}
|
|
if (((TIME() - $time3) >= 7200 ) && ($_cleanup == "true" )) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:1.1 'cd $_testing_path && $_php update_parsing.php && $_php removespecial.php && $_php update_cleanup.php' 2>&1 1> /dev/null");
|
|
$time3 = TIME();
|
|
}
|
|
if ((TIME() - $time4) >= 43200) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:1.2 'cd $_newznab_path && $_php update_tvschedule.php && $_php update_theaters.php' 2>&1 1> /dev/null");
|
|
$time4 = TIME();
|
|
}
|
|
|
|
//check if scripts need to be started
|
|
if ( $nfo_remaining_now > 0 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.1 'cd bin && $_php postprocess_nfo.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if ( $work_remaining_now > 0 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.2 'cd bin && $_php processAlternate2.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if ( $work_remaining_now > 200 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.3 'cd bin && $_php processAlternate3.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if ( $work_remaining_now > 400 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.4 'cd bin && $_php processAlternate4.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if ( $book_releases_proc > 0 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.5 'cd bin && $_php processBooks.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if ( $console_releases_proc > 0 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.6 'cd bin && $_php processGames.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if ( $movie_releases_proc > 0 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.7 'cd bin && $_php processMovies.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if ( $music_releases_proc > 0 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.8 'cd bin && $_php processMusic.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if ( $tvrage_releases_proc > 0 ) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.9 'cd bin && $_php processTv.php && clear' 2>&1 1> /dev/null");
|
|
}
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.10 'cd bin && $_php processOthers.php && clear' 2>&1 1> /dev/null");
|
|
|
|
if (( getenv('INNODB') == "true" ) && ( getenv('THREADS') == "true" )) {
|
|
$_import_path = $_innodb_path;
|
|
$_update_path = $_innodb_path;
|
|
$_import_cmd = 'nzb-import.php';
|
|
$_backfill_cmd = 'backfill_threaded.php';
|
|
$_update_cmd = 'update_binaries_threaded.php';
|
|
} elseif (( getenv('INNODB') == "true" ) && ( getenv('THREADS') != "true" )) {
|
|
$_import_path = $_admin_path;
|
|
$_update_path = $_innodb_path;
|
|
$_import_cmd = 'nzb-importmodified.php';
|
|
$_backfill_cmd = 'backfill.php';
|
|
$_update_cmd = 'update_binaries.php';
|
|
} elseif (( getenv('INNODB') != "true" ) && ( getenv('THREADS') == "true" )) {
|
|
$_import_path = $_admin_path;
|
|
$_update_path = $_newznab_path;
|
|
$_import_cmd = 'nzb-importmodified.php';
|
|
$_backfill_cmd = 'backfill_threaded.php';
|
|
$_update_cmd = 'update_binaries_threaded.php';
|
|
} else {
|
|
$_import_path = $_admin_path;
|
|
$_update_path = $_newznab_path;
|
|
$_import_cmd = 'nzb-importmodified.php';
|
|
$_backfill_cmd = 'backfill.php';
|
|
$_update_cmd = 'update_binaries.php';
|
|
}
|
|
|
|
|
|
if (( $total_work_now < $_max_releases ) && ( $_binaries == "true" )) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.11 'cd $_update_path && $_php $_update_cmd && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if (( $total_work_now < $_max_releases ) && ( $_backfill == "true" )) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.12 '$_mysql -u$_DB_USER -h $_DB_HOST --password=$_DB_PASSWORD $_DB_NAME -e \"${backfill_increment}\"' 2>&1 1> /dev/null");
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.12 'cd $_update_path && $_php $_backfill_cmd && clear' 2>&1 1> /dev/null");
|
|
}
|
|
if (( $total_work_now < $_max_releases ) && ( $_import == "true" )) {
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.13 'cd $_import_path && $_php $_import_cmd \"$_nzbs\" && clear' 2>&1 1> /dev/null");
|
|
}
|
|
shell_exec("tmux respawnp -t Newznab-dev:0.14 'cd $_newznab_path && $_php update_releases.php && clear' 2>&1 1> /dev/null");
|
|
|
|
$i=$i+1;
|
|
}
|
|
|
|
?>
|
|
|
|
|