torrent fs/stable read local file from torrent

Author: ucwong

torrentfs/torrentfs.go

@@ -143,36 +143,47 @@ func (fs *TorrentFS) GetFile(infohash string, subpath string) ([]byte, error) {
 		}
 		fn := path.Join(fs.config.DataDir, infohash, subpath)
 		data, err := ioutil.ReadFile(fn)
-		if subpath == "/data" {
-			if int64(len(data)) != torrent.BytesCompleted() {
-				log.Error("Read file not completed", "hash", infohash, "len", len(data), "total", torrent.BytesCompleted())
-				return nil, errors.New("not a complete file")
-			} else {
-				log.Warn("Read data sucess", "hash", infohash, "size", len(data), "path", subpath)
+		for _, file := range torrent.Files() {
+			if file.Path() == subpath {
+				if int64(len(data)) != file.Length() {
+					log.Error("Read file not completed", "hash", infohash, "len", len(data), "total", file.Path())
+					return nil, errors.New("not a complete file")
+				} else {
+					log.Warn("Read data sucess", "hash", infohash, "size", len(data), "path", file.Path())
+				}
 			}
-		} else if subpath == "/data/symbol" {
-			for _, file := range torrent.Files() {
-				if file.Path() == "/data/symbol" {
-					if int64(len(data)) != file.Length() {
-						log.Error("Read file not completed", "hash", infohash, "len", len(data), "total", file.Path())
-						return nil, errors.New("not a complete file")
-					} else {
-						log.Warn("Read data sucess", "hash", infohash, "size", len(data), "path", file.Path())
+		}
+		/*
+			if subpath == "/data" {
+				if int64(len(data)) != torrent.BytesCompleted() {
+					log.Error("Read file not completed", "hash", infohash, "len", len(data), "total", torrent.BytesCompleted())
+					return nil, errors.New("not a complete file")
+				} else {
+					log.Warn("Read data sucess", "hash", infohash, "size", len(data), "path", subpath)
+				}
+			} else if subpath == "/data/symbol" {
+				for _, file := range torrent.Files() {
+					if file.Path() == "/data/symbol" {
+						if int64(len(data)) != file.Length() {
+							log.Error("Read file not completed", "hash", infohash, "len", len(data), "total", file.Path())
+							return nil, errors.New("not a complete file")
+						} else {
+							log.Warn("Read data sucess", "hash", infohash, "size", len(data), "path", file.Path())
+						}
 					}
 				}
-			}
-		} else if subpath == "/data/params" {
-			for _, file := range torrent.Files() {
-				if file.Path() == "/data/params" {
-					if int64(len(data)) != file.Length() {
-						log.Error("Read file not completed", "hash", infohash, "len", len(data), "total", file.Path())
-						return nil, errors.New("not a complete file")
-					} else {
-						log.Warn("Read data sucess", "hash", infohash, "size", len(data), "path", file.Path())
+			} else if subpath == "/data/params" {
+				for _, file := range torrent.Files() {
+					if file.Path() == "/data/params" {
+						if int64(len(data)) != file.Length() {
+							log.Error("Read file not completed", "hash", infohash, "len", len(data), "total", file.Path())
+							return nil, errors.New("not a complete file")
+						} else {
+							log.Warn("Read data sucess", "hash", infohash, "size", len(data), "path", file.Path())
+						}
 					}
 				}
-			}
-		}
+			}*/
 		return data, err
 	}
 }