Proof of concept

bognix · May 26, 2016 · cd4f679 · cd4f679
1 parent 7c817ca
commit cd4f679
Showing 1 changed file with 149 additions and 131 deletions.
diff --git a/index.js b/index.js
@@ -1,159 +1,177 @@
 var RtmClient = require('@slack/client').RtmClient,
-	token = process.env.SANDBOT_TOKEN || '',
-	sheet = require('./sheets'),
-	Promise = require('bluebird'),
-	request = require('request'),
-	rtm = new RtmClient(token, {logLevel: 'error'}),
-	auth = sheet.authorize(),
-
-	RTM_EVENTS = require('@slack/client').RTM_EVENTS,
-	STATUS_PATTERN = /sandbot status/i,
-	BOOK_PATTERN = /(biore|taking) sandbox-/i,
-	RELEASE_PATTERN = /(zwalniam|releasing) sandbox-/i,
-	PING_PATTERN = /sandbot (zyjesz|ping)\?/i;
+    token = process.env.SANDBOT_TOKEN || '',
+    sheet = require('./sheets'),
+    Promise = require('bluebird'),
+    request = require('request'),
+    rtm = new RtmClient(token, {logLevel: 'error'}),
+    auth = sheet.authorize(),
+
+    RTM_EVENTS = require('@slack/client').RTM_EVENTS,
+    STATUS_PATTERN = /sandbot status/i,
+    BOOK_PATTERN = /(biore|taking) sandbox-/i,
+    RELEASE_PATTERN = /(zwalniam|releasing) sandbox-/i,
+    PING_PATTERN = /sandbot (zyjesz|ping)\?/i;
 
 rtm.start();
 
 rtm.on(RTM_EVENTS.MESSAGE, function (message) {
-	if (message.text && STATUS_PATTERN.test(message.text)) {
-
-		getStatus(message.channel).then(function (data) {
-			var promises = [];
-
-			Object.keys(data.result).forEach(function (key) {
-				promises.push(parseSandboxStatus(key, data.result[key]));
-			});
-
-			Promise.all(promises).then(function (data) {
-				var parsedMsg = '```';
-				data.forEach(function (item) {
-					parsedMsg += item[0] + ': ' + item[1] + '\n';
-				});
-				rtm.sendMessage(parsedMsg + '```', message.channel);
-			})
-		})
-	}
-
-	if (message.text && BOOK_PATTERN.test(message.text)) {
-		var sandboxName = getSandboxNameFromMessage(message),
-			msg = '<@' + message.user + '> ';
-
-		getPreviousUser(message.channel, sandboxName)
-			.then(function (previousUser) {
-				if (previousUser.result) {
-					msg += ':-1: - <@' + previousUser.result + '> is using it';
-					rtm.sendMessage(msg, message.channel)
-				} else {
-					bookSandbox(message)
-						.then(function () {
-							msg += ':+1:';
-							rtm.sendMessage(msg, message.channel)
-						})
-				}
-			});
-	}
-
-	if (message.text && RELEASE_PATTERN.test(message.text)) {
-		var msg = '<@' + message.user + '> ';
-
-		releaseSandbox(message)
-			.then(function () {
-				msg += ':+1:';
-				rtm.sendMessage(msg, message.channel)
-			})
-	}
-
-	if (message.text && PING_PATTERN.test(message.text)) {
-		rtm.sendMessage('zyje :+1:', message.channel);
-	}
+    if (message.text && STATUS_PATTERN.test(message.text)) {
+
+        getStatus(message.channel).then(function (data) {
+            var promises = [];
+
+            Object.keys(data.result).forEach(function (key) {
+                promises.push(parseSandboxStatus(key, data.result[key]));
+            });
+
+            Promise.all(promises).then(function (data) {
+                var parsedMsg = '```';
+                data.forEach(function (item) {
+                    parsedMsg += item[0] + ': ' + item[1] + '\n';
+                });
+                rtm.sendMessage(parsedMsg + '```', message.channel);
+            })
+        })
+    }
+
+    if (message.text && BOOK_PATTERN.test(message.text)) {
+        var sandboxName = getSandboxNameFromMessage(message),
+            msg = '<@' + message.user + '> ';
+
+        getPreviousUser(message.channel, sandboxName)
+            .then(function (previousUser) {
+                if (previousUser.result) {
+                    msg += ':-1: - <@' + previousUser.result + '> is using it';
+                    rtm.sendMessage(msg, message.channel)
+                } else {
+                    bookSandbox(message)
+                        .then(function () {
+                            msg += ':+1:';
+                            rtm.sendMessage(msg, message.channel)
+                        })
+                }
+            });
+    }
+
+    if (message.text && RELEASE_PATTERN.test(message.text)) {
+        var msg = '<@' + message.user + '> ';
+
+        releaseSandbox(message)
+            .then(function (data) {
+                msg += ':+1:';
+                if (data.response) {
+                    rtm.sendMessage(data.response, message.channel);
+                }
+                rtm.sendMessage(msg, message.channel)
+            })
+    }
+
+    if (message.text && PING_PATTERN.test(message.text)) {
+        rtm.sendMessage('zyje :+1:', message.channel);
+    }
 });
 
 function getStatus(channel) {
-	return new Promise(function (resolve, reject) {
-		auth
-			.then(function (authData) {
-				return sheet.getStatus(authData, channel);
-			})
-			.then(function (data) {
-				resolve(data)
-			});
-	});
+    return new Promise(function (resolve, reject) {
+        auth
+            .then(function (authData) {
+                return sheet.getStatus(authData, channel);
+            })
+            .then(function (data) {
+                resolve(data)
+            });
+    });
 }
 
 function getPreviousUser(channel, sandboxName) {
-	return new Promise(function (resolve, reject) {
-		auth
-			.then(function (authData) {
-				return sheet.getCurrentUser(authData, channel, sandboxName);
-			})
-			.then(function (data) {
-				resolve(data);
-			})
-	})
+    return new Promise(function (resolve, reject) {
+        auth
+            .then(function (authData) {
+                return sheet.getCurrentUser(authData, channel, sandboxName);
+            })
+            .then(function (data) {
+                resolve(data);
+            })
+    })
 }
 
 function bookSandbox(message) {
-	var sandboxName = getSandboxNameFromMessage(message);
-
-	return new Promise(function (resolve, reject) {
-		auth
-			.then(function (authData) {
-				return sheet.bookSandbox(authData, message.channel, sandboxName, message.user);
-			})
-			.then(function (data) {
-				resolve(data)
-			})
-	});
+    var sandboxName = getSandboxNameFromMessage(message);
+
+    return new Promise(function (resolve, reject) {
+        auth
+            .then(function (authData) {
+                return sheet.bookSandbox(authData, message.channel, sandboxName, message.user);
+            })
+            .then(function (data) {
+                resolve(data)
+            })
+    });
 }
 
 function getUserNameById(userId) {
-	return new Promise(function (resolve, reject) {
-		request(
-			{
-				url: 'https://slack.com/api/users.info',
-				qs: {
-					token: token,
-					user: userId
-				}
-			}, function (error, response, body) {
-				if (!error && response.statusCode == 200) {
-					var json = JSON.parse(body);
-					resolve(json.user.name);
-				}
-			})
-	})
+    return new Promise(function (resolve, reject) {
+        request(
+            {
+                url: 'https://slack.com/api/users.info',
+                qs: {
+                    token: token,
+                    user: userId
+                }
+            }, function (error, response, body) {
+                if (!error && response.statusCode == 200) {
+                    var json = JSON.parse(body);
+                    resolve(json.user.name);
+                }
+            })
+    })
 }
 
 function getSandboxNameFromMessage(message) {
-	var text = message.text,
-		match = text.match(/(sandbox-.*)/i);
+    var text = message.text,
+        match = text.match(/(sandbox-.*)/i);
 
-	if (match) {
-		return match[0].replace('-', '_');
-	}
+    if (match) {
+        return match[0].replace('-', '_');
+    }
 }
 
 function parseSandboxStatus(key, value) {
-	if (value) {
-		return new Promise(function (resolve, reject) {
-			getUserNameById(value)
-				.then(function (userName) {
-					resolve([key, userName]);
-				});
-		});
-	} else {
-		return [key, 'free'];
-	}
+    if (value) {
+        return new Promise(function (resolve, reject) {
+            getUserNameById(value)
+                .then(function (userName) {
+                    resolve([key, userName]);
+                });
+        });
+    } else {
+        return [key, 'free'];
+    }
 }
 
 function releaseSandbox(message) {
-	return new Promise(function (resolve, reject) {
-		auth.then(function (authData) {
-			var sandboxName = getSandboxNameFromMessage(message);
-
-			return sheet.releaseSandbox(authData, message.channel, sandboxName, message.user);
-		}).then(function (data) {
-			resolve(data)
-		});
-	});
+    var authorization, response, sandboxName;
+
+    return new Promise(function (resolve, reject) {
+        auth
+            .then(function (authData) {
+                authorization = authData;
+                sandboxName = getSandboxNameFromMessage(message);
+
+                return sheet.getCurrentUser(authData, message.channel, sandboxName);
+            })
+            .then(function (user) {
+                if (user !== message.user) {
+                    response = ':pirate: take over!!! @' + user + ', ' + message.user + ' is releasing your sandbox!';
+                }
+
+                return sheet.releaseSandbox(authorization, message.channel, sandboxName, message.user);
+            })
+            .then(function (data) {
+                resolve({
+                    response: response,
+                    data: data
+                });
+            });
+    })
 }