mirror of
https://we.phorge.it/source/phorge.git
synced 2024-11-10 08:52:39 +01:00
bbb321395a
Summary: Ref T6915. This allows multiple notification servers to talk to each other: - Every server has a list of every other server, including itself. - Every server generates a unique fingerprint at startup, like "XjeHuPKPBKHUmXkB". - Every time a server gets a message, it marks it with its personal fingerprint, then sends it to every other server. - Servers do not retransmit messages that they've already seen (already marked with their fingerprint). - Servers learn other servers' fingerprints after they send them a message, and stop sending them messages they've already seen. This is pretty crude, and the first message to a cluster will transmit N^2 times, but N is going to be like 3 or 4 in even the most extreme cases for a very long time. The fingerprinting stops cycles, and stops servers from sending themselves copies of messages. We don't need to do anything more sophisticated than this because it's fine if some notifications get lost when a server dies. Clients will reconnect after a short period of time and life will continue. Test Plan: - Wrote two server configs. - Started two servers. - Told Phabricator about all four services. - Loaded Chrome and Safari. - Saw them connect to different servers. - Sent messages in one, got notifications in the other (magic!). - Saw the fingerprinting stuff work on the console, no infinite retransmission of messages, etc. (This pretty much just worked when I ran it the first time so I probably missed something?) {F1218835} Reviewers: chad Reviewed By: chad Maniphest Tasks: T6915 Differential Revision: https://secure.phabricator.com/D15711
80 lines
1.6 KiB
JavaScript
80 lines
1.6 KiB
JavaScript
'use strict';
|
|
|
|
var JX = require('./javelin').JX;
|
|
|
|
var http = require('http');
|
|
var https = require('https');
|
|
|
|
JX.install('AphlictPeer', {
|
|
|
|
construct: function() {
|
|
},
|
|
|
|
properties: {
|
|
host: null,
|
|
port: null,
|
|
protocol: null,
|
|
fingerprint: null
|
|
},
|
|
|
|
members: {
|
|
broadcastMessage: function(instance, message) {
|
|
var data;
|
|
try {
|
|
data = JSON.stringify(message);
|
|
} catch (error) {
|
|
return;
|
|
}
|
|
|
|
// TODO: Maybe use "agent" stuff to pool connections?
|
|
|
|
var options = {
|
|
hostname: this.getHost(),
|
|
port: this.getPort(),
|
|
method: 'POST',
|
|
path: '/?instance=' + instance,
|
|
headers: {
|
|
'Content-Type': 'application/json',
|
|
'Content-Length': data.length
|
|
}
|
|
};
|
|
|
|
var onresponse = JX.bind(this, this._onresponse);
|
|
|
|
var request;
|
|
if (this.getProtocol() == 'https') {
|
|
request = https.request(options, onresponse);
|
|
} else {
|
|
request = http.request(options, onresponse);
|
|
}
|
|
|
|
request.write(data);
|
|
request.end();
|
|
},
|
|
|
|
_onresponse: function(response) {
|
|
var peer = this;
|
|
var data = '';
|
|
|
|
response.on('data', function(bytes) {
|
|
data += bytes;
|
|
});
|
|
|
|
response.on('end', function() {
|
|
var message;
|
|
try {
|
|
message = JSON.parse(data);
|
|
} catch (error) {
|
|
return;
|
|
}
|
|
|
|
// If we got a valid receipt, update the fingerprint for this server.
|
|
var fingerprint = message.fingerprint;
|
|
if (fingerprint) {
|
|
peer.setFingerprint(fingerprint);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
});
|