1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
// Copyright 2019-present Facebook Inc. All rights reserved.
// This source code is licensed under the Apache 2.0 license found
// in the LICENSE file in the root directory of this source tree.
package gremlin
import (
"context"
"sort"
"strings"
jsoniter "github.com/json-iterator/go"
"github.com/pkg/errors"
)
// ExpandBindings expands the given RoundTripper and expands the request bindings into the Gremlin traversal.
func ExpandBindings(rt RoundTripper) RoundTripper {
return RoundTripperFunc(func(ctx context.Context, r *Request) (*Response, error) {
bindings, ok := r.Arguments[ArgsBindings]
if !ok {
return rt.RoundTrip(ctx, r)
}
query, ok := r.Arguments[ArgsGremlin]
if !ok {
return rt.RoundTrip(ctx, r)
}
{
query, bindings := query.(string), bindings.(map[string]interface{})
keys := make(sort.StringSlice, 0, len(bindings))
for k := range bindings {
keys = append(keys, k)
}
sort.Sort(sort.Reverse(keys))
kv := make([]string, 0, len(bindings)*2)
for _, k := range keys {
s, err := jsoniter.MarshalToString(bindings[k])
if err != nil {
return nil, errors.WithMessagef(err, "marshal bindings value for key %s", k)
}
kv = append(kv, k, s)
}
delete(r.Arguments, ArgsBindings)
r.Arguments[ArgsGremlin] = strings.NewReplacer(kv...).Replace(query)
}
return rt.RoundTrip(ctx, r)
})
}
|
