Compare commits
6 Commits
438c0ade59
...
v0.2.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4bdee5d9a0 | ||
|
|
7c84d7650c | ||
|
|
29646808f9 | ||
|
|
8276308d52 | ||
|
|
8c050d1d89 | ||
|
|
e8a83176aa |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -3,4 +3,3 @@ todo-server-yaml
|
|||||||
cmd/cmd
|
cmd/cmd
|
||||||
cmd/cli
|
cmd/cli
|
||||||
cmd/pttodo/pttodo
|
cmd/pttodo/pttodo
|
||||||
cmd/pttodo-cli/pttodo-cli
|
|
||||||
|
|||||||
@@ -14,7 +14,6 @@ import (
|
|||||||
"sort"
|
"sort"
|
||||||
"strings"
|
"strings"
|
||||||
"syscall"
|
"syscall"
|
||||||
"time"
|
|
||||||
|
|
||||||
"gopkg.in/yaml.v2"
|
"gopkg.in/yaml.v2"
|
||||||
)
|
)
|
||||||
@@ -27,15 +26,13 @@ const (
|
|||||||
)
|
)
|
||||||
|
|
||||||
type config struct {
|
type config struct {
|
||||||
targets []string
|
targets []string
|
||||||
mergeme string
|
mergeme string
|
||||||
root string
|
root string
|
||||||
tags []string
|
tags []string
|
||||||
search string
|
search string
|
||||||
edit bool
|
edit bool
|
||||||
dry bool
|
dry bool
|
||||||
add string
|
|
||||||
addSchedule string
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
@@ -51,14 +48,6 @@ func _main() error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if config.add != "" {
|
|
||||||
if err := add(config.dry, config.targets, pttodo.Todo{
|
|
||||||
Todo: config.add,
|
|
||||||
Schedule: pttodo.Schedule(config.addSchedule),
|
|
||||||
}); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if config.edit {
|
if config.edit {
|
||||||
if err := edit(config.dry, config.targets); err != nil {
|
if err := edit(config.dry, config.targets); err != nil {
|
||||||
return err
|
return err
|
||||||
@@ -83,8 +72,6 @@ func getConfig() config {
|
|||||||
flag.StringVar(&config.search, "search", "", "fts case insensitive")
|
flag.StringVar(&config.search, "search", "", "fts case insensitive")
|
||||||
flag.BoolVar(&config.edit, "e", false, "edit file")
|
flag.BoolVar(&config.edit, "e", false, "edit file")
|
||||||
flag.BoolVar(&config.dry, "dry", false, "dry run")
|
flag.BoolVar(&config.dry, "dry", false, "dry run")
|
||||||
flag.StringVar(&config.add, "add", "", "todo to add")
|
|
||||||
flag.StringVar(&config.addSchedule, "add-schedule", "", "todo to add schedule")
|
|
||||||
flag.Parse()
|
flag.Parse()
|
||||||
|
|
||||||
config.tags = strings.Split(tagss, ",")
|
config.tags = strings.Split(tagss, ",")
|
||||||
@@ -121,34 +108,6 @@ func verifyFile(path string) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func add(dry bool, filepaths []string, todo pttodo.Todo) error {
|
|
||||||
target := filepaths[0]
|
|
||||||
var original pttodo.Root
|
|
||||||
|
|
||||||
r, err := filePathReader(target)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
if err := yaml.NewDecoder(r).Decode(&original); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
original.Todo = append([]pttodo.Todo{todo}, original.Todo...)
|
|
||||||
original.AutoMove()
|
|
||||||
|
|
||||||
c, err := yaml.Marshal(original)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
} else if dry {
|
|
||||||
log.Printf("wouldve written...\n%s", c)
|
|
||||||
return nil
|
|
||||||
} else if err := ioutil.WriteFile(target, c, os.ModePerm); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func edit(dry bool, filepaths []string) error {
|
func edit(dry bool, filepaths []string) error {
|
||||||
tempDir, err := ioutil.TempDir(os.TempDir(), "edit-pttodo-*")
|
tempDir, err := ioutil.TempDir(os.TempDir(), "edit-pttodo-*")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -157,9 +116,9 @@ func edit(dry bool, filepaths []string) error {
|
|||||||
originals := map[string]pttodo.Root{}
|
originals := map[string]pttodo.Root{}
|
||||||
for _, target := range filepaths {
|
for _, target := range filepaths {
|
||||||
var original pttodo.Root
|
var original pttodo.Root
|
||||||
if r, err := filePathReader(target); err != nil {
|
if b, err := ioutil.ReadFile(target); err != nil && !os.IsNotExist(err) {
|
||||||
return err
|
return err
|
||||||
} else if err := yaml.NewDecoder(r).Decode(&original); err != nil {
|
} else if err := yaml.Unmarshal(b, &original); err != nil {
|
||||||
return err
|
return err
|
||||||
} else if c, err := yaml.Marshal(original.Todo); err != nil {
|
} else if c, err := yaml.Marshal(original.Todo); err != nil {
|
||||||
return err
|
return err
|
||||||
@@ -175,9 +134,9 @@ func edit(dry bool, filepaths []string) error {
|
|||||||
for {
|
for {
|
||||||
err := func() error {
|
err := func() error {
|
||||||
var todos []pttodo.Todo
|
var todos []pttodo.Todo
|
||||||
if r, err := filePathReader(path.Join(tempDir, path.Base(target))); err != nil {
|
if b, err := ioutil.ReadFile(path.Join(tempDir, path.Base(target))); err != nil {
|
||||||
return err
|
return err
|
||||||
} else if err := yaml.NewDecoder(r).Decode(&todos); err != nil {
|
} else if err := yaml.Unmarshal(b, &todos); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
@@ -199,12 +158,12 @@ func edit(dry bool, filepaths []string) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
for _, target := range filepaths {
|
for _, target := range filepaths {
|
||||||
r, err := filePathReader(path.Join(tempDir, path.Base(target)))
|
b, err := ioutil.ReadFile(path.Join(tempDir, path.Base(target)))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
var newTodos []pttodo.Todo
|
var newTodos []pttodo.Todo
|
||||||
if err := yaml.NewDecoder(r).Decode(&newTodos); err != nil {
|
if err := yaml.Unmarshal(b, &newTodos); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
original := originals[target]
|
original := originals[target]
|
||||||
@@ -213,20 +172,14 @@ func edit(dry bool, filepaths []string) error {
|
|||||||
for i := range newTodos {
|
for i := range newTodos {
|
||||||
newTodoIDs[newTodos[i].ID()] = struct{}{}
|
newTodoIDs[newTodos[i].ID()] = struct{}{}
|
||||||
}
|
}
|
||||||
|
|
||||||
for i := range original.Todo {
|
for i := range original.Todo {
|
||||||
if _, ok := newTodoIDs[original.Todo[i].ID()]; !ok {
|
if _, ok := newTodoIDs[original.Todo[i].ID()]; !ok {
|
||||||
original.Todo[i].TS = pttodo.TS(time.Now().Unix())
|
|
||||||
if string(original.Todo[i].Schedule) != "" && !original.Todo[i].Triggered() {
|
|
||||||
original.Scheduled = append(original.Scheduled, original.Todo[i])
|
|
||||||
}
|
|
||||||
original.Done = append(original.Done, original.Todo[i])
|
original.Done = append(original.Done, original.Todo[i])
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
original.Todo = newTodos
|
original.Todo = newTodos
|
||||||
|
|
||||||
original.AutoMove()
|
original.AutoMove()
|
||||||
|
|
||||||
c, err := yaml.Marshal(original)
|
c, err := yaml.Marshal(original)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
@@ -301,13 +254,13 @@ func _edit(dry bool, filepaths []string) error {
|
|||||||
saveOne := func(filepath string) error {
|
saveOne := func(filepath string) error {
|
||||||
tempFile := path.Join(tempDir, path.Base(filepath))
|
tempFile := path.Join(tempDir, path.Base(filepath))
|
||||||
var rootTemp, rootOld pttodo.Root
|
var rootTemp, rootOld pttodo.Root
|
||||||
if a, err := filePathReader(tempFile); err != nil {
|
if a, err := ioutil.ReadFile(tempFile); err != nil {
|
||||||
return err
|
return err
|
||||||
} else if err := yaml.NewDecoder(a).Decode(&rootTemp); err != nil {
|
} else if err := yaml.Unmarshal(a, &rootTemp); err != nil {
|
||||||
return err
|
return err
|
||||||
} else if b, err := filePathReader(filepath); err != nil {
|
} else if b, err := ioutil.ReadFile(filepath); err != nil {
|
||||||
return err
|
return err
|
||||||
} else if err := yaml.NewDecoder(b).Decode(&rootOld); err != nil {
|
} else if err := yaml.Unmarshal(b, &rootOld); err != nil {
|
||||||
return err
|
return err
|
||||||
} else if rootTemp.Equals(rootOld) {
|
} else if rootTemp.Equals(rootOld) {
|
||||||
//log.Printf("no changes to %s", filepath)
|
//log.Printf("no changes to %s", filepath)
|
||||||
@@ -533,17 +486,17 @@ func dump(dry bool, writer io.Writer, filepaths []string, tags []string, search,
|
|||||||
}
|
}
|
||||||
|
|
||||||
func filePathReader(path string) (io.Reader, error) {
|
func filePathReader(path string) (io.Reader, error) {
|
||||||
|
var reader io.Reader
|
||||||
if path == "-" {
|
if path == "-" {
|
||||||
return os.Stdin, nil
|
reader = os.Stdin
|
||||||
|
} else {
|
||||||
|
b, err := ioutil.ReadFile(path)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
reader = bytes.NewReader(b)
|
||||||
}
|
}
|
||||||
b, err := ioutil.ReadFile(path)
|
return reader, nil
|
||||||
if os.IsNotExist(err) {
|
|
||||||
return bytes.NewReader([]byte("{}")), nil
|
|
||||||
}
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return bytes.NewReader(b), nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func listDir(dname string) ([]string, error) {
|
func listDir(dname string) ([]string, error) {
|
||||||
|
|||||||
26
cmd/pttodo-cli/testdata/test.yaml
vendored
26
cmd/pttodo-cli/testdata/test.yaml
vendored
@@ -1,10 +1,20 @@
|
|||||||
todo:
|
todo:
|
||||||
- hi20890
|
|
||||||
- hi
|
|
||||||
- b
|
- b
|
||||||
- todo: loop
|
scheduled:
|
||||||
schedule: 10s
|
- todo: abc
|
||||||
- todo: past
|
schedule: "2022-05-01"
|
||||||
schedule: "2000-01-02"
|
ts: Wed Mar 23 08:03:45 MDT 2022
|
||||||
scheduled: []
|
- todo: def
|
||||||
done: []
|
schedule: "2022-05-01"
|
||||||
|
ts: Wed Mar 23 08:04:05 MDT 2022
|
||||||
|
done:
|
||||||
|
- todo: other
|
||||||
|
ts: Wed Mar 23 09:44:57 MDT 2022
|
||||||
|
- todo: b
|
||||||
|
ts: Wed Mar 23 09:45:13 MDT 2022
|
||||||
|
- todo: a
|
||||||
|
ts: Wed Mar 23 09:45:15 MDT 2022
|
||||||
|
- todo: a
|
||||||
|
ts: Wed Mar 23 09:45:24 MDT 2022
|
||||||
|
- todo: a
|
||||||
|
ts: Wed Mar 23 09:45:31 MDT 2022
|
||||||
|
|||||||
@@ -27,14 +27,13 @@ func (root *Root) AutoMove() {
|
|||||||
|
|
||||||
func (root *Root) MoveTodoToScheduled() {
|
func (root *Root) MoveTodoToScheduled() {
|
||||||
for i := len(root.Todo) - 1; i >= 0; i-- {
|
for i := len(root.Todo) - 1; i >= 0; i-- {
|
||||||
if !root.Todo[i].Schedule.isFixedFuture() {
|
if root.Todo[i].Schedule != "" && !root.Todo[i].Triggered() {
|
||||||
continue
|
root.Scheduled = append(root.Scheduled, root.Todo[i])
|
||||||
|
for j := i; j < len(root.Todo)-1; j++ {
|
||||||
|
root.Todo[j] = root.Todo[j+1]
|
||||||
|
}
|
||||||
|
root.Todo = root.Todo[:len(root.Todo)-1]
|
||||||
}
|
}
|
||||||
root.Scheduled = append(root.Scheduled, root.Todo[i])
|
|
||||||
for j := i; j < len(root.Todo)-1; j++ {
|
|
||||||
root.Todo[j] = root.Todo[j+1]
|
|
||||||
}
|
|
||||||
root.Todo = root.Todo[:len(root.Todo)-1]
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -25,42 +25,6 @@ func (schedule Schedule) Next(t time.Time) (time.Time, error) {
|
|||||||
return scheduler.next(t)
|
return scheduler.next(t)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (schedule Schedule) isFixedFuture() bool {
|
|
||||||
if !schedule.isFixed() {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
return schedule.isFuture()
|
|
||||||
}
|
|
||||||
|
|
||||||
func (schedule Schedule) isFixed() bool {
|
|
||||||
if schedule.empty() {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
scheduler := schedulerFactory(string(schedule))
|
|
||||||
switch scheduler.(type) {
|
|
||||||
case scheduleEZDate, scheduleDue:
|
|
||||||
default:
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
|
|
||||||
func (schedule Schedule) isFuture() bool {
|
|
||||||
if schedule.empty() {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
scheduler := schedulerFactory(string(schedule))
|
|
||||||
t, err := scheduler.next(time.Now())
|
|
||||||
if err != nil {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
return time.Now().Before(t)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (schedule Schedule) empty() bool {
|
|
||||||
return string(schedule) == ""
|
|
||||||
}
|
|
||||||
|
|
||||||
type scheduler interface {
|
type scheduler interface {
|
||||||
next(time.Time) (time.Time, error)
|
next(time.Time) (time.Time, error)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -130,60 +130,3 @@ func TestSchedulerFactory(t *testing.T) {
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestScheduleIsFixedFuture(t *testing.T) {
|
|
||||||
cases := map[string]struct {
|
|
||||||
input string
|
|
||||||
want bool
|
|
||||||
}{
|
|
||||||
"empty": {
|
|
||||||
input: "",
|
|
||||||
want: false,
|
|
||||||
},
|
|
||||||
"cron": {
|
|
||||||
input: "* * * * *",
|
|
||||||
want: false,
|
|
||||||
},
|
|
||||||
"duration": {
|
|
||||||
input: "1m",
|
|
||||||
want: false,
|
|
||||||
},
|
|
||||||
"due past": {
|
|
||||||
input: "123",
|
|
||||||
want: false,
|
|
||||||
},
|
|
||||||
"due future": {
|
|
||||||
input: "9648154541",
|
|
||||||
want: true,
|
|
||||||
},
|
|
||||||
"ez date short past": {
|
|
||||||
input: "2000-01-02",
|
|
||||||
want: false,
|
|
||||||
},
|
|
||||||
"ez date short future": {
|
|
||||||
input: "2100-01-02",
|
|
||||||
want: true,
|
|
||||||
},
|
|
||||||
"ez date long past": {
|
|
||||||
input: "2000-01-02T01",
|
|
||||||
want: false,
|
|
||||||
},
|
|
||||||
"ez date long future": {
|
|
||||||
input: "2100-01-02T02",
|
|
||||||
want: true,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
for name, d := range cases {
|
|
||||||
c := d
|
|
||||||
t.Run(name, func(t *testing.T) {
|
|
||||||
schedule := Schedule(c.input)
|
|
||||||
got := schedule.isFixedFuture()
|
|
||||||
if got != c.want {
|
|
||||||
gotFuture := schedule.isFuture()
|
|
||||||
gotFixed := schedule.isFixed()
|
|
||||||
t.Errorf("want %v, got %v = %v && %v", c.want, got, gotFuture, gotFixed)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user