Add blaupload controller

2 files changed, 47 insertions, 0 deletions

diff --git a/pom.xml b/pom.xml
index b4cd29d..9f421e6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -66,6 +66,12 @@
             <version>${jackson.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.4</version>
+        </dependency>
+
     </dependencies>
     
     <build>
diff --git a/src/main/java/uk/co/blatech/blaears/controllers/BlauploadController.java b/src/main/java/uk/co/blatech/blaears/controllers/BlauploadController.java
new file mode 100644
index 0000000..c58f654
--- /dev/null
+++ b/src/main/java/uk/co/blatech/blaears/controllers/BlauploadController.java
@@ -0,0 +1,41 @@
+package uk.co.blatech.blaears.controllers;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.log4j.Logger;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.io.IOException;
+
+/**
+ * Takes notifications of uploads from Blaupload and sends them to IRC
+ */
+public class BlauploadController {
+
+    private static final Logger log = Logger.getLogger(GitPushController.class);
+
+    @RequestMapping(value = "/blaupload", method = RequestMethod.POST)
+    String notify(@RequestParam("url") String url, @RequestParam("channel") String channel, Model model) {
+
+        if (StringUtils.isBlank(url) || StringUtils.isBlank(channel)) {
+            log.error("Invalid notification from blaupload: url=" + url + ", channel=" + channel);
+            model.addAttribute("result", "failed");
+            return "blaupload";
+        }
+
+        try {
+            Runtime.getRuntime().exec(new String[]{"/bin/bash", "-c", "echo " + channel + " New file uploaded: " + url + " | bash /home/smsd/msgrelay.bash "});
+        } catch (IOException e) {
+            log.error("Failed to send message to " + channel + " for " + url);
+            e.printStackTrace();
+            model.addAttribute("result", "failed");
+            return "blaupload";
+        }
+
+        log.info("blaupload notification for " + url);
+        model.addAttribute("result", "OK");
+        return "blaupload";
+    }
+}