| 
									
										
										
										
											2017-01-20 18:15:16 -07:00
										 |  |  | 'use strict'; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | // pass a terminal arg
 | 
					
						
							| 
									
										
										
										
											2017-01-21 03:16:08 -07:00
										 |  |  | var type = process.argv[2]; | 
					
						
							| 
									
										
										
										
											2017-01-20 18:15:16 -07:00
										 |  |  | 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) { | 
					
						
							| 
									
										
										
										
											2017-01-21 14:44:37 -07:00
										 |  |  |   var path = require('path'); | 
					
						
							| 
									
										
										
										
											2017-01-21 15:07:10 -07:00
										 |  |  |   var filename = type + '-' + count + '.mdns.bin'; | 
					
						
							|  |  |  |   var fullpath = path.join('samples', filename); | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-01-21 03:16:08 -07:00
										 |  |  |   count += 1; | 
					
						
							| 
									
										
										
										
											2017-01-20 18:15:16 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-01-21 15:07:10 -07:00
										 |  |  |   fs.writeFileAsync(fullpath, buffer).then(function () { | 
					
						
							|  |  |  |     console.log('wrote ' + buffer.length + ' bytes to ' + fullpath); | 
					
						
							| 
									
										
										
										
											2017-01-20 18:15:16 -07:00
										 |  |  |   }); | 
					
						
							|  |  |  | }; | 
					
						
							|  |  |  | handlers.onListening = function () { | 
					
						
							|  |  |  |   /*jshint validthis:true*/ | 
					
						
							|  |  |  |   var server = this; | 
					
						
							|  |  |  |   console.log(server.address()); | 
					
						
							| 
									
										
										
										
											2017-01-26 19:18:46 -07:00
										 |  |  |    | 
					
						
							| 
									
										
										
										
											2017-01-20 18:15:16 -07:00
										 |  |  |   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
 | 
					
						
							| 
									
										
										
										
											2017-01-21 14:44:37 -07:00
										 |  |  | server.bind(5353); |