.gitignore

@@ -7,4 +7,3 @@
 *.iml
 out
 gen
-*_test.go

README.md

@@ -1,40 +1,2 @@
 # grsync
 
-```go
-package main
-
-import (
-    "fmt"
-    "grsync"
-    "time"
-)
-
-func main() {
-    task := grsync.NewTask(
-        "username@server.com:/source/folder",
-        "/home/user/destination",
-        grsync.RsyncOptions{},
-    )
-
-    go func() {
-        for {
-            state := task.State()
-            fmt.Printf(
-                "progress: %.2f / rem. %d / tot. %d / sp. %s \n",
-                state.Progress,
-                state.Remain,
-                state.Total,
-                state.Speed,
-            )
-            time.Sleep(time.Second)
-        }
-    }()
-
-    if err := task.Run(); err != nil {
-        panic(err)
-    }
-
-    fmt.Println("well done")
-    fmt.Println(task.Log())
-}
-```

rsync.go

@@ -21,17 +21,17 @@ type Rsync struct {
 type RsyncOptions struct {
 	// Verbose increase verbosity
 	Verbose bool
-	// Quiet suppress non-error messages
+	// Quet suppress non-error messages
 	Quiet bool
 	// Checksum skip based on checksum, not mod-time & size
 	Checksum bool
-	// Archive is archive mode; equals -rlptgoD (no -H,-A,-X)
+	// Archve is archive mode; equals -rlptgoD (no -H,-A,-X)
 	Archive bool
 	// Recurse into directories
 	Recursive bool
 	// Relative option to use relative path names
 	Relative bool
-	// NoImpliedDirs don't send implied dirs with --relative
+	// NoImliedDirs don't send implied dirs with --relative
 	NoImpliedDirs bool
 	// Update skip files that are newer on the receiver
 	Update bool
@@ -196,8 +196,7 @@ func (r Rsync) StderrPipe() (io.ReadCloser, error) {
 
 // Run start rsync task
 func (r Rsync) Run() error {
-	// 目标地址为 远程地址 则不进行文件夹创建
+	if !isExist(r.Destination) {
-	if !isRsyncPath(r.Destination) && !isExist(r.Destination) {
 		if err := createDir(r.Destination); err != nil {
 			return err
 		}
@@ -553,15 +552,3 @@ func isExist(p string) bool {
 	stat, err := os.Stat(p)
 	return os.IsExist(err) && stat.IsDir()
 }
-
-// isRsyncPath 判断一个给定的字符串或路径是否格式是否符合rsync协议的要求
-func isRsyncPath(path string) bool {
-	if strings.HasPrefix(path, "rsync://") {
-		return true
-	}
-	parts := strings.SplitN(path, ":", 2)
-	if len(parts) == 2 && strings.Contains(parts[0], "@") {
-		return true
-	}
-	return false
-}