commit d33c32c5edcd1614d473143b9c780d598d3774e1 Author: Ian Gulliver Date: Thu Jul 3 23:12:44 2025 -0700 Initial simply library diff --git a/go.mod b/go.mod new file mode 100644 index 0000000..5a91541 --- /dev/null +++ b/go.mod @@ -0,0 +1,14 @@ +module github.com/gopatchy/taskcp + +go 1.24.4 + +require ( + github.com/google/uuid v1.6.0 + github.com/stretchr/testify v1.10.0 +) + +require ( + github.com/davecgh/go-spew v1.1.1 // indirect + github.com/pmezard/go-difflib v1.0.0 // indirect + gopkg.in/yaml.v3 v3.0.1 // indirect +) diff --git a/go.sum b/go.sum new file mode 100644 index 0000000..14c872b --- /dev/null +++ b/go.sum @@ -0,0 +1,12 @@ +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= +github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA= +github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= +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/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/taskcp.go b/taskcp.go new file mode 100644 index 0000000..3b1bef9 --- /dev/null +++ b/taskcp.go @@ -0,0 +1,123 @@ +package taskcp + +import ( + "fmt" + "iter" + + "github.com/google/uuid" +) + +type Service struct { + Projects map[string]*Project +} + +type Project struct { + ID string + Tasks map[string]*Task + NextTaskID string +} + +type TaskState string + +const ( + TaskStatePending TaskState = "pending" + TaskStateRunning TaskState = "running" + TaskStateSuccess TaskState = "success" + TaskStateFailure TaskState = "failure" +) + +type Task struct { + ID string + State TaskState + NextTaskID string + ChangeCallback func(task *Task) + + // Written by creator + Instructions string + + // Written by executor + Result string + Error string + Notes string +} + +func New() *Service { + return &Service{ + Projects: map[string]*Project{}, + } +} + +func (s *Service) AddProject() *Project { + project := &Project{ + ID: uuid.New().String(), + Tasks: map[string]*Task{}, + NextTaskID: "", + } + s.Projects[project.ID] = project + return project +} + +func (s *Service) GetProject(id string) (*Project, error) { + project, ok := s.Projects[id] + if !ok { + return nil, fmt.Errorf("project not found") + } + return project, nil +} + +func (p *Project) InsertTaskBefore(id string, instructions string, changeCallback func(task *Task)) *Task { + task := p.newTask(instructions, changeCallback, id) + + for t := range p.tasks() { + if t.NextTaskID == id { + t.NextTaskID = task.ID + break + } + } + + return task +} + +func (p *Project) GetNextTask() *Task { + return p.Tasks[p.NextTaskID] +} + +func (p *Project) SetTaskSuccess(id string, result string, notes string) { + task := p.Tasks[id] + task.State = TaskStateSuccess + task.Result = result + task.Notes = notes + task.ChangeCallback(task) + p.NextTaskID = task.NextTaskID +} + +func (p *Project) SetTaskFailure(id string, error string, notes string) { + task := p.Tasks[id] + task.State = TaskStateFailure + task.Error = error + task.Notes = notes + task.ChangeCallback(task) +} + +func (p *Project) newTask(instructions string, changeCallback func(task *Task), nextTaskID string) *Task { + task := &Task{ + ID: uuid.New().String(), + State: TaskStatePending, + NextTaskID: nextTaskID, + Instructions: instructions, + ChangeCallback: changeCallback, + } + p.Tasks[task.ID] = task + return task +} + +func (p *Project) tasks() iter.Seq[*Task] { + return func(yield func(*Task) bool) { + for tid := p.NextTaskID; tid != ""; tid = p.Tasks[tid].NextTaskID { + t := p.Tasks[tid] + if !yield(t) { + return + } + } + } +} diff --git a/taskcp_test.go b/taskcp_test.go new file mode 100644 index 0000000..8e8257e --- /dev/null +++ b/taskcp_test.go @@ -0,0 +1,25 @@ +package taskcp_test + +import ( + "testing" + + "github.com/gopatchy/taskcp" + "github.com/stretchr/testify/require" +) + +func TestTaskCP(t *testing.T) { + tcp := taskcp.New() + + p := tcp.AddProject() + require.NotNil(t, p) + + tk := p.InsertTaskBefore(p.NextTaskID, "Hello, world!", func(task *taskcp.Task) { + t.Logf("Task %s changed: %+v", task.ID, task) + }) + require.NotNil(t, tk) + + p.SetTaskSuccess(tk.ID, "Hello, world!", "Notes") + require.Equal(t, taskcp.TaskStateSuccess, tk.State) + require.Equal(t, "Hello, world!", tk.Result) + require.Equal(t, "Notes", tk.Notes) +}