volcanos/lib/misc.js

Volcanos("misc", {help: "工具模块",
    POST: shy("请求后端", {order: 0}, function(can, msg, url, form, cb) {
        var args = can.core.Items(form, function(value, index, key) {
            return key+"="+encodeURIComponent(value)
        })

        var xhr = new XMLHttpRequest()
        xhr.onreadystatechange = function() {
            if (xhr.readyState != 4) {return}
            if (xhr.status != 200) {return}

            try {
                var res = JSON.parse(xhr.responseText||'[{"result":[]}]')
                res.length > 0 && res[0] && (res = res[0])

                if (res.download_file) {
                    window.open(res.download_file.join(""))
                } else if (res.page_redirect) {
                    location.href = res.page_redirect.join("")
                } else if (res.page_refresh) {
                    location.reload()
                }
            } catch (e) {
                var res = {"result": [xhr.responseText]}
            }

            typeof cb == "function" && cb(msg.Copy(res))
        }

        xhr.open("POST", url)
        xhr.setRequestHeader("Content-Type", "application/x-www-form-urlencoded")
        xhr.setRequestHeader("Accept", "application/json")
        xhr.send(args.join("&"))
        ++arguments.callee.meta.order
    }),
    Run: shy("请求后端", {order: 0}, function(event, can, dataset, cmd, cb) {
        var msg = can.Event(event)

        var option = {"cmds": cmd}
        msg.option && msg.option.forEach(function(item) {
            msg[item] && (option[item] = msg[item])
        })
        // for (var k in dataset) {
        //     option[k] = dataset[k].toLowerCase().split(",")
        // }

        var what = ++arguments.callee.meta.order

        msg._hand = true
        msg.option = []
        for (var k in option) {
            msg.option.push(k)
            msg[k] = option[k]
        }
        // msg.detail = ["run", what].concat(option.group).concat(option.names).concat(option.cmds)
        // kit.Log(msg.detail.concat([msg]))

        // kit.History("run", -1, option)
        this.POST(can, msg, can.Conf("context")+dataset.names.toLowerCase(), option, function(msg) {
            // kit.Log("run", what, "result", msg.result? msg.result[0]: "", msg)
            typeof cb == "function" && cb(msg)
        }), delete(event.msg)
    }),
    WSS: shy("请求后端", {order: 0}, function(can, cb, onerror, onclose, onopen) {var meta = arguments.callee.meta
        var s = new WebSocket(location.protocol.replace("http", "ws")+"//"+location.host+"/space/?node=active&name=some&wssid="+can._wssid)
        can._socket = s
        s.onerror = onerror || function() {
            delete(can._socket), setTimeout(function() {
                can.misc.WSS(can, cb, onerror, onclose, onopen)
            }, 1000)
        }, s.onclose = onclose, s.onopen = onopen
        s.onmessage = function(event) {var order = ++meta.order
            try {
                var msg = JSON.parse(event.data||'{}')
            } catch (e) {
                var msg = {"result": [event.data]}
            }

            // Event入口 -1.0
            msg = can.Event(event, msg)
            msg.Reply = function() {
                msg.Option("_target", msg.Option("_source"))
                can.Log(["wss", order, "result"].concat(msg.result).concat([msg]))
                delete(msg.detail)
                delete(msg.event), s.send(JSON.stringify(msg))
            }

            try {
                can.Log(["wss", order].concat(msg.detail).concat([msg]))
                typeof cb == "function" && cb(event, msg)
            } catch (e) {
                msg.Reply(can.Log("err", e))
            }
        }
    }),
})