forked from expr-lang/expr
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathfunc.go
82 lines (70 loc) · 1.51 KB
/
func.go
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package expr
type unaryOperatorFunc func(x interface{}) interface{}
type binaryOperatorFunc func(x, y interface{}) interface{}
func (fn unaryOperatorFunc) Call(a interface{}) interface{} {
if arr, ok := asArray(a); ok {
cnt := len(arr)
out := make([]interface{}, cnt)
for i := 0; i < cnt; i++ {
out[i] = fn(arr[i])
}
return out
}
return fn(a)
}
func (fn binaryOperatorFunc) Call(a, b interface{}) interface{} {
arrA, okA := asArray(a)
arrB, okB := asArray(b)
if okA && okB {
lenA, lenB := len(arrA), len(arrB)
cnt := lenA
if lenB > lenA {
cnt = lenB
}
arrC := make([]interface{}, cnt)
for i := 0; i < cnt; i++ {
arrC[i] = fn(getAt(arrA, i), getAt(arrB, i))
}
return arrC
}
if okA {
cnt := len(arrA)
arrC := make([]interface{}, cnt)
for i := 0; i < cnt; i++ {
arrC[i] = fn(getAt(arrA, i), b)
}
return arrC
}
if okB {
cnt := len(arrB)
arrC := make([]interface{}, cnt)
for i := 0; i < cnt; i++ {
arrC[i] = fn(a, getAt(arrB, i))
}
return arrC
}
return fn(a, b)
}
func asArray(v interface{}) ([]interface{}, bool) {
if casted, ok := v.([]interface{}); ok {
return casted, true
}
return nil, false
}
func getAt(arr []interface{}, at int) interface{} {
if at < 0 || at >= len(arr) {
return nil
}
return arr[at]
}
func flatten(args ...interface{}) []interface{} {
var values []interface{}
for _, a := range args {
if arr, ok := asArray(a); ok {
values = append(values, flatten(arr...)...)
} else {
values = append(values, a)
}
}
return values
}