fixup! Add randomisation test for cache concurrency.

This commit is contained in:
2023-04-08 03:13:30 +01:00
parent 07e4f75a0a
commit 833517f35c
+3 -3
View File
@@ -92,7 +92,7 @@ func (c *BaseClient) Query(queryContent string, queryVariables interface{}, quer
queryHash = strutil.Md5(fmt.Sprintf("%s-%+v", query.compiledQuery, queryHeaders))
cacheBaseClient.Logger.Debug(cacheBaseClient, "Hash calculated;", "hash:", queryHash)
cachedResponse = cacheBaseClient.cacheLookup(queryHash)
cachedResponse = c.cacheLookup(queryHash)
if cachedResponse != nil {
cacheBaseClient.Logger.Debug(cacheBaseClient, "Found cached response")
return cacheBaseClient.decodeResponse(cachedResponse), nil
@@ -113,8 +113,8 @@ func (c *BaseClient) Query(queryContent string, queryVariables interface{}, quer
return nil, err
}
if cacheBaseClient.cache.enabled {
cacheBaseClient.cache.client.Set(queryHash, jsonData)
if cacheBaseClient.cache.enabled && jsonData != nil && queryHash != "" {
c.cache.client.Set(queryHash, jsonData)
}
return cacheBaseClient.decodeResponse(jsonData), err