-
Notifications
You must be signed in to change notification settings - Fork 7
/
api.js
98 lines (87 loc) · 2.12 KB
/
api.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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
var request = require('request');
var EventEmitter = require('events').EventEmitter;
var apiRoot = 'https://api.hipchat.com/v2/';
module.exports = function(authtoken) {
function validate(cb) {
return request.get({
url: auth('room'),
json: true
}, function(err, res) {
if(err || res.statusCode !== 200) {
err = err || {error: res.body};
return cb(err);
}
return cb(false);
});
}
function message(userId, message, cb) {
return request.post({
url: auth('user/' + userId + '/message'),
json: {message: message}
}, function (err, res) {
if (err || res.statusCode !== 204) {
err = err || {error: res.body};
return cb(err);
};
return cb();
});
}
function chat(roomId, message, cb) {
return request.post({
url: auth('room/' + roomId + '/notification'),
json: {
message: message,
notify: true
}
}, function (err, res) {
if (err || res.statusCode !== 204) {
err || (err = res.body || {code: res.statusCode});
return cb(err);
};
return cb();
});
}
/* webhooks establishing enabled only for admin roles,
so we have to pull the messages instead */
function history(roomId) {
var shownIds = [];
var ev = new EventEmitter();
poll(0);
return ev;
function poll(wait) {
setTimeout(function(){
request.get({
url: auth('room/' + roomId + '/history'),
json: true
}, function (err, res) {
if (err || res.statusCode !== 200) {
err = res.body;
return ev.emit('error', err);
}
if (res.body.items) {
var messages = res.body.items.slice(-10);
messages.forEach(function(message){
if (shownIds.indexOf(message.id) === -1) {
shownIds.push(message.id);
ev.emit('message', message);
}
});
}
/* api rate limit is 100 reqs / 300 sec
in 5 min u can send 40 messages and have 60 history polling reqs with 5-sec frequency */
return poll(5000);
});
}, wait);
}
return ev;
}
function auth(url) {
return apiRoot + url + '?auth_token=' + authtoken;
}
return {
validate: validate,
message: message,
chat: chat,
history: history
}
}