Skip to content

Commit

Permalink
http: Handle missing but unambiguous ETags in response
Browse files Browse the repository at this point in the history
If a single ETag is requested in `If-None-Match`, some servers do not
include that (unambiguous) ETag header in the response.

For detailed description, see:
#905 (comment)
  • Loading branch information
rwe committed Sep 4, 2019
1 parent 9a490d3 commit e9249ce
Showing 1 changed file with 19 additions and 0 deletions.
19 changes: 19 additions & 0 deletions source/http/httpsource.go
Original file line number Diff line number Diff line change
Expand Up @@ -144,6 +144,11 @@ func (hs *httpSourceHandler) CacheKey(ctx context.Context, index int) (string, b
req = req.WithContext(ctx)
m := map[string]*metadata.StorageItem{}

// If we request a single ETag in 'If-None-Match', some servers omit the
// unambiguous ETag in their response.
// See: https://github.com/moby/buildkit/issues/905
var onlyETag string

if len(sis) > 0 {
for _, si := range sis {
// if metaDigest := getMetaDigest(si); metaDigest == hs.formatCacheKey("") {
Expand All @@ -160,6 +165,10 @@ func (hs *httpSourceHandler) CacheKey(ctx context.Context, index int) (string, b
etags = append(etags, t)
}
req.Header.Add("If-None-Match", strings.Join(etags, ", "))

if len(etags) == 1 {
onlyETag = etags[0]
}
}
}

Expand All @@ -172,6 +181,9 @@ func (hs *httpSourceHandler) CacheKey(ctx context.Context, index int) (string, b
if err == nil {
if resp.StatusCode == http.StatusOK || resp.StatusCode == http.StatusNotModified {
respETag := resp.Header.Get("ETag")
if respETag == "" && onlyETag != "" {
respETag = onlyETag
}
si, ok := m[respETag]
if ok {
hs.refID = si.ID()
Expand All @@ -197,6 +209,13 @@ func (hs *httpSourceHandler) CacheKey(ctx context.Context, index int) (string, b
}
if resp.StatusCode == http.StatusNotModified {
respETag := resp.Header.Get("ETag")
if respETag == "" && onlyETag != "" {
respETag = onlyETag

// Set the missing ETag header on the response so that it's available
// to .save()
resp.Header.Set("ETag", onlyETag)
}
si, ok := m[respETag]
if !ok {
return "", false, errors.Errorf("invalid not-modified ETag: %v", respETag)
Expand Down

0 comments on commit e9249ce

Please sign in to comment.