Added first version of kubernetes chat plugin

execute.go

@@ -0,0 +1,38 @@
+package main
+
+import (
+	"fmt"
+	"io/ioutil"
+	"os"
+	"os/exec"
+)
+
+func execute(name string, arg ...string) string {
+	rescueStdout := os.Stdout
+	r, w, _ := os.Pipe()
+	os.Stdout = w
+
+	cmd := exec.Command(name, arg...)
+
+	stdin, err := cmd.StdinPipe()
+
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+
+	if err = cmd.Start(); err != nil {
+		fmt.Println("An error occured: ", err)
+	}
+
+	stdin.Close()
+	cmd.Wait()
+
+	w.Close()
+	out, _ := ioutil.ReadAll(r)
+	os.Stdout = rescueStdout
+
+	return string(out)
+}

kubebot.go

@@ -0,0 +1,35 @@
+package main
+
+import (
+	"fmt"
+	"github.com/go-chat-bot/bot"
+	"regexp"
+	"strings"
+)
+
+const (
+	pattern = "(?i)\\b(k|kubectl)\\b"
+)
+
+var (
+	re = regexp.MustCompile(pattern)
+)
+
+func kubernetes(command *bot.PassiveCmd) (string, error) {
+	if !re.MatchString(command.Raw) {
+		return "", nil
+	}
+
+	kubecmd := re.ReplaceAllString(command.Raw, "")
+	kubecmd = strings.Trim(kubecmd, " ")
+	params := strings.Split(kubecmd, " ")
+	output := execute("kubectl", params...)
+
+	return fmt.Sprintf("```\n%s\n```", output), nil
+}
+
+func init() {
+	bot.RegisterPassiveCommand(
+		"kubernetes",
+		kubernetes)
+}

main.go

@@ -0,0 +1,10 @@
+package main
+
+import (
+	"github.com/go-chat-bot/bot/slack"
+	"os"
+)
+
+func main() {
+	slack.Run(os.Getenv("KUBEBOT_SLACK_TOKEN"))
+}