2dff772a40
Plans 1-5 complete for core/go scope. 456 tests, 84.4% coverage, 100% AX-7 naming.
Critical bugs (Plan 1):
- P4-3+P7-3: ACTION broadcast calls all handlers with panic recovery
- P7-2+P7-4: RunE() with defer ServiceShutdown, Run() delegates
- P3-1: Startable/Stoppable return Result (breaking, clean)
- P9-1: Zero os/exec — App.Find() rewritten with os.Stat+PATH
- I3: Embed() removed, I15: New() comment fixed
- I9: CommandLifecycle removed → Command.Managed field
Registry[T] (Plan 2):
- Universal thread-safe named collection with 3 lock modes
- All 5 registries migrated: services, commands, drive, data, lock
- Insertion order preserved (fixes P4-1)
- c.RegistryOf("name") cross-cutting accessor
Action/Task system (Plan 3):
- Action type with Run()/Exists(), ActionHandler signature
- c.Action("name") dual-purpose accessor (register/invoke)
- TaskDef with Steps — sequential chain, async dispatch, previous-input piping
- Panic recovery on all Action execution
- broadcast() internal, ACTION() sugar
Process primitive (Plan 4):
- c.Process() returns Action sugar — Run/RunIn/RunWithEnv/Start/Kill/Exists
- No deps added — delegates to c.Action("process.*")
- Permission-by-registration: no handler = no capability
Missing primitives (Plan 5):
- core.ID() — atomic counter + crypto/rand suffix
- ValidateName() / SanitisePath() — reusable validation
- Fs.WriteAtomic() — write-to-temp-then-rename
- Fs.NewUnrestricted() / Fs.Root() — legitimate sandbox bypass
- AX-7: 456/456 tests renamed to TestFile_Function_{Good,Bad,Ugly}
Co-Authored-By: Virgil <virgil@lethean.io>
59 lines
1.5 KiB
Go
59 lines
1.5 KiB
Go
// SPDX-License-Identifier: EUPL-1.2
|
|
|
|
// Drive is the resource handle registry for transport connections.
|
|
// Packages register their transport handles (API, MCP, SSH, VPN)
|
|
// and other packages access them by name.
|
|
//
|
|
// Register a transport:
|
|
//
|
|
// c.Drive().New(core.NewOptions(
|
|
// core.Option{Key: "name", Value: "api"},
|
|
// core.Option{Key: "transport", Value: "https://api.lthn.ai"},
|
|
// ))
|
|
// c.Drive().New(core.NewOptions(
|
|
// core.Option{Key: "name", Value: "ssh"},
|
|
// core.Option{Key: "transport", Value: "ssh://claude@10.69.69.165"},
|
|
// ))
|
|
// c.Drive().New(core.NewOptions(
|
|
// core.Option{Key: "name", Value: "mcp"},
|
|
// core.Option{Key: "transport", Value: "mcp://mcp.lthn.sh"},
|
|
// ))
|
|
//
|
|
// Retrieve a handle:
|
|
//
|
|
// api := c.Drive().Get("api")
|
|
package core
|
|
|
|
// DriveHandle holds a named transport resource.
|
|
type DriveHandle struct {
|
|
Name string
|
|
Transport string
|
|
Options Options
|
|
}
|
|
|
|
// Drive manages named transport handles. Embeds Registry[*DriveHandle].
|
|
type Drive struct {
|
|
*Registry[*DriveHandle]
|
|
}
|
|
|
|
// New registers a transport handle.
|
|
//
|
|
// c.Drive().New(core.NewOptions(
|
|
// core.Option{Key: "name", Value: "api"},
|
|
// core.Option{Key: "transport", Value: "https://api.lthn.ai"},
|
|
// ))
|
|
func (d *Drive) New(opts Options) Result {
|
|
name := opts.String("name")
|
|
if name == "" {
|
|
return Result{}
|
|
}
|
|
|
|
handle := &DriveHandle{
|
|
Name: name,
|
|
Transport: opts.String("transport"),
|
|
Options: opts,
|
|
}
|
|
|
|
d.Set(name, handle)
|
|
return Result{handle, true}
|
|
}
|