-
Notifications
You must be signed in to change notification settings - Fork 25
/
client.js
99 lines (84 loc) · 2.54 KB
/
client.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
99
// Generated by CoffeeScript 1.3.3
(function() {
var Client, apiClient, _;
_ = require('underscore');
apiClient = require('./api_client');
Client = (function() {
function Client(options) {
this.api = new apiClient.APIClient(options);
}
Client.prototype.queue = function(name) {
return new Client(_.extend({}, this.api.options, {
queue_name: name
}));
};
Client.prototype.queues = function(options, cb) {
return this.api.queuesList(options, function(error, body) {
if (!(error != null)) {
return cb(error, body);
} else {
return cb(error, body);
}
});
};
Client.prototype.info = function(cb) {
return this.api.queuesGet(this.api.options.queue_name, function(error, body) {
if (!(error != null)) {
return cb(error, body);
} else {
return cb(error, body);
}
});
};
Client.prototype.clear = function(cb) {
return this.api.queuesClear(this.api.options.queue_name, function(error, body) {
if (!(error != null)) {
return cb(error, body);
} else {
return cb(error, body);
}
});
};
Client.prototype.post = function(messages, cb) {
if (!(messages instanceof Array)) {
messages = [messages];
}
messages = _.map(messages, function(message) {
if (typeof message === 'string') {
return {
body: message
};
} else {
return message;
}
});
return this.api.messagesPost(this.api.options.queue_name, messages, function(error, body) {
if (!(error != null)) {
return cb(error, messages.length === 1 ? body.ids[0] : body.ids);
} else {
return cb(error, body);
}
});
};
Client.prototype.get = function(options, cb) {
return this.api.messagesGet(this.api.options.queue_name, options, function(error, body) {
if (!(error != null)) {
return cb(error, (!(options.n != null)) || options.n === 1 ? body.messages[0] : body.messages);
} else {
return cb(error, body);
}
});
};
Client.prototype.del = function(message_id, cb) {
return this.api.messagesDelete(this.api.options.queue_name, message_id, function(error, body) {
if (!(error != null)) {
return cb(error, body);
} else {
return cb(error, body);
}
});
};
return Client;
})();
module.exports.Client = Client;
}).call(this);