node.js - ShareDB 与其他 websocket 事件

Question

我正在尝试将 Node.js WebSockets 与 sharedb 结合使用。这是我到目前为止所拥有的

var http = require('http');
var express = require('express');
var ShareDB = require('sharedb');
var WebSocket = require('ws');
var WebSocketJSONStream = require('websocket-json-stream');
var ShareDBLogger = require('sharedb-logger');

var backend = new ShareDB();
createDoc(startServer);

// Create initial document then fire callback
function createDoc(callback) {
  var connection = backend.connect();
  const sharedbLogger = new ShareDBLogger(backend);
  var doc = connection.get('examples', 'text');

  doc.fetch(function(err) {
    if (err) throw err;
    if (doc.type === null) {
      doc.create({content: 'Hello'}, 'text', callback);
      return;
    }
    callback();
  });
}

function startServer() {
  // Create a web server to serve files and listen to WebSocket connections
  var app = express();
  var server = http.createServer(app);

  // Connect any incoming WebSocket connection to ShareDB
  var wss = new WebSocket.Server({server: server});
  wss.on('connection', function(ws, req) {
    var stream = new WebSocketJSONStream(ws);
    backend.listen(stream);

    ws.on('message', function (data) {
      const json = JSON.parse(data);
      if(json.type === 'request-id') ws.send('some-id');
    })
  });

  server.listen(8080);
  console.log('Listening on http://localhost:8080');
}

但是，由于我的客户端发送的 WebSocket 消息 {type: 'request-id'} 这不是 sharedb 的标准操作之一。我不断收到此错误消息:

Error: { type: 'request-id',
  error: { code: 4000, message: 'Invalid or unknown message' } }

如何告诉 sharedb 在监听 websocket 流时忽略某些非操作的 websocket 消息？

Answer 1

WebSocketJSONStream 假定经过的每个 websocket 事件都是 sharedb 事件。这是图书馆: https://github.com/avital/websocket-json-stream/blob/master/index.js

var util = require('util');
var Duplex = require('stream').Duplex;

function WebSocketJSONStream(ws) {
  // Make work with or without 'new'
  if (!(this instanceof WebSocketJSONStream)) return new WebSocketJSONStream(ws);
  Duplex.call(this, {objectMode: true});
  this.ws = ws;
  var self = this;

  ws.on('message', function(msg) {
    // You need to catch your own personal websocket events here that are NOT being used by sharedb - perhaps filter by its title/message?
    self.push(JSON.parse(msg)); 
  });
  ws.on('close', function() {
    self.push(null); // end readable stream
    self.end(); // end writable stream

    self.emit('close');
    self.emit('end');
  });

  this.on('error', function() { ws.close(); });
  this.on('end', function() { ws.close(); });
};
util.inherits(WebSocketJSONStream, Duplex);

WebSocketJSONStream.prototype._read = function() {};
WebSocketJSONStream.prototype._write = function(msg, encoding, next) {
  this.ws.send(JSON.stringify(msg));
  next();
};

module.exports = WebSocketJSONStream;