mirror of
https://github.com/XRPLF/rippled.git
synced 2025-11-19 10:35:50 +00:00
UT start adding WS support.
This commit is contained in:
@@ -12,6 +12,7 @@ var fs = require("fs");
|
||||
var path = require("path");
|
||||
var util = require("util");
|
||||
var child = require("child_process");
|
||||
var WebSocket = require("ws");
|
||||
|
||||
var servers = {};
|
||||
|
||||
@@ -78,6 +79,14 @@ var makeBase = function(name, done) {
|
||||
});
|
||||
};
|
||||
|
||||
var wsOpen = function(done) {
|
||||
var socket = new WebSocket(util.format("ws:://%s:%s", server.websocket_ip, server.websocket_port));
|
||||
|
||||
socket.on('open') {
|
||||
done();
|
||||
});
|
||||
};
|
||||
|
||||
// Prepare the working directory and spawn the server.
|
||||
exports.start = function(name, done) {
|
||||
makeBase(name, function (e) {
|
||||
@@ -86,7 +95,7 @@ exports.start = function(name, done) {
|
||||
}
|
||||
else {
|
||||
serverSpawnSync(name);
|
||||
done();
|
||||
wsOpen(done);
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
@@ -4,7 +4,7 @@ var path = require("path");
|
||||
|
||||
var filterErr = function(code, done) {
|
||||
return function (e) {
|
||||
done(e.code !== code ? e : undefined);
|
||||
done(e && e.code === code ? undefined : e);
|
||||
};
|
||||
};
|
||||
|
||||
@@ -38,7 +38,7 @@ var mapOr = function(func, array, done) {
|
||||
// Make a directory and sub-directories.
|
||||
var mkPath = function(dirPath, mode, done) {
|
||||
fs.mkdir(dirPath, typeof mode === "string" ? parseInt(mode, 8) : mode, function (e) {
|
||||
if (!e || e.code === "EEXIST") {
|
||||
if (!e || e.code === "EEXIST") {
|
||||
// Created or already exists, done.
|
||||
done();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user