Bootstrapify the webui
This commit is contained in:
70
source/webui/run-jobs.php
Normal file
70
source/webui/run-jobs.php
Normal file
@@ -0,0 +1,70 @@
|
||||
<?php
|
||||
|
||||
define('HBC_File', 'run-jobs');
|
||||
|
||||
require_once '_inc.php';
|
||||
|
||||
require_once 'Net/Gearman/Client.php';
|
||||
|
||||
|
||||
try {
|
||||
$main = RippingCluster_Main::instance();
|
||||
$config = $main->config();
|
||||
$log = $main->log();
|
||||
|
||||
$client = new Net_Gearman_Client($config->get('rips.job_servers'));
|
||||
$set = new Net_Gearman_Set();
|
||||
|
||||
// Retrieve a list of Created jobs
|
||||
$jobs = RippingCluster_Job::allWithStatus(RippingCluster_JobStatus::CREATED);
|
||||
|
||||
foreach ($jobs as $job) {
|
||||
// Enqueue the job using gearman
|
||||
$args = $job->queue();
|
||||
$task = new Net_Gearman_Task($args['method'], $args);
|
||||
$task->attachCallback('gearman_complete', Net_Gearman_Task::TASK_COMPLETE);
|
||||
$task->attachCallback('gearman_fail', Net_Gearman_Task::TASK_FAIL);
|
||||
$set->addTask($task);
|
||||
|
||||
$job->updateStatus(RippingCluster_JobStatus::QUEUED);
|
||||
RippingCluster_ClientLogEntry::info($log, $args['rip_options']['id'], 'Job queued', 'client');
|
||||
}
|
||||
|
||||
$job_count = count($jobs);
|
||||
RippingCluster_ClientLogEntry::info($log, null, "Job queue started with {$job_count} jobs.", 'batch');
|
||||
|
||||
// Start the job queue
|
||||
$result = $client->runSet($set);
|
||||
|
||||
RippingCluster_ClientLogEntry::info($log, null, 'Job queue completed', 'batch');
|
||||
|
||||
} catch (RippingCluster_Exception $e) {
|
||||
die("Uncaught Exception (" . get_class($e) . "): " . $e->getMessage() . "\n");
|
||||
}
|
||||
|
||||
|
||||
function gearman_complete($method, $handle, $result) {
|
||||
$main = RippingCluster_Main::instance();
|
||||
$log = $main->log();
|
||||
|
||||
$job = RippingCluster_Job::fromId($result['id']);
|
||||
$job->updateStatus(RippingCluster_JobStatus::COMPLETE);
|
||||
|
||||
RippingCluster_ClientLogEntry::info($log, $job->id(), 'Job complete');
|
||||
}
|
||||
|
||||
function gearman_fail($task) {
|
||||
$main = RippingCluster_Main::instance();
|
||||
$log = $main->log();
|
||||
|
||||
$job = RippingCluster_Job::fromId($task->arg['rip_options']['id']);
|
||||
$job->updateStatus(RippingCluster_JobStatus::FAILED);
|
||||
|
||||
RippingCluster_ClientLogEntry::info($log, $job->id(), "Job failed with message: {$task->result}");
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
?>
|
||||
@@ -6,24 +6,6 @@
|
||||
{foreach from=$running_jobs item=job}
|
||||
<li><a href="{$base_uri}jobs/details/id/{$job->id()}" title="View job details">{$job->name()}</a> <span class="progressBar" id="job_progress_{$job->id()}">{$job->currentStatus()->ripProgress()}%</span> ({RippingCluster_Main::formatDuration($job->calculateETA(), 1)} remaining)</li>
|
||||
{/foreach}
|
||||
<script type="text/javascript">
|
||||
$('.progressBar').each(
|
||||
function() {
|
||||
$(this).progressBar({
|
||||
steps: 100,
|
||||
width: 120,
|
||||
height: 12,
|
||||
boxImage: '{$base_uri}images/jquery.progressbar/progressbar.gif',
|
||||
barImage: {
|
||||
0: '{$base_uri}images/jquery.progressbar/progressbg_red.gif',
|
||||
25: '{$base_uri}images/jquery.progressbar/progressbg_orange.gif',
|
||||
50: '{$base_uri}images/jquery.progressbar/progressbg_yellow.gif',
|
||||
75: '{$base_uri}images/jquery.progressbar/progressbg_green.gif',
|
||||
}
|
||||
});
|
||||
}
|
||||
);
|
||||
</script>
|
||||
{else}
|
||||
<em>There are no currently running jobs.</em>
|
||||
{/if}
|
||||
|
||||
@@ -1,62 +1,101 @@
|
||||
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01//EN" "http://www.w3.org/TR/html4/strict.dtd">
|
||||
<html>
|
||||
<head>
|
||||
<title>Ripping Cluster WebUI</title>
|
||||
<script lang="javascript">
|
||||
</script>
|
||||
<link rel="stylesheet" type="text/css" href="{$base_uri}styles/normal.css" />
|
||||
<title>{$title}</title>
|
||||
|
||||
<!-- JQuery //-->
|
||||
<script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jquery/1.6.4/jquery.min.js"></script>
|
||||
<script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jqueryui/1.8.16/jquery-ui.min.js"></script>
|
||||
<link type="text/css" href="http://ajax.googleapis.com/ajax/libs/jqueryui/1.8.16/themes/smoothness/jquery-ui.css" rel="Stylesheet" />
|
||||
<!-- JQuery Plugins //-->
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/jquery.chained.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/jquery.jec-1.3.2.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/jquery.asmselect.js"></script>
|
||||
<link type="text/css" href="{$base_uri}styles/3rdparty/jquery.asmselect.css" rel="Stylesheet" />
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/jquery.progressbar.min.js"></script>
|
||||
|
||||
<!-- Less //-->
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/less-1.1.5.min.js"></script>
|
||||
|
||||
<!-- Bootstrap //-->
|
||||
<link rel="stylesheet" href="http://twitter.github.com/bootstrap/1.4.0/bootstrap.min.css">
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/bootstrap-alerts.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/bootstrap-twipsy.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/bootstrap-popover.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/bootstrap-dropdown.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/bootstrap-tabs.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/bootstrap-modal.js"></script>
|
||||
|
||||
<!-- Local //-->
|
||||
<script type="text/javascript" src="{$base_uri}scripts/main.js"></script>
|
||||
|
||||
<link rel="stylesheet/less" href="{$base_uri}less/bootstrap.less" media="all" />
|
||||
<link rel="stylesheet" type="text/css" href="{$base_uri}styles/normal.css" />
|
||||
|
||||
<script type="text/javascript">
|
||||
var base_uri = "{$base_uri|escape:'quote'}";
|
||||
var base_url = "{$base_url|escape:'quote'}";
|
||||
</script>
|
||||
|
||||
<link type="text/css" href="http://ajax.googleapis.com/ajax/libs/jqueryui/1.8.16/themes/smoothness/jquery-ui.css" rel="Stylesheet" />
|
||||
<link type="text/css" href="{$base_uri}styles/3rdparty/jquery.asmselect.css" rel="Stylesheet" />
|
||||
<script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jquery/1.6.4/jquery.min.js"></script>
|
||||
<script type="text/javascript" src="https://ajax.googleapis.com/ajax/libs/jqueryui/1.8.16/jquery-ui.min.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/jquery.jec-1.3.2.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/jquery.asmselect.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/3rdparty/jquery.progressbar.min.js"></script>
|
||||
<script type="text/javascript" src="{$base_uri}scripts/main.js"></script>
|
||||
</head>
|
||||
<body>
|
||||
<div class="topbar no-print">
|
||||
<div class="topbar-inner">
|
||||
<div class="container-fluid">
|
||||
{$page->include_template('navigation')}
|
||||
</div><!-- /tobar-inner -->
|
||||
</div><!-- /container-fliud -->
|
||||
</div><!-- /topbar -->
|
||||
|
||||
<div id="container">
|
||||
|
||||
<div id="banner">
|
||||
<h1>Ripping Cluster WebUI</h1>
|
||||
</div>
|
||||
|
||||
<div id="navigation">
|
||||
{include file="navigation.tpl"}
|
||||
</div>
|
||||
|
||||
<div id="page-container">
|
||||
|
||||
<div id="sidebar">
|
||||
{include file="sidebar.tpl"}
|
||||
<div class="container">
|
||||
<div class="row">
|
||||
<div class="span16">
|
||||
<h1>RippingCluster WebUI</h1>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="row">
|
||||
{if ! $messages}
|
||||
{$session = RippingCluster_Main::instance()->session()}
|
||||
{$messages = $session->get('messages')}
|
||||
{$session->delete('messages')}
|
||||
{/if}
|
||||
{if $messages}
|
||||
<div id="messages">
|
||||
{foreach from=$messages item=message}
|
||||
{if is_array($message)}
|
||||
{$severity=$message['severity']}
|
||||
<div class="alert-message {$severity}">
|
||||
{$message['content']|escape:html}
|
||||
</div>
|
||||
{else}
|
||||
<div class="alert-message info">
|
||||
{$message|escape:html}
|
||||
</div>
|
||||
{/if}
|
||||
{/foreach}
|
||||
</div><!-- /messages -->
|
||||
{/if}
|
||||
|
||||
<div id="page">
|
||||
|
||||
{if $messages}
|
||||
<div id="messages">
|
||||
{foreach from=$messages item=message}
|
||||
{$message}
|
||||
{/foreach}
|
||||
</div>
|
||||
{/if}
|
||||
|
||||
<div id="page_content">
|
||||
{$page_content}
|
||||
|
||||
</div>
|
||||
|
||||
</div>
|
||||
|
||||
<div id="footer">
|
||||
Powered by RippingCluster WebUI {$version}. Written by Ben Roberts.
|
||||
</div>
|
||||
|
||||
<footer class="no-print">
|
||||
<p>
|
||||
Powered by RippingCluster WebUI {$version}. Written by Ben Roberts.
|
||||
</p>
|
||||
<p>
|
||||
This work by <a xmlns:cc="http://creativecommons.org/ns#" href="http://benroberts.net" property="cc:attributionName" rel="cc:attributionURL">Ben Roberts</a>
|
||||
is licensed under a <a rel="license" href="http://creativecommons.org/licenses/by-nc-sa/3.0/">Creative Commons Attribution-NonCommercial-ShareAlike 3.0 Unported License</a>.
|
||||
<br />
|
||||
|
||||
<a rel="license" href="http://creativecommons.org/licenses/by-nc-sa/3.0/">
|
||||
<img alt="Creative Commons Licence" style="border-width:0" src="http://i.creativecommons.org/l/by-nc-sa/3.0/88x31.png" />
|
||||
</a>
|
||||
</p>
|
||||
</footer>
|
||||
|
||||
</div>
|
||||
|
||||
|
||||
@@ -1,5 +1,31 @@
|
||||
<ul>
|
||||
<li><a href="{$base_uri}home/" title="Home">Home</a></li>
|
||||
<li><a href="{$base_uri}jobs/" title="Jobs">Jobs</a></li>
|
||||
<li><a href="{$base_uri}logs/" title="Logs">Logs</a></li>
|
||||
<a class="brand" href="{$base_uri}home/">RippingCluster</a>
|
||||
|
||||
<ul class="nav">
|
||||
<li {if $requested_page == "home"}class="active"{/if}>
|
||||
<a href="{$base_uri}home/" title="Home">Home</a>
|
||||
</li>
|
||||
|
||||
<li {if $requested_page == "jobs"}class="active"{/if}>
|
||||
<a href="{$base_uri}jobs/" title="Jobs">Jobs</a>
|
||||
</li>
|
||||
|
||||
<li {if $requested_page == "logs"}class="active"{/if}>
|
||||
<a href="{$base_uri}logs/" title="Logs">Logs</a>
|
||||
</li>
|
||||
|
||||
<li class="dropdown {if $requested_page == "sources"}active{/if}" data-dropdown="dropdown">
|
||||
<a href="#" class="dropdown-toggle" title="Sources">Sources</a>
|
||||
<ul class="dropdown-menu">
|
||||
<li><a href="{$base_uri}sources/list/" title="All Sources">All</a></li>
|
||||
</ul>
|
||||
</li>
|
||||
|
||||
<li class="dropdown" data-dropdown="dropdown">
|
||||
<a href="#" class="dropdown-toggle" title="Admin">Admin</a>
|
||||
<ul class="dropdown-menu">
|
||||
<li><a href="{$base_uri}admin/settings/" title="Settings">Settings</a></li>
|
||||
</ul>
|
||||
</li>
|
||||
|
||||
</ul>
|
||||
|
||||
|
||||
Reference in New Issue
Block a user