| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 // Package handlers implements HTTP handlers for the workflow-launcher module. | 5 // Package handlers implements HTTP handlers for the workflow-launcher module. |
| 6 package handlers | 6 package handlers |
| 7 | 7 |
| 8 import ( | 8 import ( |
| 9 "html/template" | |
| 10 "net/http" | 9 "net/http" |
| 11 | 10 |
| 12 "google.golang.org/appengine" | 11 "google.golang.org/appengine" |
| 13 "google.golang.org/appengine/taskqueue" | 12 "google.golang.org/appengine/taskqueue" |
| 13 |
| 14 common "infra/tricium/service/common" |
| 14 ) | 15 ) |
| 15 | 16 |
| 16 func init() { | 17 func init() { |
| 17 http.HandleFunc("/workflow-launcher/status", statusPageHandler) | 18 http.HandleFunc("/workflow-launcher/status", statusPageHandler) |
| 18 http.HandleFunc("/workflow-launcher/queue-handler", queueHandler) | 19 http.HandleFunc("/workflow-launcher/queue-handler", queueHandler) |
| 19 } | 20 } |
| 20 | 21 |
| 21 var basePage = template.Must(template.ParseFiles("templates/base.html")) | |
| 22 | |
| 23 func statusPageHandler(w http.ResponseWriter, r *http.Request) { | 22 func statusPageHandler(w http.ResponseWriter, r *http.Request) { |
| 24 // TODO(emso): Add workflow launcher stats | 23 // TODO(emso): Add workflow launcher stats |
| 25 » data := map[string]interface{}{ | 24 » d := map[string]interface{}{ |
| 26 "Msg": "Status of the Workflow Launcher ...", | 25 "Msg": "Status of the Workflow Launcher ...", |
| 27 } | 26 } |
| 28 » basePage.Execute(w, data) | 27 » common.ShowBasePage(w, d) |
| 29 } | 28 } |
| 30 | 29 |
| 31 func queueHandler(w http.ResponseWriter, r *http.Request) { | 30 func queueHandler(w http.ResponseWriter, r *http.Request) { |
| 32 ctx := appengine.NewContext(r) | 31 ctx := appengine.NewContext(r) |
| 33 | 32 |
| 34 // TODO(emso): Process request (merge configs, compute workflow) and lau
nch workflow | 33 // TODO(emso): Process request (merge configs, compute workflow) and lau
nch workflow |
| 35 | 34 |
| 36 // Enqueue workflow listener task | 35 // Enqueue workflow listener task |
| 37 t := taskqueue.NewPOSTTask("/workflow-listener/queue-handler", map[strin
g][]string{"name": {"Workflow Launched"}}) | 36 t := taskqueue.NewPOSTTask("/workflow-listener/queue-handler", map[strin
g][]string{"name": {"Workflow Launched"}}) |
| 38 » if _, err := taskqueue.Add(ctx, t, "workflow-listener-queue"); err != ni
l { | 37 » if _, e := taskqueue.Add(ctx, t, "workflow-listener-queue"); e != nil { |
| 39 » » http.Error(w, err.Error(), http.StatusInternalServerError) | 38 » » http.Error(w, e.Error(), http.StatusInternalServerError) |
| 40 return | 39 return |
| 41 } | 40 } |
| 42 } | 41 } |
| OLD | NEW |