Function fetchNarInfoStatusFromHTTP

internal/devpkg/narinfo_cache.go:259–283

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

var narInfoStatusFnCache = sync.Map{}

func fetchNarInfoStatusFromHTTP(
	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) {
			ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
			defer cancel()
			url := fmt.Sprintf("%s/%s.narinfo", uri, hash)
			req, err := http.NewRequestWithContext(ctx, http.MethodHead, url, nil)
			if err != nil {
				return false, err
			}
			res, err := http.DefaultClient.Do(req)
			if err != nil {
				return false, err
			}
			defer res.Body.Close()
			return res.StatusCode == http.StatusOK, nil
		},
	))
	return fetch.(func() (bool, error))()
}

func fetchNarInfoStatusFromS3(
	ctx context.Context,