58 lines
1.3 KiB
JavaScript
58 lines
1.3 KiB
JavaScript
'use strict';
|
|
|
|
// pass a terminal arg
|
|
var type = process.argv[2] || 'unknown';
|
|
var count = parseInt(process.argv[3]) || 0;
|
|
if (!type) {
|
|
console.error("Usage: node aj-listener.js <type> [count]");
|
|
console.error("Example: node aj-listener.js _service 0");
|
|
process.exit(1);
|
|
}
|
|
|
|
var PromiseA = require('bluebird');
|
|
var fs = PromiseA.promisifyAll(require('fs'));
|
|
var dgram = require('dgram');
|
|
var server = dgram.createSocket({
|
|
type: 'udp4'
|
|
, reuseAddr: true
|
|
});
|
|
|
|
|
|
var handlers = {};
|
|
handlers.onError = function (err) {
|
|
console.error("error:", err.stack);
|
|
server.close();
|
|
};
|
|
handlers.onMessage = function (buffer) {
|
|
var name;
|
|
|
|
if (!count) {
|
|
name = type + '-' + count + '.mdns.bin';
|
|
}
|
|
else {
|
|
// probably the same device name responding
|
|
name = type + '-' + buffer.length + '.mdns.bin';
|
|
}
|
|
|
|
fs.writeFileAsync(name, buffer).then(function () {
|
|
console.log('wrote ' + buffer.length + ' bytes to ' + name);
|
|
});
|
|
};
|
|
handlers.onListening = function () {
|
|
/*jshint validthis:true*/
|
|
var server = this;
|
|
console.log(server.address());
|
|
|
|
server.setBroadcast(true);
|
|
server.addMembership('224.0.0.251');
|
|
};
|
|
|
|
|
|
server.on('error', handlers.onError);
|
|
server.on('message', handlers.onMessage);
|
|
server.on('listening', handlers.onListening);
|
|
|
|
// 53 dns
|
|
// 5353 mdns
|
|
server.bind(5353);
|