Addressed sync issues in #23

Moved to a `sync.Map`

Signed-off-by: Dave Shanley <[email protected]>

Author: daveshanley

requests/request_body.go

@@ -8,6 +8,7 @@ import (
 	"github.com/pb33f/libopenapi/datamodel/high/base"
 	"github.com/pb33f/libopenapi/datamodel/high/v3"
 	"net/http"
+	"sync"
 )
 
 // RequestBodyValidator is an interface that defines the methods for validating request bodies for Operations.
@@ -29,7 +30,7 @@ type RequestBodyValidator interface {
 
 // NewRequestBodyValidator will create a new RequestBodyValidator from an OpenAPI 3+ document
 func NewRequestBodyValidator(document *v3.Document) RequestBodyValidator {
-	return &requestBodyValidator{document: document, schemaCache: make(map[[32]byte]*schemaCache)}
+	return &requestBodyValidator{document: document, schemaCache: &sync.Map{}}
 }
 
 func (v *requestBodyValidator) SetPathItem(path *v3.PathItem, pathValue string) {
@@ -48,5 +49,5 @@ type requestBodyValidator struct {
 	pathItem    *v3.PathItem
 	pathValue   string
 	errors      []*errors.ValidationError
-	schemaCache map[[32]byte]*schemaCache
+	schemaCache *sync.Map
 }

requests/validate_body.go

@@ -64,11 +64,11 @@ func (v *requestBodyValidator) ValidateRequestBody(request *http.Request) (bool,
 	hash := mediaType.GoLow().Schema.Value.Hash()
 
 	// perform work only once and cache the result in the validator.
-	if cacheHit, ch := v.schemaCache[hash]; ch {
+	if cacheHit, ch := v.schemaCache.Load(hash); ch {
 		// got a hit, use cached values
-		schema = cacheHit.schema
-		renderedInline = cacheHit.renderedInline
-		renderedJSON = cacheHit.renderedJSON
+		schema = cacheHit.(*schemaCache).schema
+		renderedInline = cacheHit.(*schemaCache).renderedInline
+		renderedJSON = cacheHit.(*schemaCache).renderedJSON
 
 	} else {
 
@@ -77,11 +77,11 @@ func (v *requestBodyValidator) ValidateRequestBody(request *http.Request) (bool,
 		schema = mediaType.Schema.Schema()
 		renderedInline, _ = schema.RenderInline()
 		renderedJSON, _ = utils.ConvertYAMLtoJSON(renderedInline)
-		v.schemaCache[hash] = &schemaCache{
+		v.schemaCache.Store(hash, &schemaCache{
 			schema:         schema,
 			renderedInline: renderedInline,
 			renderedJSON:   renderedJSON,
-		}
+		})
 	}
 
 	// render the schema, to be used for validation