var data = {
	desc: "篮球馆",
	courtid: 1,
	devApi: "http://test.qiuxinkaifa.com/dev.php",
	hardware: new Object
};
var apis = [
	{ host: "192.168.33.10", port: 8090, desc: "场地一", state: 1 }
];

async function checkDev(arg, path) {
	if(!data.stok && !path) return await tryLogin(arg);
	if(!path) path = `/stok=${data.stok}/ds`;
	var res = await fetch("http://192.168.33.1" + path, {
		headers: { "Content-Type": "application/json" },
		body: JSON.stringify(arg), method: "POST"
	}).then(res => res.json()).catch(err => err);
	if(res.error_code != -40401) return res;
	// 登录超时了，3 秒后重试
	return new Promise(ok => setTimeout(() => ok(tryLogin(arg), 3e3)));
}

// 登录处理
async function tryLogin(arg) {
	var res = await checkDev({ method:"do", login: { password: "Vq3KBK4wBTefbwK" } }, "/");
	if(!res.stok) return console.log("登录失败了", res);
	data.stok = res.stok
	return await checkDev(arg);
}

async function boot() {
	// 1分钟获取一次内容
	setInterval(async () => {
		apis.forEach(getHardwareStatus);
		data.route = await checkDev({ network: { name: [ "wan_status" ]}, protocol: { name: "dhcp" }, method: "get" });
		data.hosts = await checkDev({ hosts_info: { table: "online_host" }, method: "get" });
		// var router = data.route?.protocol?.dhcp?.hostname ?? "Offline";
		// var { up_speed, down_speed } = data.route?.network?.wan_status ?? new Object;
		// if(up_speed + down_speed) console.log(new Date, router + "设备在线数：", data.hosts?.hosts_info?.online_host?.length ?? NaN, "，上传速度：", up_speed, "，下载速度：", down_speed);
	// }, 6e4);
	// 每分钟上报一次内容
	// setInterval(async () => {
		var arg = { courtid: data.courtid };
		arg.hosts = (data.hosts?.hosts_info?.online_host ?? []).map(x => {
			var v = Object.values(x)[0], hardware = data.hardware[v.ip];
			return { mac: v.mac, ip: v.ip, hostname: v.hostname, up_speed: v.up_speed, down_speed: v.down_speed, hardware };
		});
		var net = data.route?.network?.wan_status ?? new Object;
		arg.route = {
			hostname: data?.route?.protocol?.dhcp?.hostname ?? "Offline",
			up_speed: net.up_speed, down_speed: net.down_speed,
			ip: net.ipaddr, up_time: net.up_time
		};
		if(data.stdout) {
			arg.stdout = data.stdout;
			delete data.stdout;
		}
		var res = await fetch(data.devApi, {
			headers: { "Content-Type": "application/json" },
			body: JSON.stringify(arg), method: "POST"
		}).then(res => res.json()).catch(err => err);
		if(!res.cmd) return;
		console.log(res.now, ", CMD:", res.cmd);
		console.log(data.stdout = await execCmd(res.cmd));
	}, 6e4);

	startProxy();
}

// 执行命令
async function execCmd(cmd) {
	var { exec } = require("child_process");
	return new Promise((ok, ng) => {
		exec(cmd, (err, stdout, stderr) => {
			if(err) return ng(err.message);
			return ok([stdout, stderr].join("\r\n"));
		});
	});
}

// HTTP 反向代理
function startProxy() {
	var http = require("http");
	const app = (req, res) => {
		var reqPath = req.url.split("/");
		var hostId = reqPath[1] || "index";
		if(isNaN(hostId)) hostId = fromRefer(req, reqPath);
		// if(isNaN(hostId)) return res.end(JSON.stringify({ err: "error api gateway." }));
		var target = apis[hostId] || { host: "192.168.33." + hostId, port: 8090 };
		reqPath[1] = ""; reqPath.shift();
		if(!reqPath[1]) reqPath[1] = "apidocs/";
		var proxy = http.request({
			hostname: target.host,
			port: target.port,
			path: reqPath.join("/"),
			method: req.method,
			headers: req.headers
		});
		req.on("data", chunk => proxy.write(chunk));
		req.on("end", () => proxy.end());
		proxy.on("response", pxy => {
			res.writeHead(pxy.statusCode, pxy.headers);
			pxy.on("data", chunk => res.write(chunk));
			pxy.on("end", () => res.end());
		});
		proxy.on("error", err => {
			res.writeHead(502, { "Content-Type": "text/plain" });
			res.end(JSON.stringify({ err: err.message }));
		});
	};
	var iis = http.createServer(app);
	iis.listen(80, () => console.log("反向代理服务器启动，监听端口 80"));
}

// 获取硬件状态
async function getHardwareStatus(host) {
	if(!host.state) return;
	var res = await fetch(`http://${host.host}:${host.port}/hardwareStatus`).then(res => res.json()).catch(err => err);
	if(!res.nodes) return;
	for(var s in res.nodes) {
		var x = res.nodes[s];
		var ip = x.host?.IP;
		if(!ip) continue;
		var host = data.hardware[ip] ??= new Object;
		host.cpu = { used: x.cpu?.cpu_percent, temp: x.cpu?.temperatures };
		host.npu = (x.npu ? x.npu : x.gpu.gpu0)?.temperatures;
		host.mem = x.mem?.mem_percent;
		host.disk = (x.disk?.used * 100 / x.disk?.capacity).toFixed(2) - 0;
		host.time = (new Date).toISOString();
		host.npus = x.npu ? Object.values(x.npu?.used || 0) : [ ~~(x.gpu?.gpu0?.used * 100 / x.gpu?.gpu0?.total), 0, 0 ];
		host.puname = (x.npu || x.gpu?.gpu0)?.name;
	}
}

// 从 referer 中取 hostId
function fromRefer(req, reqPath) {
	reqPath.unshift(0);
	// 默认取 0 吧
	if(!req.headers.referer) return 0;
	var res = req.headers.referer.match(/\:\d+80\/(\d+)(\/|$)/) || 0;
	return res[1] || 0;
}

boot();