forked from TykTechnologies/tyk
-
Notifications
You must be signed in to change notification settings - Fork 0
/
middleware_method_transform.go
80 lines (66 loc) · 1.99 KB
/
middleware_method_transform.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
package main
import (
"errors"
"net/http"
"strings"
"github.com/TykTechnologies/tykcommon"
)
// TransformMiddleware is a middleware that will apply a template to a request body to transform it's contents ready for an upstream API
type TransformMethod struct {
*TykMiddleware
}
type TransformMethodConfig struct{}
// New lets you do any initialisations for the object can be done here
func (t *TransformMethod) New() {}
// GetConfig retrieves the configuration from the API config - we user mapstructure for this for simplicity
func (t *TransformMethod) GetConfig() (interface{}, error) {
return nil, nil
}
func (t *TransformMethod) IsEnabledForSpec() bool {
var used bool
for _, thisVersion := range t.TykMiddleware.Spec.VersionData.Versions {
if len(thisVersion.ExtendedPaths.MethodTransforms) > 0 {
used = true
break
}
}
return used
}
// ProcessRequest will run any checks on the request on the way through the system, return an error to have the chain fail
func (t *TransformMethod) ProcessRequest(w http.ResponseWriter, r *http.Request, configuration interface{}) (error, int) {
// Uee the request status validator to see if it's in our cache list
var stat RequestStatus
var meta interface{}
var found bool
_, versionPaths, _, _ := t.TykMiddleware.Spec.GetVersionData(r)
found, meta = t.TykMiddleware.Spec.CheckSpecMatchesStatus(r.URL.Path, r.Method, versionPaths, MethodTransformed)
if found {
stat = StatusMethodTransformed
}
if stat == StatusMethodTransformed {
thisMeta := meta.(*tykcommon.MethodTransformMeta)
switch strings.ToUpper(thisMeta.ToMethod) {
case "GET":
r.Method = "GET"
return nil, 200
case "POST":
r.Method = "POST"
return nil, 200
case "PUT":
r.Method = "PUT"
return nil, 200
case "DELETE":
r.Method = "DELETE"
return nil, 200
case "OPTIONS":
r.Method = "OPTIONS"
return nil, 200
case "PATCH":
r.Method = "PATCH"
return nil, 200
default:
return errors.New("Method not allowed"), 405
}
}
return nil, 200
}