Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
46e79c0571 | ||
|
|
f931053650 | ||
|
|
f2175e41a9 |
File diff suppressed because one or more lines are too long
@@ -42,7 +42,7 @@ func TestComment(t *testing.T) {
|
|||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := n.Comment(fpath, 10000, "big line no"); err == nil {
|
if err := n.Comment(fpath, 10000, "big line no"); err != nil {
|
||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,11 +1,16 @@
|
|||||||
package notes
|
package notes
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"local/notes-server/filetree"
|
"local/notes-server/filetree"
|
||||||
"os"
|
"os"
|
||||||
)
|
)
|
||||||
|
|
||||||
func (n *Notes) Delete(urlPath string) error {
|
func (n *Notes) Delete(urlPath string) error {
|
||||||
p := filetree.NewPathFromURL(urlPath)
|
p := filetree.NewPathFromURL(urlPath)
|
||||||
return os.Remove(p.Local)
|
err := os.Remove(p.Local)
|
||||||
|
if err != nil {
|
||||||
|
err = fmt.Errorf("failed to delete %q => %q: %v", urlPath, p.Local, err)
|
||||||
|
}
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import (
|
|||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"local/notes-server/config"
|
"local/notes-server/config"
|
||||||
"os"
|
"os"
|
||||||
|
"path"
|
||||||
"testing"
|
"testing"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -11,17 +12,22 @@ func TestDelete(t *testing.T) {
|
|||||||
config.Root = "/tmp"
|
config.Root = "/tmp"
|
||||||
ioutil.WriteFile("/tmp/a", []byte("hi"), os.ModePerm)
|
ioutil.WriteFile("/tmp/a", []byte("hi"), os.ModePerm)
|
||||||
n := &Notes{}
|
n := &Notes{}
|
||||||
|
|
||||||
|
t.Run("delete 404", func(t *testing.T) {
|
||||||
if err := n.Delete("/notes/a"); err != nil {
|
if err := n.Delete("/notes/a"); err != nil {
|
||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
if _, err := os.Stat("/tmp/a"); err == nil {
|
if _, err := os.Stat("/tmp/a"); err == nil {
|
||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
t.Run("delete w. content", func(t *testing.T) {
|
||||||
d, err := ioutil.TempDir(os.TempDir(), "trydel*")
|
d, err := ioutil.TempDir(os.TempDir(), "trydel*")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
config.Root = path.Dir(d)
|
||||||
for i := 0; i < 3; i++ {
|
for i := 0; i < 3; i++ {
|
||||||
f, err := ioutil.TempFile(d, "file*")
|
f, err := ioutil.TempFile(d, "file*")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -29,15 +35,20 @@ func TestDelete(t *testing.T) {
|
|||||||
}
|
}
|
||||||
f.Close()
|
f.Close()
|
||||||
}
|
}
|
||||||
if err := n.Delete(d); err == nil {
|
if err := n.Delete("/abc/" + path.Base(d)); err == nil {
|
||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
|
})
|
||||||
|
|
||||||
e, err := ioutil.TempDir(os.TempDir(), "trydel*")
|
t.Run("delete empty dir", func(t *testing.T) {
|
||||||
|
d2p := os.TempDir()
|
||||||
|
d2, err := ioutil.TempDir(d2p, "trydel*")
|
||||||
|
config.Root = path.Dir(d2p)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
if err := n.Delete(e); err != nil {
|
if err := n.Delete("/abc/" + path.Base(d2)); err != nil {
|
||||||
t.Error(err)
|
t.Errorf("failed to del empty dir %s in %s: %v", d2, d2p, err)
|
||||||
}
|
}
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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,26 +62,33 @@ 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
|
||||||
}
|
}
|
||||||
ok, err := grepFile(walked, searcher)
|
ok, err := searcher.file(walked)
|
||||||
if err != nil && err.Error() == "bufio.Scanner: token too long" {
|
if err != nil && err.Error() == "bufio.Scanner: token too long" {
|
||||||
err = nil
|
err = nil
|
||||||
}
|
}
|
||||||
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 grepFile(file string, searcher *searcher) (bool, error) {
|
func (searcher *searcher) file(file string) (bool, error) {
|
||||||
if d := path.Base(path.Dir(file)); strings.HasPrefix(d, ".") && strings.HasSuffix(d, ".attachments") {
|
if d := path.Base(path.Dir(file)); strings.HasPrefix(d, ".") && strings.HasSuffix(d, ".attachments") {
|
||||||
return false, nil
|
return false, nil
|
||||||
}
|
}
|
||||||
@@ -91,7 +100,11 @@ func grepFile(file string, searcher *searcher) (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)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -66,8 +66,8 @@ func htmlEdit(w http.ResponseWriter, baseHREF string) {
|
|||||||
if config.ReadOnly {
|
if config.ReadOnly {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
fmt.Fprintf(w, `<div style='display:inline-block'>
|
fmt.Fprintf(w, `<div style='display:inline-block; margin-top: .75em; margin-bottom: .75em;'>
|
||||||
<a href=%q><input type="button" value="Edit"></input></a>
|
<a href=%q class="button">Edit</a>
|
||||||
</div><br>`, path.Join("/edit/", baseHREF))
|
</div><br>`, path.Join("/edit/", baseHREF))
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -75,8 +75,8 @@ func htmlDelete(w http.ResponseWriter, baseHREF string) {
|
|||||||
if config.ReadOnly {
|
if config.ReadOnly {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
fmt.Fprintf(w, `<div style='display:inline-block'>
|
fmt.Fprintf(w, `<div style='display:inline-block; margin-top: .75em; margin-bottom: .75em;'>
|
||||||
<a href=%q><input type="button" value="Delete" onclick="return confirm('Delete?');"></input></a>
|
<a href=%q class="button" onclick="return confirm('Delete?');">Delete</a>
|
||||||
</div><br>`, path.Join("/delete/", baseHREF))
|
</div><br>`, path.Join("/delete/", baseHREF))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user