add command exists

README.md

@@ -6,7 +6,7 @@
 
 ### version
 ```
-v0.0.2
+v0.0.3
 ```
 
 ### usage
@@ -24,6 +24,7 @@ OK
 ping {message}
 ftpsync {local file} {remote file}
 files {remote folder}
+exists {remote file}
 delete {remote file}
 ```
 

src/ftpSync/const.go

@@ -1,3 +1,3 @@
 package ftpSync
 
-const VERSION = "0.0.2"
+const VERSION = "0.0.3"

src/ftpSync/syncFtp.go

@@ -268,6 +268,23 @@ func (obj *SyncFtp) DeleteFile(remoteFile string) bool {
 	return true
 }
 
+func (obj *SyncFtp) ExistsFile(remoteFile string) bool {
+	obj.Lock()
+	defer obj.Unlock()
+
+	if obj.syncFtpServer == nil && obj.connectFtpServer() == false {
+		return false
+	}
+
+	_, err := obj.syncFtpServer.FileSize(remoteFile)
+	if err != nil {
+		Logger.Printf("check ftp server file %s exists failed %v", remoteFile, err)
+		return false
+	}
+
+	return true
+}
+
 func (obj *SyncFtp) Stop() {
 	if obj.syncFtpServer != nil {
 		obj.syncStopChannel <- true

src/ftpSync/syncServer.go

@@ -67,6 +67,18 @@ func (obj *ftpSyncRedisHandler) Delete(remoteFile string) error {
 	return nil
 }
 
+func (obj *ftpSyncRedisHandler) Exists(remoteFile string) (int, error) {
+	if len(remoteFile) == 0 || strings.HasPrefix(remoteFile, "/") == false || strings.HasSuffix(remoteFile, "/") == true {
+		return 0, errors.New("error params")
+	}
+
+	if GSyncFtp.ExistsFile(remoteFile) {
+		return 1, nil
+	}
+
+	return 0, nil
+}
+
 func Run() {
 	wordsFilterHandler := &ftpSyncRedisHandler{}