feat(v0.8.0): Result-native process service

- Register factory returns core.Result
- OnStartup/OnShutdown return core.Result
- Start/StartWithOptions/Run/RunWithOptions all return core.Result
- 5 named Action handlers (process.run/start/kill/list/get)
- core.ID() replaces fmt.Sprintf for process IDs
- core.As replaces errors.As, core.Sprintf replaces fmt.Sprintf
- handleRun returns output as Value (string) always, OK = exit 0

Co-Authored-By: Virgil <virgil@lethean.io>

Author: Snider

global_test.go

@@ -11,7 +11,6 @@ import (
 )
 
 func TestGlobal_DefaultNotInitialized(t *testing.T) {
-	// Reset global state for this test
 	old := defaultService.Swap(nil)
 	defer func() {
 		if old != nil {
@@ -21,13 +20,13 @@ func TestGlobal_DefaultNotInitialized(t *testing.T) {
 
 	assert.Nil(t, Default())
 
-	_, err := Start(context.Background(), "echo", "test")
-	assert.ErrorIs(t, err, ErrServiceNotInitialized)
+	r := Start(context.Background(), "echo", "test")
+	assert.False(t, r.OK)
 
-	_, err = Run(context.Background(), "echo", "test")
-	assert.ErrorIs(t, err, ErrServiceNotInitialized)
+	r = Run(context.Background(), "echo", "test")
+	assert.False(t, r.OK)
 
-	_, err = Get("proc-1")
+	_, err := Get("proc-1")
 	assert.ErrorIs(t, err, ErrServiceNotInitialized)
 
 	assert.Nil(t, List())
@@ -36,11 +35,11 @@ func TestGlobal_DefaultNotInitialized(t *testing.T) {
 	err = Kill("proc-1")
 	assert.ErrorIs(t, err, ErrServiceNotInitialized)
 
-	_, err = StartWithOptions(context.Background(), RunOptions{Command: "echo"})
-	assert.ErrorIs(t, err, ErrServiceNotInitialized)
+	r = StartWithOptions(context.Background(), RunOptions{Command: "echo"})
+	assert.False(t, r.OK)
 
-	_, err = RunWithOptions(context.Background(), RunOptions{Command: "echo"})
-	assert.ErrorIs(t, err, ErrServiceNotInitialized)
+	r = RunWithOptions(context.Background(), RunOptions{Command: "echo"})
+	assert.False(t, r.OK)
 }
 
 func newGlobalTestService(t *testing.T) *Service {
@@ -62,7 +61,6 @@ func TestGlobal_SetDefault(t *testing.T) {
 		}()
 
 		svc := newGlobalTestService(t)
-
 		err := SetDefault(svc)
 		require.NoError(t, err)
 		assert.Equal(t, svc, Default())
@@ -83,7 +81,6 @@ func TestGlobal_ConcurrentDefault(t *testing.T) {
 	}()
 
 	svc := newGlobalTestService(t)
-
 	err := SetDefault(svc)
 	require.NoError(t, err)
 
@@ -146,7 +143,6 @@ func TestGlobal_ConcurrentOperations(t *testing.T) {
 	}()
 
 	svc := newGlobalTestService(t)
-
 	err := SetDefault(svc)
 	require.NoError(t, err)
 
@@ -158,10 +154,10 @@ func TestGlobal_ConcurrentOperations(t *testing.T) {
 		wg.Add(1)
 		go func() {
 			defer wg.Done()
-			proc, err := Start(context.Background(), "echo", "concurrent")
-			if err == nil {
+			r := Start(context.Background(), "echo", "concurrent")
+			if r.OK {
 				procMu.Lock()
-				processes = append(processes, proc)
+				processes = append(processes, r.Value.(*Process))
 				procMu.Unlock()
 			}
 		}()
@@ -201,47 +197,44 @@ func TestGlobal_ConcurrentOperations(t *testing.T) {
 
 func TestGlobal_StartWithOptions(t *testing.T) {
 	svc, _ := newTestService(t)
-
 	old := defaultService.Swap(svc)
 	defer func() {
 		if old != nil {
 			defaultService.Store(old)
 		}
 	}()
 
-	proc, err := StartWithOptions(context.Background(), RunOptions{
+	r := StartWithOptions(context.Background(), RunOptions{
 		Command: "echo",
 		Args:    []string{"with", "options"},
 	})
-	require.NoError(t, err)
+	require.True(t, r.OK)
+	proc := r.Value.(*Process)
 
 	<-proc.Done()
-
 	assert.Equal(t, 0, proc.ExitCode)
 	assert.Contains(t, proc.Output(), "with options")
 }
 
 func TestGlobal_RunWithOptions(t *testing.T) {
 	svc, _ := newTestService(t)
-
 	old := defaultService.Swap(svc)
 	defer func() {
 		if old != nil {
 			defaultService.Store(old)
 		}
 	}()
 
-	output, err := RunWithOptions(context.Background(), RunOptions{
+	r := RunWithOptions(context.Background(), RunOptions{
 		Command: "echo",
 		Args:    []string{"run", "options"},
 	})
-	require.NoError(t, err)
-	assert.Contains(t, output, "run options")
+	assert.True(t, r.OK)
+	assert.Contains(t, r.Value.(string), "run options")
 }
 
 func TestGlobal_Running(t *testing.T) {
 	svc, _ := newTestService(t)
-
 	old := defaultService.Swap(svc)
 	defer func() {
 		if old != nil {
@@ -252,8 +245,9 @@ func TestGlobal_Running(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
 
-	proc, err := Start(ctx, "sleep", "60")
-	require.NoError(t, err)
+	r := Start(ctx, "sleep", "60")
+	require.True(t, r.OK)
+	proc := r.Value.(*Process)
 
 	running := Running()
 	assert.Len(t, running, 1)

go.mod

@@ -3,16 +3,21 @@ module dappco.re/go/core/process
 go 1.26.0
 
 require (
-	dappco.re/go/core v0.4.7
-	dappco.re/go/core/io v0.1.7
-	dappco.re/go/core/log v0.0.4
-	dappco.re/go/core/ws v0.2.4
+	dappco.re/go/core v0.5.0
+	dappco.re/go/core/io v0.2.0
+	dappco.re/go/core/log v0.1.0
+	dappco.re/go/core/ws v0.3.0
 	forge.lthn.ai/core/api v0.1.5
 	github.com/gin-gonic/gin v1.12.0
 	github.com/stretchr/testify v1.11.1
 )
 
 require (
+	dappco.re/go/core/api v0.2.0
+	dappco.re/go/core/i18n v0.2.0
+	dappco.re/go/core/process v0.3.0
+	dappco.re/go/core/scm v0.4.0
+	dappco.re/go/core/store v0.2.0
 	forge.lthn.ai/core/go-io v0.1.5 // indirect
 	forge.lthn.ai/core/go-log v0.0.4 // indirect
 	github.com/99designs/gqlgen v0.17.88 // indirect
@@ -108,10 +113,3 @@ require (
 	google.golang.org/protobuf v1.36.11 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )
-
-replace (
-	dappco.re/go/core => ../go
-	dappco.re/go/core/io => ../go-io
-	dappco.re/go/core/log => ../go-log
-	dappco.re/go/core/ws => ../go-ws
-)

process_global.go

@@ -50,19 +50,19 @@ func Init(c *core.Core) error {
 // --- Global convenience functions ---
 
 // Start spawns a new process using the default service.
-func Start(ctx context.Context, command string, args ...string) (*Process, error) {
+func Start(ctx context.Context, command string, args ...string) core.Result {
 	svc := Default()
 	if svc == nil {
-		return nil, ErrServiceNotInitialized
+		return core.Result{OK: false}
 	}
 	return svc.Start(ctx, command, args...)
 }
 
 // Run executes a command and waits for completion using the default service.
-func Run(ctx context.Context, command string, args ...string) (string, error) {
+func Run(ctx context.Context, command string, args ...string) core.Result {
 	svc := Default()
 	if svc == nil {
-		return "", ErrServiceNotInitialized
+		return core.Result{Value: "", OK: false}
 	}
 	return svc.Run(ctx, command, args...)
 }
@@ -95,19 +95,19 @@ func Kill(id string) error {
 }
 
 // StartWithOptions spawns a process with full configuration using the default service.
-func StartWithOptions(ctx context.Context, opts RunOptions) (*Process, error) {
+func StartWithOptions(ctx context.Context, opts RunOptions) core.Result {
 	svc := Default()
 	if svc == nil {
-		return nil, ErrServiceNotInitialized
+		return core.Result{OK: false}
 	}
 	return svc.StartWithOptions(ctx, opts)
 }
 
 // RunWithOptions executes a command with options and waits using the default service.
-func RunWithOptions(ctx context.Context, opts RunOptions) (string, error) {
+func RunWithOptions(ctx context.Context, opts RunOptions) core.Result {
 	svc := Default()
 	if svc == nil {
-		return "", ErrServiceNotInitialized
+		return core.Result{Value: "", OK: false}
 	}
 	return svc.RunWithOptions(ctx, opts)
 }