mirror of
https://github.com/lukaszraczylo/harness-sync.git
synced 2026-10-12 00:45:22 +00:00
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
dadfd5ca06 | ||
|
|
406382a6d4 | ||
|
|
e01f3419ea |
@@ -1,6 +1,6 @@
|
|||||||
module github.com/lukaszraczylo/harness-sync
|
module github.com/lukaszraczylo/harness-sync
|
||||||
|
|
||||||
go 1.25.0
|
go 1.25.10
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/charmbracelet/huh v1.0.0
|
github.com/charmbracelet/huh v1.0.0
|
||||||
@@ -42,6 +42,6 @@ require (
|
|||||||
github.com/rivo/uniseg v0.4.7 // indirect
|
github.com/rivo/uniseg v0.4.7 // indirect
|
||||||
github.com/spf13/pflag v1.0.10 // indirect
|
github.com/spf13/pflag v1.0.10 // indirect
|
||||||
github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect
|
github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect
|
||||||
golang.org/x/sys v0.45.0 // indirect
|
golang.org/x/sys v0.46.0 // indirect
|
||||||
golang.org/x/text v0.37.0 // indirect
|
golang.org/x/text v0.38.0 // indirect
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -91,10 +91,10 @@ go.yaml.in/yaml/v3 v3.0.4/go.mod h1:DhzuOOF2ATzADvBadXxruRBLzYTpT36CKvDb3+aBEFg=
|
|||||||
golang.org/x/exp v0.0.0-20231006140011-7918f672742d h1:jtJma62tbqLibJ5sFQz8bKtEM8rJBtfilJ2qTU199MI=
|
golang.org/x/exp v0.0.0-20231006140011-7918f672742d h1:jtJma62tbqLibJ5sFQz8bKtEM8rJBtfilJ2qTU199MI=
|
||||||
golang.org/x/exp v0.0.0-20231006140011-7918f672742d/go.mod h1:ldy0pHrwJyGW56pPQzzkH36rKxoZW1tw7ZJpeKx+hdo=
|
golang.org/x/exp v0.0.0-20231006140011-7918f672742d/go.mod h1:ldy0pHrwJyGW56pPQzzkH36rKxoZW1tw7ZJpeKx+hdo=
|
||||||
golang.org/x/sys v0.0.0-20210809222454-d867a43fc93e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
golang.org/x/sys v0.0.0-20210809222454-d867a43fc93e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
golang.org/x/sys v0.45.0 h1:dO4czNzziLiiXplLQgBCEpCvXQ3dnkn0SdaZSYdQ+FY=
|
golang.org/x/sys v0.46.0 h1:noSf2Fq6F8DBgS+LysIkx7rIExoNHJsxOAtPp4rthXw=
|
||||||
golang.org/x/sys v0.45.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
|
golang.org/x/sys v0.46.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
|
||||||
golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
|
golang.org/x/text v0.38.0 h1:sXmwo9DwP3OK9EZ7PqAdaooSGozfl/3a6/xJcbzPRhE=
|
||||||
golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
|
golang.org/x/text v0.38.0/go.mod h1:YXZt3QhHUKYT53r2lLKFIVi6Ao1jdzrTR/KQ09qyxF4=
|
||||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
|
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/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 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
||||||
|
|||||||
@@ -0,0 +1,29 @@
|
|||||||
|
package adapter
|
||||||
|
|
||||||
|
import "github.com/lukaszraczylo/harness-sync/internal/adapter/common"
|
||||||
|
|
||||||
|
// Base holds the cross-adapter defaults (currently just the home directory
|
||||||
|
// used to compute target paths). Embed it in each adapter struct to inherit
|
||||||
|
// the WithHome/New constructor pattern without re-implementing it.
|
||||||
|
type Base struct {
|
||||||
|
Home string
|
||||||
|
}
|
||||||
|
|
||||||
|
// BaseOption configures a Base. Returned by WithHome and consumed by NewBase.
|
||||||
|
type BaseOption func(*Base)
|
||||||
|
|
||||||
|
// WithHome overrides the home directory used for target paths. Defaults to
|
||||||
|
// common.DefaultHome() (current $HOME) when no option is supplied.
|
||||||
|
func WithHome(h string) BaseOption {
|
||||||
|
return func(b *Base) { b.Home = h }
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewBase returns a Base populated from opts, with Home defaulting to the
|
||||||
|
// current user's home directory.
|
||||||
|
func NewBase(opts ...BaseOption) *Base {
|
||||||
|
b := &Base{Home: common.DefaultHome()}
|
||||||
|
for _, o := range opts {
|
||||||
|
o(b)
|
||||||
|
}
|
||||||
|
return b
|
||||||
|
}
|
||||||
@@ -0,0 +1,46 @@
|
|||||||
|
package adapter_test
|
||||||
|
|
||||||
|
import (
|
||||||
|
"testing"
|
||||||
|
|
||||||
|
"github.com/stretchr/testify/assert"
|
||||||
|
"github.com/stretchr/testify/require"
|
||||||
|
|
||||||
|
"github.com/lukaszraczylo/harness-sync/internal/adapter"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestNewBaseDefaultsHomeFromEnv(t *testing.T) {
|
||||||
|
b := adapter.NewBase()
|
||||||
|
// DefaultHome returns either $HOME or "". We only assert that the
|
||||||
|
// helper does not panic and that Home is a string (Go zero value is "").
|
||||||
|
// Environment-dependence: skip if HOME is unset (CI minimal envs).
|
||||||
|
if b.Home == "" {
|
||||||
|
t.Skip("HOME unset in test env; cannot verify default")
|
||||||
|
}
|
||||||
|
assert.NotEmpty(t, b.Home)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestNewBaseWithHomeOverrides(t *testing.T) {
|
||||||
|
b := adapter.NewBase(adapter.WithHome("/custom/home/path"))
|
||||||
|
assert.Equal(t, "/custom/home/path", b.Home)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestNewBaseOptionsApplyInOrder(t *testing.T) {
|
||||||
|
// Last write wins — covers the basic Apply loop in NewBase.
|
||||||
|
b := adapter.NewBase(
|
||||||
|
adapter.WithHome("/first"),
|
||||||
|
adapter.WithHome("/second"),
|
||||||
|
)
|
||||||
|
assert.Equal(t, "/second", b.Home)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestBaseOptionTypedCorrectly(t *testing.T) {
|
||||||
|
// adapter.BaseOption is the public type; WithHome must return it.
|
||||||
|
opt := adapter.WithHome("/x")
|
||||||
|
require.NotNil(t, opt)
|
||||||
|
|
||||||
|
// Apply it manually to confirm signature.
|
||||||
|
var b adapter.Base
|
||||||
|
opt(&b)
|
||||||
|
assert.Equal(t, "/x", b.Home)
|
||||||
|
}
|
||||||
@@ -29,6 +29,19 @@ func ReadIfExists(path string) (string, error) {
|
|||||||
return ReadIfExistsFS(fsx.OS(), path)
|
return ReadIfExistsFS(fsx.OS(), path)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ReadExistingFile returns the file body or (nil, nil) when missing.
|
||||||
|
// Other errors (permission denied, I/O failure) are returned verbatim so
|
||||||
|
// read-modify-write callers can distinguish a fresh first-run state from a
|
||||||
|
// broken read. Treating every error as "file is empty" silently overwrites
|
||||||
|
// the user's on-disk edits during apply.
|
||||||
|
func ReadExistingFile(path string) ([]byte, error) {
|
||||||
|
b, err := os.ReadFile(path) //nolint:gosec // caller-controlled path
|
||||||
|
if err != nil && os.IsNotExist(err) {
|
||||||
|
return nil, nil
|
||||||
|
}
|
||||||
|
return b, err
|
||||||
|
}
|
||||||
|
|
||||||
// DirExistsFS reports whether path is an existing directory on fs.
|
// DirExistsFS reports whether path is an existing directory on fs.
|
||||||
func DirExistsFS(fs fsx.FS, path string) bool {
|
func DirExistsFS(fs fsx.FS, path string) bool {
|
||||||
info, err := fs.Stat(path)
|
info, err := fs.Stat(path)
|
||||||
|
|||||||
@@ -0,0 +1,64 @@
|
|||||||
|
package common_test
|
||||||
|
|
||||||
|
import (
|
||||||
|
"errors"
|
||||||
|
"os"
|
||||||
|
"path/filepath"
|
||||||
|
"testing"
|
||||||
|
|
||||||
|
"github.com/stretchr/testify/assert"
|
||||||
|
"github.com/stretchr/testify/require"
|
||||||
|
|
||||||
|
"github.com/lukaszraczylo/harness-sync/internal/adapter/common"
|
||||||
|
)
|
||||||
|
|
||||||
|
// ReadExistingFile: missing file returns (nil, nil). Permission errors and
|
||||||
|
// other I/O failures must NOT be silently swallowed — those would let
|
||||||
|
// read-modify-write code clobber the user's on-disk state.
|
||||||
|
|
||||||
|
func TestReadExistingFileMissing(t *testing.T) {
|
||||||
|
got, err := common.ReadExistingFile(filepath.Join(t.TempDir(), "absent"))
|
||||||
|
require.NoError(t, err)
|
||||||
|
assert.Nil(t, got)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestReadExistingFileContent(t *testing.T) {
|
||||||
|
dir := t.TempDir()
|
||||||
|
path := filepath.Join(dir, "ok.txt")
|
||||||
|
require.NoError(t, os.WriteFile(path, []byte("body\n"), 0o600))
|
||||||
|
|
||||||
|
got, err := common.ReadExistingFile(path)
|
||||||
|
require.NoError(t, err)
|
||||||
|
assert.Equal(t, []byte("body\n"), got)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestReadExistingFilePropagatesError(t *testing.T) {
|
||||||
|
// Create a directory the OS will refuse us read access to.
|
||||||
|
if os.Geteuid() == 0 {
|
||||||
|
t.Skip("running as root; cannot test permission denial")
|
||||||
|
}
|
||||||
|
dir := t.TempDir()
|
||||||
|
require.NoError(t, os.Mkdir(filepath.Join(dir, "locked"), 0o000))
|
||||||
|
t.Cleanup(func() { _ = os.Chmod(filepath.Join(dir, "locked"), 0o755) })
|
||||||
|
|
||||||
|
_, err := common.ReadExistingFile(filepath.Join(dir, "locked", "file"))
|
||||||
|
require.Error(t, err)
|
||||||
|
assert.False(t, os.IsNotExist(err), "permission denied must not be reported as not-exist")
|
||||||
|
assert.True(t, errors.Is(err, os.ErrPermission) || isPermission(err),
|
||||||
|
"expected permission error, got %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
func isPermission(err error) bool {
|
||||||
|
// Some platforms wrap the error in *os.PathError. Check the string too
|
||||||
|
// for portability — it's a coarse signal but adequate here.
|
||||||
|
return err != nil && (contains(err.Error(), "permission") || contains(err.Error(), "access denied"))
|
||||||
|
}
|
||||||
|
|
||||||
|
func contains(s, sub string) bool {
|
||||||
|
for i := 0; i+len(sub) <= len(s); i++ {
|
||||||
|
if s[i:i+len(sub)] == sub {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false
|
||||||
|
}
|
||||||
@@ -19,21 +19,16 @@ import (
|
|||||||
const name = "cagent"
|
const name = "cagent"
|
||||||
|
|
||||||
// Adapter implements adapter.Adapter for the cagent harness.
|
// Adapter implements adapter.Adapter for the cagent harness.
|
||||||
type Adapter struct{ home string }
|
type Adapter struct {
|
||||||
|
*adapter.Base
|
||||||
|
}
|
||||||
|
|
||||||
// Option configures an Adapter.
|
// WithHome overrides the home directory used to resolve target paths.
|
||||||
type Option func(*Adapter)
|
func WithHome(h string) adapter.BaseOption { return func(b *adapter.Base) { b.Home = h } }
|
||||||
|
|
||||||
// WithHome overrides the home directory (defaults to os.UserHomeDir).
|
|
||||||
func WithHome(h string) Option { return func(a *Adapter) { a.home = h } }
|
|
||||||
|
|
||||||
// New returns a new Adapter with the given options applied.
|
// New returns a new Adapter with the given options applied.
|
||||||
func New(opts ...Option) *Adapter {
|
func New(opts ...adapter.BaseOption) *Adapter {
|
||||||
a := &Adapter{home: common.DefaultHome()}
|
return &Adapter{Base: adapter.NewBase(opts...)}
|
||||||
for _, o := range opts {
|
|
||||||
o(a)
|
|
||||||
}
|
|
||||||
return a
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the harness identifier.
|
// Name returns the harness identifier.
|
||||||
@@ -53,14 +48,14 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
|
|||||||
|
|
||||||
// Detect returns true when ~/.config/cagent/ exists.
|
// Detect returns true when ~/.config/cagent/ exists.
|
||||||
func (a *Adapter) Detect() bool {
|
func (a *Adapter) Detect() bool {
|
||||||
_, err := os.Stat(filepath.Join(a.home, ".config", "cagent"))
|
_, err := os.Stat(filepath.Join(a.Home, ".config", "cagent"))
|
||||||
return err == nil
|
return err == nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Render produces a starter default.yaml for cagent.
|
// Render produces a starter default.yaml for cagent.
|
||||||
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
||||||
fs := adapter.NewFileSet()
|
fs := adapter.NewFileSet()
|
||||||
cfgPath := filepath.Join(a.home, ".config", "cagent", "default.yaml")
|
cfgPath := filepath.Join(a.Home, ".config", "cagent", "default.yaml")
|
||||||
|
|
||||||
instructions := b.Instructions.Global
|
instructions := b.Instructions.Global
|
||||||
if override, ok := b.Instructions.PerHarness[name]; ok && override != "" {
|
if override, ok := b.Instructions.PerHarness[name]; ok && override != "" {
|
||||||
|
|||||||
@@ -2,6 +2,7 @@
|
|||||||
package claudecode
|
package claudecode
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
@@ -14,22 +15,15 @@ const name = "claude-code"
|
|||||||
|
|
||||||
// Adapter implements adapter.Adapter for the claude-code harness.
|
// Adapter implements adapter.Adapter for the claude-code harness.
|
||||||
type Adapter struct {
|
type Adapter struct {
|
||||||
home string
|
*adapter.Base
|
||||||
}
|
}
|
||||||
|
|
||||||
// Option configures an Adapter.
|
// WithHome overrides the home directory used to resolve target paths.
|
||||||
type Option func(*Adapter)
|
func WithHome(h string) adapter.BaseOption { return func(b *adapter.Base) { b.Home = h } }
|
||||||
|
|
||||||
// WithHome overrides the home directory (defaults to os.UserHomeDir).
|
|
||||||
func WithHome(h string) Option { return func(a *Adapter) { a.home = h } }
|
|
||||||
|
|
||||||
// New returns a new Adapter with the given options applied.
|
// New returns a new Adapter with the given options applied.
|
||||||
func New(opts ...Option) *Adapter {
|
func New(opts ...adapter.BaseOption) *Adapter {
|
||||||
a := &Adapter{home: common.DefaultHome()}
|
return &Adapter{Base: adapter.NewBase(opts...)}
|
||||||
for _, o := range opts {
|
|
||||||
o(a)
|
|
||||||
}
|
|
||||||
return a
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the harness identifier.
|
// Name returns the harness identifier.
|
||||||
@@ -50,7 +44,7 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
|
|||||||
|
|
||||||
// Detect returns true when ~/.claude exists.
|
// Detect returns true when ~/.claude exists.
|
||||||
func (a *Adapter) Detect() bool {
|
func (a *Adapter) Detect() bool {
|
||||||
_, err := os.Stat(filepath.Join(a.home, ".claude"))
|
_, err := os.Stat(filepath.Join(a.Home, ".claude"))
|
||||||
return err == nil
|
return err == nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -59,7 +53,7 @@ func (a *Adapter) Detect() bool {
|
|||||||
// only manages skills/agents symlinks, CLAUDE.md, and MCP servers.
|
// only manages skills/agents symlinks, CLAUDE.md, and MCP servers.
|
||||||
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
||||||
fs := adapter.NewFileSet()
|
fs := adapter.NewFileSet()
|
||||||
base := filepath.Join(a.home, ".claude")
|
base := filepath.Join(a.Home, ".claude")
|
||||||
|
|
||||||
fs.Add(adapter.File{
|
fs.Add(adapter.File{
|
||||||
Dest: filepath.Join(base, "skills"),
|
Dest: filepath.Join(base, "skills"),
|
||||||
@@ -92,7 +86,10 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
|||||||
overlay := map[string]any{"mcpServers": mcpMap}
|
overlay := map[string]any{"mcpServers": mcpMap}
|
||||||
|
|
||||||
dedicatedPath := filepath.Join(base, "mcp_servers.json")
|
dedicatedPath := filepath.Join(base, "mcp_servers.json")
|
||||||
dedicatedExisting, _ := os.ReadFile(dedicatedPath)
|
dedicatedExisting, err := common.ReadExistingFile(dedicatedPath)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("read %s: %w", dedicatedPath, err)
|
||||||
|
}
|
||||||
dedicatedMerged, err := common.MergeJSONKeys(dedicatedExisting, overlay)
|
dedicatedMerged, err := common.MergeJSONKeys(dedicatedExisting, overlay)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -103,9 +100,12 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
|||||||
Content: dedicatedMerged,
|
Content: dedicatedMerged,
|
||||||
})
|
})
|
||||||
|
|
||||||
livePath := filepath.Join(a.home, ".claude.json")
|
livePath := filepath.Join(a.Home, ".claude.json")
|
||||||
if _, err := os.Stat(livePath); err == nil {
|
if _, err := os.Stat(livePath); err == nil {
|
||||||
liveExisting, _ := os.ReadFile(livePath)
|
liveExisting, err := common.ReadExistingFile(livePath)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("read %s: %w", livePath, err)
|
||||||
|
}
|
||||||
liveMerged, err := common.MergeJSONKeys(liveExisting, overlay)
|
liveMerged, err := common.MergeJSONKeys(liveExisting, overlay)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
@@ -2,6 +2,7 @@
|
|||||||
package crush
|
package crush
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
@@ -13,21 +14,16 @@ import (
|
|||||||
const name = "crush"
|
const name = "crush"
|
||||||
|
|
||||||
// Adapter implements adapter.Adapter for the crush harness.
|
// Adapter implements adapter.Adapter for the crush harness.
|
||||||
type Adapter struct{ home string }
|
type Adapter struct {
|
||||||
|
*adapter.Base
|
||||||
|
}
|
||||||
|
|
||||||
// Option configures an Adapter.
|
// WithHome overrides the home directory used to resolve target paths.
|
||||||
type Option func(*Adapter)
|
func WithHome(h string) adapter.BaseOption { return func(b *adapter.Base) { b.Home = h } }
|
||||||
|
|
||||||
// WithHome overrides the home directory (defaults to os.UserHomeDir).
|
|
||||||
func WithHome(h string) Option { return func(a *Adapter) { a.home = h } }
|
|
||||||
|
|
||||||
// New returns a new Adapter with the given options applied.
|
// New returns a new Adapter with the given options applied.
|
||||||
func New(opts ...Option) *Adapter {
|
func New(opts ...adapter.BaseOption) *Adapter {
|
||||||
a := &Adapter{home: common.DefaultHome()}
|
return &Adapter{Base: adapter.NewBase(opts...)}
|
||||||
for _, o := range opts {
|
|
||||||
o(a)
|
|
||||||
}
|
|
||||||
return a
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the harness identifier.
|
// Name returns the harness identifier.
|
||||||
@@ -47,7 +43,7 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
|
|||||||
|
|
||||||
// Detect returns true when ~/.config/crush exists.
|
// Detect returns true when ~/.config/crush exists.
|
||||||
func (a *Adapter) Detect() bool {
|
func (a *Adapter) Detect() bool {
|
||||||
_, err := os.Stat(filepath.Join(a.home, ".config", "crush"))
|
_, err := os.Stat(filepath.Join(a.Home, ".config", "crush"))
|
||||||
return err == nil
|
return err == nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -56,7 +52,7 @@ func (a *Adapter) Detect() bool {
|
|||||||
// MCP key is "mcp" (not "mcpServers"); entries include a "type" field.
|
// MCP key is "mcp" (not "mcpServers"); entries include a "type" field.
|
||||||
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
||||||
fs := adapter.NewFileSet()
|
fs := adapter.NewFileSet()
|
||||||
base := filepath.Join(a.home, ".config", "crush")
|
base := filepath.Join(a.Home, ".config", "crush")
|
||||||
|
|
||||||
fs.Add(adapter.File{
|
fs.Add(adapter.File{
|
||||||
Dest: filepath.Join(base, "skills"),
|
Dest: filepath.Join(base, "skills"),
|
||||||
@@ -65,7 +61,10 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
|||||||
})
|
})
|
||||||
|
|
||||||
cfgPath := filepath.Join(base, "crush.json")
|
cfgPath := filepath.Join(base, "crush.json")
|
||||||
existing, _ := os.ReadFile(cfgPath)
|
existing, err := common.ReadExistingFile(cfgPath)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("read %s: %w", cfgPath, err)
|
||||||
|
}
|
||||||
overlay := map[string]any{}
|
overlay := map[string]any{}
|
||||||
if providers := common.ProvidersAsCrushMap(&b.Profile); len(providers) > 0 {
|
if providers := common.ProvidersAsCrushMap(&b.Profile); len(providers) > 0 {
|
||||||
overlay["providers"] = providers
|
overlay["providers"] = providers
|
||||||
|
|||||||
@@ -10,6 +10,7 @@
|
|||||||
package goose
|
package goose
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"strings"
|
"strings"
|
||||||
@@ -22,21 +23,16 @@ import (
|
|||||||
const name = "goose"
|
const name = "goose"
|
||||||
|
|
||||||
// Adapter implements adapter.Adapter for the Goose harness.
|
// Adapter implements adapter.Adapter for the Goose harness.
|
||||||
type Adapter struct{ home string }
|
type Adapter struct {
|
||||||
|
*adapter.Base
|
||||||
|
}
|
||||||
|
|
||||||
// Option configures an Adapter.
|
// WithHome overrides the home directory used to resolve target paths.
|
||||||
type Option func(*Adapter)
|
func WithHome(h string) adapter.BaseOption { return func(b *adapter.Base) { b.Home = h } }
|
||||||
|
|
||||||
// WithHome overrides the home directory (defaults to os.UserHomeDir).
|
|
||||||
func WithHome(h string) Option { return func(a *Adapter) { a.home = h } }
|
|
||||||
|
|
||||||
// New returns a new Adapter with the given options applied.
|
// New returns a new Adapter with the given options applied.
|
||||||
func New(opts ...Option) *Adapter {
|
func New(opts ...adapter.BaseOption) *Adapter {
|
||||||
a := &Adapter{home: common.DefaultHome()}
|
return &Adapter{Base: adapter.NewBase(opts...)}
|
||||||
for _, o := range opts {
|
|
||||||
o(a)
|
|
||||||
}
|
|
||||||
return a
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the harness identifier.
|
// Name returns the harness identifier.
|
||||||
@@ -56,7 +52,7 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
|
|||||||
|
|
||||||
// Detect returns true when ~/.config/goose/ exists.
|
// Detect returns true when ~/.config/goose/ exists.
|
||||||
func (a *Adapter) Detect() bool {
|
func (a *Adapter) Detect() bool {
|
||||||
_, err := os.Stat(filepath.Join(a.home, ".config", "goose"))
|
_, err := os.Stat(filepath.Join(a.Home, ".config", "goose"))
|
||||||
return err == nil
|
return err == nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -67,23 +63,26 @@ func (a *Adapter) Detect() bool {
|
|||||||
// also added to the FileSet so goose can load the provider on first run.
|
// also added to the FileSet so goose can load the provider on first run.
|
||||||
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
||||||
fs := adapter.NewFileSet()
|
fs := adapter.NewFileSet()
|
||||||
cfgPath := filepath.Join(a.home, ".config", "goose", "config.yaml")
|
cfgPath := filepath.Join(a.Home, ".config", "goose", "config.yaml")
|
||||||
|
|
||||||
// goose reads skills from ~/.agents/skills/<name>/SKILL.md (open Agent Skills spec)
|
// goose reads skills from ~/.agents/skills/<name>/SKILL.md (open Agent Skills spec)
|
||||||
fs.Add(adapter.File{
|
fs.Add(adapter.File{
|
||||||
Dest: filepath.Join(a.home, ".agents", "skills"),
|
Dest: filepath.Join(a.Home, ".agents", "skills"),
|
||||||
Kind: adapter.SymlinkDir,
|
Kind: adapter.SymlinkDir,
|
||||||
SymlinkTarget: filepath.Join(b.Root, "skills"),
|
SymlinkTarget: filepath.Join(b.Root, "skills"),
|
||||||
})
|
})
|
||||||
|
|
||||||
existing, _ := os.ReadFile(cfgPath)
|
existing, err := common.ReadExistingFile(cfgPath)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("read %s: %w", cfgPath, err)
|
||||||
|
}
|
||||||
|
|
||||||
provider, model := splitProviderModel(b.Profile.Gateway.DefaultModel)
|
provider, model := splitProviderModel(b.Profile.Gateway.DefaultModel)
|
||||||
if b.Profile.Gateway.URL != "" {
|
if b.Profile.Gateway.URL != "" {
|
||||||
// Emit the custom provider JSON file.
|
// Emit the custom provider JSON file.
|
||||||
body, providerName := common.GooseCustomProviderFile(&b.Profile)
|
body, providerName := common.GooseCustomProviderFile(&b.Profile)
|
||||||
if body != nil {
|
if body != nil {
|
||||||
cpDir := filepath.Join(a.home, ".config", "goose", "custom_providers")
|
cpDir := filepath.Join(a.Home, ".config", "goose", "custom_providers")
|
||||||
fs.Add(adapter.File{
|
fs.Add(adapter.File{
|
||||||
Dest: filepath.Join(cpDir, providerName+".json"),
|
Dest: filepath.Join(cpDir, providerName+".json"),
|
||||||
Kind: adapter.RenderedFile,
|
Kind: adapter.RenderedFile,
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ package kilo
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"fmt"
|
||||||
"maps"
|
"maps"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
@@ -16,22 +17,15 @@ const name = "kilo"
|
|||||||
|
|
||||||
// Adapter implements adapter.Adapter for the kilo harness.
|
// Adapter implements adapter.Adapter for the kilo harness.
|
||||||
type Adapter struct {
|
type Adapter struct {
|
||||||
home string
|
*adapter.Base
|
||||||
}
|
}
|
||||||
|
|
||||||
// Option configures an Adapter.
|
// WithHome overrides the home directory used to resolve target paths.
|
||||||
type Option func(*Adapter)
|
func WithHome(h string) adapter.BaseOption { return func(b *adapter.Base) { b.Home = h } }
|
||||||
|
|
||||||
// WithHome overrides the home directory (defaults to os.UserHomeDir).
|
|
||||||
func WithHome(h string) Option { return func(a *Adapter) { a.home = h } }
|
|
||||||
|
|
||||||
// New returns a new Adapter with the given options applied.
|
// New returns a new Adapter with the given options applied.
|
||||||
func New(opts ...Option) *Adapter {
|
func New(opts ...adapter.BaseOption) *Adapter {
|
||||||
a := &Adapter{home: common.DefaultHome()}
|
return &Adapter{Base: adapter.NewBase(opts...)}
|
||||||
for _, o := range opts {
|
|
||||||
o(a)
|
|
||||||
}
|
|
||||||
return a
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the harness identifier.
|
// Name returns the harness identifier.
|
||||||
@@ -51,7 +45,7 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
|
|||||||
|
|
||||||
// Detect returns true when ~/.config/kilo exists.
|
// Detect returns true when ~/.config/kilo exists.
|
||||||
func (a *Adapter) Detect() bool {
|
func (a *Adapter) Detect() bool {
|
||||||
_, err := os.Stat(filepath.Join(a.home, ".config", "kilo"))
|
_, err := os.Stat(filepath.Join(a.Home, ".config", "kilo"))
|
||||||
return err == nil
|
return err == nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -62,7 +56,7 @@ func (a *Adapter) Detect() bool {
|
|||||||
// No "providers" key — kilo has no such concept.
|
// No "providers" key — kilo has no such concept.
|
||||||
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
||||||
fs := adapter.NewFileSet()
|
fs := adapter.NewFileSet()
|
||||||
base := filepath.Join(a.home, ".config", "kilo")
|
base := filepath.Join(a.Home, ".config", "kilo")
|
||||||
|
|
||||||
fs.Add(adapter.File{
|
fs.Add(adapter.File{
|
||||||
Dest: filepath.Join(base, "agent"),
|
Dest: filepath.Join(base, "agent"),
|
||||||
@@ -71,13 +65,16 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
|||||||
})
|
})
|
||||||
// kilo reads skills from ~/.kilo/skills/<name>/SKILL.md
|
// kilo reads skills from ~/.kilo/skills/<name>/SKILL.md
|
||||||
fs.Add(adapter.File{
|
fs.Add(adapter.File{
|
||||||
Dest: filepath.Join(a.home, ".kilo", "skills"),
|
Dest: filepath.Join(a.Home, ".kilo", "skills"),
|
||||||
Kind: adapter.SymlinkDir,
|
Kind: adapter.SymlinkDir,
|
||||||
SymlinkTarget: filepath.Join(b.Root, "skills"),
|
SymlinkTarget: filepath.Join(b.Root, "skills"),
|
||||||
})
|
})
|
||||||
|
|
||||||
cfgPath := filepath.Join(base, "kilo.json")
|
cfgPath := filepath.Join(base, "kilo.json")
|
||||||
existing, _ := os.ReadFile(cfgPath)
|
existing, err := common.ReadExistingFile(cfgPath)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("read %s: %w", cfgPath, err)
|
||||||
|
}
|
||||||
modelStr := common.KiloModelString(&b.Profile)
|
modelStr := common.KiloModelString(&b.Profile)
|
||||||
overlay := map[string]any{}
|
overlay := map[string]any{}
|
||||||
if providers := common.ProvidersAsMap(&b.Profile); len(providers) > 0 {
|
if providers := common.ProvidersAsMap(&b.Profile); len(providers) > 0 {
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ package opencode
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
@@ -14,21 +15,16 @@ import (
|
|||||||
const name = "opencode"
|
const name = "opencode"
|
||||||
|
|
||||||
// Adapter implements adapter.Adapter for the opencode harness.
|
// Adapter implements adapter.Adapter for the opencode harness.
|
||||||
type Adapter struct{ home string }
|
type Adapter struct {
|
||||||
|
*adapter.Base
|
||||||
|
}
|
||||||
|
|
||||||
// Option configures an Adapter.
|
// WithHome overrides the home directory used to resolve target paths.
|
||||||
type Option func(*Adapter)
|
func WithHome(h string) adapter.BaseOption { return func(b *adapter.Base) { b.Home = h } }
|
||||||
|
|
||||||
// WithHome overrides the home directory (defaults to os.UserHomeDir).
|
|
||||||
func WithHome(h string) Option { return func(a *Adapter) { a.home = h } }
|
|
||||||
|
|
||||||
// New returns a new Adapter with the given options applied.
|
// New returns a new Adapter with the given options applied.
|
||||||
func New(opts ...Option) *Adapter {
|
func New(opts ...adapter.BaseOption) *Adapter {
|
||||||
a := &Adapter{home: common.DefaultHome()}
|
return &Adapter{Base: adapter.NewBase(opts...)}
|
||||||
for _, o := range opts {
|
|
||||||
o(a)
|
|
||||||
}
|
|
||||||
return a
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the harness identifier.
|
// Name returns the harness identifier.
|
||||||
@@ -48,7 +44,7 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
|
|||||||
|
|
||||||
// Detect returns true when ~/.config/opencode exists.
|
// Detect returns true when ~/.config/opencode exists.
|
||||||
func (a *Adapter) Detect() bool {
|
func (a *Adapter) Detect() bool {
|
||||||
_, err := os.Stat(filepath.Join(a.home, ".config", "opencode"))
|
_, err := os.Stat(filepath.Join(a.Home, ".config", "opencode"))
|
||||||
return err == nil
|
return err == nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -58,7 +54,7 @@ func (a *Adapter) Detect() bool {
|
|||||||
// "mcp" (map with type: local|remote entries).
|
// "mcp" (map with type: local|remote entries).
|
||||||
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
||||||
fs := adapter.NewFileSet()
|
fs := adapter.NewFileSet()
|
||||||
base := filepath.Join(a.home, ".config", "opencode")
|
base := filepath.Join(a.Home, ".config", "opencode")
|
||||||
|
|
||||||
// opencode reads skills from ~/.config/opencode/skills/<name>/SKILL.md
|
// opencode reads skills from ~/.config/opencode/skills/<name>/SKILL.md
|
||||||
fs.Add(adapter.File{
|
fs.Add(adapter.File{
|
||||||
@@ -68,7 +64,10 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
|||||||
})
|
})
|
||||||
|
|
||||||
cfgPath := filepath.Join(base, "opencode.jsonc")
|
cfgPath := filepath.Join(base, "opencode.jsonc")
|
||||||
existing, _ := os.ReadFile(cfgPath)
|
existing, err := common.ReadExistingFile(cfgPath)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("read %s: %w", cfgPath, err)
|
||||||
|
}
|
||||||
|
|
||||||
// Build the provider map, then absorb any existing providers at the same
|
// Build the provider map, then absorb any existing providers at the same
|
||||||
// gateway URL so duplicates don't accumulate across apply runs.
|
// gateway URL so duplicates don't accumulate across apply runs.
|
||||||
|
|||||||
@@ -7,6 +7,7 @@ package zed
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
@@ -18,21 +19,16 @@ import (
|
|||||||
const name = "zed"
|
const name = "zed"
|
||||||
|
|
||||||
// Adapter implements adapter.Adapter for the Zed harness.
|
// Adapter implements adapter.Adapter for the Zed harness.
|
||||||
type Adapter struct{ home string }
|
type Adapter struct {
|
||||||
|
*adapter.Base
|
||||||
|
}
|
||||||
|
|
||||||
// Option configures an Adapter.
|
// WithHome overrides the home directory used to resolve target paths.
|
||||||
type Option func(*Adapter)
|
func WithHome(h string) adapter.BaseOption { return func(b *adapter.Base) { b.Home = h } }
|
||||||
|
|
||||||
// WithHome overrides the home directory (defaults to os.UserHomeDir).
|
|
||||||
func WithHome(h string) Option { return func(a *Adapter) { a.home = h } }
|
|
||||||
|
|
||||||
// New returns a new Adapter with the given options applied.
|
// New returns a new Adapter with the given options applied.
|
||||||
func New(opts ...Option) *Adapter {
|
func New(opts ...adapter.BaseOption) *Adapter {
|
||||||
a := &Adapter{home: common.DefaultHome()}
|
return &Adapter{Base: adapter.NewBase(opts...)}
|
||||||
for _, o := range opts {
|
|
||||||
o(a)
|
|
||||||
}
|
|
||||||
return a
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Name returns the harness identifier.
|
// Name returns the harness identifier.
|
||||||
@@ -53,7 +49,7 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
|
|||||||
|
|
||||||
// Detect returns true when ~/.config/zed/ exists.
|
// Detect returns true when ~/.config/zed/ exists.
|
||||||
func (a *Adapter) Detect() bool {
|
func (a *Adapter) Detect() bool {
|
||||||
_, err := os.Stat(filepath.Join(a.home, ".config", "zed"))
|
_, err := os.Stat(filepath.Join(a.Home, ".config", "zed"))
|
||||||
return err == nil
|
return err == nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -68,8 +64,11 @@ func (a *Adapter) Detect() bool {
|
|||||||
// pre-existing parse errors from user-configured entries.
|
// pre-existing parse errors from user-configured entries.
|
||||||
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
|
||||||
fs := adapter.NewFileSet()
|
fs := adapter.NewFileSet()
|
||||||
cfgPath := filepath.Join(a.home, ".config", "zed", "settings.json")
|
cfgPath := filepath.Join(a.Home, ".config", "zed", "settings.json")
|
||||||
existing, _ := os.ReadFile(cfgPath)
|
existing, err := common.ReadExistingFile(cfgPath)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("read %s: %w", cfgPath, err)
|
||||||
|
}
|
||||||
|
|
||||||
// Set context_servers to nil so MergeJSONKeys removes the key entirely,
|
// Set context_servers to nil so MergeJSONKeys removes the key entirely,
|
||||||
// clearing any entries that trigger the serde ContextServerSettingsContent bug.
|
// clearing any entries that trigger the serde ContextServerSettingsContent bug.
|
||||||
|
|||||||
+38
-9
@@ -9,6 +9,7 @@ import (
|
|||||||
"path/filepath"
|
"path/filepath"
|
||||||
|
|
||||||
"github.com/lukaszraczylo/harness-sync/internal/adapter"
|
"github.com/lukaszraczylo/harness-sync/internal/adapter"
|
||||||
|
"github.com/lukaszraczylo/harness-sync/internal/adapter/common"
|
||||||
"github.com/lukaszraczylo/harness-sync/internal/canonical"
|
"github.com/lukaszraczylo/harness-sync/internal/canonical"
|
||||||
"github.com/lukaszraczylo/harness-sync/internal/gitx"
|
"github.com/lukaszraczylo/harness-sync/internal/gitx"
|
||||||
"github.com/lukaszraczylo/harness-sync/internal/merge"
|
"github.com/lukaszraczylo/harness-sync/internal/merge"
|
||||||
@@ -42,6 +43,11 @@ type Action struct {
|
|||||||
// Run renders all adapters and writes their FileSets to disk.
|
// Run renders all adapters and writes their FileSets to disk.
|
||||||
// Conflicts are recorded as <dest>.rej files; processing continues past conflicts.
|
// Conflicts are recorded as <dest>.rej files; processing continues past conflicts.
|
||||||
//
|
//
|
||||||
|
// When Options.Repo is nil the canonical repo is auto-opened from Bundle.Root.
|
||||||
|
// If that directory is not a git repository the commit step is silently
|
||||||
|
// skipped — useful for one-off renders (CI smoke tests, dry-runs) where
|
||||||
|
// initialising a repo would be more surprising than useful.
|
||||||
|
//
|
||||||
// IMPORTANT: harness-sync intentionally does NOT resolve ${VAR} references in
|
// IMPORTANT: harness-sync intentionally does NOT resolve ${VAR} references in
|
||||||
// canonical configs. Every supported harness performs its own env-var
|
// canonical configs. Every supported harness performs its own env-var
|
||||||
// expansion at MCP launch / config-load time, so resolving here would only
|
// expansion at MCP launch / config-load time, so resolving here would only
|
||||||
@@ -66,13 +72,30 @@ func Run(opt Options) (*Report, error) {
|
|||||||
return rep, renderErr
|
return rep, renderErr
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if !opt.DryRun && rep.Written > 0 && opt.Repo != nil {
|
if opt.DryRun || rep.Written == 0 {
|
||||||
if err := opt.Repo.AddAll(); err != nil {
|
return rep, nil
|
||||||
return rep, err
|
}
|
||||||
}
|
repo := opt.Repo
|
||||||
if err := opt.Repo.Commit(fmt.Sprintf("apply: %d files, %d conflicts", rep.Written, rep.Conflicts)); err != nil {
|
if repo == nil {
|
||||||
return rep, err
|
repo = gitx.New(opt.Bundle.Root)
|
||||||
}
|
}
|
||||||
|
if !repo.IsRepo() {
|
||||||
|
return rep, nil
|
||||||
|
}
|
||||||
|
if err := repo.AddAll(); err != nil {
|
||||||
|
return rep, err
|
||||||
|
}
|
||||||
|
dirty, err := repo.HasStagedChanges()
|
||||||
|
if err != nil {
|
||||||
|
return rep, err
|
||||||
|
}
|
||||||
|
if !dirty {
|
||||||
|
// Nothing changed inside the canonical repo (writes were outside it,
|
||||||
|
// e.g. symlinks to temp dirs in tests). Skip the no-op commit.
|
||||||
|
return rep, nil
|
||||||
|
}
|
||||||
|
if err := repo.Commit(fmt.Sprintf("apply: %d files, %d conflicts", rep.Written, rep.Conflicts)); err != nil {
|
||||||
|
return rep, err
|
||||||
}
|
}
|
||||||
return rep, nil
|
return rep, nil
|
||||||
}
|
}
|
||||||
@@ -93,8 +116,14 @@ func statePath(root, adapterName, dest string) string {
|
|||||||
|
|
||||||
func handleRendered(opt Options, adapterName string, f adapter.File, rep *Report) error {
|
func handleRendered(opt Options, adapterName string, f adapter.File, rep *Report) error {
|
||||||
sp := statePath(opt.Bundle.Root, adapterName, f.Dest)
|
sp := statePath(opt.Bundle.Root, adapterName, f.Dest)
|
||||||
base, _ := os.ReadFile(sp)
|
base, readErr := common.ReadExistingFile(sp)
|
||||||
current, _ := os.ReadFile(f.Dest)
|
if readErr != nil {
|
||||||
|
return fmt.Errorf("read state %s: %w", sp, readErr)
|
||||||
|
}
|
||||||
|
current, readErr := common.ReadExistingFile(f.Dest)
|
||||||
|
if readErr != nil {
|
||||||
|
return fmt.Errorf("read target %s: %w", f.Dest, readErr)
|
||||||
|
}
|
||||||
|
|
||||||
if string(current) == string(f.Content) {
|
if string(current) == string(f.Content) {
|
||||||
rep.Skipped++
|
rep.Skipped++
|
||||||
|
|||||||
@@ -584,6 +584,160 @@ func TestApplyUnknownFileKind(t *testing.T) {
|
|||||||
assert.Contains(t, err.Error(), "unknown file kind")
|
assert.Contains(t, err.Error(), "unknown file kind")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
// TestApplyPropagatesReadErrors — regression for the silent-read footgun.
|
||||||
|
// A target file in a directory we can no longer read must surface as an
|
||||||
|
// error from Run, not as a fast-forward overwrite.
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
|
func TestApplyPropagatesReadErrors(t *testing.T) {
|
||||||
|
if os.Geteuid() == 0 {
|
||||||
|
t.Skip("running as root; cannot test permission denial")
|
||||||
|
}
|
||||||
|
root := t.TempDir()
|
||||||
|
targetDir := t.TempDir()
|
||||||
|
target := filepath.Join(targetDir, "out.txt")
|
||||||
|
require.NoError(t, os.WriteFile(target, []byte("user-content\n"), 0o600))
|
||||||
|
require.NoError(t, initCanonical(root))
|
||||||
|
|
||||||
|
// Strip read perms on the target's parent so os.ReadFile fails.
|
||||||
|
require.NoError(t, os.Chmod(targetDir, 0o000))
|
||||||
|
t.Cleanup(func() { _ = os.Chmod(targetDir, 0o755) })
|
||||||
|
|
||||||
|
ad := &stubAdapter{name: "stub", files: []adapter.File{
|
||||||
|
{Dest: target, Kind: adapter.RenderedFile, Content: []byte("new-render\n")},
|
||||||
|
}}
|
||||||
|
_, err := Run(Options{
|
||||||
|
Bundle: &canonical.Bundle{Root: root},
|
||||||
|
Adapters: []adapter.Adapter{ad},
|
||||||
|
Repo: gitx.New(root),
|
||||||
|
})
|
||||||
|
require.Error(t, err)
|
||||||
|
assert.Contains(t, err.Error(), "read target")
|
||||||
|
|
||||||
|
// User's on-disk file must be untouched.
|
||||||
|
_ = os.Chmod(targetDir, 0o755)
|
||||||
|
body, rerr := os.ReadFile(target)
|
||||||
|
require.NoError(t, rerr)
|
||||||
|
assert.Equal(t, "user-content\n", string(body),
|
||||||
|
"target must not be overwritten when read fails")
|
||||||
|
}
|
||||||
|
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
// TestApplyAutoOpensRepoFromBundleRoot — regression: callers no longer need
|
||||||
|
// to pre-construct a *gitx.Repo. Run opens one from Bundle.Root, skips
|
||||||
|
// commit gracefully when the root is not a git repo, and commits when it is.
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
|
func TestApplyAutoOpensRepoFromBundleRoot(t *testing.T) {
|
||||||
|
root := t.TempDir()
|
||||||
|
target := filepath.Join(t.TempDir(), "out.txt")
|
||||||
|
require.NoError(t, initCanonical(root))
|
||||||
|
|
||||||
|
ad := &stubAdapter{name: "stub", files: []adapter.File{
|
||||||
|
{Dest: target, Kind: adapter.RenderedFile, Content: []byte("auto\n")},
|
||||||
|
}}
|
||||||
|
// Intentionally pass Repo: nil — the new behaviour should open one itself.
|
||||||
|
rep, err := Run(Options{
|
||||||
|
Bundle: &canonical.Bundle{Root: root},
|
||||||
|
Adapters: []adapter.Adapter{ad},
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
assert.Equal(t, 1, rep.Written)
|
||||||
|
|
||||||
|
// git log should have a new commit from apply, on top of the init one.
|
||||||
|
out, gitErr := runGit(root, "log", "--oneline")
|
||||||
|
require.NoError(t, gitErr)
|
||||||
|
assert.GreaterOrEqual(t, countLines(out), 2)
|
||||||
|
}
|
||||||
|
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
// TestApplyNoRepoSkipsCommit — when Bundle.Root isn't a git repo, Run must
|
||||||
|
// still succeed (no error, no commit attempt). One-off renders / dry-runs.
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
|
func TestApplyNoRepoSkipsCommit(t *testing.T) {
|
||||||
|
root := t.TempDir() // NOT initCanonical — no .git
|
||||||
|
target := filepath.Join(t.TempDir(), "out.txt")
|
||||||
|
|
||||||
|
ad := &stubAdapter{name: "stub", files: []adapter.File{
|
||||||
|
{Dest: target, Kind: adapter.RenderedFile, Content: []byte("x\n")},
|
||||||
|
}}
|
||||||
|
rep, err := Run(Options{
|
||||||
|
Bundle: &canonical.Bundle{Root: root},
|
||||||
|
Adapters: []adapter.Adapter{ad},
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
assert.Equal(t, 1, rep.Written)
|
||||||
|
body, rerr := os.ReadFile(target)
|
||||||
|
require.NoError(t, rerr)
|
||||||
|
assert.Equal(t, "x\n", string(body))
|
||||||
|
}
|
||||||
|
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
// TestApplySkipsNoOpCommit — symlinks at a path outside the canonical repo
|
||||||
|
// do not write a state snapshot inside the repo (handleSymlink has no
|
||||||
|
// state-tracking), so git has nothing to commit. apply.Run must detect
|
||||||
|
// "no staged changes" and skip the commit instead of failing with
|
||||||
|
// "nothing to commit" from git itself.
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
|
func TestApplySkipsNoOpCommit(t *testing.T) {
|
||||||
|
root := t.TempDir()
|
||||||
|
require.NoError(t, initCanonical(root))
|
||||||
|
targetDir := t.TempDir()
|
||||||
|
target := filepath.Join(targetDir, "outside-link")
|
||||||
|
real := filepath.Join(targetDir, "real.txt")
|
||||||
|
require.NoError(t, os.WriteFile(real, []byte("real\n"), 0o600))
|
||||||
|
|
||||||
|
ad := &stubAdapter{name: "stub", files: []adapter.File{
|
||||||
|
{Dest: target, Kind: adapter.SymlinkFile, SymlinkTarget: real},
|
||||||
|
}}
|
||||||
|
rep, err := Run(Options{
|
||||||
|
Bundle: &canonical.Bundle{Root: root},
|
||||||
|
Adapters: []adapter.Adapter{ad},
|
||||||
|
// Repo: nil — auto-open from Bundle.Root (which IS a git repo).
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
assert.Equal(t, 1, rep.Written)
|
||||||
|
|
||||||
|
// Symlink exists on disk.
|
||||||
|
got, lerr := os.Readlink(target)
|
||||||
|
require.NoError(t, lerr)
|
||||||
|
assert.Equal(t, real, got)
|
||||||
|
|
||||||
|
// No extra commit — still just the init commit. A failed "nothing to
|
||||||
|
// commit" would surface here as an error from Run.
|
||||||
|
out, gitErr := runGit(root, "log", "--oneline")
|
||||||
|
require.NoError(t, gitErr)
|
||||||
|
assert.Equal(t, 1, countLines(out),
|
||||||
|
"expected only the init commit; symlink outside canonical root should not create one")
|
||||||
|
}
|
||||||
|
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
// TestApplyCommitMessageHasCounts — commit message includes the file and
|
||||||
|
// conflict counts so the rollback story is auditable from git log alone.
|
||||||
|
// ---------------------------------------------------------------------------
|
||||||
|
|
||||||
|
func TestApplyCommitMessageHasCounts(t *testing.T) {
|
||||||
|
root := t.TempDir()
|
||||||
|
target := filepath.Join(t.TempDir(), "msg.txt")
|
||||||
|
require.NoError(t, initCanonical(root))
|
||||||
|
|
||||||
|
ad := &stubAdapter{name: "stub", files: []adapter.File{
|
||||||
|
{Dest: target, Kind: adapter.RenderedFile, Content: []byte("m\n")},
|
||||||
|
}}
|
||||||
|
_, err := Run(Options{
|
||||||
|
Bundle: &canonical.Bundle{Root: root},
|
||||||
|
Adapters: []adapter.Adapter{ad},
|
||||||
|
})
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
out, gitErr := runGit(root, "log", "-1", "--pretty=%s")
|
||||||
|
require.NoError(t, gitErr)
|
||||||
|
assert.Contains(t, out, "apply: 1 files, 0 conflicts")
|
||||||
|
}
|
||||||
|
|
||||||
// ---------------------------------------------------------------------------
|
// ---------------------------------------------------------------------------
|
||||||
// helpers
|
// helpers
|
||||||
// ---------------------------------------------------------------------------
|
// ---------------------------------------------------------------------------
|
||||||
|
|||||||
@@ -71,6 +71,17 @@ func (r *Repo) IsRepo() bool {
|
|||||||
return err == nil
|
return err == nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// HasStagedChanges reports whether the index currently differs from HEAD.
|
||||||
|
// Used by callers that want to skip a no-op `git commit` (commit exits 1
|
||||||
|
// when there is nothing to commit, which is the wrong signal to propagate).
|
||||||
|
func (r *Repo) HasStagedChanges() (bool, error) {
|
||||||
|
b, err := r.run("status", "--porcelain")
|
||||||
|
if err != nil {
|
||||||
|
return false, err
|
||||||
|
}
|
||||||
|
return len(bytes.TrimSpace(b)) > 0, nil
|
||||||
|
}
|
||||||
|
|
||||||
// Revert undoes the last N commits with `git revert --no-edit HEAD~N..HEAD`.
|
// Revert undoes the last N commits with `git revert --no-edit HEAD~N..HEAD`.
|
||||||
// n must be >= 1.
|
// n must be >= 1.
|
||||||
func (r *Repo) Revert(n int) error {
|
func (r *Repo) Revert(n int) error {
|
||||||
|
|||||||
@@ -41,3 +41,33 @@ func TestShowFileAtHead(t *testing.T) {
|
|||||||
_, err = r.ShowFileAtHead("nope.txt")
|
_, err = r.ShowFileAtHead("nope.txt")
|
||||||
assert.Error(t, err)
|
assert.Error(t, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestHasStagedChangesEmptyAfterInit(t *testing.T) {
|
||||||
|
dir := t.TempDir()
|
||||||
|
r := New(dir)
|
||||||
|
require.NoError(t, r.Init())
|
||||||
|
require.NoError(t, r.Configure("nobody", "[email protected]"))
|
||||||
|
// No commits yet, working tree clean.
|
||||||
|
dirty, err := r.HasStagedChanges()
|
||||||
|
require.NoError(t, err)
|
||||||
|
assert.False(t, dirty)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestHasStagedChangesAfterAdd(t *testing.T) {
|
||||||
|
dir := t.TempDir()
|
||||||
|
r := New(dir)
|
||||||
|
require.NoError(t, r.Init())
|
||||||
|
require.NoError(t, r.Configure("nobody", "[email protected]"))
|
||||||
|
require.NoError(t, os.WriteFile(filepath.Join(dir, "a.txt"), []byte("x"), 0o600))
|
||||||
|
require.NoError(t, r.AddAll())
|
||||||
|
|
||||||
|
dirty, err := r.HasStagedChanges()
|
||||||
|
require.NoError(t, err)
|
||||||
|
assert.True(t, dirty)
|
||||||
|
|
||||||
|
// After commit, index matches HEAD again → no staged changes.
|
||||||
|
require.NoError(t, r.Commit("c"))
|
||||||
|
dirty, err = r.HasStagedChanges()
|
||||||
|
require.NoError(t, err)
|
||||||
|
assert.False(t, dirty)
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user