mirror-web/_src/lib/mirrorList.js

import { TUNASYNC_JSON_PATH } from "../lib/consts";
import { options as globalOptions } from "virtual:jekyll-data";
import { ref, onMounted, nextTick } from "vue";
import { format as TimeAgoFormat } from "timeago.js";

const label_map = globalOptions.label_map;

export const useMirrorList = (additional = []) => {
	const mirrorList = ref([]);
	let refreshTimer = null;

	const refreshMirrorList = async () => {
		if (document.hidden === true) {
			return;
		}
		try {
			const res = await fetch(TUNASYNC_JSON_PATH);
			const status_data = await res.json();
			const processed = status_data
				.concat(additional)
				.map((d) => processMirrorItem(d));
			mirrorList.value = sortAndUniqMirrors(processLinkItem(processed));
		} catch (e) {
			throw e;
		} finally {
			refreshTimer = setTimeout(refreshMirrorList, 10000);
		}
	};

	nextTick().then(() => refreshMirrorList());

	onMounted(() => {
		window.addEventListener("visibilitychange", () => {
			if (refreshTimer) {
				clearTimeout(refreshTimer);
				refreshTimer = null;
			}
			if (document.visibilityState === "visible") {
				refreshMirrorList().then();
			}
		});
	});

	return mirrorList;
};

const processLinkItem = (mirrors) => {
	var processed = [];
	for (let d of mirrors) {
		if (d.link_to === undefined) {
			processed.push(d);
			continue;
		}
		for (const target of mirrors) {
			if (d.link_to === target.name) {
				d.status = target.status;
				d.label = target.label;
				d.upstream = target.upstream;
				d.show_status = target.show_status;
				d.last_update = target.last_update;
				d.last_update_ago = target.last_update_ago;
				d.last_ended = target.last_ended;
				d.last_ended_ago = target.last_ended_ago;
				d.last_schedule = target.last_schedule;
				d.last_schedule_ago = target.last_schedule_ago;
				processed.push(d);
				break;
			}
		}
	}
	return processed;
};

const stringifyTime = (ts) => {
	const date = new Date(ts * 1000);
	let str = "";
	let ago = "";
	if (date.getFullYear() > 2000) {
		str =
			`${("000" + date.getFullYear()).slice(-4)}-${("0" + (date.getMonth() + 1)).slice(-2)}-${("0" + date.getDate()).slice(-2)}` +
			` ${("0" + date.getHours()).slice(-2)}:${("0" + date.getMinutes()).slice(-2)}`;
		ago = TimeAgoFormat(date);
	} else {
		str = "0000-00-00 00:00";
		ago = "Never";
	}
	return [str, ago];
};

const processMirrorItem = (d) => {
	if (d.is_master === undefined) {
		d.is_master = true;
	}
	if (d.link_to !== undefined) {
		return d;
	}
	d.label = label_map[d.status];
	d.show_status = d.status != "success";
	// Strip the second component of last_update
	[d.last_update, d.last_update_ago] = stringifyTime(d.last_update_ts);
	[d.last_ended, d.last_ended_ago] = stringifyTime(d.last_ended_ts);
	[d.last_started, d.last_started_ago] = stringifyTime(d.last_started_ts);
	[d.next_schedule, d.next_schedule_ago] = stringifyTime(d.next_schedule_ts);
	return d;
};

const sortAndUniqMirrors = (mirs) => {
	mirs.sort((a, b) => {
		return a.name < b.name ? -1 : 1;
	});
	return mirs.reduce((acc, cur) => {
		if (acc.length > 1 && acc[acc.length - 1].name == cur.name) {
			if (acc[acc.length - 1].last_update_ts && cur.last_update_ts) {
				if (acc[acc.length - 1].last_update_ts < cur.last_update_ts) {
					acc[acc.length - 1] = cur;
				}
			} else if (cur.last_update_ts) {
				acc[acc.length - 1] = cur;
			}
		} else {
			acc.push(cur);
		}
		return acc;
	}, []);
};