/
index.js
55 lines (44 loc) · 1.1 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
/**
* @author Juliano Castilho <julianocomg@gmail.com>
*/
var UdpTransport = require('./transport/Udp');
var url = require('url');
/*
* @param {String} urlString
*/
function Horus(urlString) {
var parsed = url.parse(urlString, false);
if (!(parsed.hostname && parsed.port && parsed.protocol)) {
throw '...invalid url `' + urlString + '`';
}
switch (parsed.protocol) {
case 'udp:':
this.transport = new UdpTransport(parsed.hostname, parsed.port);
break;
default:
throw '...`' + parsed.protocol + '` is not supported!';
}
}
Horus.prototype = {
/**
* @param {Object} payload
*/
send: function(payload) {
var tags = payload.tags;
var message = payload.message;
var transport = this.transport;
if (!tags || tags.length < 1) {
return transport.send(message);
}
tags.map(function(tag) {
if (typeof tag === 'array') {
tag = tag.join('\0\0');
}
if (typeof tag === 'string') {
tag = tag.split(' ').join('\0\0');
}
transport.send(tag + '\0' + message);
});
}
};
module.exports = Horus;