scheduler WIP: add GetAllJobs api.

scheduler/appengine/apiservers/scheduler.go

 // Copyright 2016 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package apiservers
 
 import (
+        "github.com/luci/luci-go/common/logging"
         "github.com/luci/luci-go/scheduler/api/scheduler/v1"
         "github.com/luci/luci-go/scheduler/appengine/catalog"
         "github.com/luci/luci-go/scheduler/appengine/engine"
+        "github.com/luci/luci-go/scheduler/appengine/presentation"
+        "github.com/luci/luci-go/scheduler/appengine/task"
+        "golang.org/x/net/context"
+        "google.golang.org/grpc"
+        "google.golang.org/grpc/codes"
 )
 
 // SchedulerServer implements scheduler.Scheduler API.
 type SchedulerServer struct {
         Engine  engine.Engine
         Catalog catalog.Catalog
 }
 
 var _ scheduler.SchedulerServer = (*SchedulerServer)(nil)
+
+// GetJobs fetches all jobs satisfying JobsRequest and visibility ACLs.
+func (s SchedulerServer) GetJobs(ctx context.Context, in *scheduler.JobsRequest) (*scheduler.JobsReply, error) {
+        var ejobs []*engine.Job
+        var err error
+        if in.GetProject() == "" {
+                ejobs, err = s.Engine.GetAllJobs(ctx)
+        } else {
+                ejobs, err = s.Engine.GetProjectJobs(ctx, in.GetProject())
+        }
+        if err != nil {
+                return nil, grpc.Errorf(codes.Internal, "datastore error: %s", err)
+        }
+
+        jobs := make([]*scheduler.Job, len(ejobs))
+        for i, ej := range ejobs {
+                jobs[i] = &scheduler.Job{
+                        Id:       ej.JobID,
+                        Project:  ej.ProjectID,
+                        Schedule: ej.Schedule,
+                        State: &scheduler.JobState{
+                                UiStatus: string(presentation.GetPublicStateKind(ej, s.getTaskTraits(ctx, ej))),
+                        },
+                }
+        }
+        return &scheduler.JobsReply{Jobs: jobs}, nil
+}
+
+////
+
+func (s SchedulerServer) getTaskTraits(ctx context.Context, j *engine.Job) task.Traits {

[Vadim Sh., 2017/06/20 17:48:54]

I think this should be moved somewhere else, so it can be reused from both
places. Maybe 'presentation' too?..

GetTaskTraits(cat *catalog.Catalog, j *engine.Job) (task.Traits, error)

(and return an error in case of failed deserialization or what not)

[tandrii(chromium), 2017/06/20 19:48:36]

Done.

+        var manager task.Manager
+        taskDef, err := s.Catalog.UnmarshalTask(j.Task)
+        if err != nil {
+                logging.WithError(err).Warningf(ctx, "Failed to unmarshal task proto for %s", j.JobID)
+        } else {
+                manager = s.Catalog.GetTaskManager(taskDef)
+        }
+        if manager != nil {
+                return manager.Traits()
+        }
+        return task.Traits{}
+}