const Koa = require("koa");
const app = new Koa();
const views = require("koa-views");
const router = require('koa-router');
const json = require("koa-json");
const onerror = require("koa-onerror");
const bodyparser = require("koa-bodyparser");
const logger = require("koa-logger");
const koajwt = require("koa-jwt");
const cors = require("koa2-cors");
const koaBody = require("koa-body");
const user = require("./routes/user");
const base = require("./routes/base");
const apicloud = require("./routes/apicloud");
const apiSDK = require("./routes/apiSDK");
const NewsOptionNoToken = require("./routes/NewsOptionNoToken");
const Dataapi = require("./routes/dataapi");
const tokenCheck = require("./utils/checkToken")
const mysql = require("./utils/mysql_db");


var http = require("http");
var fs = require("fs");
var paths = require("path");
var querystring = require("querystring");


var apps = http.createServer();
apps.on("request", function (req, res) {
	console.log("+++++++++");
	if (
		(req.url === "/warnning/diskused" && req.method === "POST") ||
		(req.url === "/warnning/memoryused" && req.method === "POST")
	) {
		var data = "";
		req.on("data", function (chunk) {
			data += chunk;
		});
		req.on("end", function () {
			data = decodeURI(data);
		});
	}
	console.log("+++++++++");
});

// apps.listen(4444, function () {
// 	console.log("------------");
// 	console.log("ok");
// 	console.log("------------");
// });

// app.use(
// 	koaBody({
// 		multipart: true,
// 		// formidable: {
// 		//     maxFileSize: 200*1024*1024    // 设置上传文件大小最大限制，默认2M
// 		// }
// 	})
// );
// error handler
onerror(app);

// middlewares
// app.use(
// 	bodyparser({
// 		enableTypes: ["json", "form", "text"],
// 	})
// );
// app.use(json());
// app.use(logger());
// app.use(require("koa-static")(__dirname + "/public"));
// app.use(
// 	views(__dirname + "/views", {
// 		extension: "pug",
// 	})
// );

/* 路由权限控制 */
app.use(koajwt({ secret: 'sxyd' }).unless({
	// 设置login、register接口，可以不需要认证访问
	path: [
		/^\/api\/login/,
		/^\/api\/register/,
		/^((?!\/api).)*$/   // 设置除了私有接口外的其它资源，可以不需要认证访问
	]
}));

//app.use(tokenCheck())

// cors
app.use(
	cors({
		origin: "*",
		exposeHeaders: ["WWW-Authenticate", "Server-Authorization"],
		maxAge: 5,
		credentials: true,
		allowMethods: ["GET", "POST", "DELETE", "PUT"],
		allowHeaders: ["Content-Type", "Authorization", "Accept"],
	})
);

// logger
const logsUtil = require("./utils/logs.js");
app.use(async (ctx, next) => {
	console.log("------------------------------");
	console.log(ctx);
	console.log("------------------------------");
	const start = new Date(); // 响应开始时间
	let intervals; // 响应间隔时间
	try {
		await next();
		intervals = new Date() - start;
		//logsUtil.logResponse(ctx, intervals); //记录响应日志
	} catch (error) {
		intervals = new Date() - start;
		logsUtil.logError(ctx, error, intervals); //记录异常日志
	}
});

const server = require("http").Server(app.callback());
const io = require("socket.io")(server);
io.on("connection", (socket) => {
	console.log("初始化成功！下面可以用socket绑定事件和触发事件了");
	// socket.on("send", (data) => {
	//   console.log("客户端发送的内容：", data);
	//   socket.emit("getMsg", "我是返回的消息... ...");
	// });
	// socket.emit("getMsg",msg);

	// socket.emit("getMsg", "我是初始化3s后的返回消息... ...");

});
setInterval(() => {
	io.sockets.emit("getMsg", "我是初始化5分钟后的返回消息... ...");
	console.log("123")
}, 3000000);

server.listen(20214);

const schedule_ = require("./models/taskSchedule.js");
schedule_.job_();


app.use(user.routes(), user.allowedMethods());
app.use(base.routes(), base.allowedMethods());
app.use(apicloud.routes(), apicloud.allowedMethods());
app.use(apiSDK.routes(), apiSDK.allowedMethods());
app.use(NewsOptionNoToken.routes(), NewsOptionNoToken.allowedMethods());
app.use(Dataapi.routes(), Dataapi.allowedMethods());

// error-handling
app.on("error", (err, ctx) => {
	console.error("server error", err, ctx);
});

module.exports = app;