Function TestCopyToPod

pkg/cmd/cp/cp_test.go:611–680

(t *testing.T)

}

func TestCopyToPod(t *testing.T) {
	tf := cmdtesting.NewTestFactory().WithNamespace("test")
	ns := scheme.Codecs.WithoutConversion()
	codec := scheme.Codecs.LegacyCodec(scheme.Scheme.PrioritizedVersionsAllGroups()...)

	tf.Client = &fake.RESTClient{
		GroupVersion:         schema.GroupVersion{Group: "", Version: "v1"},
		NegotiatedSerializer: ns,
		Client: fake.CreateHTTPClient(func(req *http.Request) (*http.Response, error) {
			responsePod := &v1.Pod{}
			return &http.Response{StatusCode: http.StatusNotFound, Header: cmdtesting.DefaultHeader(), Body: io.NopCloser(bytes.NewReader([]byte(runtime.EncodeOrDie(codec, responsePod))))}, nil
		}),
	}

	tf.ClientConfigVal = cmdtesting.DefaultClientConfig()
	ioStreams, _, _, _ := genericiooptions.NewTestIOStreams()

	cmd := NewCmdCp(tf, ioStreams)

	srcFile, err := os.MkdirTemp("", "test")
	if err != nil {
		t.Errorf("unexpected error: %v", err)
		t.FailNow()
	}
	defer os.RemoveAll(srcFile)

	tests := map[string]struct {
		src         string
		dest        string
		expectedErr bool
	}{
		"copy to directory": {
			src:         srcFile,
			dest:        "/tmp/",
			expectedErr: false,
		},
		"copy to root": {
			src:         srcFile,
			dest:        "/",
			expectedErr: false,
		},
		"copy to empty file name": {
			src:         srcFile,
			dest:        "",
			expectedErr: true,
		},
		"copy unexisting file": {
			src:         filepath.Join(srcFile, "nope"),
			dest:        "/tmp",
			expectedErr: true,
		},
	}

	for name, test := range tests {
		opts := NewCopyOptions(ioStreams)
		opts.Complete(tf, cmd, []string{test.src, fmt.Sprintf("pod-ns/pod-name:%s", test.dest)})
		t.Run(name, func(t *testing.T) {
			err = opts.Run()