transfer service

Signed-off-by: ChengyuZhu6 <[email protected]>

Author: ChengyuZhu6

cmd/nerdctl/container/container_run_test.go

@@ -786,7 +786,7 @@ func TestRunFromOCIArchive(t *testing.T) {
 	tarPath := fmt.Sprintf("%s/%s.tar", buildCtx, imageName)
 
 	base.Cmd("build", "--tag", tag, fmt.Sprintf("--output=type=oci,dest=%s", tarPath), buildCtx).AssertOK()
-	base.Cmd("run", "--rm", fmt.Sprintf("oci-archive://%s", tarPath)).AssertOutContainsAll(fmt.Sprintf("Loaded image: %s", tag), sentinel)
+	base.Cmd("run", "--rm", fmt.Sprintf("oci-archive://%s", tarPath)).AssertOutContainsAll(tag, sentinel)
 }
 
 func TestRunDomainname(t *testing.T) {

cmd/nerdctl/image/image_load_test.go

@@ -17,7 +17,6 @@
 package image
 
 import (
-	"fmt"
 	"os"
 	"path/filepath"
 	"strings"
@@ -61,7 +60,7 @@ func TestLoadStdinFromPipe(t *testing.T) {
 			identifier := data.Identifier()
 			return &test.Expected{
 				Output: expect.All(
-					expect.Contains(fmt.Sprintf("Loaded image: %s:latest", identifier)),
+					expect.Contains(identifier),
 					func(stdout string, t tig.T) {
 						assert.Assert(t, strings.Contains(helpers.Capture("images"), identifier))
 					},
@@ -107,7 +106,7 @@ func TestLoadQuiet(t *testing.T) {
 		Expected: func(data test.Data, helpers test.Helpers) *test.Expected {
 			return &test.Expected{
 				Output: expect.All(
-					expect.Contains(fmt.Sprintf("Loaded image: %s:latest", data.Identifier())),
+					expect.Contains(data.Identifier()),
 					expect.DoesNotContain("Loading layer"),
 				),
 			}

mod/tigron/test/data.go

@@ -31,7 +31,6 @@ import (
 
 const (
 	identifierMaxLength       = 76
-	identifierSeparator       = "-"
 	identifierSignatureLength = 8
 )
 
@@ -250,27 +249,18 @@ func newData(t tig.T, seed, parent Data) Data {
 func defaultIdentifierHashing(names ...string) string {
 	// Notes: identifier MAY be used for namespaces, image names, etc.
 	// So, the rules are stringent on what it can contain.
-	replaceWith := []byte(identifierSeparator)
-	name := strings.ToLower(strings.Join(names, string(replaceWith)))
+	// Join names without separator to avoid '-' which causes display issues in progress output
+	name := strings.ToLower(strings.Join(names, ""))
 	// Ensure we have a unique identifier despite characters replacements
 	// (well, as unique as the names collection being passed)
 	signature := fmt.Sprintf("%x", sha256.Sum256([]byte(name)))[0:identifierSignatureLength]
-	// Make sure we do not use any unsafe characters
-	safeName := regexp.MustCompile(`[^a-z0-9-]+`)
-	// And we avoid repeats of the separator
-	noRepeat := regexp.MustCompile(fmt.Sprintf(`[%s]{2,}`, replaceWith))
-	escapedName := safeName.ReplaceAll([]byte(name), replaceWith)
-	escapedName = noRepeat.ReplaceAll(escapedName, replaceWith)
-	// Do not allow trailing or leading dash (as that may stutter)
-	name = strings.Trim(string(escapedName), string(replaceWith))
+	safeName := regexp.MustCompile(`[^a-z0-9]+`)
+	escapedName := safeName.ReplaceAll([]byte(name), []byte(""))
+	name = string(escapedName)
 
 	// Ensure we will never go above 76 characters in length (with signature)
-	if len(name) > (identifierMaxLength - len(signature)) {
-		name = name[0 : identifierMaxLength-identifierSignatureLength-len(identifierSeparator)]
-	}
-
-	if name[len(name)-1:] != identifierSeparator {
-		signature = identifierSeparator + signature
+	if len(name) > (identifierMaxLength - identifierSignatureLength) {
+		name = name[0 : identifierMaxLength-identifierSignatureLength]
 	}
 
 	return name + signature

mod/tigron/test/data_test.go

@@ -71,7 +71,7 @@ func TestDataIdentifier(t *testing.T) {
 	assertive.HasPrefix(t, one, "testdataidentifier")
 
 	three := dataObj.Identifier("Some Add ∞ Funky∞Prefix")
-	assertive.HasPrefix(t, three, "testdataidentifier-some-add-funky-prefix")
+	assertive.HasPrefix(t, three, "testdataidentifiersomeaddfunkyprefix")
 }
 
 func TestDataIdentifierThatIsReallyReallyReallyReallyReallyReallyReallyReallyReallyReallyReallyLong(

pkg/cmd/image/ensure.go

@@ -18,8 +18,6 @@ package image
 
 import (
 	"context"
-	"errors"
-	"net/http"
 	"os"
 
 	ocispec "github.com/opencontainers/image-spec/specs-go/v1"
@@ -80,7 +78,6 @@ func ensureOne(ctx context.Context, client *containerd.Client, rawRef string, ta
 		// Get a resolver
 		var dOpts []dockerconfigresolver.Opt
 		if options.InsecureRegistry {
-			log.G(ctx).Warnf("skipping verifying HTTPS certs for %q", parsedReference.Domain)
 			dOpts = append(dOpts, dockerconfigresolver.WithSkipVerifyCerts(true))
 		}
 		dOpts = append(dOpts, dockerconfigresolver.WithHostsDirs(options.HostsDir))
@@ -99,7 +96,7 @@ func ensureOne(ctx context.Context, client *containerd.Client, rawRef string, ta
 
 		if err != nil {
 			// In some circumstance (e.g. people just use 80 port to support pure http), the error will contain message like "dial tcp <port>: connection refused".
-			if !errors.Is(err, http.ErrSchemeMismatch) && !errutil.IsErrConnectionRefused(err) {
+			if !errutil.IsErrHTTPSFallbackNeeded(err) {
 				return err
 			}
 			if options.InsecureRegistry {