remove getcapabilities for each blob

internal/build_cache/kv/methods.go

@@ -23,6 +23,15 @@ type FileDigest struct {
  SizeInBytes int64
 }
 
+func (c *Client) GetCapabilities(ctx context.Context) error {
+ _, err := c.capabilitiesClient.GetCapabilities(ctx, &remoteexecution.GetCapabilitiesRequest{})
+ if err != nil {
+ return fmt.Errorf("get capabilities: %w", err)
+ }
+
+ return nil
+}
+
 func (c *Client) Put(ctx context.Context, params PutParams) (io.WriteCloser, error) {
  md := metadata.Pairs(
  "authorization", fmt.Sprintf("bearer %s", c.authConfig.AuthToken),
@@ -36,11 +45,6 @@ func (c *Client) Put(ctx context.Context, params PutParams) (io.WriteCloser, err
  }
  ctx = metadata.NewOutgoingContext(ctx, md)
 
- _, err := c.capabilitiesClient.GetCapabilities(ctx, &remoteexecution.GetCapabilitiesRequest{})
- if err != nil {
- return nil, fmt.Errorf("get capabilities: %w", err)
- }
-
  stream, err := c.bitriseKVClient.Put(ctx)
  if err != nil {
  return nil, fmt.Errorf("initiate put: %w", err)

internal/xcode/batch_upload.go

@@ -35,6 +35,11 @@ func UploadDerivedDataFilesToBuildCache(dd DerivedData, cacheURL string, authCon
  return fmt.Errorf("new KV client: %w", err)
  }
 
+ err = kvClient.GetCapabilities(ctx)
+ if err != nil {
+ return fmt.Errorf("failed to get capabilities: %w", err)
+ }
+
  missingBlobs, err := findMissingBlobs(ctx, dd, kvClient, logger)
  if err != nil {
  return fmt.Errorf("failed to check for missing blobs: %w", err)

internal/xcode/upload.go

@@ -51,6 +51,11 @@ func UploadToBuildCache(filePath, key, cacheURL string, authConfig common.CacheA
  return fmt.Errorf("new kv client: %w", err), false
  }
 
+ err = kvClient.GetCapabilities(ctx)
+ if err != nil {
+ return err, false
+ }
+
  fileSize, err := uploadFile(ctx, kvClient, filePath, key, checksum, logger)
  logger.Infof("(i) Uploaded: %s", humanize.Bytes(uint64(fileSize)))