core/go-git
8
0
Fork 0
Code Issues 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:00 +00:00
parent 616c181efc
commit 27b6e5b9f8
2 changed files with 27 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
service.go
View file

@ -5,7 +5,7 @@ import (
"iter"
"slices"
"forge.lthn.ai/core/go/pkg/framework"
"forge.lthn.ai/core/go/pkg/core"
)
// Queries for git service
@ -49,15 +49,15 @@ type ServiceOptions struct {
// Service provides git operations as a Core service.
type Service struct {
*framework.ServiceRuntime[ServiceOptions]
*core.ServiceRuntime[ServiceOptions]
lastStatus []RepoStatus
}
// NewService creates a git 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
}
}
@ -69,7 +69,7 @@ func (s *Service) OnStartup(ctx context.Context) error {
return nil
}
func (s *Service) handleQuery(c *framework.Core, q framework.Query) (any, bool, error) {
func (s *Service) handleQuery(c *core.Core, q core.Query) (any, bool, error) {
switch m := q.(type) {
case QueryStatus:
statuses := Status(context.Background(), StatusOptions(m))
@ -85,7 +85,7 @@ func (s *Service) handleQuery(c *framework.Core, q framework.Query) (any, bool,
return nil, false, 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 TaskPush:
err := Push(context.Background(), m.Path)

40
service_extra_test.go
View file

@ -10,7 +10,7 @@ import (
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"forge.lthn.ai/core/go/pkg/framework"
"forge.lthn.ai/core/go/pkg/core"
)
func TestNewService_Good(t *testing.T) {
@ -19,7 +19,7 @@ func TestNewService_Good(t *testing.T) {
assert.NotNil(t, factory)
// Create a minimal Core to test the factory.
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc, err := factory(c)
@ -32,12 +32,12 @@ func TestNewService_Good(t *testing.T) {
}
func TestService_OnStartup_Good(t *testing.T) {
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
opts := ServiceOptions{WorkDir: "/tmp"}
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, opts),
ServiceRuntime: core.NewServiceRuntime(c, opts),
}
err = svc.OnStartup(context.Background())
@ -47,11 +47,11 @@ func TestService_OnStartup_Good(t *testing.T) {
func TestService_HandleQuery_Good_Status(t *testing.T) {
dir := initTestRepo(t)
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, ServiceOptions{}),
ServiceRuntime: core.NewServiceRuntime(c, ServiceOptions{}),
}
// Call handleQuery directly.
@ -73,11 +73,11 @@ func TestService_HandleQuery_Good_Status(t *testing.T) {
}
func TestService_HandleQuery_Good_DirtyRepos(t *testing.T) {
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, ServiceOptions{}),
ServiceRuntime: core.NewServiceRuntime(c, ServiceOptions{}),
lastStatus: []RepoStatus{
{Name: "clean"},
{Name: "dirty", Modified: 1},
@ -95,11 +95,11 @@ func TestService_HandleQuery_Good_DirtyRepos(t *testing.T) {
}
func TestService_HandleQuery_Good_AheadRepos(t *testing.T) {
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, ServiceOptions{}),
ServiceRuntime: core.NewServiceRuntime(c, ServiceOptions{}),
lastStatus: []RepoStatus{
{Name: "synced"},
{Name: "ahead", Ahead: 3},
@ -117,11 +117,11 @@ func TestService_HandleQuery_Good_AheadRepos(t *testing.T) {
}
func TestService_HandleQuery_Good_UnknownQuery(t *testing.T) {
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, ServiceOptions{}),
ServiceRuntime: core.NewServiceRuntime(c, ServiceOptions{}),
}
result, handled, err := svc.handleQuery(c, "unknown query type")
@ -133,11 +133,11 @@ func TestService_HandleQuery_Good_UnknownQuery(t *testing.T) {
func TestService_HandleTask_Good_Push(t *testing.T) {
dir := initTestRepo(t)
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, ServiceOptions{}),
ServiceRuntime: core.NewServiceRuntime(c, ServiceOptions{}),
}
// Push without a remote will fail, but handleTask should still handle it.
@ -149,11 +149,11 @@ func TestService_HandleTask_Good_Push(t *testing.T) {
func TestService_HandleTask_Good_Pull(t *testing.T) {
dir := initTestRepo(t)
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, ServiceOptions{}),
ServiceRuntime: core.NewServiceRuntime(c, ServiceOptions{}),
}
_, handled, err := svc.handleTask(c, TaskPull{Path: dir, Name: "test"})
@ -164,11 +164,11 @@ func TestService_HandleTask_Good_Pull(t *testing.T) {
func TestService_HandleTask_Good_PushMultiple(t *testing.T) {
dir := initTestRepo(t)
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, ServiceOptions{}),
ServiceRuntime: core.NewServiceRuntime(c, ServiceOptions{}),
}
result, handled, err := svc.handleTask(c, TaskPushMultiple{
@ -186,11 +186,11 @@ func TestService_HandleTask_Good_PushMultiple(t *testing.T) {
}
func TestService_HandleTask_Good_UnknownTask(t *testing.T) {
c, err := framework.New()
c, err := core.New()
require.NoError(t, err)
svc := &Service{
ServiceRuntime: framework.NewServiceRuntime(c, ServiceOptions{}),
ServiceRuntime: core.NewServiceRuntime(c, ServiceOptions{}),
}
result, handled, err := svc.handleTask(c, "unknown task")