Method fileResult

core/http.go:377–432

(
	ctx context.Context,
	query *Query,
	name string,
	permissions int,
)

}

func (state *HTTPState) fileResult(
	ctx context.Context,
	query *Query,
	name string,
	permissions int,
) (*HTTPFetchResult, error) {
	if state.snapshot == nil {
		return nil, fmt.Errorf("http state %q has no snapshot", state.URL)
	}
	newRef, err := query.SnapshotManager().New(
		ctx,
		state.snapshot,
		bkcache.WithRecordType(bkclient.UsageRecordTypeRegular),
		bkcache.WithDescription(fmt.Sprintf("http state resolve %s", name)),
	)
	if err != nil {
		return nil, err
	}
	err = MountRef(ctx, newRef, func(root string, _ *mount.Mount) error {
		src, err := RootPathWithoutFinalSymlink(root, httpStateCanonicalPath)
		if err != nil {
			return err
		}
		dst, err := RootPathWithoutFinalSymlink(root, name)
		if err != nil {
			return err
		}
		if err := os.Rename(src, dst); err != nil {
			return TrimErrPathPrefix(err, root)
		}
		if err := os.Chmod(dst, os.FileMode(permissions)); err != nil {
			return TrimErrPathPrefix(err, root)
		}
		return nil
	})
	if err != nil {
		_ = newRef.Release(context.WithoutCancel(ctx))
		return nil, err
	}
	snap, err := newRef.Commit(ctx)
	if err != nil {
		return nil, err
	}
	file := &File{
		Platform: query.Platform(),
		File:     new(LazyAccessor[string, *File]),
		Snapshot: new(LazyAccessor[bkcache.ImmutableRef, *File]),
	}
	file.File.setValue(name)
	file.Snapshot.setValue(snap)
	return &HTTPFetchResult{
		File:          file,
		ContentDigest: state.ContentDigest,
		LastModified:  state.LastModified,
	}, nil
}

func FetchHTTPFile(