refactor getReferences
This commit is contained in:
parent
bbb6d2a7ab
commit
5b25f5df99
34
gql/util.go
34
gql/util.go
@ -164,26 +164,26 @@ func GetGQLAuction(auction *auctiontypes.Auction, bids []*auctiontypes.Bid) (*Au
|
|||||||
}
|
}
|
||||||
|
|
||||||
func getReferences(ctx context.Context, resolver QueryResolver, r *registrytypes.RecordType) ([]*Record, error) {
|
func getReferences(ctx context.Context, resolver QueryResolver, r *registrytypes.RecordType) ([]*Record, error) {
|
||||||
var ids []string
|
ids := getIds(r.Attributes)
|
||||||
|
|
||||||
// #nosec G705
|
|
||||||
for key := range r.Attributes {
|
|
||||||
//nolint: all
|
|
||||||
switch r.Attributes[key].(type) {
|
|
||||||
case interface{}:
|
|
||||||
if obj, ok := r.Attributes[key].(map[string]interface{}); ok {
|
|
||||||
if _, ok := obj["/"]; ok && len(obj) == 1 {
|
|
||||||
if _, ok := obj["/"].(string); ok {
|
|
||||||
ids = append(ids, obj["/"].(string))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return resolver.GetRecordsByIds(ctx, ids)
|
return resolver.GetRecordsByIds(ctx, ids)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func getIds(obj map[string]interface{}) []string {
|
||||||
|
var ids []string
|
||||||
|
for _, val := range obj {
|
||||||
|
if innerObj, ok := val.(map[string]interface{}); ok {
|
||||||
|
if _, ok := innerObj["/"]; ok && len(innerObj) == 1 {
|
||||||
|
if _, ok := innerObj["/"].(string); ok {
|
||||||
|
ids = append(ids, innerObj["/"].(string))
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
ids = append(ids, getIds(innerObj)...)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return ids
|
||||||
|
}
|
||||||
|
|
||||||
func getAttributes(r *registrytypes.RecordType) ([]*KeyValue, error) {
|
func getAttributes(r *registrytypes.RecordType) ([]*KeyValue, error) {
|
||||||
return mapToKeyValuePairs(r.Attributes)
|
return mapToKeyValuePairs(r.Attributes)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user