parent
f2175e41a9
commit
f931053650
|
|
@ -3,6 +3,7 @@ package notes
|
||||||
import (
|
import (
|
||||||
"bufio"
|
"bufio"
|
||||||
"errors"
|
"errors"
|
||||||
|
"io"
|
||||||
"local/notes-server/filetree"
|
"local/notes-server/filetree"
|
||||||
"log"
|
"log"
|
||||||
"os"
|
"os"
|
||||||
|
|
@ -51,6 +52,7 @@ func (n *Notes) Search(phrase string) (string, error) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
|
perffiles := filetree.NewFiles()
|
||||||
files := filetree.NewFiles()
|
files := filetree.NewFiles()
|
||||||
err = filepath.Walk(n.root,
|
err = filepath.Walk(n.root,
|
||||||
func(walked string, info os.FileInfo, err error) error {
|
func(walked string, info os.FileInfo, err error) error {
|
||||||
|
|
@ -60,6 +62,11 @@ func (n *Notes) Search(phrase string) (string, error) {
|
||||||
if !info.Mode().IsRegular() {
|
if !info.Mode().IsRegular() {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
p := filetree.NewPathFromLocal(path.Dir(walked))
|
||||||
|
if ok, _ := searcher.stream(strings.NewReader(info.Name())); ok {
|
||||||
|
perffiles.Push(p, info)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
if size := info.Size(); size < 1 || size > (5*1024*1024) {
|
if size := info.Size(); size < 1 || size > (5*1024*1024) {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
@ -70,13 +77,15 @@ func (n *Notes) Search(phrase string) (string, error) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Printf("failed to scan %v: %v", walked, err)
|
log.Printf("failed to scan %v: %v", walked, err)
|
||||||
} else if ok {
|
} else if ok {
|
||||||
p := filetree.NewPathFromLocal(path.Dir(walked))
|
|
||||||
files.Push(p, info)
|
files.Push(p, info)
|
||||||
}
|
}
|
||||||
return err
|
return err
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
return filetree.Paths(*files).List(true), err
|
for _, file := range *files {
|
||||||
|
*perffiles = append(*perffiles, file)
|
||||||
|
}
|
||||||
|
return filetree.Paths(*perffiles).List(true), err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (searcher *searcher) file(file string) (bool, error) {
|
func (searcher *searcher) file(file string) (bool, error) {
|
||||||
|
|
@ -91,7 +100,11 @@ func (searcher *searcher) file(file string) (bool, error) {
|
||||||
return false, err
|
return false, err
|
||||||
}
|
}
|
||||||
defer f.Close()
|
defer f.Close()
|
||||||
scanner := bufio.NewScanner(f)
|
return searcher.stream(f)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (searcher *searcher) stream(r io.Reader) (bool, error) {
|
||||||
|
scanner := bufio.NewScanner(r)
|
||||||
for scanner.Scan() {
|
for scanner.Scan() {
|
||||||
if searcher.matches(scanner.Bytes()) {
|
if searcher.matches(scanner.Bytes()) {
|
||||||
return true, scanner.Err()
|
return true, scanner.Err()
|
||||||
|
|
|
||||||
|
|
@ -34,7 +34,7 @@ func TestSearch(t *testing.T) {
|
||||||
t.Fatal(v, result)
|
t.Fatal(v, result)
|
||||||
}
|
}
|
||||||
|
|
||||||
result, err = n.Search("4")
|
result, err = n.Search("number.4")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue