| package main | |
| import ( | |
| "bytes" | |
| "context" | |
| "encoding/base64" | |
| "io/ioutil" | |
| "net/http" | |
| "os" | |
| "github.com/buger/jsonparser" | |
| "github.com/TykTechnologies/tyk-pump/analytics" | |
| "github.com/TykTechnologies/tyk/ctx" | |
| "github.com/TykTechnologies/tyk/log" | |
| "github.com/TykTechnologies/tyk/request" | |
| "github.com/TykTechnologies/tyk/user" | |
| ) | |
| var logger = log.Get() | |
| // IP Rate Limiter | |
| func Authenticate(rw http.ResponseWriter, r *http.Request) { | |
| requestedAPI := ctx.GetDefinition(r) | |
| if requestedAPI == nil { | |
| logger.Error("Could not get API Definition") | |
| rw.WriteHeader(http.StatusInternalServerError) | |
| return | |
| } | |
| realIp := request.RealIP(r) | |
| sessionObject := &user.SessionState{} | |
| sessionObject = &user.SessionState{ | |
| OrgID: requestedAPI.OrgID, | |
| Rate: 2, | |
| Per: 5, | |
| AccessRights: map[string]user.AccessDefinition{ | |
| requestedAPI.APIID: { | |
| APIID: requestedAPI.APIID, | |
| }, | |
| }, | |
| MetaData: map[string]interface{}{ | |
| "rate_limit_pattern": realIp, | |
| }, | |
| } | |
| logger.Info("Session Alias: ", sessionObject.Alias) | |
| // Set session state using session object | |
| ctx.SetSession(r, sessionObject, false) | |
| logger.Info("Session created for request") | |
| } |