Compare commits
No commits in common. "e49562b7f649a5fdd542128bb5149f975b501907" and "c209ba6197c0cc86d970955a1317b6e62836069d" have entirely different histories.
e49562b7f6
...
c209ba6197
|
@ -86,26 +86,26 @@ type Add struct {
|
||||||
args AddArgs
|
args AddArgs
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *Add) Do(deps Dependencies) ([][]string, error) {
|
func (a *Add) Do(deps Dependencies) error {
|
||||||
if err := deps.TaskRepo.Store(a.args.task); err != nil {
|
if err := deps.TaskRepo.Store(a.args.task); err != nil {
|
||||||
return nil, fmt.Errorf("could not store event: %v", err)
|
return fmt.Errorf("could not store event: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
localID, err := deps.LocalIDRepo.Next()
|
localID, err := deps.LocalIDRepo.Next()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not create next local id: %v", err)
|
return fmt.Errorf("could not create next local id: %v", err)
|
||||||
}
|
}
|
||||||
if err := deps.LocalIDRepo.Store(a.args.task.ID, localID); err != nil {
|
if err := deps.LocalIDRepo.Store(a.args.task.ID, localID); err != nil {
|
||||||
return nil, fmt.Errorf("could not store local id: %v", err)
|
return fmt.Errorf("could not store local id: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
it, err := a.args.task.Item()
|
it, err := a.args.task.Item()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not convert event to sync item: %v", err)
|
return fmt.Errorf("could not convert event to sync item: %v", err)
|
||||||
}
|
}
|
||||||
if err := deps.SyncRepo.Store(it); err != nil {
|
if err := deps.SyncRepo.Store(it); err != nil {
|
||||||
return nil, fmt.Errorf("could not store sync item: %v", err)
|
return fmt.Errorf("could not store sync item: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil, nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -6,7 +6,6 @@ import (
|
||||||
|
|
||||||
"go-mod.ewintr.nl/planner/item"
|
"go-mod.ewintr.nl/planner/item"
|
||||||
"go-mod.ewintr.nl/planner/plan/command"
|
"go-mod.ewintr.nl/planner/plan/command"
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
|
||||||
"go-mod.ewintr.nl/planner/plan/storage/memory"
|
"go-mod.ewintr.nl/planner/plan/storage/memory"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -67,7 +66,7 @@ func TestAdd(t *testing.T) {
|
||||||
if tc.expErr {
|
if tc.expErr {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if _, err := cmd.Do(command.Dependencies{
|
if err := cmd.Do(command.Dependencies{
|
||||||
TaskRepo: taskRepo,
|
TaskRepo: taskRepo,
|
||||||
LocalIDRepo: localIDRepo,
|
LocalIDRepo: localIDRepo,
|
||||||
SyncRepo: syncRepo,
|
SyncRepo: syncRepo,
|
||||||
|
@ -75,7 +74,7 @@ func TestAdd(t *testing.T) {
|
||||||
t.Errorf("exp nil, got %v", err)
|
t.Errorf("exp nil, got %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
actTasks, err := taskRepo.FindMany(storage.TaskListParams{})
|
actTasks, err := taskRepo.FindAll()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("exp nil, got %v", err)
|
t.Errorf("exp nil, got %v", err)
|
||||||
}
|
}
|
||||||
|
|
|
@ -6,7 +6,6 @@ import (
|
||||||
"slices"
|
"slices"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
"go-mod.ewintr.nl/planner/plan/format"
|
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
"go-mod.ewintr.nl/planner/plan/storage"
|
||||||
"go-mod.ewintr.nl/planner/sync/client"
|
"go-mod.ewintr.nl/planner/sync/client"
|
||||||
)
|
)
|
||||||
|
@ -33,7 +32,7 @@ type CommandArgs interface {
|
||||||
}
|
}
|
||||||
|
|
||||||
type Command interface {
|
type Command interface {
|
||||||
Do(deps Dependencies) ([][]string, error)
|
Do(deps Dependencies) error
|
||||||
}
|
}
|
||||||
|
|
||||||
type CLI struct {
|
type CLI struct {
|
||||||
|
@ -45,7 +44,6 @@ func NewCLI(deps Dependencies) *CLI {
|
||||||
return &CLI{
|
return &CLI{
|
||||||
deps: deps,
|
deps: deps,
|
||||||
cmdArgs: []CommandArgs{
|
cmdArgs: []CommandArgs{
|
||||||
NewShowArgs(),
|
|
||||||
NewAddArgs(), NewDeleteArgs(), NewListArgs(),
|
NewAddArgs(), NewDeleteArgs(), NewListArgs(),
|
||||||
NewSyncArgs(), NewUpdateArgs(),
|
NewSyncArgs(), NewUpdateArgs(),
|
||||||
},
|
},
|
||||||
|
@ -53,29 +51,17 @@ func NewCLI(deps Dependencies) *CLI {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cli *CLI) Run(args []string) error {
|
func (cli *CLI) Run(args []string) error {
|
||||||
main, fields := FindFields(args)
|
main, flags := FindFields(args)
|
||||||
for _, ca := range cli.cmdArgs {
|
for _, ca := range cli.cmdArgs {
|
||||||
cmd, err := ca.Parse(main, fields)
|
cmd, err := ca.Parse(main, flags)
|
||||||
switch {
|
switch {
|
||||||
case errors.Is(err, ErrWrongCommand):
|
case errors.Is(err, ErrWrongCommand):
|
||||||
continue
|
continue
|
||||||
case err != nil:
|
case err != nil:
|
||||||
return err
|
return err
|
||||||
}
|
|
||||||
|
|
||||||
data, err := cmd.Do(cli.deps)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
switch {
|
|
||||||
case len(data) == 0:
|
|
||||||
case len(data) == 1 && len(data[0]) == 1:
|
|
||||||
fmt.Println(data[0][0])
|
|
||||||
default:
|
default:
|
||||||
fmt.Printf("\n%s\n", format.Table(data))
|
return cmd.Do(cli.deps)
|
||||||
}
|
}
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return fmt.Errorf("could not find matching command")
|
return fmt.Errorf("could not find matching command")
|
||||||
|
|
|
@ -34,11 +34,11 @@ type Delete struct {
|
||||||
args DeleteArgs
|
args DeleteArgs
|
||||||
}
|
}
|
||||||
|
|
||||||
func (del *Delete) Do(deps Dependencies) ([][]string, error) {
|
func (del *Delete) Do(deps Dependencies) error {
|
||||||
var id string
|
var id string
|
||||||
idMap, err := deps.LocalIDRepo.FindAll()
|
idMap, err := deps.LocalIDRepo.FindAll()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not get local ids: %v", err)
|
return fmt.Errorf("could not get local ids: %v", err)
|
||||||
}
|
}
|
||||||
for tskID, lid := range idMap {
|
for tskID, lid := range idMap {
|
||||||
if del.args.LocalID == lid {
|
if del.args.LocalID == lid {
|
||||||
|
@ -46,30 +46,30 @@ func (del *Delete) Do(deps Dependencies) ([][]string, error) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if id == "" {
|
if id == "" {
|
||||||
return nil, fmt.Errorf("could not find local id")
|
return fmt.Errorf("could not find local id")
|
||||||
}
|
}
|
||||||
|
|
||||||
tsk, err := deps.TaskRepo.FindOne(id)
|
tsk, err := deps.TaskRepo.Find(id)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not get task: %v", err)
|
return fmt.Errorf("could not get task: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
it, err := tsk.Item()
|
it, err := tsk.Item()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not convert task to sync item: %v", err)
|
return fmt.Errorf("could not convert task to sync item: %v", err)
|
||||||
}
|
}
|
||||||
it.Deleted = true
|
it.Deleted = true
|
||||||
if err := deps.SyncRepo.Store(it); err != nil {
|
if err := deps.SyncRepo.Store(it); err != nil {
|
||||||
return nil, fmt.Errorf("could not store sync item: %v", err)
|
return fmt.Errorf("could not store sync item: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := deps.LocalIDRepo.Delete(id); err != nil {
|
if err := deps.LocalIDRepo.Delete(id); err != nil {
|
||||||
return nil, fmt.Errorf("could not delete local id: %v", err)
|
return fmt.Errorf("could not delete local id: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := deps.TaskRepo.Delete(id); err != nil {
|
if err := deps.TaskRepo.Delete(id); err != nil {
|
||||||
return nil, fmt.Errorf("could not delete task: %v", err)
|
return fmt.Errorf("could not delete task: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil, nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -61,19 +61,19 @@ func TestDelete(t *testing.T) {
|
||||||
if tc.expParseErr {
|
if tc.expParseErr {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
_, actDoErr := cmd.Do(command.Dependencies{
|
actDoErr := cmd.Do(command.Dependencies{
|
||||||
TaskRepo: taskRepo,
|
TaskRepo: taskRepo,
|
||||||
LocalIDRepo: localIDRepo,
|
LocalIDRepo: localIDRepo,
|
||||||
SyncRepo: syncRepo,
|
SyncRepo: syncRepo,
|
||||||
})
|
}) != nil
|
||||||
if tc.expDoErr != (actDoErr != nil) {
|
if tc.expDoErr != actDoErr {
|
||||||
t.Errorf("exp false, got %v", actDoErr)
|
t.Errorf("exp false, got %v", actDoErr)
|
||||||
}
|
}
|
||||||
if tc.expDoErr {
|
if tc.expDoErr {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
_, repoErr := taskRepo.FindOne(e.ID)
|
_, repoErr := taskRepo.Find(e.ID)
|
||||||
if !errors.Is(repoErr, storage.ErrNotFound) {
|
if !errors.Is(repoErr, storage.ErrNotFound) {
|
||||||
t.Errorf("exp %v, got %v", storage.ErrNotFound, repoErr)
|
t.Errorf("exp %v, got %v", storage.ErrNotFound, repoErr)
|
||||||
}
|
}
|
||||||
|
|
|
@ -2,8 +2,6 @@ package command
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type ListArgs struct {
|
type ListArgs struct {
|
||||||
|
@ -24,22 +22,22 @@ func (la ListArgs) Parse(main []string, flags map[string]string) (Command, error
|
||||||
type List struct {
|
type List struct {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (list *List) Do(deps Dependencies) ([][]string, error) {
|
func (list *List) Do(deps Dependencies) error {
|
||||||
localIDs, err := deps.LocalIDRepo.FindAll()
|
localIDs, err := deps.LocalIDRepo.FindAll()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not get local ids: %v", err)
|
return fmt.Errorf("could not get local ids: %v", err)
|
||||||
}
|
}
|
||||||
all, err := deps.TaskRepo.FindMany(storage.TaskListParams{})
|
all, err := deps.TaskRepo.FindAll()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return err
|
||||||
}
|
}
|
||||||
for _, e := range all {
|
for _, e := range all {
|
||||||
lid, ok := localIDs[e.ID]
|
lid, ok := localIDs[e.ID]
|
||||||
if !ok {
|
if !ok {
|
||||||
return nil, fmt.Errorf("could not find local id for %s", e.ID)
|
return fmt.Errorf("could not find local id for %s", e.ID)
|
||||||
}
|
}
|
||||||
fmt.Printf("%s\t%d\t%s\t%s\t%s\n", e.ID, lid, e.Title, e.Date.String(), e.Duration.String())
|
fmt.Printf("%s\t%d\t%s\t%s\t%s\n", e.ID, lid, e.Title, e.Date.String(), e.Duration.String())
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil, nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -54,7 +54,7 @@ func TestList(t *testing.T) {
|
||||||
if tc.expErr {
|
if tc.expErr {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if _, err := cmd.Do(command.Dependencies{
|
if err := cmd.Do(command.Dependencies{
|
||||||
TaskRepo: taskRepo,
|
TaskRepo: taskRepo,
|
||||||
LocalIDRepo: localRepo,
|
LocalIDRepo: localRepo,
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
|
|
|
@ -1,68 +1 @@
|
||||||
package command
|
package command
|
||||||
|
|
||||||
import (
|
|
||||||
"errors"
|
|
||||||
"fmt"
|
|
||||||
"strconv"
|
|
||||||
|
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
|
||||||
)
|
|
||||||
|
|
||||||
type ShowArgs struct {
|
|
||||||
localID int
|
|
||||||
}
|
|
||||||
|
|
||||||
func NewShowArgs() ShowArgs {
|
|
||||||
return ShowArgs{}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (sa ShowArgs) Parse(main []string, fields map[string]string) (Command, error) {
|
|
||||||
if len(main) != 1 {
|
|
||||||
return nil, ErrWrongCommand
|
|
||||||
}
|
|
||||||
lid, err := strconv.Atoi(main[0])
|
|
||||||
if err != nil {
|
|
||||||
return nil, ErrWrongCommand
|
|
||||||
}
|
|
||||||
|
|
||||||
return &Show{
|
|
||||||
args: ShowArgs{
|
|
||||||
localID: lid,
|
|
||||||
},
|
|
||||||
}, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
type Show struct {
|
|
||||||
args ShowArgs
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *Show) Do(deps Dependencies) ([][]string, error) {
|
|
||||||
id, err := deps.LocalIDRepo.FindOne(s.args.localID)
|
|
||||||
switch {
|
|
||||||
case errors.Is(err, storage.ErrNotFound):
|
|
||||||
return nil, fmt.Errorf("could not find local id")
|
|
||||||
case err != nil:
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
tsk, err := deps.TaskRepo.FindOne(id)
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("could not find task")
|
|
||||||
}
|
|
||||||
|
|
||||||
var recurStr string
|
|
||||||
if tsk.Recurrer != nil {
|
|
||||||
recurStr = tsk.Recurrer.String()
|
|
||||||
}
|
|
||||||
data := [][]string{
|
|
||||||
{"title", tsk.Title},
|
|
||||||
{"local id", fmt.Sprintf("%d", s.args.localID)},
|
|
||||||
{"date", tsk.Date.String()},
|
|
||||||
{"time", tsk.Time.String()},
|
|
||||||
{"duration", tsk.Duration.String()},
|
|
||||||
{"recur", recurStr},
|
|
||||||
// {"id", tsk.ID},
|
|
||||||
}
|
|
||||||
|
|
||||||
return data, nil
|
|
||||||
}
|
|
||||||
|
|
|
@ -1,86 +0,0 @@
|
||||||
package command_test
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"testing"
|
|
||||||
|
|
||||||
"github.com/google/go-cmp/cmp"
|
|
||||||
"go-mod.ewintr.nl/planner/item"
|
|
||||||
"go-mod.ewintr.nl/planner/plan/command"
|
|
||||||
"go-mod.ewintr.nl/planner/plan/storage/memory"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestShow(t *testing.T) {
|
|
||||||
t.Parallel()
|
|
||||||
|
|
||||||
taskRepo := memory.NewTask()
|
|
||||||
localRepo := memory.NewLocalID()
|
|
||||||
tsk := item.Task{
|
|
||||||
ID: "id",
|
|
||||||
Date: item.NewDate(2024, 10, 7),
|
|
||||||
TaskBody: item.TaskBody{
|
|
||||||
Title: "name",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
if err := taskRepo.Store(tsk); err != nil {
|
|
||||||
t.Errorf("exp nil, got %v", err)
|
|
||||||
}
|
|
||||||
if err := localRepo.Store(tsk.ID, 1); err != nil {
|
|
||||||
t.Errorf("exp nil, got %v", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, tc := range []struct {
|
|
||||||
name string
|
|
||||||
main []string
|
|
||||||
expData [][]string
|
|
||||||
expParseErr bool
|
|
||||||
expDoErr bool
|
|
||||||
}{
|
|
||||||
{
|
|
||||||
name: "empty",
|
|
||||||
main: []string{},
|
|
||||||
expParseErr: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "wrong",
|
|
||||||
main: []string{"delete"},
|
|
||||||
expParseErr: true,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "local id",
|
|
||||||
main: []string{"1"},
|
|
||||||
expData: [][]string{
|
|
||||||
{"title", tsk.Title},
|
|
||||||
{"local id", fmt.Sprintf("%d", 1)},
|
|
||||||
{"date", tsk.Date.String()},
|
|
||||||
{"time", tsk.Time.String()},
|
|
||||||
{"duration", tsk.Duration.String()},
|
|
||||||
{"recur", ""},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
} {
|
|
||||||
t.Run(tc.name, func(t *testing.T) {
|
|
||||||
cmd, actParseErr := command.NewShowArgs().Parse(tc.main, nil)
|
|
||||||
if tc.expParseErr != (actParseErr != nil) {
|
|
||||||
t.Errorf("exp %v, got %v", tc.expParseErr, actParseErr != nil)
|
|
||||||
}
|
|
||||||
if tc.expParseErr {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
actData, actDoErr := cmd.Do(command.Dependencies{
|
|
||||||
TaskRepo: taskRepo,
|
|
||||||
LocalIDRepo: localRepo,
|
|
||||||
})
|
|
||||||
if tc.expDoErr != (actDoErr != nil) {
|
|
||||||
t.Errorf("exp %v, got %v", tc.expDoErr, actDoErr != nil)
|
|
||||||
}
|
|
||||||
if tc.expDoErr {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
if diff := cmp.Diff(tc.expData, actData); diff != "" {
|
|
||||||
t.Errorf("(+exp, -got)%s\n", diff)
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
|
@ -25,37 +25,37 @@ func (sa SyncArgs) Parse(main []string, flags map[string]string) (Command, error
|
||||||
|
|
||||||
type Sync struct{}
|
type Sync struct{}
|
||||||
|
|
||||||
func (s *Sync) Do(deps Dependencies) ([][]string, error) {
|
func (s *Sync) Do(deps Dependencies) error {
|
||||||
// local new and updated
|
// local new and updated
|
||||||
sendItems, err := deps.SyncRepo.FindAll()
|
sendItems, err := deps.SyncRepo.FindAll()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not get updated items: %v", err)
|
return fmt.Errorf("could not get updated items: %v", err)
|
||||||
}
|
}
|
||||||
if err := deps.SyncClient.Update(sendItems); err != nil {
|
if err := deps.SyncClient.Update(sendItems); err != nil {
|
||||||
return nil, fmt.Errorf("could not send updated items: %v", err)
|
return fmt.Errorf("could not send updated items: %v", err)
|
||||||
}
|
}
|
||||||
if err := deps.SyncRepo.DeleteAll(); err != nil {
|
if err := deps.SyncRepo.DeleteAll(); err != nil {
|
||||||
return nil, fmt.Errorf("could not clear updated items: %v", err)
|
return fmt.Errorf("could not clear updated items: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// get new/updated items
|
// get new/updated items
|
||||||
ts, err := deps.SyncRepo.LastUpdate()
|
ts, err := deps.SyncRepo.LastUpdate()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not find timestamp of last update: %v", err)
|
return fmt.Errorf("could not find timestamp of last update: %v", err)
|
||||||
}
|
}
|
||||||
recItems, err := deps.SyncClient.Updated([]item.Kind{item.KindTask}, ts)
|
recItems, err := deps.SyncClient.Updated([]item.Kind{item.KindTask}, ts)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not receive updates: %v", err)
|
return fmt.Errorf("could not receive updates: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
updated := make([]item.Item, 0)
|
updated := make([]item.Item, 0)
|
||||||
for _, ri := range recItems {
|
for _, ri := range recItems {
|
||||||
if ri.Deleted {
|
if ri.Deleted {
|
||||||
if err := deps.LocalIDRepo.Delete(ri.ID); err != nil && !errors.Is(err, storage.ErrNotFound) {
|
if err := deps.LocalIDRepo.Delete(ri.ID); err != nil && !errors.Is(err, storage.ErrNotFound) {
|
||||||
return nil, fmt.Errorf("could not delete local id: %v", err)
|
return fmt.Errorf("could not delete local id: %v", err)
|
||||||
}
|
}
|
||||||
if err := deps.TaskRepo.Delete(ri.ID); err != nil && !errors.Is(err, storage.ErrNotFound) {
|
if err := deps.TaskRepo.Delete(ri.ID); err != nil && !errors.Is(err, storage.ErrNotFound) {
|
||||||
return nil, fmt.Errorf("could not delete task: %v", err)
|
return fmt.Errorf("could not delete task: %v", err)
|
||||||
}
|
}
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
@ -64,12 +64,12 @@ func (s *Sync) Do(deps Dependencies) ([][]string, error) {
|
||||||
|
|
||||||
lidMap, err := deps.LocalIDRepo.FindAll()
|
lidMap, err := deps.LocalIDRepo.FindAll()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not get local ids: %v", err)
|
return fmt.Errorf("could not get local ids: %v", err)
|
||||||
}
|
}
|
||||||
for _, u := range updated {
|
for _, u := range updated {
|
||||||
var tskBody item.TaskBody
|
var tskBody item.TaskBody
|
||||||
if err := json.Unmarshal([]byte(u.Body), &tskBody); err != nil {
|
if err := json.Unmarshal([]byte(u.Body), &tskBody); err != nil {
|
||||||
return nil, fmt.Errorf("could not unmarshal task body: %v", err)
|
return fmt.Errorf("could not unmarshal task body: %v", err)
|
||||||
}
|
}
|
||||||
tsk := item.Task{
|
tsk := item.Task{
|
||||||
ID: u.ID,
|
ID: u.ID,
|
||||||
|
@ -79,20 +79,20 @@ func (s *Sync) Do(deps Dependencies) ([][]string, error) {
|
||||||
TaskBody: tskBody,
|
TaskBody: tskBody,
|
||||||
}
|
}
|
||||||
if err := deps.TaskRepo.Store(tsk); err != nil {
|
if err := deps.TaskRepo.Store(tsk); err != nil {
|
||||||
return nil, fmt.Errorf("could not store task: %v", err)
|
return fmt.Errorf("could not store task: %v", err)
|
||||||
}
|
}
|
||||||
lid, ok := lidMap[u.ID]
|
lid, ok := lidMap[u.ID]
|
||||||
if !ok {
|
if !ok {
|
||||||
lid, err = deps.LocalIDRepo.Next()
|
lid, err = deps.LocalIDRepo.Next()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not get next local id: %v", err)
|
return fmt.Errorf("could not get next local id: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := deps.LocalIDRepo.Store(u.ID, lid); err != nil {
|
if err := deps.LocalIDRepo.Store(u.ID, lid); err != nil {
|
||||||
return nil, fmt.Errorf("could not store local id: %v", err)
|
return fmt.Errorf("could not store local id: %v", err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil, nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -7,7 +7,6 @@ import (
|
||||||
"github.com/google/go-cmp/cmp"
|
"github.com/google/go-cmp/cmp"
|
||||||
"go-mod.ewintr.nl/planner/item"
|
"go-mod.ewintr.nl/planner/item"
|
||||||
"go-mod.ewintr.nl/planner/plan/command"
|
"go-mod.ewintr.nl/planner/plan/command"
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
|
||||||
"go-mod.ewintr.nl/planner/plan/storage/memory"
|
"go-mod.ewintr.nl/planner/plan/storage/memory"
|
||||||
"go-mod.ewintr.nl/planner/sync/client"
|
"go-mod.ewintr.nl/planner/sync/client"
|
||||||
)
|
)
|
||||||
|
@ -81,7 +80,7 @@ func TestSyncSend(t *testing.T) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("exp nil, got %v", err)
|
t.Errorf("exp nil, got %v", err)
|
||||||
}
|
}
|
||||||
if _, err := cmd.Do(command.Dependencies{
|
if err := cmd.Do(command.Dependencies{
|
||||||
TaskRepo: taskRepo,
|
TaskRepo: taskRepo,
|
||||||
LocalIDRepo: localIDRepo,
|
LocalIDRepo: localIDRepo,
|
||||||
SyncRepo: syncRepo,
|
SyncRepo: syncRepo,
|
||||||
|
@ -207,7 +206,7 @@ func TestSyncReceive(t *testing.T) {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("exp nil, got %v", err)
|
t.Errorf("exp nil, got %v", err)
|
||||||
}
|
}
|
||||||
if _, err := cmd.Do(command.Dependencies{
|
if err := cmd.Do(command.Dependencies{
|
||||||
TaskRepo: taskRepo,
|
TaskRepo: taskRepo,
|
||||||
LocalIDRepo: localIDRepo,
|
LocalIDRepo: localIDRepo,
|
||||||
SyncRepo: syncRepo,
|
SyncRepo: syncRepo,
|
||||||
|
@ -217,7 +216,7 @@ func TestSyncReceive(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// check result
|
// check result
|
||||||
actTasks, err := taskRepo.FindMany(storage.TaskListParams{})
|
actTasks, err := taskRepo.FindAll()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("exp nil, got %v", err)
|
t.Errorf("exp nil, got %v", err)
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,14 +1,12 @@
|
||||||
package command
|
package command
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"go-mod.ewintr.nl/planner/item"
|
"go-mod.ewintr.nl/planner/item"
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type UpdateArgs struct {
|
type UpdateArgs struct {
|
||||||
|
@ -85,18 +83,24 @@ type Update struct {
|
||||||
args UpdateArgs
|
args UpdateArgs
|
||||||
}
|
}
|
||||||
|
|
||||||
func (u *Update) Do(deps Dependencies) ([][]string, error) {
|
func (u *Update) Do(deps Dependencies) error {
|
||||||
id, err := deps.LocalIDRepo.FindOne(u.args.LocalID)
|
var id string
|
||||||
switch {
|
idMap, err := deps.LocalIDRepo.FindAll()
|
||||||
case errors.Is(err, storage.ErrNotFound):
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not find local id")
|
return fmt.Errorf("could not get local ids: %v", err)
|
||||||
case err != nil:
|
}
|
||||||
return nil, err
|
for tid, lid := range idMap {
|
||||||
|
if u.args.LocalID == lid {
|
||||||
|
id = tid
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if id == "" {
|
||||||
|
return fmt.Errorf("could not find local id")
|
||||||
}
|
}
|
||||||
|
|
||||||
tsk, err := deps.TaskRepo.FindOne(id)
|
tsk, err := deps.TaskRepo.Find(id)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not find task")
|
return fmt.Errorf("could not find task")
|
||||||
}
|
}
|
||||||
|
|
||||||
if u.args.Title != "" {
|
if u.args.Title != "" {
|
||||||
|
@ -117,20 +121,20 @@ func (u *Update) Do(deps Dependencies) ([][]string, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
if !tsk.Valid() {
|
if !tsk.Valid() {
|
||||||
return nil, fmt.Errorf("task is unvalid")
|
return fmt.Errorf("task is unvalid")
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := deps.TaskRepo.Store(tsk); err != nil {
|
if err := deps.TaskRepo.Store(tsk); err != nil {
|
||||||
return nil, fmt.Errorf("could not store task: %v", err)
|
return fmt.Errorf("could not store task: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
it, err := tsk.Item()
|
it, err := tsk.Item()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("could not convert task to sync item: %v", err)
|
return fmt.Errorf("could not convert task to sync item: %v", err)
|
||||||
}
|
}
|
||||||
if err := deps.SyncRepo.Store(it); err != nil {
|
if err := deps.SyncRepo.Store(it); err != nil {
|
||||||
return nil, fmt.Errorf("could not store sync item: %v", err)
|
return fmt.Errorf("could not store sync item: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil, nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -189,19 +189,19 @@ func TestUpdateExecute(t *testing.T) {
|
||||||
if tc.expParseErr {
|
if tc.expParseErr {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
_, actDoErr := cmd.Do(command.Dependencies{
|
actDoErr := cmd.Do(command.Dependencies{
|
||||||
TaskRepo: taskRepo,
|
TaskRepo: taskRepo,
|
||||||
LocalIDRepo: localIDRepo,
|
LocalIDRepo: localIDRepo,
|
||||||
SyncRepo: syncRepo,
|
SyncRepo: syncRepo,
|
||||||
})
|
}) != nil
|
||||||
if tc.expDoErr != (actDoErr != nil) {
|
if tc.expDoErr != actDoErr {
|
||||||
t.Errorf("exp %v, got %v", tc.expDoErr, actDoErr)
|
t.Errorf("exp %v, got %v", tc.expDoErr, actDoErr)
|
||||||
}
|
}
|
||||||
if tc.expDoErr {
|
if tc.expDoErr {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
actTask, err := taskRepo.FindOne(tskID)
|
actTask, err := taskRepo.Find(tskID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("exp nil, got %v", err)
|
t.Errorf("exp nil, got %v", err)
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,97 +0,0 @@
|
||||||
package format
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"os"
|
|
||||||
"os/exec"
|
|
||||||
"strconv"
|
|
||||||
"strings"
|
|
||||||
)
|
|
||||||
|
|
||||||
func Table(data [][]string) string {
|
|
||||||
if len(data) == 0 {
|
|
||||||
return ""
|
|
||||||
}
|
|
||||||
|
|
||||||
// make all cells in a column the same width
|
|
||||||
max := make([]int, len(data[0]))
|
|
||||||
for _, row := range data {
|
|
||||||
for c, cell := range row {
|
|
||||||
if len(cell) > max[c] {
|
|
||||||
max[c] = len(cell)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for r, row := range data {
|
|
||||||
for c, cell := range row {
|
|
||||||
for s := len(cell); s < max[c]; s++ {
|
|
||||||
data[r][c] += " "
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// make it smaller if the result is too wide
|
|
||||||
// only by making the widest column smaller for now
|
|
||||||
maxWidth := findTermWidth()
|
|
||||||
if maxWidth != 0 {
|
|
||||||
width := len(max) - 1
|
|
||||||
for _, m := range max {
|
|
||||||
width += m
|
|
||||||
}
|
|
||||||
shortenWith := width - maxWidth
|
|
||||||
widestColNo, widestColLen := 0, 0
|
|
||||||
for i, m := range max {
|
|
||||||
if m > widestColLen {
|
|
||||||
widestColNo, widestColLen = i, m
|
|
||||||
}
|
|
||||||
}
|
|
||||||
newTaskColWidth := max[widestColNo] - shortenWith
|
|
||||||
if newTaskColWidth < 0 {
|
|
||||||
return "table is too wide to display\n"
|
|
||||||
}
|
|
||||||
if newTaskColWidth < max[widestColNo] {
|
|
||||||
for r, row := range data {
|
|
||||||
data[r][widestColNo] = row[widestColNo][:newTaskColWidth]
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// print the rows
|
|
||||||
var output string
|
|
||||||
for r, row := range data {
|
|
||||||
if r%3 == 0 {
|
|
||||||
output += fmt.Sprintf("%s", "\x1b[48;5;237m")
|
|
||||||
}
|
|
||||||
for c, col := range row {
|
|
||||||
output += col
|
|
||||||
if c != len(row)-1 {
|
|
||||||
output += " "
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if r%3 == 0 {
|
|
||||||
output += fmt.Sprintf("%s", "\x1b[49m")
|
|
||||||
}
|
|
||||||
output += "\n"
|
|
||||||
}
|
|
||||||
|
|
||||||
return output
|
|
||||||
}
|
|
||||||
|
|
||||||
func findTermWidth() int {
|
|
||||||
cmd := exec.Command("stty", "size")
|
|
||||||
cmd.Stdin = os.Stdin
|
|
||||||
out, err := cmd.Output()
|
|
||||||
if err != nil {
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
|
|
||||||
s := string(out)
|
|
||||||
s = strings.TrimSpace(s)
|
|
||||||
sArr := strings.Split(s, " ")
|
|
||||||
|
|
||||||
width, err := strconv.Atoi(sArr[1])
|
|
||||||
if err != nil {
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
return width
|
|
||||||
}
|
|
|
@ -18,19 +18,6 @@ func NewLocalID() *LocalID {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (ml *LocalID) FindOne(lid int) (string, error) {
|
|
||||||
ml.mutex.RLock()
|
|
||||||
defer ml.mutex.RUnlock()
|
|
||||||
|
|
||||||
for id, l := range ml.ids {
|
|
||||||
if lid == l {
|
|
||||||
return id, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return "", storage.ErrNotFound
|
|
||||||
}
|
|
||||||
|
|
||||||
func (ml *LocalID) FindAll() (map[string]int, error) {
|
func (ml *LocalID) FindAll() (map[string]int, error) {
|
||||||
ml.mutex.RLock()
|
ml.mutex.RLock()
|
||||||
defer ml.mutex.RUnlock()
|
defer ml.mutex.RUnlock()
|
||||||
|
|
|
@ -54,21 +54,6 @@ func TestLocalID(t *testing.T) {
|
||||||
t.Errorf("exp 2, got %v", actLid)
|
t.Errorf("exp 2, got %v", actLid)
|
||||||
}
|
}
|
||||||
|
|
||||||
t.Log("find by local id")
|
|
||||||
actID, actErr := repo.FindOne(1)
|
|
||||||
if actErr != nil {
|
|
||||||
t.Errorf("exp nil, got %v", actErr)
|
|
||||||
}
|
|
||||||
if actID != "test" {
|
|
||||||
t.Errorf("exp test, got %v", actID)
|
|
||||||
}
|
|
||||||
|
|
||||||
t.Log("unknown local id")
|
|
||||||
actID, actErr = repo.FindOne(2)
|
|
||||||
if !errors.Is(actErr, storage.ErrNotFound) {
|
|
||||||
t.Errorf("exp ErrNotFound, got %v", actErr)
|
|
||||||
}
|
|
||||||
|
|
||||||
actIDs, actErr = repo.FindAll()
|
actIDs, actErr = repo.FindAll()
|
||||||
if actErr != nil {
|
if actErr != nil {
|
||||||
t.Errorf("exp nil, got %v", actErr)
|
t.Errorf("exp nil, got %v", actErr)
|
||||||
|
|
|
@ -19,7 +19,7 @@ func NewTask() *Task {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *Task) FindOne(id string) (item.Task, error) {
|
func (t *Task) Find(id string) (item.Task, error) {
|
||||||
t.mutex.RLock()
|
t.mutex.RLock()
|
||||||
defer t.mutex.RUnlock()
|
defer t.mutex.RUnlock()
|
||||||
|
|
||||||
|
@ -30,15 +30,13 @@ func (t *Task) FindOne(id string) (item.Task, error) {
|
||||||
return task, nil
|
return task, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *Task) FindMany(params storage.TaskListParams) ([]item.Task, error) {
|
func (t *Task) FindAll() ([]item.Task, error) {
|
||||||
t.mutex.RLock()
|
t.mutex.RLock()
|
||||||
defer t.mutex.RUnlock()
|
defer t.mutex.RUnlock()
|
||||||
|
|
||||||
tasks := make([]item.Task, 0, len(t.tasks))
|
tasks := make([]item.Task, 0, len(t.tasks))
|
||||||
for _, tsk := range t.tasks {
|
for _, tsk := range t.tasks {
|
||||||
if storage.Match(tsk, params) {
|
tasks = append(tasks, tsk)
|
||||||
tasks = append(tasks, tsk)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
sort.Slice(tasks, func(i, j int) bool {
|
sort.Slice(tasks, func(i, j int) bool {
|
||||||
return tasks[i].ID < tasks[j].ID
|
return tasks[i].ID < tasks[j].ID
|
||||||
|
|
|
@ -4,7 +4,6 @@ import (
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"go-mod.ewintr.nl/planner/item"
|
"go-mod.ewintr.nl/planner/item"
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestTask(t *testing.T) {
|
func TestTask(t *testing.T) {
|
||||||
|
@ -13,7 +12,7 @@ func TestTask(t *testing.T) {
|
||||||
mem := NewTask()
|
mem := NewTask()
|
||||||
|
|
||||||
t.Log("empty")
|
t.Log("empty")
|
||||||
actTasks, actErr := mem.FindMany(storage.TaskListParams{})
|
actTasks, actErr := mem.FindAll()
|
||||||
if actErr != nil {
|
if actErr != nil {
|
||||||
t.Errorf("exp nil, got %v", actErr)
|
t.Errorf("exp nil, got %v", actErr)
|
||||||
}
|
}
|
||||||
|
@ -37,7 +36,7 @@ func TestTask(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
t.Log("find one")
|
t.Log("find one")
|
||||||
actTask, actErr := mem.FindOne(tsk1.ID)
|
actTask, actErr := mem.Find(tsk1.ID)
|
||||||
if actErr != nil {
|
if actErr != nil {
|
||||||
t.Errorf("exp nil, got %v", actErr)
|
t.Errorf("exp nil, got %v", actErr)
|
||||||
}
|
}
|
||||||
|
@ -46,7 +45,7 @@ func TestTask(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
t.Log("find all")
|
t.Log("find all")
|
||||||
actTasks, actErr = mem.FindMany(storage.TaskListParams{})
|
actTasks, actErr = mem.FindAll()
|
||||||
if actErr != nil {
|
if actErr != nil {
|
||||||
t.Errorf("exp nil, got %v", actErr)
|
t.Errorf("exp nil, got %v", actErr)
|
||||||
}
|
}
|
||||||
|
|
|
@ -2,7 +2,6 @@ package sqlite
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
"go-mod.ewintr.nl/planner/plan/storage"
|
||||||
|
@ -12,23 +11,6 @@ type LocalID struct {
|
||||||
db *sql.DB
|
db *sql.DB
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *LocalID) FindOne(lid int) (string, error) {
|
|
||||||
var id string
|
|
||||||
err := l.db.QueryRow(`
|
|
||||||
SELECT id
|
|
||||||
FROM localids
|
|
||||||
WHERE local_id = ?
|
|
||||||
`, lid).Scan(&id)
|
|
||||||
switch {
|
|
||||||
case errors.Is(err, sql.ErrNoRows):
|
|
||||||
return "", storage.ErrNotFound
|
|
||||||
case err != nil:
|
|
||||||
return "", fmt.Errorf("%w: %v", ErrSqliteFailure, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
return id, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (l *LocalID) FindAll() (map[string]int, error) {
|
func (l *LocalID) FindAll() (map[string]int, error) {
|
||||||
rows, err := l.db.Query(`
|
rows, err := l.db.Query(`
|
||||||
SELECT id, local_id
|
SELECT id, local_id
|
||||||
|
|
|
@ -38,7 +38,7 @@ recurrer=?
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *SqliteTask) FindOne(id string) (item.Task, error) {
|
func (t *SqliteTask) Find(id string) (item.Task, error) {
|
||||||
var tsk item.Task
|
var tsk item.Task
|
||||||
var dateStr, timeStr, recurStr, durStr string
|
var dateStr, timeStr, recurStr, durStr string
|
||||||
err := t.db.QueryRow(`
|
err := t.db.QueryRow(`
|
||||||
|
@ -63,7 +63,7 @@ WHERE id = ?`, id).Scan(&tsk.ID, &tsk.Title, &dateStr, &timeStr, &durStr, &recur
|
||||||
return tsk, nil
|
return tsk, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *SqliteTask) FindMany(params storage.TaskListParams) ([]item.Task, error) {
|
func (t *SqliteTask) FindAll() ([]item.Task, error) {
|
||||||
rows, err := t.db.Query(`
|
rows, err := t.db.Query(`
|
||||||
SELECT id, title, date, time, duration, recurrer
|
SELECT id, title, date, time, duration, recurrer
|
||||||
FROM tasks`)
|
FROM tasks`)
|
||||||
|
|
|
@ -13,7 +13,6 @@ var (
|
||||||
)
|
)
|
||||||
|
|
||||||
type LocalID interface {
|
type LocalID interface {
|
||||||
FindOne(lid int) (string, error)
|
|
||||||
FindAll() (map[string]int, error)
|
FindAll() (map[string]int, error)
|
||||||
FindOrNext(id string) (int, error)
|
FindOrNext(id string) (int, error)
|
||||||
Next() (int, error)
|
Next() (int, error)
|
||||||
|
@ -28,29 +27,13 @@ type Sync interface {
|
||||||
LastUpdate() (time.Time, error)
|
LastUpdate() (time.Time, error)
|
||||||
}
|
}
|
||||||
|
|
||||||
type TaskListParams struct {
|
|
||||||
Recurrer bool
|
|
||||||
Date item.Date
|
|
||||||
}
|
|
||||||
|
|
||||||
type Task interface {
|
type Task interface {
|
||||||
Store(task item.Task) error
|
Store(task item.Task) error
|
||||||
FindOne(id string) (item.Task, error)
|
Find(id string) (item.Task, error)
|
||||||
FindMany(params TaskListParams) ([]item.Task, error)
|
FindAll() ([]item.Task, error)
|
||||||
Delete(id string) error
|
Delete(id string) error
|
||||||
}
|
}
|
||||||
|
|
||||||
func Match(tsk item.Task, req TaskListParams) bool {
|
|
||||||
if req.Recurrer && tsk.Recurrer == nil {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
if !req.Date.IsZero() && !req.Date.Equal(tsk.Date) {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
return true
|
|
||||||
}
|
|
||||||
|
|
||||||
func NextLocalID(used []int) int {
|
func NextLocalID(used []int) int {
|
||||||
if len(used) == 0 {
|
if len(used) == 0 {
|
||||||
return 1
|
return 1
|
||||||
|
|
|
@ -3,60 +3,10 @@ package storage_test
|
||||||
import (
|
import (
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"go-mod.ewintr.nl/planner/item"
|
|
||||||
"go-mod.ewintr.nl/planner/plan/storage"
|
"go-mod.ewintr.nl/planner/plan/storage"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestMatch(t *testing.T) {
|
|
||||||
t.Parallel()
|
|
||||||
|
|
||||||
tskMatch := item.Task{
|
|
||||||
ID: "id",
|
|
||||||
Date: item.NewDate(2024, 12, 29),
|
|
||||||
Recurrer: item.NewRecurrer("2024-12-29, daily"),
|
|
||||||
TaskBody: item.TaskBody{
|
|
||||||
Title: "name",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
tskNotMatch := item.Task{
|
|
||||||
ID: "id",
|
|
||||||
Date: item.NewDate(2024, 12, 28),
|
|
||||||
TaskBody: item.TaskBody{
|
|
||||||
Title: "name",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, tc := range []struct {
|
|
||||||
name string
|
|
||||||
params storage.TaskListParams
|
|
||||||
}{
|
|
||||||
{
|
|
||||||
name: "date",
|
|
||||||
params: storage.TaskListParams{
|
|
||||||
Date: item.NewDate(2024, 12, 29),
|
|
||||||
},
|
|
||||||
},
|
|
||||||
{
|
|
||||||
name: "recurrer",
|
|
||||||
params: storage.TaskListParams{
|
|
||||||
Recurrer: true,
|
|
||||||
},
|
|
||||||
},
|
|
||||||
} {
|
|
||||||
t.Run(tc.name, func(t *testing.T) {
|
|
||||||
if !storage.Match(tskMatch, tc.params) {
|
|
||||||
t.Errorf("exp tsk to match")
|
|
||||||
}
|
|
||||||
if storage.Match(tskNotMatch, tc.params) {
|
|
||||||
t.Errorf("exp tsk to not match")
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestNextLocalId(t *testing.T) {
|
func TestNextLocalId(t *testing.T) {
|
||||||
t.Parallel()
|
|
||||||
|
|
||||||
for _, tc := range []struct {
|
for _, tc := range []struct {
|
||||||
name string
|
name string
|
||||||
used []int
|
used []int
|
||||||
|
|
Loading…
Reference in New Issue