From c869babecb193f02a24f071b8fd101e16aeec680 Mon Sep 17 00:00:00 2001 From: Ward Vandewege Date: Mon, 8 Mar 2021 17:03:29 -0500 Subject: [PATCH] 17119: implement review feedback. Arvados-DCO-1.1-Signed-off-by: Ward Vandewege --- lib/controller/federation/conn.go | 3 +- lib/controller/router/response.go | 56 ++++++++++++++----------------- 2 files changed, 27 insertions(+), 32 deletions(-) diff --git a/lib/controller/federation/conn.go b/lib/controller/federation/conn.go index 09540a5f4b..a9352098d3 100644 --- a/lib/controller/federation/conn.go +++ b/lib/controller/federation/conn.go @@ -423,8 +423,7 @@ func (conn *Conn) GroupContents(ctx context.Context, options arvados.GroupConten } func (conn *Conn) GroupShared(ctx context.Context, options arvados.ListOptions) (arvados.GroupList, error) { - // FIXME is this right?? We don't have options.UUID to cue the chooseBackend off - return conn.chooseBackend(conn.cluster.ClusterID).GroupShared(ctx, options) + return conn.chooseBackend(options.ClusterID).GroupShared(ctx, options) } func (conn *Conn) GroupDelete(ctx context.Context, options arvados.DeleteOptions) (arvados.Group, error) { diff --git a/lib/controller/router/response.go b/lib/controller/router/response.go index aee2fc590b..e1fc2691a5 100644 --- a/lib/controller/router/response.go +++ b/lib/controller/router/response.go @@ -82,38 +82,34 @@ func (rtr *router) sendResponse(w http.ResponseWriter, req *http.Request, resp i defaultItemKind = strings.TrimSuffix(respKind, "List") } - var items, included []interface{} - var itemsOK, includedOK bool - items, itemsOK = tmp["items"].([]interface{}) - included, includedOK = tmp["included"].([]interface{}) - if includedOK && len(included) > 0 { - items = append(items, included...) - } - - if itemsOK { - for i, item := range items { - // Fill in "kind" by inspecting UUID/PDH if - // possible; fall back on assuming each - // Items[] entry in an "arvados#fooList" - // response should have kind="arvados#foo". - item, _ := item.(map[string]interface{}) - infix := "" - if uuid, _ := item["uuid"].(string); len(uuid) == 27 { - infix = uuid[6:11] + if _, isListResponse := tmp["items"].([]interface{}); isListResponse { + items, _ := tmp["items"].([]interface{}) + included, _ := tmp["included"].([]interface{}) + for _, slice := range [][]interface{}{items, included} { + for i, item := range slice { + // Fill in "kind" by inspecting UUID/PDH if + // possible; fall back on assuming each + // Items[] entry in an "arvados#fooList" + // response should have kind="arvados#foo". + item, _ := item.(map[string]interface{}) + infix := "" + if uuid, _ := item["uuid"].(string); len(uuid) == 27 { + infix = uuid[6:11] + } + if k := kind(infixMap[infix]); k != "" { + item["kind"] = k + } else if pdh, _ := item["portable_data_hash"].(string); pdh != "" { + item["kind"] = "arvados#collection" + } else if defaultItemKind != "" { + item["kind"] = defaultItemKind + } + item = applySelectParam(opts.Select, item) + rtr.mungeItemFields(item) + slice[i] = item } - if k := kind(infixMap[infix]); k != "" { - item["kind"] = k - } else if pdh, _ := item["portable_data_hash"].(string); pdh != "" { - item["kind"] = "arvados#collection" - } else if defaultItemKind != "" { - item["kind"] = defaultItemKind + if opts.Count == "none" { + delete(tmp, "items_available") } - item = applySelectParam(opts.Select, item) - rtr.mungeItemFields(item) - items[i] = item - } - if opts.Count == "none" { - delete(tmp, "items_available") } } else { tmp = applySelectParam(opts.Select, tmp) -- 2.30.2