pretecno/crowdsec-bouncer-traefik-plugin
3
0
Fork 0
mirror of https://github.com/maxlerebourg/crowdsec-bouncer-traefik-plugin.git synced 2026-07-21 19:48:59 +02:00
Code Issues Packages Releases Activity

fix lint

Browse Source
This commit is contained in:
Max Lerebourg
2022-09-29 09:18:39 +02:00
parent 1d9bd3fab0
commit 45eca85f3a
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bouncer.go
+6 -6
View File
@@ -105,12 +105,12 @@ func New(ctx context.Context, next http.Handler, config *Config, name string) (h
if !contains([]string{"http", "https"}, config.CrowdsecLapiScheme) { if !contains([]string{"http", "https"}, config.CrowdsecLapiScheme) {
return nil, fmt.Errorf("CrowdsecLapiScheme must be one of: http, https") return nil, fmt.Errorf("CrowdsecLapiScheme must be one of: http, https")
} }
testUrl := url.URL{ testURL := url.URL{
Scheme: config.CrowdsecLapiScheme, Scheme: config.CrowdsecLapiScheme,
Host: config.CrowdsecLapiHost, Host: config.CrowdsecLapiHost,
Path: crowdsecRoute, Path: crowdsecRoute,
} }
_, err := http.NewRequest(http.MethodGet, testUrl.String(), nil) _, err := http.NewRequest(http.MethodGet, testURL.String(), nil)
if err != nil { if err != nil {
return nil, fmt.Errorf("CrowdsecLapiScheme://CrowdsecLapiHost: '%v://%v' must be an URL", config.CrowdsecLapiScheme, config.CrowdsecLapiHost) return nil, fmt.Errorf("CrowdsecLapiScheme://CrowdsecLapiHost: '%v://%v' must be an URL", config.CrowdsecLapiScheme, config.CrowdsecLapiHost)
} }
@@ -182,13 +182,13 @@ func (a *Bouncer) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
} }
// We are now in none or live mode. // We are now in none or live mode.
noneUrl := url.URL{ noneURL := url.URL{
Scheme: a.crowdsecScheme, Scheme: a.crowdsecScheme,
Host: a.crowdsecHost, Host: a.crowdsecHost,
Path: crowdsecRoute, Path: crowdsecRoute,
RawQuery: fmt.Sprintf("ip=%v&banned=true", remoteHost), RawQuery: fmt.Sprintf("ip=%v&banned=true", remoteHost),
} }
request, _ := http.NewRequest(http.MethodGet, noneUrl.String(), nil) request, _ := http.NewRequest(http.MethodGet, noneURL.String(), nil)
request.Header.Add(crowdsecAuthHeader, a.crowdsecKey) request.Header.Add(crowdsecAuthHeader, a.crowdsecKey)
res, err := a.client.Do(request) res, err := a.client.Do(request)
if err != nil { if err != nil {
@@ -292,13 +292,13 @@ func handleStreamCache(a *Bouncer, initialized bool) {
time.AfterFunc(time.Duration(a.updateInterval)*time.Second, func() { time.AfterFunc(time.Duration(a.updateInterval)*time.Second, func() {
handleStreamCache(a, false) handleStreamCache(a, false)
}) })
streamUrl := url.URL{ streamURL := url.URL{
Scheme: a.crowdsecScheme, Scheme: a.crowdsecScheme,
Host: a.crowdsecHost, Host: a.crowdsecHost,
Path: crowdsecStreamRoute, Path: crowdsecStreamRoute,
RawQuery: fmt.Sprintf("startup=%t", initialized), RawQuery: fmt.Sprintf("startup=%t", initialized),
} }
req, _ := http.NewRequest(http.MethodGet, streamUrl.String(), nil) req, _ := http.NewRequest(http.MethodGet, streamURL.String(), nil)
req.Header.Add(crowdsecAuthHeader, a.crowdsecKey) req.Header.Add(crowdsecAuthHeader, a.crowdsecKey)
res, err := a.client.Do(req) res, err := a.client.Do(req)
if err != nil || res.StatusCode == http.StatusForbidden { if err != nil || res.StatusCode == http.StatusForbidden {