Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5c76476bb4 | ||
|
|
cf05dac581 |
21
ftp.go
21
ftp.go
@@ -8,7 +8,6 @@ import (
|
||||
"context"
|
||||
"crypto/tls"
|
||||
"errors"
|
||||
"fmt"
|
||||
"io"
|
||||
"net"
|
||||
"net/textproto"
|
||||
@@ -1097,15 +1096,13 @@ func (c *ServerConn) Walk(root string) *Walker {
|
||||
|
||||
// Search returns all the directories matching the search pattern
|
||||
func (c *ServerConn) Search(pattern string) ([]string, error) {
|
||||
_, message, err := c.cmd(StatusCommandOK, "SITE SEARCH %s", pattern)
|
||||
_, message, err := c.cmd(StatusCommandOK, "SITE SEARCH %s --LIMIT 50000", pattern)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
fmt.Printf("SEARCH:\r\n-----------------------------------\r\n%s\r\n-----------------------------------\r\n", message)
|
||||
|
||||
msgs := make([]string, 0)
|
||||
re := regexp.MustCompile(`^200- (?P<Path>.*) \(.*\).*$`)
|
||||
re := regexp.MustCompile(`^[^\/]*(?P<Path>\/.*) \(.*\).*$`)
|
||||
for _, msg := range strings.Split(message, "\n") {
|
||||
if re.MatchString(msg) {
|
||||
msgs = append(msgs, re.ReplaceAllString(msg, "${Path}"))
|
||||
@@ -1115,6 +1112,20 @@ func (c *ServerConn) Search(pattern string) ([]string, error) {
|
||||
return msgs, nil
|
||||
}
|
||||
|
||||
// Search returns all the directories matching the search pattern
|
||||
func (c *ServerConn) Searches(patterns []string) ([]string, error) {
|
||||
msgs := make([]string, 0)
|
||||
for _, pattern := range patterns {
|
||||
msg, err := c.Search(pattern)
|
||||
if err != nil {
|
||||
return msgs, err
|
||||
}
|
||||
msgs = append(msgs, msg...)
|
||||
}
|
||||
|
||||
return msgs, nil
|
||||
}
|
||||
|
||||
// NoOp issues a NOOP FTP command.
|
||||
// NOOP has no effects and is usually used to prevent the remote FTP server to
|
||||
// close the otherwise idle connection.
|
||||
|
||||
Reference in New Issue
Block a user