javascript - 发送未平仓头寸订阅后，带有 kraken 的 Websocket 关闭

Question

我正在尝试订阅 OpenPositions 的 kraken websocket API。我已经发送了一个质询请求并收到了质询，我还用我的密钥正确地对其进行了签名，但似乎一旦我发送了 openpositions 订阅请求，网络套接字就会直接关闭，代码为 1006 和原因''。

我正在使用本机库 websocket 和事件发射器在 Nodejs 中编写以发出“kraken-update”的数据

这是我运行的主文件：

const con = new Connection(key = keys.api_key, secret=keys.secret);
con.on('kraken-update', (data) => {
    console.log(new Date, "DATA", data);
    return;
});
const go = async(key, secret) => {
    console.log(new Date, 'connecting...');
    await con.connect();
    console.log(new Date, 'connected');
    await con.sendchallenge()
}

这是连接类

const WebSocket = require('ws');
const crypto = require('crypto');
const EventEmitter = require('events');

class Connection extends EventEmitter {
    constructor( key, secret, challenge = '') {
        super();
        this.url = 'wss://futures.kraken.com/ws/v1';
        this.connected = false;
        this.challenge = challenge;
        this.lastMessageAt = 0;
        this.key=key;
        this.secret=secret;
    }

    disconnect() {
        this.ws.disconnect();
    }

    connect() {
        if(this.connected) {
            console.log("ALREADY CONNECTED")
            return;
        }
        let readyHook;
        this.onOpen = new Promise(r => readyHook = r);
        this.ws = new WebSocket(this.url);
        this.ws.onopen = () => {
            this.connected = true;
            readyHook();
        }
        this.ws.onerror = (e) => {
            console.log(new Date, '[KRAKEN] error', e);
        }
        this.ws.onclose = (e) => {
            console.log(new Date, '[KRAKEN] close', e);
        }
        this.ws.onmessage = (e) => {
            //console.log("MESSAGE ",e.data)
            setImmediate(()=>this.handleMessage(e))
        }

        // initial book data coming in on the same tick as the subscription data
        // we defer this so the subscription promise resloves before we send
        // initial OB data.
        return this.onOpen;
    }

    handleMessage(e){
        this.lastMessageAt = new Date;
        console.log(e)
        const payload = JSON.parse(e.data);
        if(payload.event === 'subscribed') {
            this.emit('kraken-update', payload)
            console.log(new Date, "SUBSCRIBED ",payload)
            return;
        }
        if (payload.event === 'challenge'){
            this.challenge = payload.message
            this.emit('kraken-update', payload.message);
            this.subscribeOpenPositions();
            return;
        }
        if (payload.feed === "open_positions"){
            this.emit('kraken-update', payload.message);
            return;
        }

        else{
            console.log(new Date, "UNDETECTED ",payload)
            return;
        }
    }

    sendchallenge(){
        try{
            let onReady = new Promise(e => e);
            const data = JSON.stringify({'event': 'challenge','api_key':this.key})
            this.ws.send(data);
            return onReady;
        }
        catch(e){
            console.log(new Date, 'ERROR SENDING CHALLENGE')
            throw(e)
        }
    }

    subscribeOpenPositions(){
        //how to sign challenge:
        //https://support.kraken.com/hc/en-us/articles/360022635652-Sign-Challenge-Web-Socket-API-
        console.log(new Date, `SUBSCRIBING OPENPOSITION WITH ${this.challenge}....`);
        try{
            const secret_buffer = new Buffer.from(this.secret, 'base64');
            const hash          = new crypto.createHash('sha256');
            const hmac          = new crypto.createHmac('sha512', secret_buffer);
            const hash_digest   = hash.update(this.challenge).digest('binary');
            const hmac_digest   = hmac.update(hash_digest, 'binary').digest('base64');
            this.ws.send(JSON.stringify({"event":"ping"}))
            this.ws.send(JSON.stringify(
                {"event":"subscribe",
                "feed":"open_positions",
                "api_key":this.key,
                "original_challenge":this.challenge,
                "signed_challenge":hmac_digest}
            ));
            console.log("SENT");
        }
        catch(e){
            console.log(new Date,"ERROR SENDING SUBSCRIPTION REQUEST")
            throw(e)
        }
    }
}

module.exports = Connection;

发生的事情的摘要：

连接到海妖未来服务器 => 请求挑战 => 处理挑战然后在处理挑战时请求 openorder 订阅 => websocket 关闭

标签： javascriptwebsocketprivate-methodskraken.js