3 files changed, 156 insertions, 0 deletions
diff --git a/contrib/dashboard.css b/contrib/dashboard.css
new file mode 100644
index 0000000..469db78
--- /dev/null
+++ b/contrib/dashboard.css
@@ -0,0 +1,7 @@
+.jid {
+	font-family: Consolas, mono;
+}
+.job .urls {
+	max-height: 10em;
+	overflow-y: scroll;
+}
diff --git a/contrib/dashboard.html b/contrib/dashboard.html
new file mode 100644
index 0000000..cc09d50
--- /dev/null
+++ b/contrib/dashboard.html
@@ -0,0 +1,22 @@
+<!DOCTYPE html>
+<html lang="en">
+    <head>
+		<meta charset="utf-8">
+		 <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no">
+        <title>chromebot dashboard</title>
+		<!--<script src="https://cdn.jsdelivr.net/npm/vue/dist/vue.js"></script>-->
+		<script src="https://cdn.jsdelivr.net/npm/vue@2/dist/vue.min.js"></script>
+		<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/bulma@0.7/css/bulma.min.css">
+		<link rel="stylesheet" href="dashboard.css">
+    </head>
+    <body>
+		<noscript>Please enable JavaScript.</noscript>
+		<section id="app" class="section">
+		<h1 class="title">chromebot dashboard</h1>
+		<div class="jobs">
+			<job-item v-for="j in jobs" v-bind:job="j" v-bind:jobs="jobs" v-bind:ignored="ignored" v-bind:key="j.id"></job-item>
+		</div>
+		</section>
+		<script src="dashboard.js"></script>
+    </body>
+</html>
diff --git a/contrib/dashboard.js b/contrib/dashboard.js
new file mode 100644
index 0000000..eb34d43
--- /dev/null
+++ b/contrib/dashboard.js
@@ -0,0 +1,127 @@
+/* configuration */
+let socket = "ws://localhost:6789/",
+	urllogMax = 100;
+
+function formatSize (bytes) {
+	let prefixes = ['B', 'KiB', 'MiB', 'GiB', 'TiB'];
+	while (bytes >= 1024 && prefixes.length > 1) {
+		bytes /= 1024;
+		prefixes.shift ();
+	}
+	return bytes.toFixed (1) + ' ' + prefixes[0];
+}
+
+class Job {
+	constructor (id, url, user, queued) {
+		this.id = id;
+		this.url = url;
+		this.user = user;
+		this.status = undefined;
+		this.stats = {'pending': 0, 'have': 0, 'running': 0,
+				'requests': 0, 'finished': 0, 'failed': 0,
+				'bytesRcv': 0, 'crashed': 0, 'ignored': 0};
+		this.urllog = [];
+		this.queued = queued;
+		this.started = undefined;
+		this.finished = undefined;
+		this.aborted = undefined;
+	}
+
+	addUrl (url) {
+		if (this.urllog.push (url) > urllogMax) {
+			this.urllog.shift ();
+		}
+	}
+}
+
+let jobs = {};
+/* list of ignored job ids, i.e. those the user deleted from the dashboard */
+let ignored = [];
+let ws = new WebSocket(socket);
+ws.onmessage = function (event) {
+	var msg = JSON.parse (event.data);
+	let msgdate = new Date (Date.parse (msg.date));
+	var j = undefined;
+	console.log (msg);
+	if (msg.job) {
+		if (ignored.includes (msg.job)) {
+			console.log ("job ignored", msg.job);
+			return;
+		}
+		j = jobs[msg.job];
+		if (j === undefined) {
+			j = new Job (msg.job, 'unknown', '<unknown>', new Date ());
+			Vue.set (jobs, msg.job, j);
+		}
+	}
+	if (msg.uuid == '36cc34a6-061b-4cc5-84a9-4ab6552c8d75') {
+		j = new Job (msg.job, msg.url, msg.user, msgdate);
+		/* jobs[msg.job] = j does not work with vue, see
+		https://vuejs.org/v2/guide/list.html#Object-Change-Detection-Caveats
+		*/
+		Vue.set (jobs, msg.job, j);
+		j.status = 'pending';
+	} else if (msg.uuid == '46e62d60-f498-4ab0-90e1-d08a073b10fb') {
+		j.status = 'running';
+		j.started = msgdate;
+	} else if (msg.uuid == '7b40ffbb-faab-4224-90ed-cd4febd8f7ec') {
+		j.status = 'finished';
+		j.finished = msgdate;
+	} else if (msg.uuid == '865b3b3e-a54a-4a56-a545-f38a37bac295') {
+		j.status = 'aborted';
+		j.aborted = msgdate;
+	} else if (msg.uuid == '5c0f9a11-dcd8-4182-a60f-54f4d3ab3687') {
+		/* forwarded job message */
+		let rmsg = msg.data;
+		if (rmsg.uuid == '24d92d16-770e-4088-b769-4020e127a7ff') {
+			/* job status */
+			Object.assign (j.stats, rmsg);
+		} else if (rmsg.uuid == '5b8498e4-868d-413c-a67e-004516b8452c') {
+			/* recursion status */
+			Object.assign (j.stats, rmsg);
+		} else if (rmsg.uuid == '1680f384-744c-4b8a-815b-7346e632e8db') {
+			/* fetch */
+			j.addUrl (rmsg.url);
+		}
+	}
+};
+ws.onopen = function (event) {
+};
+ws.onerror = function (event) {
+};
+
+Vue.component('job-item', {
+  props: ['job', 'jobs', 'ignored'],
+  template: '<div class="job box" :id="job.id"><ul class="columns"><li class="jid column is-narrow"><a :href="\'#\' + job.id">{{ job.id }}</a></li><li class="url column"><a :href="job.url">{{ job.url }}</a></li><li class="status column is-narrow"><job-status v-bind:job="job"></job-status></li><li class="column is-narrow"><a class="delete" v-on:click="del(job.id)"></a></li></ul><job-stats v-bind:job="job"></job-stats></div>',
+  methods: {
+  	del: function (id) {
+		Vue.delete(this.jobs, id);
+		this.ignored.push (id);
+	}
+	}
+});
+Vue.component('job-status', {
+	props: ['job'],
+	template: '<span v-if="job.status == \'pending\'">queued on {{ job.queued.toLocaleString() }}</span><span v-else-if="job.status == \'aborted\'">aborted on {{ job.aborted.toLocaleString() }}</span><span v-else-if="job.status == \'running\'">running since {{ job.started.toLocaleString() }}</span><span v-else-if="job.status == \'finished\'">finished since {{ job.finished.toLocaleString() }}</span>'
+});
+Vue.component('job-stats', {
+  props: ['job'],
+  template: '<div><progress class="progress is-info" :value="job.stats.have" :max="job.stats.have+job.stats.pending+job.stats.running"></progress><ul class="stats columns"><li class="column">{{ job.stats.have }} <small>have</small></li><li class="column">{{ job.stats.running }} <small>running</small></li><li class="column">{{ job.stats.pending }} <small>pending</small></li><li class="column">{{ job.stats.requests }} <small>requests</small><li class="column"><filesize v-bind:value="job.stats.bytesRcv"></filesize></li></ul><job-urls v-bind:job="job"></job-urls></div>'
+});
+Vue.component('job-urls', {
+  props: ['job'],
+  template: '<ul class="urls"><li v-for="u in job.urllog">{{ u }}</li></ul>'
+});
+Vue.component('filesize', {
+  props: ['value'],
+  template: '<span class="filesize">{{ fvalue }}</span>',
+  computed: { fvalue: function () { return formatSize (this.value); } }
+});
+
+let app = new Vue({
+  el: '#app',
+  data: {
+	jobs: jobs,
+  }
+});
+