Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(378)

Unified Diff: scheduler/appengine/ui/job.go

Issue 2949093003: scheduler: more of s/JobID/JobName/ where JobID != Job.JobID. (Closed)
Patch Set: review Created 3 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « scheduler/appengine/ui/invocation.go ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: scheduler/appengine/ui/job.go
diff --git a/scheduler/appengine/ui/job.go b/scheduler/appengine/ui/job.go
index 24af27522d5be540b2d01f7b62236dd40d6b20aa..d77a197f40a18d1eac0c44d7ea2a47b97462d72c 100644
--- a/scheduler/appengine/ui/job.go
+++ b/scheduler/appengine/ui/job.go
@@ -13,6 +13,7 @@ import (
mc "github.com/luci/gae/service/memcache"
"github.com/luci/luci-go/common/clock"
+ "github.com/luci/luci-go/scheduler/appengine/presentation"
"github.com/luci/luci-go/server/auth"
"github.com/luci/luci-go/server/router"
"github.com/luci/luci-go/server/templates"
@@ -22,11 +23,11 @@ func jobPage(ctx *router.Context) {
c, w, r, p := ctx.Context, ctx.Writer, ctx.Request, ctx.Params
projectID := p.ByName("ProjectID")
- jobID := p.ByName("JobID")
+ jobName := p.ByName("JobName")
cursor := r.URL.Query().Get("c")
// Grab the job from the datastore.
- job, err := config(c).Engine.GetJob(c, projectID+"/"+jobID)
+ job, err := config(c).Engine.GetJob(c, projectID+"/"+jobName)
if err != nil {
panic(err)
}
@@ -91,8 +92,8 @@ func runJobAction(ctx *router.Context) {
c, w, r, p := ctx.Context, ctx.Writer, ctx.Request, ctx.Params
projectID := p.ByName("ProjectID")
- jobID := p.ByName("JobID")
- if !isJobOwner(c, projectID, jobID) {
+ jobName := p.ByName("JobName")
+ if !presentation.IsJobOwner(c, projectID, jobName) {
http.Error(w, "Forbidden", 403)
return
}
@@ -102,7 +103,7 @@ func runJobAction(ctx *router.Context) {
genericReply := func(err error) {
templates.MustRender(c, w, "pages/run_job_result.html", map[string]interface{}{
"ProjectID": projectID,
- "JobID": jobID,
+ "JobName": jobName,
"Error": err,
})
}
@@ -110,8 +111,8 @@ func runJobAction(ctx *router.Context) {
// Enqueue new invocation request, and wait for corresponding invocation to
// appear. Give up if task queue or datastore indexes are lagging too much.
e := config(c).Engine
- fullJobID := projectID + "/" + jobID
- invNonce, err := e.TriggerInvocation(c, fullJobID, auth.CurrentIdentity(c))
+ jobID := projectID + "/" + jobName
+ invNonce, err := e.TriggerInvocation(c, jobID, auth.CurrentIdentity(c))
if err != nil {
genericReply(err)
return
@@ -132,7 +133,7 @@ func runJobAction(ctx *router.Context) {
invs, _ := e.GetInvocationsByNonce(c, invNonce)
bestTS := time.Time{}
for _, inv := range invs {
- if inv.JobKey.StringID() == fullJobID && inv.Started.Sub(bestTS) > 0 {
+ if inv.JobKey.StringID() == jobID && inv.Started.Sub(bestTS) > 0 {
invID = inv.ID
bestTS = inv.Started
}
@@ -140,7 +141,7 @@ func runJobAction(ctx *router.Context) {
}
if invID != 0 {
- http.Redirect(w, r, fmt.Sprintf("/jobs/%s/%s/%d", projectID, jobID, invID), http.StatusFound)
+ http.Redirect(w, r, fmt.Sprintf("/jobs/%s/%s/%d", projectID, jobName, invID), http.StatusFound)
} else {
genericReply(nil) // deadline
}
@@ -169,13 +170,13 @@ func abortJobAction(c *router.Context) {
func handleJobAction(c *router.Context, cb func(string) error) {
projectID := c.Params.ByName("ProjectID")
- jobID := c.Params.ByName("JobID")
- if !isJobOwner(c.Context, projectID, jobID) {
+ jobName := c.Params.ByName("JobName")
+ if !presentation.IsJobOwner(c.Context, projectID, jobName) {
http.Error(c.Writer, "Forbidden", 403)
return
}
- if err := cb(projectID + "/" + jobID); err != nil {
+ if err := cb(projectID + "/" + jobName); err != nil {
panic(err)
}
- http.Redirect(c.Writer, c.Request, fmt.Sprintf("/jobs/%s/%s", projectID, jobID), http.StatusFound)
+ http.Redirect(c.Writer, c.Request, fmt.Sprintf("/jobs/%s/%s", projectID, jobName), http.StatusFound)
}
« no previous file with comments | « scheduler/appengine/ui/invocation.go ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698