package com.meteorcat.cer.api;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.DigestUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.io.Serializable;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;


/**
 * 授权登录, 先单独集成该文件, 后续重构直接分离处理
 * 这里仅仅作为示例编写
 */
@RestController
@RequestMapping("/auth")
public class AuthApi {


    /**
     * 日志句柄
     */
    final Logger logger = LoggerFactory.getLogger(getClass());


    /**
     * 先暂时手动编写的返回的响应体
     *
     * @param error   错误码
     * @param message 消息内容
     * @param data    返回数据
     * @return JsonMap
     */
    protected Map<String, Object> response(int error, String message, Object data) {
        return new HashMap<>(3) {{
            put("error", error);
            put("message", message);
            put("data", data == null ? new HashMap<>(0) : data);
        }};
    }


    /**
     * 暂时放置的请求提交体
     */
    public static class UserForm implements Serializable {
        private String username;
        private String password;

        public String getPassword() {
            return password;
        }

        public String getUsername() {
            return username;
        }

        public void setPassword(String password) {
            this.password = password;
        }

        public void setUsername(String username) {
            this.username = username;
        }

        @Override
        public String toString() {
            return "UserForm{" +
                    "username='" + username + '\'' +
                    ", password='" + password + '\'' +
                    '}';
        }
    }


    /**
     * 已经完成登录授权的玩家
     */
    private final Map<String, Integer> online = new HashMap<>();

    /**
     * 登录接口
     *
     * @param userForm 玩家提交格式
     * @return JSON
     */
    @PostMapping("/login")
    public Object login(@RequestBody UserForm userForm) {

        logger.debug("User: {}", userForm);

        // Todo:这里先手动验证账号信息, 后续如果想数据库挂载出内容这里再处理
        if (!"meteorcat".equals(userForm.username) || !"meteorcat".equals(userForm.password)) {
            return response(1, "找不到玩家信息", null);
        }


        // todo: 临时写死的玩家ID
        Integer uid = 1;


        // 生成登录Token
        String format = String.format("%s-%d", userForm.username, System.currentTimeMillis());
        String hash = DigestUtils.md5DigestAsHex(format.getBytes(StandardCharsets.UTF_8));

        // 构建出具体的暴露穿透的内容
        ArrayList<Map<String, Object>> servers = new ArrayList<>();


        // Todo: 这里先写死返回的数据内容, 后续通过加载本地来处理
        servers.add(new HashMap<>() {{
            put("id", 1);
            put("address", "https://192.168.1.100:22404");
            // 下面的内容需要去读取内容返回
            put("cer", "CER_DATA内容");
            put("key", "KEY_DATA内容");
            put("p12", "P12_DATA内容");
        }});


        // 确认已经在线的数据
        if (online.containsValue(uid)) {
            for (Map.Entry<String, Integer> active : online.entrySet()) {
                if (active.getValue().equals(uid)) {
                    online.remove(active.getKey());
                    break;
                }
            }
        }

        // 写入在线数据
        online.put(hash, uid);

        // 响应出内容
        return response(0, "success", new HashMap<>() {{
            put("uid", uid);
            put("token", hash);
            put("servers", servers);
        }});
    }


    /**
     * 暂时放置的请求提交体
     */
    public static class CheckForm implements Serializable {
        private String token;

        private Integer id;

        private String address;

        private String cer;

        private String key;

        private String p12;

        public String getToken() {
            return token;
        }

        public void setToken(String token) {
            this.token = token;
        }

        public void setId(Integer id) {
            this.id = id;
        }

        public Integer getId() {
            return id;
        }

        public void setAddress(String address) {
            this.address = address;
        }

        public void setCer(String cer) {
            this.cer = cer;
        }

        public void setKey(String key) {
            this.key = key;
        }

        public void setP12(String p12) {
            this.p12 = p12;
        }

        public String getAddress() {
            return address;
        }

        public String getCer() {
            return cer;
        }

        public String getKey() {
            return key;
        }

        public String getP12() {
            return p12;
        }

        @Override
        public String toString() {
            return "CheckForm{" +
                    "token='" + token + '\'' +
                    ", id=" + id +
                    ", address='" + address + '\'' +
                    ", cer='" + cer + '\'' +
                    ", key='" + key + '\'' +
                    ", p12='" + p12 + '\'' +
                    '}';
        }
    }


    /**
     * 检查最新授权验证
     *
     * @param checkForm 请求结构体
     * @return JSON
     */
    @PostMapping("/check")
    public Object check(@RequestBody CheckForm checkForm) {
        logger.debug("Check: {}", checkForm);

        // 首先确认授权是否存在
        String token = checkForm.token;
        if (!online.containsKey(token)) {
            return response(1, "用户登录授权过期, 请重试", null);
        }

        // todo: 去服务器本地比较授权数据

        // 最后确认授权验证通过
        return response(0, "success", null);
    }

}