| 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 gerrit-poller module. | 5 // Package handlers implements HTTP handlers for the gerrit-poller module. |
| 6 package handlers | 6 package handlers |
| 7 | 7 |
| 8 import ( | 8 import ( |
| 9 "html/template" | 9 "html/template" |
| 10 "net/http" | 10 "net/http" |
| 11 | 11 |
| 12 "google.golang.org/appengine" | 12 "google.golang.org/appengine" |
| 13 "google.golang.org/appengine/taskqueue" | 13 "google.golang.org/appengine/taskqueue" |
| 14 ) | 14 ) |
| 15 | 15 |
| 16 func init() { | 16 func init() { |
| 17 http.HandleFunc("/gerrit-poller/status", statusPageHandler) | 17 http.HandleFunc("/gerrit-poller/status", statusPageHandler) |
| 18 http.HandleFunc("/gerrit-poller/poll", pollHandler) | 18 http.HandleFunc("/gerrit-poller/poll", pollHandler) |
| 19 } | 19 } |
| 20 | 20 |
| 21 var basePage = template.Must(template.ParseFiles("templates/base.html")) | 21 var basePage = template.Must(template.ParseFiles("templates/base.html")) |
| 22 | 22 |
| 23 func statusPageHandler(w http.ResponseWriter, r *http.Request) { | 23 func statusPageHandler(w http.ResponseWriter, r *http.Request) { |
| 24 // TODO(emso): Add Gerrit poller stats | 24 // TODO(emso): Add Gerrit poller stats |
| 25 data := map[string]interface{}{ | 25 data := map[string]interface{}{ |
| 26 "Msg": "Status of the Gerrit Poller ...", | 26 "Msg": "Status of the Gerrit Poller ...", |
| 27 } | 27 } |
| 28 » basePage.Execute(w, data) | 28 » if e := basePage.Execute(w, data); e != nil { |
| 29 » » http.Error(w, e.Error(), http.StatusInternalServerError) |
| 30 » » return |
| 31 » } |
| 29 } | 32 } |
| 30 | 33 |
| 31 func pollHandler(w http.ResponseWriter, r *http.Request) { | 34 func pollHandler(w http.ResponseWriter, r *http.Request) { |
| 32 ctx := appengine.NewContext(r) | 35 ctx := appengine.NewContext(r) |
| 33 | 36 |
| 34 // TODO(emso): Poll Gerrit and convert changes to workflow event tasks. | 37 // TODO(emso): Poll Gerrit and convert changes to workflow event tasks. |
| 35 | 38 |
| 36 // Enqueue workflow event task. | 39 // Enqueue workflow event task. |
| 37 t := taskqueue.NewPOSTTask("/workflow-launcher/queue-handler", map[strin
g][]string{"name": {"Analysis Request"}}) | 40 t := taskqueue.NewPOSTTask("/workflow-launcher/queue-handler", map[strin
g][]string{"name": {"Analysis Request"}}) |
| 38 » if _, err := taskqueue.Add(ctx, t, "workflow-launcher-queue"); err != ni
l { | 41 » if _, e := taskqueue.Add(ctx, t, "workflow-launcher-queue"); e != nil { |
| 39 » » http.Error(w, err.Error(), http.StatusInternalServerError) | 42 » » http.Error(w, e.Error(), http.StatusInternalServerError) |
| 40 return | 43 return |
| 41 } | 44 } |
| 42 } | 45 } |
| OLD | NEW |