Mango/public/js/download-manager.js

const component = () => {
	return {
		jobs: [],
		paused: undefined,
		loading: false,
		toggling: false,

		init() {
			const ws = new WebSocket(`ws://${location.host}/api/admin/mangadex/queue`);
			ws.onmessage = event => {
				const data = JSON.parse(event.data);
				this.jobs = data.jobs;
				this.paused = data.paused;
			};
			ws.onerror = err => {
				alert('danger', `Socket connection failed. Error: ${err}`);
			};
			ws.onclose = err => {
				alert('danger', 'Socket connection failed');
			};

			this.load();
		},
		load() {
			this.loading = true;
			$.ajax({
					type: 'GET',
					url: base_url + 'api/admin/mangadex/queue',
					dataType: 'json'
				})
				.done(data => {
					if (!data.success && data.error) {
						alert('danger', `Failed to fetch download queue. Error: ${data.error}`);
						return;
					}
					this.jobs = data.jobs;
					this.paused = data.paused;
				})
				.fail((jqXHR, status) => {
					alert('danger', `Failed to fetch download queue. Error: [${jqXHR.status}] ${jqXHR.statusText}`);
				})
				.always(() => {
					this.loading = false;
				});
		},
		jobAction(action, id) {
			let url = `${base_url}api/admin/mangadex/queue/${action}`;
			if (id !== undefined)
				url += '?' + $.param({
					id: id
				});
			console.log(url);
			$.ajax({
					type: 'POST',
					url: url,
					dataType: 'json'
				})
				.done(data => {
					if (!data.success && data.error) {
						alert('danger', `Failed to ${action} job from download queue. Error: ${data.error}`);
						return;
					}
					this.load();
				})
				.fail((jqXHR, status) => {
					alert('danger', `Failed to ${action} job from download queue. Error: [${jqXHR.status}] ${jqXHR.statusText}`);
				});
		},
		toggle() {
			this.toggling = true;
			const action = this.paused ? 'resume' : 'pause';
			const url = `${base_url}api/admin/mangadex/queue/${action}`;
			$.ajax({
					type: 'POST',
					url: url,
					dataType: 'json'
				})
				.fail((jqXHR, status) => {
					alert('danger', `Failed to ${action} download queue. Error: [${jqXHR.status}] ${jqXHR.statusText}`);
				})
				.always(() => {
					this.load();
					this.toggling = false;
				});
		},
		statusClass(status) {
			let cls = 'label ';
			switch (status) {
				case 'Pending':
					cls += 'label-pending';
					break;
				case 'Completed':
					cls += 'label-success';
					break;
				case 'Error':
					cls += 'label-danger';
					break;
				case 'MissingPages':
					cls += 'label-warning';
					break;
			}
			return cls;
		}
	};
};