24 Commits

Author SHA1 Message Date
bel
87c937b6f1 oop 2023-10-15 10:40:13 -06:00
bel
ed474b8c3a default file path if not empty 2023-10-15 10:39:58 -06:00
bel
46e62dc485 fix nil ptr on no previous file 2023-10-15 10:39:01 -06:00
Bel LaPointe
236355b69d skip hidden files 2023-08-16 06:54:21 -06:00
Bel LaPointe
6bb6c847aa nil ptr 2023-07-16 19:47:11 -06:00
Bel LaPointe
6bad1e1365 on write conflict during vim, save as filename.uuid..fileExtension 2023-07-02 10:22:04 -06:00
Bel LaPointe
d105df15e9 support -add-tags x,y,z 2023-04-24 15:02:13 -06:00
Bel LaPointe
afc7d6001a fix 2023-04-10 10:45:16 -06:00
Bel LaPointe
242f9ee1b4 gr 2023-04-10 10:44:41 -06:00
Bel LaPointe
5a30481ff1 partial go mod 2023-04-10 10:42:11 -06:00
Bel LaPointe
438c0ade59 gitignore 2022-09-10 11:25:23 -06:00
Bel LaPointe
e5b3fd3195 no prior file exists ok 2022-09-10 11:24:41 -06:00
Bel LaPointe
49893c7ffe on scheduled task done, in addition to requeue, add to done 2022-09-10 11:13:18 -06:00
Bel LaPointe
39d222b133 quick add via cli -add, -add-schedule 2022-04-07 12:48:17 -06:00
Bel LaPointe
461e88ee17 root moves fixed future schedules to shceduled on automove 2022-03-24 14:43:45 -06:00
Bel LaPointe
916ad212f4 revert to clean todo 2022-03-24 09:26:44 -06:00
Bel LaPointe
bd5028ff8d revert automove for crons 2022-03-24 09:25:34 -06:00
Bel LaPointe
21ccb7ff4c always write ts, when a todo with schedule deleted, conditionally go back to schedule for loopers 2022-03-24 09:18:19 -06:00
Bel LaPointe
1b1ed01937 cli on delete todo, write in Done identified by entire struct so dupes wouldnt but thats ok 2022-03-23 09:46:16 -06:00
Bel LaPointe
5a1936721d add todo.ID() 2022-03-23 09:42:21 -06:00
Bel LaPointe
77fb27dc09 ready for find deleted 2022-03-23 08:06:57 -06:00
Bel LaPointe
2eda765ad9 if item in todo is scheduled for later, then move it 2022-03-23 08:04:35 -06:00
Bel LaPointe
a8fbc13e7c new edit ready for shuffles 2022-03-23 07:49:54 -06:00
Bel LaPointe
d8e732087a getconfig in pttodo-cli 2022-03-23 07:27:49 -06:00
13 changed files with 427 additions and 151 deletions

1
.gitignore vendored
View File

@@ -3,3 +3,4 @@ todo-server-yaml
cmd/cmd cmd/cmd
cmd/cli cmd/cli
cmd/pttodo/pttodo cmd/pttodo/pttodo
cmd/pttodo-cli/pttodo-cli

View File

@@ -6,7 +6,6 @@ import (
"fmt" "fmt"
"io" "io"
"io/ioutil" "io/ioutil"
"local/pt-todo-server/pttodo"
"log" "log"
"os" "os"
"os/exec" "os/exec"
@@ -14,6 +13,11 @@ import (
"sort" "sort"
"strings" "strings"
"syscall" "syscall"
"time"
"github.com/google/uuid"
"gogs.inhome.blapointe.com/bel/pttodo/pttodo"
"gopkg.in/yaml.v2" "gopkg.in/yaml.v2"
) )
@@ -25,6 +29,19 @@ const (
DUMP_DONE = "done" DUMP_DONE = "done"
) )
type config struct {
targets []string
mergeme string
root string
tags []string
search string
edit bool
dry bool
add string
addSchedule string
addTags string
}
func main() { func main() {
if err := _main(); err != nil { if err := _main(); err != nil {
panic(err) panic(err)
@@ -32,42 +49,58 @@ func main() {
} }
func _main() error { func _main() error {
defaultFilepath, ok := os.LookupEnv("PTTODO_FILE") config := getConfig()
if !ok { if config.mergeme != "" {
if err := merge(config.dry, config.targets[0], config.mergeme); err != nil {
return err
}
}
if config.add != "" {
v := pttodo.Todo{
Todo: config.add,
Schedule: pttodo.Schedule(config.addSchedule),
Tags: config.addTags,
}
if err := add(config.dry, config.targets, v); err != nil {
return err
}
}
if config.edit {
if err := edit(config.dry, config.targets); err != nil {
return err
}
}
return dump(config.dry, os.Stdout, config.targets, config.tags, config.search, config.root)
}
func getConfig() config {
defaultFilepath := os.Getenv("PTTODO_FILE")
if defaultFilepath == "" {
defaultFilepath = "./todo.yaml" defaultFilepath = "./todo.yaml"
} }
filepath := flag.String("f", defaultFilepath, "($PTTODO_FILE) path to yaml file or dir (starting with root then alphabetical for dir)")
filepathToMergeIn := flag.String("g", "", "path to yaml file to merge into -f (modifies f)") var config config
root := flag.String("root", DUMP_TODO, "path to pretty print ("+fmt.Sprint([]string{DUMP_ALL, DUMP_TODO, DUMP_SCHEDULED, DUMP_DONE})+")") var target string
tags := flag.String("tags", "", "csv of all tags to find, -tag to invert") flag.StringVar(&target, "f", defaultFilepath, "($PTTODO_FILE) path to yaml file or dir (starting with root then alphabetical for dir)")
search := flag.String("search", "", "fts case insensitive") flag.StringVar(&config.mergeme, "g", "", "path to yaml file to merge into -f (modifies f)")
e := flag.Bool("e", false, "edit file") flag.StringVar(&config.root, "root", DUMP_TODO, "path to pretty print ("+fmt.Sprint([]string{DUMP_ALL, DUMP_TODO, DUMP_SCHEDULED, DUMP_DONE})+")")
dry := flag.Bool("dry", false, "dry run") var tagss string
flag.StringVar(&tagss, "tags", "", "csv of all tags to find, -x to invert")
flag.StringVar(&config.search, "search", "", "fts case insensitive")
flag.BoolVar(&config.edit, "e", false, "edit file")
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.StringVar(&config.addTags, "add-tags", "", "todo to add csv tags")
flag.Parse() flag.Parse()
if *filepathToMergeIn != "" {
if err := merge(*dry, *filepath, *filepathToMergeIn); err != nil { config.tags = strings.Split(tagss, ",")
return err config.targets = []string{target}
if stat, err := os.Stat(target); err == nil && stat.IsDir() {
config.targets, _ = listDir(target)
} }
}
filepaths := []string{*filepath} return config
if stat, err := os.Stat(*filepath); err != nil && !os.IsNotExist(err) {
return err
} else if err == nil && stat.IsDir() {
filepaths, err = listDir(*filepath)
if err != nil {
return err
}
}
if *e {
if err := edit(*dry, filepaths); err != nil {
return err
}
}
var tagslist []string
if *tags != "" {
tagslist = strings.Split(*tags, ",")
}
return dump(*dry, os.Stdout, filepaths, tagslist, *search, *root)
} }
func verifyRoot(root pttodo.Root) error { func verifyRoot(root pttodo.Root) error {
@@ -95,7 +128,134 @@ 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-*")
if err != nil {
return err
}
originals := map[string]pttodo.Root{}
lastModified := map[string]time.Time{}
for _, target := range filepaths {
var original pttodo.Root
if r, err := filePathReader(target); err != nil {
return err
} else if err := yaml.NewDecoder(r).Decode(&original); err != nil {
return err
} else if c, err := yaml.Marshal(original.Todo); err != nil {
return err
} else if err := ioutil.WriteFile(path.Join(tempDir, path.Base(target)), c, os.ModePerm); err != nil {
return err
}
originals[target] = original
if info, _ := os.Stat(target); info != nil {
lastModified[target] = info.ModTime()
} else {
lastModified[target] = time.Time{}
}
}
if err := vimd(tempDir); err != nil {
return err
}
for _, target := range filepaths {
for {
err := func() error {
var todos []pttodo.Todo
if r, err := filePathReader(path.Join(tempDir, path.Base(target))); err != nil {
return err
} else if err := yaml.NewDecoder(r).Decode(&todos); err != nil {
return err
}
return nil
}()
if err == nil {
break
}
log.Printf("%s, press <Enter> to resume editing", err)
b := make([]byte, 1)
if _, err := os.Stdin.Read(b); err != nil {
return err
}
if err := vimd(tempDir); err != nil {
return err
}
}
}
if dry {
return nil
}
for _, target := range filepaths {
r, err := filePathReader(path.Join(tempDir, path.Base(target)))
if err != nil {
return err
}
var newTodos []pttodo.Todo
if err := yaml.NewDecoder(r).Decode(&newTodos); err != nil {
return err
}
original := originals[target]
newTodoIDs := map[string]struct{}{}
for i := range newTodos {
newTodoIDs[newTodos[i].ID()] = struct{}{}
}
for i := range original.Todo {
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.Todo = newTodos
original.AutoMove()
c, err := yaml.Marshal(original)
if err != nil {
return err
}
outputPath := target
if info, _ := os.Stat(target); info != nil && info.ModTime() != lastModified[target] {
outputPath = fmt.Sprintf("%s.%s.%s", outputPath, uuid.New().String(), path.Ext(outputPath))
}
if err := ioutil.WriteFile(outputPath, c, os.ModePerm); err != nil {
return err
}
}
return nil
}
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 {
return err return err
@@ -127,45 +287,7 @@ func edit(dry bool, filepaths []string) error {
return nil return nil
} }
vi := func() error { vi := func() error {
bin := "vim" return vimd(tempDir)
editorbin, err := exec.LookPath(bin)
if err != nil {
editorbin, err = exec.LookPath("vi")
}
if err != nil {
return err
}
args := []string{editorbin, "-p"}
tempfiles, err := listDir(tempDir)
if err != nil {
return err
}
args = append(args, tempfiles...)
cpid, err := syscall.ForkExec(
editorbin,
args,
&syscall.ProcAttr{
Dir: tempDir,
Env: os.Environ(),
Files: []uintptr{os.Stdin.Fd(), os.Stdout.Fd(), os.Stderr.Fd()},
Sys: nil,
},
)
if err != nil {
return err
}
proc, err := os.FindProcess(cpid)
if err != nil {
return err
}
state, err := proc.Wait()
if err != nil {
return err
}
if exitCode := state.ExitCode(); exitCode != 0 {
return fmt.Errorf("bad exit code on vim: %d, state: %+v", exitCode, state)
}
return nil
} }
verifyOne := func(tempFile string) error { verifyOne := func(tempFile string) error {
for { for {
@@ -196,13 +318,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 := ioutil.ReadFile(tempFile); err != nil { if a, err := filePathReader(tempFile); err != nil {
return err return err
} else if err := yaml.Unmarshal(a, &rootTemp); err != nil { } else if err := yaml.NewDecoder(a).Decode(&rootTemp); err != nil {
return err return err
} else if b, err := ioutil.ReadFile(filepath); err != nil { } else if b, err := filePathReader(filepath); err != nil {
return err return err
} else if err := yaml.Unmarshal(b, &rootOld); err != nil { } else if err := yaml.NewDecoder(b).Decode(&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)
@@ -235,6 +357,48 @@ func edit(dry bool, filepaths []string) error {
return nil return nil
} }
func vimd(d string) error {
bin := "vim"
editorbin, err := exec.LookPath(bin)
if err != nil {
editorbin, err = exec.LookPath("vi")
}
if err != nil {
return err
}
args := []string{editorbin, "-p"}
files, err := listDir(d)
if err != nil {
return err
}
args = append(args, files...)
cpid, err := syscall.ForkExec(
editorbin,
args,
&syscall.ProcAttr{
Dir: d,
Env: os.Environ(),
Files: []uintptr{os.Stdin.Fd(), os.Stdout.Fd(), os.Stderr.Fd()},
Sys: nil,
},
)
if err != nil {
return err
}
proc, err := os.FindProcess(cpid)
if err != nil {
return err
}
state, err := proc.Wait()
if err != nil {
return err
}
if exitCode := state.ExitCode(); exitCode != 0 {
return fmt.Errorf("bad exit code on vim: %d, state: %+v", exitCode, state)
}
return nil
}
func merge(dry bool, filepath string, mergeTargetFilePath string) error { func merge(dry bool, filepath string, mergeTargetFilePath string) error {
baseReader, err := filePathReader(filepath) baseReader, err := filePathReader(filepath)
if err != nil { if err != nil {
@@ -386,17 +550,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 == "-" {
reader = os.Stdin return os.Stdin, nil
} else { }
b, err := ioutil.ReadFile(path) b, err := ioutil.ReadFile(path)
if os.IsNotExist(err) {
return bytes.NewReader([]byte("{}")), nil
}
if err != nil { if err != nil {
return nil, err return nil, err
} }
reader = bytes.NewReader(b) return bytes.NewReader(b), nil
}
return reader, nil
} }
func listDir(dname string) ([]string, error) { func listDir(dname string) ([]string, error) {
@@ -409,6 +573,9 @@ func listDir(dname string) ([]string, error) {
if entries[i].IsDir() { if entries[i].IsDir() {
continue continue
} }
if strings.HasPrefix(path.Base(entries[i].Name()), ".") {
continue
}
paths = append(paths, path.Join(dname, entries[i].Name())) paths = append(paths, path.Join(dname, entries[i].Name()))
} }
sort.Slice(paths, func(i, j int) bool { sort.Slice(paths, func(i, j int) bool {

View File

@@ -3,10 +3,13 @@ module pttodo-cli
go 1.17 go 1.17
require ( require (
gogs.inhome.blapointe.com/bel/pttodo v0.4.0
gopkg.in/yaml.v2 v2.4.0 gopkg.in/yaml.v2 v2.4.0
local/pt-todo-server v0.0.0-00010101000000-000000000000
) )
require github.com/robfig/cron/v3 v3.0.1 // indirect require (
github.com/google/uuid v1.3.0 // indirect
github.com/robfig/cron/v3 v3.0.1 // indirect
)
replace local/pt-todo-server => ../../ replace gogs.inhome.blapointe.com/bel/pttodo => ../..

View File

@@ -1,3 +1,5 @@
github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs= github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro= github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=

10
cmd/pttodo-cli/testdata/test.yaml vendored Executable file
View File

@@ -0,0 +1,10 @@
todo:
- hi20890
- hi
- b
- todo: loop
schedule: 10s
- todo: past
schedule: "2000-01-02"
scheduled: []
done: []

12
go.mod
View File

@@ -1,18 +1,8 @@
module pttodo module gogs.inhome.blapointe.com/bel/pttodo
go 1.17 go 1.17
require ( require (
github.com/robfig/cron/v3 v3.0.1 github.com/robfig/cron/v3 v3.0.1
gopkg.in/yaml.v2 v2.4.0 gopkg.in/yaml.v2 v2.4.0
local/sandbox/contact/contact v0.0.0-00010101000000-000000000000
) )
require (
github.com/bytbox/go-pop3 v0.0.0-20120201222208-3046caf0763e // indirect
github.com/emersion/go-imap v1.2.0 // indirect
github.com/emersion/go-sasl v0.0.0-20200509203442-7bfe0ed36a21 // indirect
golang.org/x/text v0.3.7 // indirect
)
replace local/sandbox/contact/contact => ../sandbox/contact/contact

12
go.sum
View File

@@ -1,17 +1,5 @@
github.com/bytbox/go-pop3 v0.0.0-20120201222208-3046caf0763e h1:mQTN05gz0rDZSABqKMzAPMb5ATWcvvdMljRzEh0LjBo=
github.com/bytbox/go-pop3 v0.0.0-20120201222208-3046caf0763e/go.mod h1:alXX+s7a4cKaIprgjeEboqi4Tm7XR/HXEwUTxUV/ywU=
github.com/emersion/go-imap v1.2.0 h1:lyUQ3+EVM21/qbWE/4Ya5UG9r5+usDxlg4yfp3TgHFA=
github.com/emersion/go-imap v1.2.0/go.mod h1:Qlx1FSx2FTxjnjWpIlVNEuX+ylerZQNFE5NsmKFSejY=
github.com/emersion/go-message v0.15.0/go.mod h1:wQUEfE+38+7EW8p8aZ96ptg6bAb1iwdgej19uXASlE4=
github.com/emersion/go-sasl v0.0.0-20200509203442-7bfe0ed36a21 h1:OJyUGMJTzHTd1XQp98QTaHernxMYzRaOasRir9hUlFQ=
github.com/emersion/go-sasl v0.0.0-20200509203442-7bfe0ed36a21/go.mod h1:iL2twTeMvZnrg54ZoPDNfJaJaqy0xIQFuBdrLsmspwQ=
github.com/emersion/go-textwrapper v0.0.0-20200911093747-65d896831594/go.mod h1:aqO8z8wPrjkscevZJFVE1wXJrLpC5LtJG7fqLOsPb2U=
github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs= github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro= github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
golang.org/x/text v0.3.7 h1:olpwvP2KacW1ZWvsR7uQhoyTYvKAupfQrRGBFM352Gk=
golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY= gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=

View File

@@ -1,40 +0,0 @@
package pttodo
/*
action is something like 'send an email on trigger' but is not impl or use
*/
import (
"errors"
"local/sandbox/contact/contact"
"net/url"
"regexp"
)
type Action string
var (
actionEmailPattern = regexp.MustCompile(`[^@]+@.*[^\.]+\.[a-z]+`)
)
func (action Action) String() string {
return string(action)
}
func (action Action) CB() (func() error, error) {
u, _ := url.Parse(action.String())
switch u.Scheme {
case "email":
return action.email, nil
}
if actionEmailPattern.MatchString(action.String()) {
return action.email, nil
}
return nil, errors.New("unrecognized action")
}
func (action Action) email() error {
em := contact.NewEmailer()
_ = em
return errors.New("not impl")
}

View File

@@ -20,6 +20,24 @@ func (root Root) Equals(other Root) bool {
return true return true
} }
func (root *Root) AutoMove() {
root.MoveScheduledToTodo()
root.MoveTodoToScheduled()
}
func (root *Root) MoveTodoToScheduled() {
for i := len(root.Todo) - 1; i >= 0; i-- {
if !root.Todo[i].Schedule.isFixedFuture() {
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]
}
}
func (root *Root) MoveScheduledToTodo() { func (root *Root) MoveScheduledToTodo() {
for i := len(root.Scheduled) - 1; i >= 0; i-- { for i := len(root.Scheduled) - 1; i >= 0; i-- {
if root.Scheduled[i].Triggered() { if root.Scheduled[i].Triggered() {

View File

@@ -25,6 +25,42 @@ 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)
} }

View File

@@ -130,3 +130,60 @@ 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)
}
})
}
}

View File

@@ -1,7 +1,9 @@
package pttodo package pttodo
import ( import (
"encoding/base64"
"fmt" "fmt"
"hash/crc32"
"time" "time"
) )
@@ -15,6 +17,18 @@ type Todo struct {
writeTS bool writeTS bool
} }
func (todo Todo) ID() string {
hash := crc32.NewIEEE()
fmt.Fprintf(hash, "%d:%s", 0, todo.Todo)
fmt.Fprintf(hash, "%d:%s", 1, todo.Details)
fmt.Fprintf(hash, "%d:%s", 2, todo.Schedule)
fmt.Fprintf(hash, "%d:%s", 3, todo.Tags)
for i := range todo.Subtasks {
fmt.Fprintf(hash, "%d:%s", 4, todo.Subtasks[i].ID())
}
return base64.StdEncoding.EncodeToString(hash.Sum(nil))
}
func (todo Todo) Triggered() bool { func (todo Todo) Triggered() bool {
last := todo.TS last := todo.TS
next, err := todo.Schedule.Next(last.time()) next, err := todo.Schedule.Next(last.time())

View File

@@ -125,3 +125,33 @@ func TestMarshalTodo(t *testing.T) {
} }
}) })
} }
func TestTodoID(t *testing.T) {
cases := map[string]Todo{
"empty": Todo{},
"todo": Todo{Todo: "abc"},
"details": Todo{Details: "abc"},
"todo,details": Todo{Todo: "abc", Details: "abc"},
}
got := map[string]bool{}
for name, todod := range cases {
todo := todod
t.Run(name, func(t *testing.T) {
if _, ok := got[todo.ID()]; ok {
t.Error("dupe", todo.ID())
}
got[todo.ID()] = true
t.Logf("%s: %+v", todo.ID(), todo)
todo2 := todo
todo2.TS = 1
if todo.ID() != todo2.ID() {
t.Error("ts changed")
}
todo2.writeTS = true
if todo.ID() != todo2.ID() {
t.Error("writets changed")
}
})
}
}