core/go-devops
8
0
Fork 0
Code Issues 4 Pull requests Projects Releases Packages Wiki Activity Actions

refactor: swap pkg/framework imports to pkg/core

Browse source 
Co-Authored-By: Virgil <virgil@lethean.io>
This commit is contained in:
Snider 2026-03-06 14:11:01 +00:00
parent 3fcefd5edc
commit 5a0aee4b2b
2 changed files with 18 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
cmd/dev/cmd_bundles.go
View file

@ -4,13 +4,13 @@ import (
"context"
"forge.lthn.ai/core/go-agentic"
"forge.lthn.ai/core/go/pkg/framework"
"forge.lthn.ai/core/go/pkg/core"
"forge.lthn.ai/core/go-scm/git"
)
// WorkBundle contains the Core instance for dev work operations.
type WorkBundle struct {
Core *framework.Core
Core *core.Core
}
// WorkBundleOptions configures the work bundle.
@ -22,15 +22,15 @@ type WorkBundleOptions struct {
// NewWorkBundle creates a bundle for dev work operations.
// Includes: dev (orchestration), git, agentic services.
func NewWorkBundle(opts WorkBundleOptions) (*WorkBundle, error) {
c, err := framework.New(
framework.WithService(NewService(ServiceOptions{
c, err := core.New(
core.WithService(NewService(ServiceOptions{
RegistryPath: opts.RegistryPath,
})),
framework.WithService(git.NewService(git.ServiceOptions{})),
framework.WithService(agentic.NewService(agentic.ServiceOptions{
core.WithService(git.NewService(git.ServiceOptions{})),
core.WithService(agentic.NewService(agentic.ServiceOptions{
AllowEdit: opts.AllowEdit,
})),
framework.WithServiceLock(),
core.WithServiceLock(),
)
if err != nil {
return nil, err
@ -51,7 +51,7 @@ func (b *WorkBundle) Stop(ctx context.Context) error {
// StatusBundle contains the Core instance for status-only operations.
type StatusBundle struct {
Core *framework.Core
Core *core.Core
}
// StatusBundleOptions configures the status bundle.
@ -62,11 +62,11 @@ type StatusBundleOptions struct {
// NewStatusBundle creates a bundle for status-only operations.
// Includes: dev (orchestration), git services. No agentic - commits not available.
func NewStatusBundle(opts StatusBundleOptions) (*StatusBundle, error) {
c, err := framework.New(
framework.WithService(NewService(ServiceOptions(opts))),
framework.WithService(git.NewService(git.ServiceOptions{})),
c, err := core.New(
core.WithService(NewService(ServiceOptions(opts))),
core.WithService(git.NewService(git.ServiceOptions{})),
// No agentic service - TaskCommit will be unhandled
framework.WithServiceLock(),
core.WithServiceLock(),
)
if err != nil {
return nil, err

12
cmd/dev/service.go
View file

@ -9,7 +9,7 @@ import (
"forge.lthn.ai/core/cli/pkg/cli"
"forge.lthn.ai/core/go-agentic"
"forge.lthn.ai/core/go-scm/git"
"forge.lthn.ai/core/go/pkg/framework"
"forge.lthn.ai/core/go/pkg/core"
)
// Tasks for dev service
@ -34,14 +34,14 @@ type ServiceOptions struct {
// Service provides dev workflow orchestration as a Core service.
type Service struct {
*framework.ServiceRuntime[ServiceOptions]
*core.ServiceRuntime[ServiceOptions]
}
// NewService creates a dev service factory.
func NewService(opts ServiceOptions) func(*framework.Core) (any, error) {
return func(c *framework.Core) (any, error) {
func NewService(opts ServiceOptions) func(*core.Core) (any, error) {
return func(c *core.Core) (any, error) {
return &Service{
ServiceRuntime: framework.NewServiceRuntime(c, opts),
ServiceRuntime: core.NewServiceRuntime(c, opts),
}, nil
}
}
@ -52,7 +52,7 @@ func (s *Service) OnStartup(ctx context.Context) error {
return nil
}
func (s *Service) handleTask(c *framework.Core, t framework.Task) (any, bool, error) {
func (s *Service) handleTask(c *core.Core, t core.Task) (any, bool, error) {
switch m := t.(type) {
case TaskWork:
err := s.runWork(m)