update 'isNewChannel'
This commit is contained in:
parent
9498669ffe
commit
6a5ab1ff87
10
rpc.js
10
rpc.js
@ -1475,8 +1475,10 @@ var removeLoginBlock = function (Env, msg, cb) {
|
|||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
// FIXME METADATA
|
var ARRAY_LINE = /^\[/;
|
||||||
|
|
||||||
// since we're changing how metadata works this can lead to false positives
|
// since we're changing how metadata works this can lead to false positives
|
||||||
|
// XXX rewrite this such that we can abort once we have a conclusive answer
|
||||||
var isNewChannel = function (Env, channel, cb) {
|
var isNewChannel = function (Env, channel, cb) {
|
||||||
if (!isValidId(channel)) { return void cb('INVALID_CHAN'); }
|
if (!isValidId(channel)) { return void cb('INVALID_CHAN'); }
|
||||||
if (channel.length !== 32) { return void cb('INVALID_CHAN'); }
|
if (channel.length !== 32) { return void cb('INVALID_CHAN'); }
|
||||||
@ -1487,6 +1489,12 @@ var isNewChannel = function (Env, channel, cb) {
|
|||||||
if (done) { return; }
|
if (done) { return; }
|
||||||
var parsed;
|
var parsed;
|
||||||
try {
|
try {
|
||||||
|
if (count === 0 && typeof(msg) === 'string' && ARRAY_LINE.test(msg)) {
|
||||||
|
done = true;
|
||||||
|
count++;
|
||||||
|
return void cb(void 0, false);
|
||||||
|
}
|
||||||
|
|
||||||
parsed = JSON.parse(msg);
|
parsed = JSON.parse(msg);
|
||||||
if (parsed && typeof(parsed) === 'object') { count++; }
|
if (parsed && typeof(parsed) === 'object') { count++; }
|
||||||
if (count >= 2) {
|
if (count >= 2) {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user