Method putFileToLocal

registry/app/pkg/npm/proxy.go:206–229

(ctx context.Context, info npm2.ArtifactInfo, remote RemoteRegistryHelper)

}

func (r *proxy) putFileToLocal(ctx context.Context, info npm2.ArtifactInfo, remote RemoteRegistryHelper) error {
	versionMetadata, err := remote.GetVersionMetadata(ctx, info.Image, info.GetVersion())
	if err != nil {
		log.Ctx(ctx).Error().Stack().Err(err).Msgf("fetching metadata of pkg with name %s,"+
			" version %s failed, %v", info.Image, info.Version, err)
		return err
	}
	file, err := remote.GetPackage(ctx, info.Image, info.Version)
	if err != nil {
		log.Ctx(ctx).Error().Stack().Err(err).Msgf("fetching pkg with name %s,"+
			" version %s failed, %v", info.Image, info.Version, err)
		return err
	}
	defer file.Close()

	info.Metadata = *versionMetadata
	_, sha256, err2 := r.localRegistryHelper.UploadPackageFile(ctx, info, file)
	if err2 != nil {
		log.Ctx(ctx).Error().Stack().Err(err2).Msgf("uploading file %s failed, %v", info.Filename, err)
		return err2
	}
	log.Ctx(ctx).Info().Msgf("Successfully uploaded %s with SHA256: %s", info.Filename, sha256)
	return nil
}