-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathrequest_validator.go
83 lines (74 loc) · 2.52 KB
/
request_validator.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
83
package api
import (
"encoding/json"
"io"
"net/http"
"github.com/jgolang/api/core"
)
// RequestContextKey type
type RequestContextKey string
// RequestDataContextContextKey request data context key to finds request context
const RequestDataContextContextKey = RequestContextKey("requestData")
// RequestReceiver implementation of core.APIRequestReceiver interface
type RequestReceiver struct{}
// ProcessEncryptedBody process API request encription information.
func (receiver RequestReceiver) ProcessEncryptedBody(r *http.Request) (*core.RequestEncryptedData, error) {
var request JSONEncryptedBody
rawBody, err := io.ReadAll(r.Body)
if err != nil {
return nil, err
}
err = json.Unmarshal(rawBody, &request)
if err != nil {
return nil, err
}
requestData := core.RequestEncryptedData{
Data: request.Data,
Metadata: request.DeviceUUID,
}
return &requestData, nil
}
// ProcessBody process API request body information.
func (receiver RequestReceiver) ProcessBody(r *http.Request) (*core.RequestDataContext, error) {
var request JSONRequest
rawBody, err := io.ReadAll(r.Body)
if err != nil {
return nil, err
}
err = json.Unmarshal(rawBody, &request)
if err != nil {
return nil, err
}
requestData := core.RequestDataContext{
Context: r.Context(),
UUID: request.Header.UUID,
DeviceType: request.Header.DeviceType,
DeviceBrand: request.Header.DeviceBrand,
DeviceModel: request.Header.DeviceModel,
DeviceOS: request.Header.OS,
OSVersion: request.Header.OSVersion,
OSTimezone: request.Header.Timezone,
AppLanguage: request.Header.Lang,
AppVersion: request.Header.AppVersion,
AppBuildInfo: request.Header.AppBuildVersion,
AppName: request.Header.AppName,
SecurityToken: request.Header.SecurityToken,
DeviceSerial: request.Header.DeviceSerial,
DeviceId: request.Header.DeviceId,
Latitude: request.Header.Latitude,
Longitude: request.Header.Longitude,
RawBody: rawBody,
Content: core.JSONContent(request.Content),
}
return &requestData, nil
}
// GetRouteVar returns the route variables for the current request, if any
func (receiver RequestReceiver) GetRouteVar(key string, r *http.Request) string {
return GetRouteVar(key, r)
}
// GetRouteVar returns the route variables for the current request, if any
// define it as: api.GetRouteVar = myCustomGetRouteVarFunc
var GetRouteVar func(string, *http.Request) string = func(string, *http.Request) string {
PrintError("Define a GetRouteVar function in this package")
return ""
}