Added message acknowledging

This commit is contained in:
hydrabolt
2015-11-15 13:32:01 +00:00
parent 9ad55668a1
commit 4973412439
2 changed files with 52 additions and 0 deletions

View File

@@ -948,6 +948,29 @@ var InternalClient = (function () {
return this.setChannelNameAndTopic(chann, data.name, data.topic);
};
//def ack
InternalClient.prototype.ack = function ack(msg) {
var self = this;
return new Promise(function (resolve, reject) {
msg = self.resolver.resolveMessage(msg);
if (msg) {
request.post(Endpoints.CHANNEL_MESSAGE(msg.channel.id, msg.id) + "/ack").set("authorization", self.token).end(function (err) {
if (err) {
reject(err);
} else {
resolve();
}
});
} else {
reject(new Error("Message does not exist"));
}
});
};
InternalClient.prototype.sendWS = function sendWS(object) {
if (this.websocket) this.websocket.send(JSON.stringify(object));
};
@@ -1031,6 +1054,7 @@ var InternalClient = (function () {
if (channel) {
var msg = channel.messages.add(new Message(data, channel, client));
client.emit("message", msg);
self.ack(msg);
} else {
client.emit("warn", "message created but channel is not cached");
}

View File

@@ -1006,6 +1006,33 @@ class InternalClient {
updateChannel(chann, data) {
return this.setChannelNameAndTopic(chann, data.name, data.topic);
}
//def ack
ack(msg){
var self = this;
return new Promise((resolve, reject) => {
msg = self.resolver.resolveMessage(msg);
if(msg){
request
.post(Endpoints.CHANNEL_MESSAGE(msg.channel.id, msg.id)+"/ack")
.set("authorization", self.token)
.end((err) => {
if(err){
reject(err);
}else{
resolve();
}
});
}else{
reject(new Error("Message does not exist"));
}
});
}
sendWS(object) {
if (this.websocket)
@@ -1090,6 +1117,7 @@ class InternalClient {
if (channel) {
var msg = channel.messages.add(new Message(data, channel, client));
client.emit("message", msg);
self.ack(msg);
} else {
client.emit("warn", "message created but channel is not cached");
}