Merge pull request #3 from bsm/feature/filter-pending

Allow to filter pending

backend/internal/testdata/lint.go

@@ -175,6 +175,14 @@ func BehavesLikeBackend(data *BehavesLikeBackendData) func() {
 			})).To(Ω.Succeed())
 			Ω.Expect(results).To(Ω.HaveLen(2))
 
+			// List pending
+			results = results[:0]
+			Ω.Expect(subject.List(ctx, &rpc.ListRequest{Filter: &rpc.ListRequest_Filter{Status: rpc.ListRequest_Filter_PENDING}}, func(h *backend.HandleData) error {
+				results = append(results, h)
+				return nil
+			})).To(Ω.Succeed())
+			Ω.Expect(results).To(Ω.HaveLen(1))
+
 			// With namespace
 			results = results[:0]
 			Ω.Expect(subject.List(ctx, &rpc.ListRequest{Filter: &rpc.ListRequest_Filter{Prefix: "a/b"}}, func(h *backend.HandleData) error {

backend/mock/mock.go

@@ -138,6 +138,8 @@ func (*Backend) Close() error { return nil }
 func isSelected(filter *rpc.ListRequest_Filter, handle *backend.HandleData) bool {
 	if filter.Status == rpc.ListRequest_Filter_DONE && !handle.IsDone() {
 		return false
+	} else if filter.Status == rpc.ListRequest_Filter_PENDING && handle.IsDone() {
+		return false
 	}
 
 	if filter.Prefix != "" && !strings.HasPrefix(handle.Namespace, filter.Prefix) {

backend/postgres/postgres.go

@@ -152,6 +152,8 @@ func (b *postgres) List(ctx context.Context, req *rpc.ListRequest, iter backend.
 	if f := req.GetFilter(); f != nil {
 		if f.Status == rpc.ListRequest_Filter_DONE {
 			stmt = stmt.Where(sq.NotEq{"done_at": nil})
+		} else if f.Status == rpc.ListRequest_Filter_PENDING {
+			stmt = stmt.Where(sq.Eq{"done_at": nil})
 		}
 		if f.Prefix != "" {
 			stmt = stmt.Where(sq.Like{"namespace": f.Prefix + "%"})

rpc/accord.proto

@@ -107,6 +107,7 @@ message ListRequest {
 		enum Status {
 			ALL = 0;
 			DONE = 1;
+			PENDING = 2;
 		}
 
 		// Namespace prefix.