Function writeHTTPStateSnapshot

core/http.go:322–375

(
	ctx context.Context,
	query *Query,
	url string,
	resp *http.Response,
)

}

func writeHTTPStateSnapshot(
	ctx context.Context,
	query *Query,
	url string,
	resp *http.Response,
) (_ bkcache.ImmutableRef, _ digest.Digest, _ string, _ string, rerr error) {
	bkref, err := query.SnapshotManager().New(ctx, nil,
		bkcache.WithRecordType(bkclient.UsageRecordTypeRegular),
		bkcache.WithDescription(fmt.Sprintf("http state %s", url)),
	)
	if err != nil {
		return nil, "", "", "", err
	}
	defer func() {
		if rerr != nil && bkref != nil {
			_ = bkref.Release(context.WithoutCancel(ctx))
		}
	}()

	h := sha256.New()
	lastModified := resp.Header.Get("Last-Modified")
	err = MountRef(ctx, bkref, func(out string, _ *mount.Mount) error {
		dest := filepath.Join(out, httpStateCanonicalPath)
		f, err := os.OpenFile(dest, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, os.FileMode(httpStateCanonicalPermissions))
		if err != nil {
			return err
		}
		if _, err := io.Copy(io.MultiWriter(f, h), resp.Body); err != nil {
			_ = f.Close()
			return err
		}
		if err := f.Close(); err != nil {
			return err
		}

		timestamp := time.Unix(0, 0)
		if lastModified != "" {
			if parsed, err := http.ParseTime(lastModified); err == nil {
				timestamp = parsed
			}
		}
		return os.Chtimes(dest, timestamp, timestamp)
	})
	if err != nil {
		return nil, "", "", "", fmt.Errorf("file write failed: %w", err)
	}

	snap, err := bkref.Commit(ctx)
	if err != nil {
		return nil, "", "", "", err
	}
	bkref = nil
	return snap, digest.NewDigest(digest.SHA256, h), lastModified, etagValue(resp.Header.Get("ETag")), nil
}

func (state *HTTPState) fileResult(
	ctx context.Context,