Adds initial Tricium service GAE configs

go/src/infra/tricium/service/workflow-listener/handlers.go

Index: go/src/infra/tricium/service/workflow-listener/handlers.go
diff --git a/go/src/infra/tricium/service/workflow-listener/handlers.go b/go/src/infra/tricium/service/workflow-listener/handlers.go
new file mode 100644
index 0000000000000000000000000000000000000000..4c777a993a7d4379e08f8fe665eb8188e6213fb5
--- /dev/null
+++ b/go/src/infra/tricium/service/workflow-listener/handlers.go
@@ -0,0 +1,37 @@
+package handlers
+
+import (
+	"html/template"
+	"net/http"
+
+	"appengine"
+	"appengine/taskqueue"
+)
+
+func init() {
+	http.HandleFunc("/workflow-listener/status", statusPageHandler)
+	http.HandleFunc("/workflow-listener/queue-handler", queueHandler)
+}
+
+var basePage = template.Must(template.ParseFiles("templates/base.html"))
+
+func statusPageHandler(w http.ResponseWriter, r *http.Request) {
+	// TODO(emso): Add workflow listener stats
+	data := map[string]interface{}{
+		"Msg": "Status of the Workflow Listener ...",
+	}
+	basePage.Execute(w, data)
+}
+
+func queueHandler(w http.ResponseWriter, r *http.Request) {
+	ctx := appengine.NewContext(r)
+
+	// TODO(emso): Process task (find LogDog streams to listen to) and listen to events.
+
+	// Enqueue gerrit reporter task.
+	t := taskqueue.NewPOSTTask("/gerrit-reporter/queue-handler", map[string][]string{"name": {"Workflow Event"}})
+	if _, err := taskqueue.Add(ctx, t, "gerrit-reporter-queue"); err != nil {
+		http.Error(w, err.Error(), http.StatusInternalServerError)
+		return
+	}
+}