Initial simply library

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
+)

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=

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
+			}
+		}
+	}
+}

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)
+}