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