// pushcat自定义设备,可接收消息推送并通知
window.PushCatDevice = /** @class */ (function () {
    function PushCatDevice(param) {
        var _this = this;
        this.accessKey = param.accessKey;
        this.host = param.host || "https://sct.icodef.com/";
        this.lasttime = param.lasttime || Math.floor(new Date().getTime() / 1000);
        // 先注册设备
        GM_xmlhttpRequest({
            url: this.host + "openapi/v1/device/register?access_key=" + this.accessKey,
            method: "POST",
            data: JSON.stringify({
                name: param.name,
                describe: param.describe,
                tags: param.tags,
                auto_create: param.auto_create,
            }),
            headers: {
                "Content-Type": "application/json",
            },
            onload: function (resp) {
                var data = JSON.parse(resp.responseText);
                if (data.code !== 0) {
                    _this.onerror && _this.onerror(data);
                }
                else {
                    // 第一个版本使用每分钟轮询的形式,以减少服务器压,后续缓存websocket
                    _this.timer = setInterval(function () {
                        GM_xmlhttpRequest({
                            url: _this.host +
                                "openapi/v1/message/pull?access_key=" +
                                _this.accessKey +
                                "&last_time=" +
                                _this.lasttime +
                                "&device_id=" +
                                data.data.id,
                            method: "GET",
                            onload: function (resp) {
                                var data = JSON.parse(resp.responseText);
                                if (data.code === 0) {
                                    _this.lasttime = Math.floor(new Date().getTime() / 1000);
                                    _this.onmessage && _this.onmessage(data.data.list);
                                }
                                else {
                                    _this.onerror && _this.onerror(data);
                                }
                            }
                        });
                    }, (param.check_interval || 60) * 1000);
                }
            },
        });
    }
    PushCatDevice.prototype.onMessage = function (callback) {
        this.onmessage = callback;
    };
    PushCatDevice.prototype.onError = function (callback) { };
    // TODO
    PushCatDevice.prototype.listen = function (callback, onerror) {
        // const ws = new WebSocket(this.host + "ws/" + this.accessKey);
        // ws.onmessage = (e) => {
        //   callback();
        // };
        // ws.onerror = (e) => {
        //   onerror();
        // };
    };
    PushCatDevice.prototype.stop = function () {
        clearInterval(this.timer);
    };
    return PushCatDevice;
}());
window.PushCat = /** @class */ (function () {
    function PushCat(param) {
        this.accessKey = param.accessKey;
        this.host = param.host || "https://sct.icodef.com/";
    }
    PushCat.prototype.send = function (title, content, target, options) {
        if ((options === null || options === void 0 ? void 0 : options.method) === "GET") {
            var searchParams_1 = new URLSearchParams();
            searchParams_1.append("access_key", this.accessKey);
            searchParams_1.append("title", title);
            searchParams_1.append("content", content);
            if (options === null || options === void 0 ? void 0 : options.parameters) {
                searchParams_1.append("parameters", JSON.stringify(options === null || options === void 0 ? void 0 : options.parameters));
            }
            if (target) {
                if (target.tags) {
                    target.tags.forEach(function (val) {
                        searchParams_1.append("tags", val);
                    });
                }
                else if (target.devices) {
                    target.devices.forEach(function (val) {
                        searchParams_1.append("devices", val);
                    });
                }
            }
            return new Promise((resolve, reject) => {
                GM_xmlhttpRequest({
                    url: this.host + "openapi/v1/message/send?" + searchParams_1,
                    method: "GET",
                    onload: function (resp) {
                        resolve(resp);
                    }, onerror: () => {
                        reject();
                    }
                })
            });
        }
        return new Promise((resolve, reject) => {
            GM_xmlhttpRequest({
                url: this.host + "openapi/v1/message/send?access_key=" + this.accessKey,
                method: "POST",
                data: JSON.stringify({
                    title: title,
                    content: content,
                    devices: target === null || target === void 0 ? void 0 : target.devices,
                    tags: target === null || target === void 0 ? void 0 : target.tags,
                    parameters: options === null || options === void 0 ? void 0 : options.parameters,
                }),
                headers: {
                    "Content-Type": "application/json",
                },
                onload: function (resp) {
                    resolve(resp);
                }, onerror: () => {
                    reject();
                }
            })
        });
    };
    return PushCat;
}());