Function fetchNarInfoStatusFromS3

internal/devpkg/narinfo_cache.go:285–318

(
	ctx context.Context,
	uri string,
	hash string,
)

}

func fetchNarInfoStatusFromS3(
	ctx context.Context,
	uri string,
	hash string,
) (bool, error) {
	key := fmt.Sprintf("%s/%s", uri, hash)
	fetch, _ := narInfoStatusFnCache.LoadOrStore(key, sync.OnceValues(
		func() (bool, error) {
			s3Client, err := nixcache.S3Client(ctx)
			if err != nil {
				return false, err
			}

			bucketURI, err := url.Parse(uri)
			if err != nil {
				return false, errors.WithStack(err)
			}

			_, err = s3Client.GetObject(ctx,
				&s3.GetObjectInput{
					Bucket: aws.String(bucketURI.Hostname()),
					Key:    aws.String(hash + ".narinfo"),
				},
				func(o *s3.Options) {
					if bucketURI.Query().Get("region") != "" {
						o.Region = bucketURI.Query().Get("region")
					}
				},
			)
			return err == nil, nil
		},
	))
	return fetch.(func() (bool, error))()
}

var nixCacheIsConfigured = goutil.OnceValueWithContext(nixcache.IsConfigured)