client.*requestCacheTransportDecorator.RoundTrip - Code Metrics - Inspection of "Adding configurable requests cache" - stefanoj3/dirstalk - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( b9ce7a...fa5039 )

by Stefano

created 2019-08-04 06:24 UTC

client.*requestCacheTransportDecorator.RoundTrip A

↳ Parent: pkg/scan/client/request_cache.go

Complexity

Conditions

Size

Total Lines	11
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	2
eloc	7
nop	1
dl	0
loc	11
rs	10
c	0
b	0
f	0

package client

import (
	"errors"
	"fmt"
	"net/http"
	"sync"
)

var (
	// ErrRequestRedundant this error is returned when trying to perform the
	// same request (method, host, path) more than one time
	ErrRequestRedundant = errors.New("this request has been made already")
)

func decorateTransportWithRequestCacheDecorator(decorated http.RoundTripper) (*requestCacheTransportDecorator, error) {
	if decorated == nil {
		return nil, errors.New("decorated round tripper is nil")
	}

	return &requestCacheTransportDecorator{decorated: decorated}, nil
}

type requestCacheTransportDecorator struct {
	decorated  http.RoundTripper
	requestMap sync.Map
}

func (u *requestCacheTransportDecorator) RoundTrip(r *http.Request) (*http.Response, error) {
	key := u.keyForRequest(r)

	_, found := u.requestMap.Load(key)
	if found {
		return nil, ErrRequestRedundant
	}

	u.requestMap.Store(key, struct{}{})

	return u.decorated.RoundTrip(r)
}

func (u *requestCacheTransportDecorator) keyForRequest(r *http.Request) string {
	return fmt.Sprintf("%s~%s~%s", r.Method, r.Host, r.URL.Path)
}


1			package client
2
3			import (
4			"errors"
5			"fmt"
6			"net/http"
7			"sync"
8			)
9
10			var (
11			// ErrRequestRedundant this error is returned when trying to perform the
12			// same request (method, host, path) more than one time
13			ErrRequestRedundant = errors.New("this request has been made already")
14			)
15
16			func decorateTransportWithRequestCacheDecorator(decorated http.RoundTripper) (*requestCacheTransportDecorator, error) {
17			if decorated == nil {
18			return nil, errors.New("decorated round tripper is nil")
19			}
20
21			return &requestCacheTransportDecorator{decorated: decorated}, nil
22			}
23
24			type requestCacheTransportDecorator struct {
25			decorated http.RoundTripper
26			requestMap sync.Map
27			}
28
29			func (u requestCacheTransportDecorator) RoundTrip(r http.Request) (*http.Response, error) {
30			key := u.keyForRequest(r)
31
32			_, found := u.requestMap.Load(key)
33			if found {
34			return nil, ErrRequestRedundant
35			}
36
37			u.requestMap.Store(key, struct{}{})
38
39			return u.decorated.RoundTrip(r)
40			}
41
42			func (u requestCacheTransportDecorator) keyForRequest(r http.Request) string {
43			return fmt.Sprintf("%s~%s~%s", r.Method, r.Host, r.URL.Path)
44			}
45

stefanoj3 / dirstalk

Push — master ( b9ce7a...fa5039 )

client.*requestCacheTransportDecorator.RoundTrip A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like