RPC ouvert, événements et connexions partagées

Total.js 5 · total5@0.0.19 total5reference Exécutée avec Total.js 5

OPENCLIENT(url, [id]) est le client natif du protocole Open Platform. Il convertit les URL http/https en ws/wss. Les clients logiques ayant la même URL partagent un WebSocket. .online(fn) reçoit les métadonnées {type:'init',id:...} du serveur ; .message(fn) reçoit les messages non sollicités. .rpc(message) renvoie une promesse ; .send(message, callback, [filter], [timeoutMs]) utilise un callback ; .cmd(message) envoie sans attendre. .remove() ne ferme le socket physique qu'après la suppression de son dernier client logique.

L'exemple inclut un serveur de protocole local. callbackid, error et response sont des champs de protocoles. Un temps d'appel est opt-in; définissez un pour les demandes qui nécessitent une date limite.

controllers/open.js

exports.install = function() {
	ROUTE('SOCKET /fixture/', fixture);
	ROUTE('GET /openclient/', exercise);
};
function fixture() {
	var server = this;
	server.on('open', function(client) {
		client.send({ type: 'init', id: 'local-fixture', version: 1 });
	});
	server.on('message', function(client, message) {
		if (message.type === 'ignore')
			return;
		if (message.type === 'event') {
			client.send({ type: 'notice', value: message.value });
			return;
		}
		client.send({ callbackid: message.callbackid, error: message.type === 'fail' ? 'denied' : null, response: { value: message.value } });
	});
}
async function exercise($) {
	var a;
	var b;
	try {
		var url = $.hostname('/fixture/');
		a = OPENCLIENT(url, 'first');
		await new Promise(function(resolve, reject) {
			var timer = setTimeout(() => reject(new Error('init deadline')), 2000);
			a.online(function(meta) { if (meta) { clearTimeout(timer); resolve(); } });
		});
		b = OPENCLIENT(url, 'second');
		var shared = a.ws === b.ws;
		var sum = await a.rpc({ type: 'echo', value: 7 });
		var event = new Promise(resolve => a.message(resolve));
		a.cmd({ type: 'event', value: 9 });
		var notice = await event;
		var denied = await new Promise(resolve => a.send({ type: 'fail' }, err => resolve(String(err)), 300));
		var timeout = await new Promise(resolve => a.send({ type: 'ignore' }, err => resolve(String(err)), 50));
		a.remove();
		a = null;
		var alive = await b.rpc({ type: 'echo', value: 11 });
		var meta = b.meta;
		b.remove();
		b = null;
		$.json({ shared: shared, sum: sum, notice: notice, denied: denied, timeout: timeout, alive: alive, meta: meta });
	} catch (e) { $.invalid(e); }
	finally { if (a) a.remove(); if (b) b.remove(); }
}