kubectl cp support colons-in-filename

pkg/kubectl/cmd/cp.go

@@ -113,18 +113,12 @@ var (
 )
 
 func extractFileSpec(arg string) (fileSpec, error) {
-	pieces := strings.Split(arg, ":")
+	if i := strings.Index(arg, ":"); i == -1 {
-	if len(pieces) == 1 {
 		return fileSpec{File: arg}, nil
-	}
+	} else if i > 0 {
-	if len(pieces) != 2 {
+		file := arg[i+1:]
-		// FIXME Kubernetes can't copy files that contain a ':'
+		pod := arg[:i]
-		// character.
+		pieces := strings.Split(pod, "/")
-		return fileSpec{}, errFileSpecDoesntMatchFormat
-	}
-	file := pieces[1]
-
-	pieces = strings.Split(pieces[0], "/")
 		if len(pieces) == 1 {
 			return fileSpec{
 				PodName: pieces[0],
@@ -138,6 +132,7 @@ func extractFileSpec(arg string) (fileSpec, error) {
 				File:         file,
 			}, nil
 		}
+	}
 
 	return fileSpec{}, errFileSpecDoesntMatchFormat
 }
@@ -177,13 +172,21 @@ func (o *CopyOptions) Run(args []string) error {
 	if err != nil {
 		return err
 	}
+
+	if len(srcSpec.PodName) != 0 && len(destSpec.PodName) != 0 {
+		if _, err := os.Stat(args[0]); err == nil {
+			return o.copyToPod(fileSpec{File: args[0]}, destSpec)
+		}
+		return fmt.Errorf("src doesn't exist in local filesystem")
+	}
+
 	if len(srcSpec.PodName) != 0 {
 		return o.copyFromPod(srcSpec, destSpec)
 	}
 	if len(destSpec.PodName) != 0 {
 		return o.copyToPod(srcSpec, destSpec)
 	}
-	return fmt.Errorf("One of src or dest must be a remote file specification")
+	return fmt.Errorf("one of src or dest must be a remote file specification")
 }
 
 // checkDestinationIsDir receives a destination fileSpec and

pkg/kubectl/cmd/cp_test.go

@@ -71,13 +71,18 @@ func TestExtractFileSpec(t *testing.T) {
 			expectedFile: "/some/file",
 		},
 		{
-			spec:      "some:bad:spec",
+			spec:      ":file:not:exist:in:local:filesystem",
 			expectErr: true,
 		},
 		{
 			spec:      "namespace/pod/invalid:/some/file",
 			expectErr: true,
 		},
+		{
+			spec:         "pod:/some/filenamewith:in",
+			expectedPod:  "pod",
+			expectedFile: "/some/filenamewith:in",
+		},
 	}
 	for _, test := range tests {
 		spec, err := extractFileSpec(test.spec)