Compare commits

...
25 Commits
Author SHA1 Message Date
github-actions[bot]andGitHub 89c9b60dac chore(deps): update module github.com/stretchr/testify to v1.12.1
Automated dependency update. All tests passed.
2026-10-04 04:21:05 +00:00
lukaszraczylo 9ae011ac62 ci(deps): update dependencies with Renovate [skip ci] 2026-10-03 18:44:37 +01:00
lukaszraczyloandGitHub 18919ca926 Update go.mod and go.sum (#29) 2026-10-03 04:27:45 +01:00
lukaszraczylo 12e448ca39 fix(deps): require Go 1.26.8
Go 1.26.0 carries 17 standard library vulnerabilities that govulncheck reports. The security workflow takes its toolchain from go.mod, so the scan failed. Go 1.26.8 clears them.
2026-10-02 16:18:05 +01:00
lukaszraczylo 0865c405fb feat(pi): emit model context and output limits when set
The pi adapter writes contextWindow and maxTokens to models.json only
when the profile sets them. Pi keeps its own defaults for every other
model. Tests cover both cases.
2026-10-02 05:11:46 +01:00
lukaszraczylo b6bd5303e0 ci(security): resolve latest Go patch in govulncheck job
The govulncheck job fails on 17 standard library findings. The runner
uses an outdated Go toolchain. Set check-latest so setup-go installs
the newest patch release.
2026-10-02 05:10:31 +01:00
lukaszraczyloandGitHub f81492eb46 Update go.mod and go.sum (#28) 2026-09-19 04:18:26 +01:00
lukaszraczyloandGitHub 76ac377b5d Update go.mod and go.sum (#27) 2026-09-14 04:22:09 +01:00
lukaszraczyloandGitHub 2e661fb526 Update go.mod and go.sum (#26) 2026-09-11 04:19:54 +01:00
lukaszraczyloandGitHub c4f1b0fa1d Update go.mod and go.sum (#25) 2026-09-09 04:19:47 +01:00
lukaszraczyloandGitHub bf7be9d9c5 Update go.mod and go.sum (#24) 2026-09-02 04:19:26 +01:00
lukaszraczyloandGitHub c5707acfd3 Update go.mod and go.sum (#23) 2026-08-18 04:20:33 +01:00
lukaszraczyloandGitHub 3e3c78725e Update go.mod and go.sum (#22) 2026-08-12 04:47:48 +01:00
lukaszraczyloandGitHub 82e1de9773 Update go.mod and go.sum (#21) 2026-08-11 04:36:13 +01:00
lukaszraczyloandGitHub 565d72768b Update go.mod and go.sum (#20) 2026-08-03 07:28:07 +01:00
lukaszraczyloandGitHub 4701b45a12 Update go.mod and go.sum (#19) 2026-07-24 06:53:40 +01:00
lukaszraczyloandGitHub 8e3ec78e2b Update go.mod and go.sum (#18) 2026-07-23 07:05:08 +01:00
lukaszraczylo 62debbfcda fixup! Add pi support 2026-07-22 11:00:04 +01:00
lukaszraczylo b5e3bcd301 Add pi support 2026-06-28 00:51:34 +01:00
lukaszraczyloandGitHub fd6519eed1 Update go.mod and go.sum (#13) 2026-06-24 05:30:56 +01:00
lukaszraczyloandGitHub bca4a4be1a Update go.mod and go.sum (#12) 2026-06-23 05:28:57 +01:00
lukaszraczyloandGitHub fa17e9a289 Update go.mod and go.sum (#11) 2026-06-17 05:37:11 +01:00
lukaszraczylo f30c0f65a6 feat: sync rules across all harnesses + agents to opencode/kilo
Add Rule as a first-class canonical kind (rules/<name>.md, loaded like
agents) and propagate it the way each harness actually loads it:

- claude-code: native ~/.claude/rules directory symlink (preserves rule
  path-scoping frontmatter); rules NOT folded into CLAUDE.md.
- opencode/kilo/zed/crush: fold rule bodies into the global AGENTS.md
  always-on instructions file (frontmatter stripped). crush has no global
  instructions file, so register the absolute AGENTS.md path in
  options.context_paths (defaults are re-prepended at load, so nothing is
  clobbered).
- goose: fold into ~/.config/goose/.goosehints.
- cagent: fold into the per-agent instruction.

Also:
- Wire markdown agents to opencode (~/.config/opencode/agents) and fix the
  kilo agents symlink: plural ~/.config/kilo/agents (singular "agent" is a
  silent no-op on current Kilo CLI).
- Add ManagesAgents/ManagesRules to HarnessCapabilities + ImportResult.Rules;
  claude-code/opencode import rules/agents round-trip.
- Centralize instruction selection in Bundle.InstructionText /
  InstructionTextWithRules (replaces per-adapter override duplication).
- init scaffolds + imports rules; README capability matrix gains
  Agents/Rules columns with native-vs-folded footnotes.

Grounded each harness's sink against official docs + config source this
session. Gate: gofmt, go vet, go test -race ./..., golangci-lint (0),
govulncheck (clean).
2026-06-16 21:32:12 +01:00
lukaszraczyloandGitHub 0892cb317e Update go.mod and go.sum (#10) 2026-06-12 05:36:13 +01:00
lukaszraczylo 1053d223e5 fixup! fix(apply): propagate read errors, auto-open repo, dedupe adapter base (#6) 2026-06-12 01:32:21 +01:00
46 changed files with 1225 additions and 100 deletions
+2
View File
@@ -1,2 +1,4 @@
{"action":"prune","keep":10,"kept":[],"removed":[],"auditedAt":"2026-05-23T19:08:40.613Z"}
{"action":"prune","keep":10,"kept":[],"removed":[],"auditedAt":"2026-05-23T19:55:51.755Z"}
{"action":"prune","keep":10,"kept":[],"removed":[],"auditedAt":"2026-06-27T23:46:20.411Z"}
{"action":"prune","keep":10,"kept":[],"removed":[],"auditedAt":"2026-06-27T23:48:27.473Z"}
+3
View File
@@ -0,0 +1,3 @@
{"exportedAt":"2026-06-27T23:47:20.367Z","snapshots":[{"type":"counter","name":"crew.run.count","description":"Total runs by status","values":[]},{"type":"counter","name":"crew.task.count","description":"Total tasks by status","values":[]},{"type":"counter","name":"crew.subagent.count","description":"Total subagent records by status","values":[]},{"type":"counter","name":"crew.mailbox.count","description":"Total mailbox messages by direction","values":[]},{"type":"counter","name":"crew.task.retry_attempt_total","description":"Retry attempts by run and task","values":[]},{"type":"counter","name":"crew.task.deadletter_total","description":"Deadletter triggers by reason","values":[]},{"type":"counter","name":"crew.task.overflow_phase_total","description":"Overflow recovery phase transitions","values":[]},{"type":"counter","name":"crew.task.supervisor_contact_total","description":"Supervisor contact requests by reason","values":[]},{"type":"gauge","name":"crew.heartbeat.staleness_ms","description":"Heartbeat elapsed since last seen, milliseconds","values":[]},{"type":"histogram","name":"crew.run.duration_ms","description":"Run end-to-end duration, milliseconds","values":[]},{"type":"histogram","name":"crew.task.duration_ms","description":"Task duration, milliseconds","values":[]},{"type":"histogram","name":"crew.task.retry_count","description":"Retries per task","values":[]},{"type":"histogram","name":"crew.task.tokens_total","description":"Token usage per task","values":[]}]}
{"exportedAt":"2026-06-27T23:48:20.367Z","snapshots":[{"type":"counter","name":"crew.run.count","description":"Total runs by status","values":[]},{"type":"counter","name":"crew.task.count","description":"Total tasks by status","values":[]},{"type":"counter","name":"crew.subagent.count","description":"Total subagent records by status","values":[]},{"type":"counter","name":"crew.mailbox.count","description":"Total mailbox messages by direction","values":[]},{"type":"counter","name":"crew.task.retry_attempt_total","description":"Retry attempts by run and task","values":[]},{"type":"counter","name":"crew.task.deadletter_total","description":"Deadletter triggers by reason","values":[]},{"type":"counter","name":"crew.task.overflow_phase_total","description":"Overflow recovery phase transitions","values":[]},{"type":"counter","name":"crew.task.supervisor_contact_total","description":"Supervisor contact requests by reason","values":[]},{"type":"gauge","name":"crew.heartbeat.staleness_ms","description":"Heartbeat elapsed since last seen, milliseconds","values":[]},{"type":"histogram","name":"crew.run.duration_ms","description":"Run end-to-end duration, milliseconds","values":[]},{"type":"histogram","name":"crew.task.duration_ms","description":"Task duration, milliseconds","values":[]},{"type":"histogram","name":"crew.task.retry_count","description":"Retries per task","values":[]},{"type":"histogram","name":"crew.task.tokens_total","description":"Token usage per task","values":[]}]}
{"exportedAt":"2026-06-27T23:49:20.368Z","snapshots":[{"type":"counter","name":"crew.run.count","description":"Total runs by status","values":[]},{"type":"counter","name":"crew.task.count","description":"Total tasks by status","values":[]},{"type":"counter","name":"crew.subagent.count","description":"Total subagent records by status","values":[]},{"type":"counter","name":"crew.mailbox.count","description":"Total mailbox messages by direction","values":[]},{"type":"counter","name":"crew.task.retry_attempt_total","description":"Retry attempts by run and task","values":[]},{"type":"counter","name":"crew.task.deadletter_total","description":"Deadletter triggers by reason","values":[]},{"type":"counter","name":"crew.task.overflow_phase_total","description":"Overflow recovery phase transitions","values":[]},{"type":"counter","name":"crew.task.supervisor_contact_total","description":"Supervisor contact requests by reason","values":[]},{"type":"gauge","name":"crew.heartbeat.staleness_ms","description":"Heartbeat elapsed since last seen, milliseconds","values":[]},{"type":"histogram","name":"crew.run.duration_ms","description":"Run end-to-end duration, milliseconds","values":[]},{"type":"histogram","name":"crew.task.duration_ms","description":"Task duration, milliseconds","values":[]},{"type":"histogram","name":"crew.task.retry_count","description":"Retries per task","values":[]},{"type":"histogram","name":"crew.task.tokens_total","description":"Token usage per task","values":[]}]}
+7 -7
View File
@@ -1,4 +1,4 @@
name: Autoupdate go.mod and go.sum
name: Update dependencies
on:
workflow_dispatch:
@@ -6,15 +6,15 @@ on:
- cron: "0 3 * * *"
permissions:
contents: write
actions: write
contents: write
issues: write
pull-requests: write
security-events: write
jobs:
autoupdate:
uses: lukaszraczylo/shared-actions/.github/workflows/go-autoupdate.yaml@main
update:
uses: lukaszraczylo/shared-actions/.github/workflows/renovate-autoupdate.yaml@main
with:
go-version: ">=1.25"
release-workflow: "release.yaml"
secrets: inherit
node: false
release-workflow: release.yaml
+1
View File
@@ -31,6 +31,7 @@ jobs:
uses: actions/setup-go@v5
with:
go-version-file: go.mod
check-latest: true
cache: true
- name: Install govulncheck
+3
View File
@@ -0,0 +1,3 @@
{
"history": []
}
+25 -13
View File
@@ -3,7 +3,7 @@
</p>
<p align="center">
<strong>One canonical source of truth</strong> for skills, agents, MCP servers, LLM endpoints, and global instructions across every LLM harness on your machine.
<strong>One canonical source of truth</strong> for skills, agents, rules, MCP servers, LLM endpoints, and global instructions across every LLM harness on your machine.
</p>
<p align="center">
@@ -40,6 +40,7 @@ Edit once. Forget the others. They drift. Things stop working in odd places.
│ • profiles/<name>.yaml │
│ • skills/<name>/SKILL.md │
│ • agents/<name>.md │
│ • rules/<name>.md │
│ • mcp.yaml │
│ • instructions/global.md │
└──────────────┬───────────────────┘
@@ -139,27 +140,38 @@ harness-sync goes out of its way to avoid.
| **crush** | `~/.config/crush/crush.json` (merged) | `mcp` (`type: stdio`/`http`/`sse`) | `providers` map + `default_model` | `~/.config/crush/skills/` |
| **kilo** | `~/.config/kilo/kilo.json` (merged) | `mcp` (`type: local`/`remote`) | `provider` map + `model` + `small_model` | `~/.kilo/skills/` |
| **opencode** | `~/.config/opencode/opencode.jsonc` (merged) | `mcp` (`type: local`/`remote`) | `provider` map + `model` | `~/.config/opencode/skills/` |
| **pi** | `~/.pi/agent/settings.json` (merged) + `~/.pi/agent/models.json` | — | `defaultProvider` + `defaultModel` + `models.json` provider | `~/.pi/agent/skills/` |
| **goose** | `~/.config/goose/config.yaml` (merged) + `custom_providers/<name>.json` | `extensions` map (`type: stdio`) | `GOOSE_PROVIDER` + `GOOSE_MODEL` | `~/.agents/skills/` |
| **cagent** | `~/.config/cagent/default.yaml` (starter) | `mcps` | `providers` map + per-agent `model:` | — |
| **zed** | `~/.config/zed/settings.json` (merged) | `context_servers` | `language_models.openai.{api_url, available_models}` + `agent.default_model` | — |
### Capability matrix
What harness-sync writes per harness. Harnesses with a **built-in subscription** receive MCP + skills + instructions only — provider/model/endpoint config is skipped to avoid conflicting with the harness's own auth.
What harness-sync writes per harness. Harnesses with a **built-in subscription** receive MCP + skills + agents + rules + instructions only — provider/model/endpoint config is skipped to avoid conflicting with the harness's own auth.
Skills paths are grounded in each harness's official documentation (kilo.ai, opencode.ai, goose-docs.ai). kilo, opencode, and goose also scan `~/.claude/skills/` as a compatibility path, so the claude-code symlink passively reaches them already.
| Harness | Built-in sub | Providers | Models | MCP | Skills | Instructions |
|---|:---:|:---:|:---:|:---:|:---:|:---:|
| **claude-code** | ✓ | — | — | ✓ | ✓ | ✓ |
| **crush** | — | ✓ | ✓ | ✓ | ✓ | — |
| **kilo** | — | ✓ | ✓ | ✓ | ✓ | — |
| **opencode** | — | ✓ | ✓ | ✓ | ✓ | ✓ |
| **goose** | — | ✓ | ✓ | ✓ | ✓ | — |
| **cagent** | — | ✓ | ✓ | ✓ | — | ✓ |
| **zed** | — | ✓ | ✓ | ✓ | — | — |
| Harness | Built-in sub | Providers | Models | MCP | Skills | Agents | Rules | Instructions |
|---|:---:|:---:|:---:|:---:|:---:|:---:|:---:|:---:|
| **claude-code** | ✓ | — | — | ✓ | ✓ | ✓ | ✓ⁿ | ✓ |
| **crush** | — | ✓ | ✓ | ✓ | ✓ | — | ✓ᶠ | ✓ᶠ |
| **kilo** | — | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ᶠ | ✓ᶠ |
| **opencode** | — | ✓ | ✓ | ✓ | ✓ | ✓ | ✓ᶠ | ✓ |
| **pi** | — | ✓ | ✓ | — | ✓ | — | ✓ᶠ | ✓ᶠ |
| **goose** | — | ✓ | ✓ | ✓ | ✓ | — | ✓ᶠ | ✓ᶠ |
| **cagent** | — | ✓ | ✓ | ✓ | — | — | ✓ᶠ | ✓ |
| **zed** | — | ✓ | ✓ | — | — | — | ✓ᶠ | ✓ᶠ |
The matrix is machine-readable via `adapter.Capabilities()` — every adapter implements `HarnessCapabilities` so tooling can inspect what will change before running `apply`.
The matrix is machine-readable via `adapter.Capabilities()` — every adapter implements `HarnessCapabilities` (`ManagesProviders/Models/MCP/Skills/Agents/Rules/Instructions`) so tooling can inspect what will change before running `apply`.
### Agents & rules — native where possible, folded where necessary
Each kind is delivered the way the target harness actually loads it (grounded in each harness's docs and config source — a wrong path is a silent no-op):
- **Agents** are markdown subagents. They map cleanly to **claude-code** (`~/.claude/agents/`), **kilo** (`~/.config/kilo/agents/` — plural; the older singular `agent/` is a no-op on current Kilo CLI), and **opencode** (`~/.config/opencode/agents/`), all as directory symlinks. **goose** (YAML recipes) and **cagent** (inline YAML `agents:`) use incompatible agent formats, and **crush**/**zed** have no markdown-subagent concept — so agents are not propagated there.
- **Rules** (`rules/<name>.md`) are topic-scoped instruction fragments. **claude-code** auto-loads a rules *directory* natively (ⁿ), so they're delivered as a `~/.claude/rules` symlink — preserving each rule's optional path-scoping frontmatter. No other harness has a rules directory, so their bodies are **folded** (ᶠ) into that harness's global always-on instructions file — `AGENTS.md` (opencode/kilo/zed/crush), `.goosehints` (goose), or the per-agent `instruction:` (cagent). crush has no global instructions file, so harness-sync writes `~/.config/crush/AGENTS.md` and registers its absolute path in `options.context_paths` (crush always re-adds its built-in defaults at load, so nothing is clobbered).
ⁿ delivered as a native rules directory ᶠ folded into the harness's global instructions file
> **Merged, not replaced.** For harnesses with user-managed config keys (every one
> except cagent), harness-sync reads the existing file, overlays only the keys
@@ -279,7 +291,7 @@ end-to-end test that runs the real binary against a fake `$HOME`.
```
cmd/harness-sync/main.go # cobra entrypoint + adapter registration
internal/canonical/ # Bundle, Profile, MCPRegistry, Skill, Agent types + loader
internal/canonical/ # Bundle, Profile, MCPRegistry, Skill, Agent, Rule types + loader
internal/adapter/ # Adapter interface, Registry, FileSet
internal/adapter/common/ # shared building blocks (BuildProviders, BuildMCPMapStyled, MergeJSONKeys, MergeYAMLKeys, …)
internal/adapters/<harness>/ # one package per harness, ~50-100 LOC of harness-specific glue
+2
View File
@@ -12,6 +12,7 @@ import (
"github.com/lukaszraczylo/harness-sync/internal/adapters/goose"
"github.com/lukaszraczylo/harness-sync/internal/adapters/kilo"
"github.com/lukaszraczylo/harness-sync/internal/adapters/opencode"
"github.com/lukaszraczylo/harness-sync/internal/adapters/pi"
"github.com/lukaszraczylo/harness-sync/internal/adapters/zed"
"github.com/lukaszraczylo/harness-sync/internal/cli"
"github.com/lukaszraczylo/oss-telemetry"
@@ -28,6 +29,7 @@ func main() {
reg.Register(crush.New())
reg.Register(kilo.New())
reg.Register(opencode.New())
reg.Register(pi.New())
reg.Register(goose.New())
reg.Register(cagent.New())
reg.Register(zed.New())
+13 -14
View File
@@ -1,14 +1,14 @@
module github.com/lukaszraczylo/harness-sync
go 1.25.0
go 1.26.8
require (
github.com/charmbracelet/huh v1.0.0
github.com/lukaszraczylo/oss-telemetry v0.2.3
github.com/pelletier/go-toml/v2 v2.3.1
github.com/lukaszraczylo/oss-telemetry v0.2.5
github.com/pelletier/go-toml/v2 v2.4.3
github.com/spf13/afero v1.15.0
github.com/spf13/cobra v1.10.2
github.com/stretchr/testify v1.9.0
github.com/stretchr/testify v1.12.1
gopkg.in/yaml.v3 v3.0.1
)
@@ -20,28 +20,27 @@ require (
github.com/charmbracelet/bubbletea v1.3.10 // indirect
github.com/charmbracelet/colorprofile v0.4.3 // indirect
github.com/charmbracelet/lipgloss v1.1.0 // indirect
github.com/charmbracelet/x/ansi v0.11.7 // indirect
github.com/charmbracelet/x/ansi v0.11.8 // indirect
github.com/charmbracelet/x/cellbuf v0.0.15 // indirect
github.com/charmbracelet/x/exp/strings v0.1.0 // indirect
github.com/charmbracelet/x/term v0.2.2 // indirect
github.com/clipperhouse/displaywidth v0.11.0 // indirect
github.com/clipperhouse/uax29/v2 v2.7.0 // indirect
github.com/davecgh/go-spew v1.1.1 // indirect
github.com/dustin/go-humanize v1.0.1 // indirect
github.com/dustin/go-humanize v1.1.0 // indirect
github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f // indirect
github.com/inconshreveable/mousetrap v1.1.0 // indirect
github.com/lucasb-eyer/go-colorful v1.4.0 // indirect
github.com/mattn/go-isatty v0.0.22 // indirect
github.com/lucasb-eyer/go-colorful v1.4.1 // indirect
github.com/mattn/go-isatty v0.0.24 // indirect
github.com/mattn/go-localereader v0.0.1 // indirect
github.com/mattn/go-runewidth v0.0.24 // indirect
github.com/mattn/go-runewidth v0.0.30 // indirect
github.com/mitchellh/hashstructure/v2 v2.0.2 // indirect
github.com/muesli/ansi v0.0.0-20230316100256-276c6243b2f6 // indirect
github.com/muesli/cancelreader v0.2.2 // indirect
github.com/muesli/termenv v0.16.0 // indirect
github.com/pmezard/go-difflib v1.0.0 // indirect
github.com/rivo/uniseg v0.4.7 // indirect
github.com/spf13/pflag v1.0.10 // indirect
github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect
golang.org/x/sys v0.45.0 // indirect
golang.org/x/text v0.37.0 // indirect
github.com/xo/terminfo v1.2.0 // indirect
go.yaml.in/yaml/v3 v3.0.5 // indirect
golang.org/x/sys v0.48.0 // indirect
golang.org/x/text v0.42.0 // indirect
)
+24 -28
View File
@@ -18,8 +18,8 @@ github.com/charmbracelet/huh v1.0.0 h1:wOnedH8G4qzJbmhftTqrpppyqHakl/zbbNdXIWJyI
github.com/charmbracelet/huh v1.0.0/go.mod h1:5YVc+SlZ1IhQALxRPpkGwwEKftN/+OlJlnJYlDRFqN4=
github.com/charmbracelet/lipgloss v1.1.0 h1:vYXsiLHVkK7fp74RkV7b2kq9+zDLoEU4MZoFqR/noCY=
github.com/charmbracelet/lipgloss v1.1.0/go.mod h1:/6Q8FR2o+kj8rz4Dq0zQc3vYf7X+B0binUUBwA0aL30=
github.com/charmbracelet/x/ansi v0.11.7 h1:kzv1kJvjg2S3r9KHo8hDdHFQLEqn4RBCb39dAYC84jI=
github.com/charmbracelet/x/ansi v0.11.7/go.mod h1:9qGpnAVYz+8ACONkZBUWPtL7lulP9No6p1epAihUZwQ=
github.com/charmbracelet/x/ansi v0.11.8 h1:JMFwp0CgDC2+jcOB162HH5k7I3FVbgFSMMYg7dSPBQQ=
github.com/charmbracelet/x/ansi v0.11.8/go.mod h1:ZNN+3mXny/516oTQPLMPIBeSINvNJJQ8uQXDgbeJxY0=
github.com/charmbracelet/x/cellbuf v0.0.15 h1:ur3pZy0o6z/R7EylET877CBxaiE1Sp1GMxoFPAIztPI=
github.com/charmbracelet/x/cellbuf v0.0.15/go.mod h1:J1YVbR7MUuEGIFPCaaZ96KDl5NoS0DAWkskup+mOY+Q=
github.com/charmbracelet/x/conpty v0.1.0 h1:4zc8KaIcbiL4mghEON8D72agYtSeIgq8FSThSPQIb+U=
@@ -43,24 +43,22 @@ github.com/clipperhouse/uax29/v2 v2.7.0/go.mod h1:EFJ2TJMRUaplDxHKj1qAEhCtQPW2tJ
github.com/cpuguy83/go-md2man/v2 v2.0.6/go.mod h1:oOW0eioCTA6cOiMLiUPZOpcVxMig6NIQQ7OS05n1F4g=
github.com/creack/pty v1.1.24 h1:bJrF4RRfyJnbTJqzRLHzcGaZK1NeM5kTC9jGgovnR1s=
github.com/creack/pty v1.1.24/go.mod h1:08sCNb52WyoAwi2QDyzUCTgcvVFhUzewun7wtTfvcwE=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
github.com/dustin/go-humanize v1.1.0 h1:dbKTrvD0klcbBV/h4AWJdMuZogJACoMlvWIWZ5b2xWg=
github.com/dustin/go-humanize v1.1.0/go.mod h1:hc1CvRkJMsgxqjmjMQF3QNRAZBwY8AXBAzKYoSX9sFI=
github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f h1:Y/CXytFA4m6baUTXGLOoWe4PQhGxaX0KpnayAqC48p4=
github.com/erikgeiser/coninput v0.0.0-20211004153227-1c3628e74d0f/go.mod h1:vw97MGsxSvLiUE2X8qFplwetxpGLQrlU1Q9AUEIzCaM=
github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
github.com/lucasb-eyer/go-colorful v1.4.0 h1:UtrWVfLdarDgc44HcS7pYloGHJUjHV/4FwW4TvVgFr4=
github.com/lucasb-eyer/go-colorful v1.4.0/go.mod h1:R4dSotOR9KMtayYi1e77YzuveK+i7ruzyGqttikkLy0=
github.com/lukaszraczylo/oss-telemetry v0.2.3 h1:xoDtBqeZGmXj7IteiE1M5WMuzeoqag58qEleI0Cf2Ms=
github.com/lukaszraczylo/oss-telemetry v0.2.3/go.mod h1:+Cn78qZo8rc3T9eZt0v3oICYRdd75wORtSidc8lNjDQ=
github.com/mattn/go-isatty v0.0.22 h1:j8l17JJ9i6VGPUFUYoTUKPSgKe/83EYU2zBC7YNKMw4=
github.com/mattn/go-isatty v0.0.22/go.mod h1:ZXfXG4SQHsB/w3ZeOYbR0PrPwLy+n6xiMrJlRFqopa4=
github.com/lucasb-eyer/go-colorful v1.4.1 h1:1EO+WB73+EH8EVbzlrG3KLAfEypQWVHIBqlTf+2hNss=
github.com/lucasb-eyer/go-colorful v1.4.1/go.mod h1:R4dSotOR9KMtayYi1e77YzuveK+i7ruzyGqttikkLy0=
github.com/lukaszraczylo/oss-telemetry v0.2.5 h1:W6Qgwp7IY4yBRO361MmnEAmM59motdQpbAFAx8v6fJM=
github.com/lukaszraczylo/oss-telemetry v0.2.5/go.mod h1:+Cn78qZo8rc3T9eZt0v3oICYRdd75wORtSidc8lNjDQ=
github.com/mattn/go-isatty v0.0.24 h1:tGZZoVgT/KiqK1c8ocVLeDS8BSWMRd47J3Lbz7vsReI=
github.com/mattn/go-isatty v0.0.24/go.mod h1:nMCL3Zebbrt45jsMDgnfIwz6ydEQApk5oEI3HqDio6A=
github.com/mattn/go-localereader v0.0.1 h1:ygSAOl7ZXTx4RdPYinUpg6W99U8jWvWi9Ye2JC/oIi4=
github.com/mattn/go-localereader v0.0.1/go.mod h1:8fBrzywKY7BI3czFoHkuzRoWE9C+EiG4R1k4Cjx5p88=
github.com/mattn/go-runewidth v0.0.24 h1:cpokDiIn0MGnhdHwuWnJBITySJ20QyNGnY2kR/ay2DU=
github.com/mattn/go-runewidth v0.0.24/go.mod h1:XBkDxAl56ILZc9knddidhrOlY5R/pDhgLpndooCuJAs=
github.com/mattn/go-runewidth v0.0.30 h1:+KUuiDA4fF0R1p5FeueHefjDm+GIM+kWfFnDjybOPgk=
github.com/mattn/go-runewidth v0.0.30/go.mod h1:3qAiGCV4Koz/yuveO58qUefmUTRm8r0IGEXZ9jeHp/8=
github.com/mitchellh/hashstructure/v2 v2.0.2 h1:vGKWl0YJqUNxE8d+h8f6NJLcCJrgbhC4NcD46KavDd4=
github.com/mitchellh/hashstructure/v2 v2.0.2/go.mod h1:MG3aRVU/N29oo/V/IhBX8GR/zz4kQkprJgF2EVszyDE=
github.com/muesli/ansi v0.0.0-20230316100256-276c6243b2f6 h1:ZK8zHtRHOkbHy6Mmr5D264iyp3TiX5OmNcI5cIARiQI=
@@ -69,10 +67,8 @@ github.com/muesli/cancelreader v0.2.2 h1:3I4Kt4BQjOR54NavqnDogx/MIoWBFa0StPA8ELU
github.com/muesli/cancelreader v0.2.2/go.mod h1:3XuTXfFS2VjM+HTLZY9Ak0l6eUKfijIfMUZ4EgX0QYo=
github.com/muesli/termenv v0.16.0 h1:S5AlUN9dENB57rsbnkPyfdGuWIlkmzJjbFf0Tf5FWUc=
github.com/muesli/termenv v0.16.0/go.mod h1:ZRfOIKPFDYQoDFF4Olj7/QJbW60Ol/kL1pU3VfY/Cnk=
github.com/pelletier/go-toml/v2 v2.3.1 h1:MYEvvGnQjeNkRF1qUuGolNtNExTDwct51yp7olPtrEc=
github.com/pelletier/go-toml/v2 v2.3.1/go.mod h1:2gIqNv+qfxSVS7cM2xJQKtLSTLUE9V8t9Stt+h56mCY=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/pelletier/go-toml/v2 v2.4.3 h1:GTRvJQutkOSftxIFD5xw9aepkYNuPWmVJpffdDPYVpY=
github.com/pelletier/go-toml/v2 v2.4.3/go.mod h1:2gIqNv+qfxSVS7cM2xJQKtLSTLUE9V8t9Stt+h56mCY=
github.com/rivo/uniseg v0.4.7 h1:WUdvkW8uEhrYfLC4ZzdpI2ztxP1I582+49Oc5Mq64VQ=
github.com/rivo/uniseg v0.4.7/go.mod h1:FN3SvrM+Zdj16jyLfmOkMNblXMcoc8DfTHruCPUcx88=
github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=
@@ -83,18 +79,18 @@ github.com/spf13/cobra v1.10.2/go.mod h1:7C1pvHqHw5A4vrJfjNwvOdzYu0Gml16OCs2GRiT
github.com/spf13/pflag v1.0.9/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
github.com/spf13/pflag v1.0.10 h1:4EBh2KAYBwaONj6b2Ye1GiHfwjqyROoF4RwYO+vPwFk=
github.com/spf13/pflag v1.0.10/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e h1:JVG44RsyaB9T2KIHavMF/ppJZNG9ZpyihvCd0w101no=
github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e/go.mod h1:RbqR21r5mrJuqunuUZ/Dhy/avygyECGrLceyNeo4LiM=
github.com/stretchr/testify v1.12.1 h1:EuwCh5fleGS7H32xRwO3wRGT7DxrDhLAT6FF8MpWDWE=
github.com/stretchr/testify v1.12.1/go.mod h1:MDEgiDPPsNp5cuIrHPPCyornHKgEVbtFUmoNlxoYthg=
github.com/xo/terminfo v1.2.0 h1:d0ZTOCpuGE0lwSAOs0zcJjwz3jWQyqcRt9XbGJpCOl4=
github.com/xo/terminfo v1.2.0/go.mod h1:lGzkSo8Fe7IRh/w+Gqz7n5mDog4FVXCj3gy/DYTBqio=
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/go.mod h1:ldy0pHrwJyGW56pPQzzkH36rKxoZW1tw7ZJpeKx+hdo=
go.yaml.in/yaml/v3 v3.0.5 h1:N6y/pJk8buWs9NY5ERU2HSMfm+IuD/OtfdAnq6kESPw=
go.yaml.in/yaml/v3 v3.0.5/go.mod h1:HVTZu1O7/Vkt2N+BFy8Zza+lnLsABggaTM2ZpNIGuKg=
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.45.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
golang.org/x/text v0.37.0 h1:Cqjiwd9eSg8e0QAkyCaQTNHFIIzWtidPahFWR83rTrc=
golang.org/x/text v0.37.0/go.mod h1:a5sjxXGs9hsn/AJVwuElvCAo9v8QYLzvavO5z2PiM38=
golang.org/x/sys v0.48.0 h1:bbX/i/6MgT9BVLM9RT1thmxL04yeTAhbEz4SyadbXoo=
golang.org/x/sys v0.48.0/go.mod h1:hNLxWAXmnKAxqDtdwIYC4bM9oQPEecfsnNMuSxOs3og=
golang.org/x/text v0.42.0 h1:JbOZXgfeCPU9gacVtYliJqOhD+zhrEqK4LfdpmlUZqI=
golang.org/x/text v0.42.0/go.mod h1:ojzP1Z+2QtioaF8DTtO8K5q7JWVVYwZKenzujK0Zd0E=
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/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+3
View File
@@ -31,6 +31,8 @@ type HarnessCapabilities struct {
ManagesModels bool // writes model selection config
ManagesMCP bool // writes MCP server config
ManagesSkills bool // writes skills symlink or equivalent
ManagesAgents bool // writes agents symlink or equivalent
ManagesRules bool // delivers rules (native rules dir, or folded into instructions)
ManagesInstructions bool // writes instructions file (CLAUDE.md, AGENTS.md, etc.)
HasBuiltInSub bool // has its own subscription; provider/model config is skipped
}
@@ -47,6 +49,7 @@ type ImportResult struct {
Instructions string
Skills []canonical.Skill
Agents []canonical.Agent
Rules []canonical.Rule
MCP []canonical.MCPServer
Profiles []canonical.Profile
}
+10 -10
View File
@@ -31,16 +31,16 @@ func GatewayProviderKey(gatewayURL string) string {
}
// crushModel builds a 10-field model entry required by the crush schema.
func crushModel(id string) map[string]any {
func crushModel(m canonical.Model) map[string]any {
return map[string]any{
"id": id,
"name": id,
"id": m.ID,
"name": m.ID,
"cost_per_1m_in": 0,
"cost_per_1m_out": 0,
"cost_per_1m_in_cached": 0,
"cost_per_1m_out_cached": 0,
"context_window": 200000,
"default_max_tokens": 8192,
"context_window": m.ContextLimit(),
"default_max_tokens": m.OutputLimit(),
"can_reason": false,
"supports_attachments": true,
}
@@ -56,10 +56,10 @@ func ProvidersAsCrushMap(p *canonical.Profile) map[string]any {
}
models := make([]map[string]any, 0)
for _, m := range p.Models {
models = append(models, crushModel(m.ID))
models = append(models, crushModel(m))
}
if len(models) == 0 && p.Gateway.DefaultModel != "" {
models = append(models, crushModel(p.Gateway.DefaultModel))
models = append(models, crushModel(canonical.Model{ID: p.Gateway.DefaultModel}))
}
out[GatewayProviderKey(p.Gateway.URL)] = map[string]any{
"type": "openai-compat",
@@ -101,7 +101,7 @@ func ProvidersAsMap(p *canonical.Profile) map[string]any {
}
models[m.ID] = map[string]any{
"name": displayName,
"limit": map[string]any{"context": 200000, "output": 8192},
"limit": map[string]any{"context": m.ContextLimit(), "output": m.OutputLimit()},
}
}
entry := map[string]any{
@@ -172,7 +172,7 @@ func GooseCustomProviderFile(p *canonical.Profile) ([]byte, string) {
for _, m := range p.Models {
models = append(models, map[string]any{
"name": m.ID,
"context_limit": 200000,
"context_limit": m.ContextLimit(),
})
}
if len(models) == 0 && p.Gateway.DefaultModel != "" {
@@ -183,7 +183,7 @@ func GooseCustomProviderFile(p *canonical.Profile) ([]byte, string) {
}
models = append(models, map[string]any{
"name": modelID,
"context_limit": 200000,
"context_limit": canonical.DefaultContextLimit,
})
}
+50
View File
@@ -1,6 +1,7 @@
package common
import (
"encoding/json"
"testing"
"github.com/stretchr/testify/assert"
@@ -64,3 +65,52 @@ func TestParseMCPFromJSONMissingKey(t *testing.T) {
require.NoError(t, err)
assert.Nil(t, servers)
}
func TestProvidersAsMapHonorsPerModelLimits(t *testing.T) {
p := &canonical.Profile{
Gateway: canonical.Gateway{URL: "https://gw.example.com/v1", Token: "t"},
Models: []canonical.Model{
{ID: "prov/big", Context: 262144, Output: 65536},
{ID: "prov/default"},
},
}
models := ProvidersAsMap(p)[GatewayProviderKey(p.Gateway.URL)].(map[string]any)["models"].(map[string]any)
big := models["prov/big"].(map[string]any)["limit"].(map[string]any)
assert.Equal(t, 262144, big["context"], "explicit context override should win")
assert.Equal(t, 65536, big["output"], "explicit output override should win")
def := models["prov/default"].(map[string]any)["limit"].(map[string]any)
assert.Equal(t, 200000, def["context"], "unset model falls back to default context")
assert.Equal(t, 8192, def["output"], "unset model falls back to default output")
}
func TestProvidersAsCrushMapHonorsPerModelLimits(t *testing.T) {
p := &canonical.Profile{
Gateway: canonical.Gateway{URL: "https://gw.example.com/v1", Token: "t"},
Models: []canonical.Model{
{ID: "prov/big", Context: 262144, Output: 65536},
{ID: "prov/default"},
},
}
models := ProvidersAsCrushMap(p)[GatewayProviderKey(p.Gateway.URL)].(map[string]any)["models"].([]map[string]any)
assert.Equal(t, 262144, models[0]["context_window"], "explicit context override should win")
assert.Equal(t, 65536, models[0]["default_max_tokens"], "explicit output override should win")
assert.Equal(t, 200000, models[1]["context_window"], "unset model falls back to default context")
assert.Equal(t, 8192, models[1]["default_max_tokens"], "unset model falls back to default output")
}
func TestGooseCustomProviderFileHonorsPerModelContext(t *testing.T) {
p := &canonical.Profile{
Gateway: canonical.Gateway{URL: "https://gw.example.com/v1", Token: "t"},
Models: []canonical.Model{{ID: "big", Context: 262144}, {ID: "default"}},
}
body, _ := GooseCustomProviderFile(p)
var entry map[string]any
require.NoError(t, json.Unmarshal(body, &entry))
models := entry["models"].([]any)
assert.Equal(t, float64(262144), models[0].(map[string]any)["context_limit"], "explicit context override should win")
assert.Equal(t, float64(200000), models[1].(map[string]any)["context_limit"], "unset model falls back to default context")
}
+2
View File
@@ -168,6 +168,7 @@ func parseMCPEntry(name string, raw json.RawMessage) (canonical.MCPServer, bool)
Cmd json.RawMessage `json:"cmd"`
Args []string `json:"args"`
URL string `json:"url"`
Headers map[string]string `json:"headers"`
Env map[string]string `json:"env"`
Environment map[string]string `json:"environment"`
}
@@ -198,6 +199,7 @@ func parseMCPEntry(name string, raw json.RawMessage) (canonical.MCPServer, bool)
Args: args,
URL: e.URL,
Transport: transport,
Headers: e.Headers,
Env: env,
}, true
}
+2
View File
@@ -42,6 +42,7 @@ func TestImportMCPFromJSONFileFSExtractsServers(t *testing.T) {
"myserver": {
"command": "/usr/bin/mytool",
"args": ["--flag"],
"headers": {"Authorization": "Bearer ${MCP_TOKEN}"},
"type": "stdio"
}
}
@@ -55,6 +56,7 @@ func TestImportMCPFromJSONFileFSExtractsServers(t *testing.T) {
assert.Equal(t, "/usr/bin/mytool", servers[0].Command)
assert.Equal(t, []string{"--flag"}, servers[0].Args)
assert.Equal(t, "stdio", servers[0].Transport)
assert.Equal(t, map[string]string{"Authorization": "Bearer ${MCP_TOKEN}"}, servers[0].Headers)
}
func TestImportMCPFromJSONFileFSReadOnlyFS(t *testing.T) {
+9
View File
@@ -39,6 +39,9 @@ func mcpEntry(s canonical.MCPServer, style MCPStyle) map[string]any {
}
e["type"] = t
e["url"] = s.URL
if len(s.Headers) > 0 {
e["headers"] = s.Headers
}
} else {
// Claude honours Transport field; Crush always uses "stdio".
t := "stdio"
@@ -60,6 +63,9 @@ func mcpEntry(s canonical.MCPServer, style MCPStyle) map[string]any {
if s.URL != "" {
e["type"] = "remote"
e["url"] = s.URL
if len(s.Headers) > 0 {
e["headers"] = s.Headers
}
} else {
e["type"] = "local"
cmd := []string{}
@@ -79,6 +85,9 @@ func mcpEntry(s canonical.MCPServer, style MCPStyle) map[string]any {
// fail all of them. Omitting "enabled" defaults to true.
if s.URL != "" {
e["url"] = s.URL
if len(s.Headers) > 0 {
e["headers"] = s.Headers
}
} else {
if s.Command != "" {
e["command"] = s.Command
+12 -2
View File
@@ -26,11 +26,16 @@ func TestBuildMCPMapStyledClaudeStyle(t *testing.T) {
}
func TestBuildMCPMapStyledClaudeStyleURL(t *testing.T) {
r := reg(canonical.MCPServer{Name: "remote", URL: "https://example.com"})
r := reg(canonical.MCPServer{
Name: "remote",
URL: "https://example.com",
Headers: map[string]string{"Authorization": "Bearer ${MCP_TOKEN}"},
})
out := BuildMCPMapStyled(r, MCPClaudeStyle)
e := out["remote"].(map[string]any)
assert.Equal(t, "https://example.com", e["url"])
assert.Equal(t, "http", e["type"])
assert.Equal(t, map[string]string{"Authorization": "Bearer ${MCP_TOKEN}"}, e["headers"])
}
func TestBuildMCPMapStyledCrushStdio(t *testing.T) {
@@ -70,12 +75,17 @@ func TestBuildMCPMapStyledOpencodeLocal(t *testing.T) {
}
func TestBuildMCPMapStyledOpencodeRemote(t *testing.T) {
r := reg(canonical.MCPServer{Name: "r", URL: "https://example.com"})
r := reg(canonical.MCPServer{
Name: "r",
URL: "https://example.com",
Headers: map[string]string{"X-Tenant": "tenant-a"},
})
out := BuildMCPMapStyled(r, MCPOpencodeStyle)
e := out["r"].(map[string]any)
assert.Equal(t, "remote", e["type"])
assert.Equal(t, true, e["enabled"])
assert.Equal(t, "https://example.com", e["url"])
assert.Equal(t, map[string]string{"X-Tenant": "tenant-a"}, e["headers"])
}
func TestBuildMCPMapStyledOpencodeEnv(t *testing.T) {
+4 -4
View File
@@ -41,6 +41,7 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
ManagesModels: true,
ManagesMCP: true,
ManagesSkills: false,
ManagesRules: true,
ManagesInstructions: true,
HasBuiltInSub: false,
}
@@ -57,10 +58,9 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
fs := adapter.NewFileSet()
cfgPath := filepath.Join(a.Home, ".config", "cagent", "default.yaml")
instructions := b.Instructions.Global
if override, ok := b.Instructions.PerHarness[name]; ok && override != "" {
instructions = override
}
// cagent has no rules concept; the per-agent instruction (system prompt) is
// the only sink, so fold rules into it.
instructions := b.InstructionTextWithRules(name)
mcps := map[string]any{}
for _, s := range b.MCP.Servers {
+37
View File
@@ -0,0 +1,37 @@
package cagent
import (
"path/filepath"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
"gopkg.in/yaml.v3"
)
func TestCagentFoldsRulesIntoInstruction(t *testing.T) {
home := t.TempDir()
b := &canonical.Bundle{
Instructions: canonical.Instructions{Global: "# global"},
Rules: []canonical.Rule{{Name: "rust", Body: "# Rust\n\nno unwrap"}},
}
fs, err := New(WithHome(home)).Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
cfg := seen[filepath.Join(home, ".config", "cagent", "default.yaml")]
require.Equal(t, adapter.RenderedFile, cfg.Kind)
var parsed map[string]any
require.NoError(t, yaml.Unmarshal(cfg.Content, &parsed))
agents := parsed["agents"].(map[string]any)
def := agents["default"].(map[string]any)
instr := def["instruction"].(string)
assert.Contains(t, instr, "# global")
assert.Contains(t, instr, "no unwrap")
}
+11 -5
View File
@@ -37,6 +37,8 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
ManagesModels: false,
ManagesMCP: true,
ManagesSkills: true,
ManagesAgents: true,
ManagesRules: true,
ManagesInstructions: true,
HasBuiltInSub: true,
}
@@ -65,15 +67,19 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
Kind: adapter.SymlinkDir,
SymlinkTarget: filepath.Join(b.Root, "agents"),
})
// Claude Code natively auto-loads ~/.claude/rules/*.md (memory feature), so
// rules are delivered as their own directory symlink — NOT folded into
// CLAUDE.md — preserving each rule's optional path-scoping frontmatter.
fs.Add(adapter.File{
Dest: filepath.Join(base, "rules"),
Kind: adapter.SymlinkDir,
SymlinkTarget: filepath.Join(b.Root, "rules"),
})
instructions := b.Instructions.Global
if override, ok := b.Instructions.PerHarness[name]; ok && override != "" {
instructions = override
}
fs.Add(adapter.File{
Dest: filepath.Join(base, "CLAUDE.md"),
Kind: adapter.RenderedFile,
Content: []byte(instructions),
Content: []byte(b.InstructionText(name)),
})
// Claude Code reads MCP servers from two files on disk:
+10
View File
@@ -32,6 +32,16 @@ func importFrom(home string) (*adapter.ImportResult, error) {
})
}
rules, err := common.ImportMarkdownTree(filepath.Join(base, "rules"), "")
if err != nil {
return nil, err
}
for _, r := range rules {
res.Rules = append(res.Rules, canonical.Rule{
Name: r.Name, Description: r.Description, Body: r.Body, Path: r.Path,
})
}
body, err := common.ReadIfExists(filepath.Join(base, "CLAUDE.md"))
if err != nil {
return nil, err
@@ -0,0 +1,47 @@
package claudecode
import (
"os"
"path/filepath"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
func TestClaudeCodeRendersRulesSymlink(t *testing.T) {
home := t.TempDir()
ad := New(WithHome(home))
b := &canonical.Bundle{Root: "/canon"}
fs, err := ad.Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
rulesDest := filepath.Join(home, ".claude", "rules")
assert.Equal(t, adapter.SymlinkDir, seen[rulesDest].Kind)
assert.Equal(t, "/canon/rules", seen[rulesDest].SymlinkTarget)
// Rules are delivered natively as a directory — never folded into CLAUDE.md.
claudemd := string(seen[filepath.Join(home, ".claude", "CLAUDE.md")].Content)
assert.NotContains(t, claudemd, "/canon/rules")
}
func TestClaudeCodeImportsRules(t *testing.T) {
home := t.TempDir()
rulesDir := filepath.Join(home, ".claude", "rules")
require.NoError(t, os.MkdirAll(rulesDir, 0o750))
require.NoError(t, os.WriteFile(filepath.Join(rulesDir, "go.md"),
[]byte("# Go Rules\n\ngofmt always"), 0o600))
ad := New(WithHome(home))
res, err := ad.Import(home)
require.NoError(t, err)
require.Len(t, res.Rules, 1)
assert.Equal(t, "go", res.Rules[0].Name)
assert.Contains(t, res.Rules[0].Body, "gofmt always")
}
+44 -1
View File
@@ -2,6 +2,7 @@
package crush
import (
"encoding/json"
"fmt"
"os"
"path/filepath"
@@ -36,7 +37,8 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
ManagesModels: true,
ManagesMCP: true,
ManagesSkills: true,
ManagesInstructions: false,
ManagesRules: true,
ManagesInstructions: true,
HasBuiltInSub: false,
}
}
@@ -60,12 +62,25 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
SymlinkTarget: filepath.Join(b.Root, "skills"),
})
// crush has no global instructions file and no rules directory: it loads
// context from the files listed in options.context_paths (defaults are always
// prepended; absolute paths load verbatim; the global config applies to every
// project). Write a global AGENTS.md with rules folded in, and register its
// absolute path so crush loads it in every session.
agentsMD := filepath.Join(base, "AGENTS.md")
fs.Add(adapter.File{
Dest: agentsMD,
Kind: adapter.RenderedFile,
Content: []byte(b.InstructionTextWithRules(name)),
})
cfgPath := filepath.Join(base, "crush.json")
existing, err := common.ReadExistingFile(cfgPath)
if err != nil {
return nil, fmt.Errorf("read %s: %w", cfgPath, err)
}
overlay := map[string]any{}
overlay["options"] = crushOptionsWithContextPath(existing, agentsMD)
if providers := common.ProvidersAsCrushMap(&b.Profile); len(providers) > 0 {
overlay["providers"] = providers
}
@@ -89,6 +104,34 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
return fs, nil
}
// crushOptionsWithContextPath returns the crush "options" object with contextFile
// added to options.context_paths, preserving every other existing option key
// (lsp, permissions, …). crush always prepends its built-in default context
// paths at load time, so only the extra path is set here. Idempotent.
func crushOptionsWithContextPath(existing []byte, contextFile string) map[string]any {
opts := map[string]any{}
if len(existing) > 0 {
var raw map[string]any
clean := common.StripJSONComments(string(existing))
if json.Unmarshal([]byte(clean), &raw) == nil {
if o, ok := raw["options"].(map[string]any); ok {
opts = o
}
}
}
var paths []any
if existingPaths, ok := opts["context_paths"].([]any); ok {
paths = existingPaths
}
for _, p := range paths {
if s, ok := p.(string); ok && s == contextFile {
return opts // already registered
}
}
opts["context_paths"] = append(paths, contextFile)
return opts
}
// Import reads crush config from home and returns a canonical ImportResult.
func (a *Adapter) Import(home string) (*adapter.ImportResult, error) {
return importFrom(home)
+83
View File
@@ -0,0 +1,83 @@
package crush
import (
"encoding/json"
"os"
"path/filepath"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
func renderCrush(t *testing.T, home string, b *canonical.Bundle) map[string]adapter.File {
t.Helper()
fs, err := New(WithHome(home)).Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
return seen
}
func TestCrushWritesAGENTSAndRegistersContextPath(t *testing.T) {
home := t.TempDir()
b := &canonical.Bundle{
Root: "/canon",
Instructions: canonical.Instructions{Global: "# global"},
Rules: []canonical.Rule{{Name: "sec", Body: "# Security\n\nno secrets in code"}},
}
seen := renderCrush(t, home, b)
base := filepath.Join(home, ".config", "crush")
agentsMD := filepath.Join(base, "AGENTS.md")
assert.Equal(t, adapter.RenderedFile, seen[agentsMD].Kind)
body := string(seen[agentsMD].Content)
assert.Contains(t, body, "# global")
assert.Contains(t, body, "no secrets in code")
var cfg map[string]any
require.NoError(t, json.Unmarshal(seen[filepath.Join(base, "crush.json")].Content, &cfg))
opts := cfg["options"].(map[string]any)
paths := opts["context_paths"].([]any)
assert.Contains(t, paths, agentsMD, "absolute AGENTS.md path must be registered for global load")
}
func TestCrushPreservesExistingOptionsAndIsIdempotent(t *testing.T) {
home := t.TempDir()
base := filepath.Join(home, ".config", "crush")
require.NoError(t, os.MkdirAll(base, 0o750))
agentsMD := filepath.Join(base, "AGENTS.md")
// Existing crush.json with other options keys and a pre-existing context path
// (including our own — second apply must not duplicate it).
existing := map[string]any{
"options": map[string]any{
"context_paths": []any{"PROJECT.md", agentsMD},
"lsp": map[string]any{"go": true},
},
}
body, _ := json.Marshal(existing)
require.NoError(t, os.WriteFile(filepath.Join(base, "crush.json"), body, 0o600))
seen := renderCrush(t, home, &canonical.Bundle{Root: "/canon"})
var cfg map[string]any
require.NoError(t, json.Unmarshal(seen[filepath.Join(base, "crush.json")].Content, &cfg))
opts := cfg["options"].(map[string]any)
// Other option keys survive.
assert.Contains(t, opts, "lsp")
// Pre-existing user path survives; ours is present exactly once (idempotent).
paths := opts["context_paths"].([]any)
count := 0
for _, p := range paths {
if p == agentsMD {
count++
}
}
assert.Equal(t, 1, count, "our context path must not be duplicated on re-apply")
assert.Contains(t, paths, "PROJECT.md")
}
+12 -1
View File
@@ -45,7 +45,8 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
ManagesModels: true,
ManagesMCP: true,
ManagesSkills: true,
ManagesInstructions: false,
ManagesRules: true,
ManagesInstructions: true,
HasBuiltInSub: false,
}
}
@@ -113,6 +114,16 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
Content: merged,
})
// goose has no native rules directory; ~/.config/goose/.goosehints is the
// global hints file applied to every session, so fold rules into it.
if hints := b.InstructionTextWithRules(name); hints != "" {
fs.Add(adapter.File{
Dest: filepath.Join(a.Home, ".config", "goose", ".goosehints"),
Kind: adapter.RenderedFile,
Content: []byte(hints),
})
}
return fs, nil
}
+31
View File
@@ -0,0 +1,31 @@
package goose
import (
"path/filepath"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
func TestGooseFoldsRulesIntoGoosehints(t *testing.T) {
home := t.TempDir()
b := &canonical.Bundle{
Instructions: canonical.Instructions{Global: "# global"},
Rules: []canonical.Rule{{Name: "k8s", Body: "# Kube\n\nlabel everything"}},
}
fs, err := New(WithHome(home)).Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
hints := filepath.Join(home, ".config", "goose", ".goosehints")
require.Contains(t, seen, hints)
assert.Equal(t, adapter.RenderedFile, seen[hints].Kind)
body := string(seen[hints].Content)
assert.Contains(t, body, "# global")
assert.Contains(t, body, "label everything")
}
+14 -2
View File
@@ -38,7 +38,9 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
ManagesModels: true,
ManagesMCP: true,
ManagesSkills: true,
ManagesInstructions: false,
ManagesAgents: true,
ManagesRules: true,
ManagesInstructions: true,
HasBuiltInSub: false,
}
}
@@ -58,8 +60,11 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
fs := adapter.NewFileSet()
base := filepath.Join(a.Home, ".config", "kilo")
// Kilo CLI reads global markdown subagents from ~/.config/kilo/agents/<name>.md
// (PLURAL — the singular "agent/" used by older OpenCode-fork builds is a
// silent no-op on current Kilo).
fs.Add(adapter.File{
Dest: filepath.Join(base, "agent"),
Dest: filepath.Join(base, "agents"),
Kind: adapter.SymlinkDir,
SymlinkTarget: filepath.Join(b.Root, "agents"),
})
@@ -69,6 +74,13 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
Kind: adapter.SymlinkDir,
SymlinkTarget: filepath.Join(b.Root, "skills"),
})
// kilo has no global rules directory; ~/.config/kilo/AGENTS.md is the
// always-on global instructions file, so fold rules into it.
fs.Add(adapter.File{
Dest: filepath.Join(base, "AGENTS.md"),
Kind: adapter.RenderedFile,
Content: []byte(b.InstructionTextWithRules(name)),
})
cfgPath := filepath.Join(base, "kilo.json")
existing, err := common.ReadExistingFile(cfgPath)
+2 -1
View File
@@ -33,7 +33,8 @@ func TestKiloRender(t *testing.T) {
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
agentDest := filepath.Join(home, ".config", "kilo", "agent")
// Global markdown subagents dir is PLURAL "agents" on current Kilo CLI.
agentDest := filepath.Join(home, ".config", "kilo", "agents")
assert.Equal(t, adapter.SymlinkDir, seen[agentDest].Kind)
assert.Equal(t, "/canon/agents", seen[agentDest].SymlinkTarget)
+32
View File
@@ -0,0 +1,32 @@
package kilo
import (
"path/filepath"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
func TestKiloFoldsRulesIntoAGENTS(t *testing.T) {
home := t.TempDir()
b := &canonical.Bundle{
Root: "/canon",
Instructions: canonical.Instructions{Global: "# global"},
Rules: []canonical.Rule{{Name: "py", Body: "# Py\n\ntype hints"}},
}
fs, err := New(WithHome(home)).Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
agentsMD := filepath.Join(home, ".config", "kilo", "AGENTS.md")
require.Contains(t, seen, agentsMD)
assert.Equal(t, adapter.RenderedFile, seen[agentsMD].Kind)
body := string(seen[agentsMD].Content)
assert.Contains(t, body, "# global")
assert.Contains(t, body, "type hints")
}
+11
View File
@@ -5,12 +5,23 @@ import (
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/adapter/common"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
func importFrom(home string) (*adapter.ImportResult, error) {
base := filepath.Join(home, ".config", "opencode")
res := &adapter.ImportResult{}
agents, err := common.ImportMarkdownTree(filepath.Join(base, "agents"), "")
if err != nil {
return nil, err
}
for _, a := range agents {
res.Agents = append(res.Agents, canonical.Agent{
Name: a.Name, Description: a.Description, Body: a.Body, Path: a.Path,
})
}
cfgBody, err := common.ReadIfExists(filepath.Join(base, "opencode.jsonc"))
if err != nil {
return nil, err
+11 -5
View File
@@ -37,6 +37,8 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
ManagesModels: true,
ManagesMCP: true,
ManagesSkills: true,
ManagesAgents: true,
ManagesRules: true,
ManagesInstructions: true,
HasBuiltInSub: false,
}
@@ -62,6 +64,12 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
Kind: adapter.SymlinkDir,
SymlinkTarget: filepath.Join(b.Root, "skills"),
})
// opencode reads markdown subagents from ~/.config/opencode/agents/<name>.md
fs.Add(adapter.File{
Dest: filepath.Join(base, "agents"),
Kind: adapter.SymlinkDir,
SymlinkTarget: filepath.Join(b.Root, "agents"),
})
cfgPath := filepath.Join(base, "opencode.jsonc")
existing, err := common.ReadExistingFile(cfgPath)
@@ -104,14 +112,12 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
Content: merged,
})
instructions := b.Instructions.Global
if override, ok := b.Instructions.PerHarness[name]; ok && override != "" {
instructions = override
}
// opencode has no native rules directory; rule content reaches it only via
// the global AGENTS.md instructions file, so fold the rules in here.
fs.Add(adapter.File{
Dest: filepath.Join(base, "AGENTS.md"),
Kind: adapter.RenderedFile,
Content: []byte(instructions),
Content: []byte(b.InstructionTextWithRules(name)),
})
return fs, nil
+52
View File
@@ -0,0 +1,52 @@
package opencode
import (
"os"
"path/filepath"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
func TestOpencodeRendersAgentsSymlinkAndFoldsRules(t *testing.T) {
home := t.TempDir()
ad := New(WithHome(home))
b := &canonical.Bundle{
Root: "/canon",
Instructions: canonical.Instructions{Global: "# global"},
Rules: []canonical.Rule{{Name: "go", Body: "# Go\n\ngofmt always"}},
}
fs, err := ad.Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
agentsDest := filepath.Join(home, ".config", "opencode", "agents")
assert.Equal(t, adapter.SymlinkDir, seen[agentsDest].Kind)
assert.Equal(t, "/canon/agents", seen[agentsDest].SymlinkTarget)
agentsMD := filepath.Join(home, ".config", "opencode", "AGENTS.md")
assert.Equal(t, adapter.RenderedFile, seen[agentsMD].Kind)
body := string(seen[agentsMD].Content)
assert.Contains(t, body, "# global")
assert.Contains(t, body, "gofmt always")
}
func TestOpencodeImportsAgents(t *testing.T) {
home := t.TempDir()
agentsDir := filepath.Join(home, ".config", "opencode", "agents")
require.NoError(t, os.MkdirAll(agentsDir, 0o750))
require.NoError(t, os.WriteFile(filepath.Join(agentsDir, "review.md"),
[]byte("---\nname: review\ndescription: d\n---\nbody"), 0o600))
ad := New(WithHome(home))
res, err := ad.Import(home)
require.NoError(t, err)
require.Len(t, res.Agents, 1)
assert.Equal(t, "review", res.Agents[0].Name)
}
+21
View File
@@ -0,0 +1,21 @@
package pi
import (
"os"
"path/filepath"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
)
func importFrom(home string) (*adapter.ImportResult, error) {
base := filepath.Join(home, ".pi", "agent")
res := &adapter.ImportResult{}
if body, err := os.ReadFile(filepath.Join(base, "AGENTS.md")); err == nil {
res.Instructions = string(body)
} else if !os.IsNotExist(err) {
return nil, err
}
return res, nil
}
+159
View File
@@ -0,0 +1,159 @@
// Package pi is the Pi coding agent harness adapter.
package pi
import (
"encoding/json"
"fmt"
"os"
"path/filepath"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/adapter/common"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
const name = "pi"
// Adapter implements adapter.Adapter for the Pi coding agent harness.
type Adapter struct {
*adapter.Base
}
// WithHome overrides the home directory used to resolve target paths.
func WithHome(h string) adapter.BaseOption { return func(b *adapter.Base) { b.Home = h } }
// New returns a new Adapter with the given options applied.
func New(opts ...adapter.BaseOption) *Adapter {
return &Adapter{Base: adapter.NewBase(opts...)}
}
// Name returns the harness identifier.
func (a *Adapter) Name() string { return name }
// Capabilities declares what pi harness-sync manages.
func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
return adapter.HarnessCapabilities{
ManagesProviders: true,
ManagesModels: true,
ManagesMCP: false,
ManagesSkills: true,
ManagesAgents: false,
ManagesRules: true,
ManagesInstructions: true,
HasBuiltInSub: false,
}
}
// Detect returns true when ~/.pi/agent exists.
func (a *Adapter) Detect() bool {
_, err := os.Stat(filepath.Join(a.Home, ".pi", "agent"))
return err == nil
}
// Render produces the FileSet that applies the canonical bundle to Pi.
func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
fs := adapter.NewFileSet()
base := filepath.Join(a.Home, ".pi", "agent")
fs.Add(adapter.File{
Dest: filepath.Join(base, "skills"),
Kind: adapter.SymlinkDir,
SymlinkTarget: filepath.Join(b.Root, "skills"),
})
if instr := b.InstructionTextWithRules(name); instr != "" {
fs.Add(adapter.File{
Dest: filepath.Join(base, "AGENTS.md"),
Kind: adapter.RenderedFile,
Content: []byte(instr),
})
}
cfgPath := filepath.Join(base, "settings.json")
existing, err := common.ReadExistingFile(cfgPath)
if err != nil {
return nil, fmt.Errorf("read %s: %w", cfgPath, err)
}
overlay := map[string]any{}
if b.Profile.Gateway.DefaultModel != "" {
overlay["defaultProvider"] = common.GatewayProviderKey(b.Profile.Gateway.URL)
overlay["defaultModel"] = b.Profile.Gateway.DefaultModel
}
if len(overlay) > 0 {
merged, err := common.MergeJSONKeys(existing, overlay)
if err != nil {
return nil, err
}
fs.Add(adapter.File{
Dest: cfgPath,
Kind: adapter.RenderedFile,
Content: merged,
})
}
if modelsContent, err := piModelsJSON(b); err != nil {
return nil, err
} else if len(modelsContent) > 0 {
fs.Add(adapter.File{
Dest: filepath.Join(base, "models.json"),
Kind: adapter.RenderedFile,
Content: modelsContent,
})
}
return fs, nil
}
func piModelsJSON(b *canonical.Bundle) ([]byte, error) {
if b.Profile.Gateway.URL == "" {
return nil, nil
}
modelEntries := make([]map[string]any, 0, len(b.Profile.Models))
for _, m := range b.Profile.Models {
entry := map[string]any{"id": m.ID}
if m.Alias != "" {
entry["name"] = m.Alias
}
// Emit limits only when the profile sets them explicitly. Pi applies
// its own defaults (contextWindow 128000, maxTokens 16384) to a model
// definition that omits them, so writing ContextLimit()/OutputLimit()
// unconditionally would push canonical's defaults onto every model
// that never asked for them.
if m.Context > 0 {
entry["contextWindow"] = m.Context
}
if m.Output > 0 {
entry["maxTokens"] = m.Output
}
modelEntries = append(modelEntries, entry)
}
if len(modelEntries) == 0 && b.Profile.Gateway.DefaultModel != "" {
modelEntries = append(modelEntries, map[string]any{"id": b.Profile.Gateway.DefaultModel})
}
provider := map[string]any{
"baseUrl": b.Profile.Gateway.URL,
"api": "openai-completions",
"apiKey": b.Profile.Gateway.Token,
}
if len(modelEntries) > 0 {
provider["models"] = modelEntries
}
body, err := json.MarshalIndent(map[string]any{
"providers": map[string]any{
common.GatewayProviderKey(b.Profile.Gateway.URL): provider,
},
}, "", " ")
if err != nil {
return nil, err
}
return append(body, '\n'), nil
}
// Import reads Pi config from home and returns a canonical ImportResult.
func (a *Adapter) Import(home string) (*adapter.ImportResult, error) {
return importFrom(home)
}
+149
View File
@@ -0,0 +1,149 @@
package pi
import (
"encoding/json"
"os"
"path/filepath"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
func TestPiRender(t *testing.T) {
home := t.TempDir()
ad := New(WithHome(home))
b := &canonical.Bundle{
Root: "/canon",
Profile: canonical.Profile{
Gateway: canonical.Gateway{URL: "https://gw", Token: "dummy", DefaultModel: "sonnet"},
Models: []canonical.Model{{ID: "claude-sonnet-4-6", Alias: "Sonnet"}},
},
Instructions: canonical.Instructions{Global: "# global"},
}
fs, err := ad.Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
skillsDest := filepath.Join(home, ".pi", "agent", "skills")
assert.Equal(t, adapter.SymlinkDir, seen[skillsDest].Kind)
assert.Equal(t, "/canon/skills", seen[skillsDest].SymlinkTarget)
agentsDest := filepath.Join(home, ".pi", "agent", "AGENTS.md")
assert.Equal(t, adapter.RenderedFile, seen[agentsDest].Kind)
assert.Contains(t, string(seen[agentsDest].Content), "# global")
settingsDest := filepath.Join(home, ".pi", "agent", "settings.json")
var settings map[string]any
require.NoError(t, json.Unmarshal(seen[settingsDest].Content, &settings))
assert.Equal(t, "hs-gw", settings["defaultProvider"])
assert.Equal(t, "sonnet", settings["defaultModel"])
modelsDest := filepath.Join(home, ".pi", "agent", "models.json")
var models map[string]any
require.NoError(t, json.Unmarshal(seen[modelsDest].Content, &models))
providers := models["providers"].(map[string]any)
gw := providers["hs-gw"].(map[string]any)
assert.Equal(t, "https://gw", gw["baseUrl"])
assert.Equal(t, "openai-completions", gw["api"])
assert.Equal(t, "dummy", gw["apiKey"])
modelList := gw["models"].([]any)
first := modelList[0].(map[string]any)
assert.Equal(t, "claude-sonnet-4-6", first["id"])
assert.Equal(t, "Sonnet", first["name"])
// A model with no explicit limits must carry none, so pi keeps applying
// its own defaults rather than inheriting canonical's.
assert.NotContains(t, first, "contextWindow")
assert.NotContains(t, first, "maxTokens")
}
func TestPiRenderEmitsExplicitModelLimits(t *testing.T) {
home := t.TempDir()
ad := New(WithHome(home))
b := &canonical.Bundle{
Profile: canonical.Profile{
Gateway: canonical.Gateway{URL: "https://gw", Token: "dummy"},
Models: []canonical.Model{
{ID: "local/current-model", Alias: "Local", Context: 1048576, Output: 32768},
{ID: "bare/model"},
},
},
}
fs, err := ad.Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
var models map[string]any
require.NoError(t, json.Unmarshal(seen[filepath.Join(home, ".pi", "agent", "models.json")].Content, &models))
list := models["providers"].(map[string]any)["hs-gw"].(map[string]any)["models"].([]any)
withLimits := list[0].(map[string]any)
assert.InDelta(t, float64(1048576), withLimits["contextWindow"], 0)
assert.InDelta(t, float64(32768), withLimits["maxTokens"], 0)
withoutLimits := list[1].(map[string]any)
assert.NotContains(t, withoutLimits, "contextWindow")
assert.NotContains(t, withoutLimits, "maxTokens")
}
func TestPiRenderMergesExistingSettings(t *testing.T) {
home := t.TempDir()
base := filepath.Join(home, ".pi", "agent")
require.NoError(t, os.MkdirAll(base, 0o750))
existing := map[string]any{
"theme": "light",
"defaultThinkingLevel": "high",
}
body, _ := json.Marshal(existing)
require.NoError(t, os.WriteFile(filepath.Join(base, "settings.json"), body, 0o600))
ad := New(WithHome(home))
b := &canonical.Bundle{Profile: canonical.Profile{Gateway: canonical.Gateway{URL: "https://gw", DefaultModel: "sonnet"}}}
fs, err := ad.Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
var parsed map[string]any
require.NoError(t, json.Unmarshal(seen[filepath.Join(base, "settings.json")].Content, &parsed))
assert.Equal(t, "light", parsed["theme"])
assert.Equal(t, "high", parsed["defaultThinkingLevel"])
assert.Equal(t, "hs-gw", parsed["defaultProvider"])
assert.Equal(t, "sonnet", parsed["defaultModel"])
}
func TestPiRenderWithoutGatewaySkipsProviderFiles(t *testing.T) {
home := t.TempDir()
ad := New(WithHome(home))
b := &canonical.Bundle{Root: "/canon"}
fs, err := ad.Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
assert.Contains(t, seen, filepath.Join(home, ".pi", "agent", "skills"))
assert.NotContains(t, seen, filepath.Join(home, ".pi", "agent", "settings.json"))
assert.NotContains(t, seen, filepath.Join(home, ".pi", "agent", "models.json"))
}
func TestPiImport(t *testing.T) {
home := t.TempDir()
base := filepath.Join(home, ".pi", "agent")
require.NoError(t, os.MkdirAll(base, 0o750))
require.NoError(t, os.WriteFile(filepath.Join(base, "AGENTS.md"), []byte("# global"), 0o600))
ad := New(WithHome(home))
res, err := ad.Import(home)
require.NoError(t, err)
assert.Equal(t, "# global", res.Instructions)
}
+31
View File
@@ -0,0 +1,31 @@
package zed
import (
"path/filepath"
"testing"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/lukaszraczylo/harness-sync/internal/adapter"
"github.com/lukaszraczylo/harness-sync/internal/canonical"
)
func TestZedFoldsRulesIntoAGENTS(t *testing.T) {
home := t.TempDir()
b := &canonical.Bundle{
Instructions: canonical.Instructions{Global: "# global"},
Rules: []canonical.Rule{{Name: "ts", Body: "# TS\n\nstrict mode"}},
}
fs, err := New(WithHome(home)).Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
agentsMD := filepath.Join(home, ".config", "zed", "AGENTS.md")
require.Contains(t, seen, agentsMD)
assert.Equal(t, adapter.RenderedFile, seen[agentsMD].Kind)
body := string(seen[agentsMD].Content)
assert.Contains(t, body, "# global")
assert.Contains(t, body, "strict mode")
}
+14 -2
View File
@@ -42,7 +42,8 @@ func (a *Adapter) Capabilities() adapter.HarnessCapabilities {
ManagesModels: true,
ManagesMCP: false, // Agent panel uses Extensions; context_servers key causes serde parse errors
ManagesSkills: false,
ManagesInstructions: false,
ManagesRules: true,
ManagesInstructions: true,
HasBuiltInSub: false,
}
}
@@ -97,6 +98,17 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
NoMerge: true,
})
// Zed reads personal/global instructions from ~/.config/zed/AGENTS.md
// (always-on for the Agent across all projects). Zed has no rules directory,
// so fold rules into it.
if instr := b.InstructionTextWithRules(name); instr != "" {
fs.Add(adapter.File{
Dest: filepath.Join(a.Home, ".config", "zed", "AGENTS.md"),
Kind: adapter.RenderedFile,
Content: []byte(instr),
})
}
return fs, nil
}
@@ -110,7 +122,7 @@ func zedLanguageModels(p *canonical.Profile) map[string]any {
for _, m := range p.Models {
me := map[string]any{
"name": m.ID,
"max_tokens": 200000,
"max_tokens": m.ContextLimit(),
"capabilities": map[string]any{
"tools": true,
"images": false,
+19
View File
@@ -63,6 +63,25 @@ func TestZedRenderProducesExpectedTargets(t *testing.T) {
assert.NotContains(t, parsed, "context_servers")
}
func TestZedRenderHonorsPerModelContext(t *testing.T) {
home := t.TempDir()
b := bundle()
b.Profile.Models = []canonical.Model{{ID: "big", Context: 262144}}
fs, err := New(WithHome(home)).Render(b)
require.NoError(t, err)
seen := map[string]adapter.File{}
fs.ForEach(func(f adapter.File) { seen[f.Dest] = f })
cfgDest := filepath.Join(home, ".config", "zed", "settings.json")
require.Contains(t, seen, cfgDest)
var parsed map[string]any
require.NoError(t, json.Unmarshal(seen[cfgDest].Content, &parsed))
models := parsed["language_models"].(map[string]any)["openai_compatible"].(map[string]any)["hs-llmgw-example-com"].(map[string]any)["available_models"].([]any)
assert.Equal(t, float64(262144), models[0].(map[string]any)["max_tokens"], "explicit context override should win")
}
func TestZedRenderMergesExistingKeys(t *testing.T) {
home := t.TempDir()
base := filepath.Join(home, ".config", "zed")
+47
View File
@@ -0,0 +1,47 @@
package canonical
import "strings"
// InstructionText returns the instruction body a harness should receive: the
// per-harness override when one is set, otherwise the global instructions.
func (b *Bundle) InstructionText(harness string) string {
if override, ok := b.Instructions.PerHarness[harness]; ok && override != "" {
return override
}
return b.Instructions.Global
}
// InstructionTextWithRules returns InstructionText for the harness with every
// canonical rule body folded in. Harnesses without a native rules directory
// (everything except claude-code/kilo) only receive rule content this way —
// via their global instructions file. Rule frontmatter is stripped so the
// folded output stays clean; bodies are joined in load order (deterministic).
func (b *Bundle) InstructionTextWithRules(harness string) string {
base := b.InstructionText(harness)
var sb strings.Builder
sb.WriteString(base)
for _, r := range b.Rules {
body := strings.TrimSpace(stripFrontmatter(r.Body))
if body == "" {
continue
}
if sb.Len() > 0 {
sb.WriteString("\n\n")
}
sb.WriteString(body)
}
return sb.String()
}
// stripFrontmatter removes a leading YAML frontmatter block ("---\n…\n---") so
// folding a rule into a plain instructions file does not leak its metadata.
func stripFrontmatter(s string) string {
if !strings.HasPrefix(s, "---\n") {
return s
}
end := strings.Index(s[4:], "\n---")
if end == -1 {
return s
}
return strings.TrimPrefix(s[4+end+len("\n---"):], "\n")
}
+102
View File
@@ -0,0 +1,102 @@
package canonical
import (
"testing"
"github.com/stretchr/testify/assert"
)
func TestInstructionText(t *testing.T) {
t.Run("global when no override", func(t *testing.T) {
t.Parallel()
b := Bundle{Instructions: Instructions{Global: "G"}}
assert.Equal(t, "G", b.InstructionText("zed"))
})
t.Run("per-harness override wins", func(t *testing.T) {
t.Parallel()
b := Bundle{Instructions: Instructions{Global: "G", PerHarness: map[string]string{"zed": "Z"}}}
assert.Equal(t, "Z", b.InstructionText("zed"))
})
t.Run("empty override falls back to global", func(t *testing.T) {
t.Parallel()
b := Bundle{Instructions: Instructions{Global: "G", PerHarness: map[string]string{"zed": ""}}}
assert.Equal(t, "G", b.InstructionText("zed"))
})
t.Run("empty everything", func(t *testing.T) {
t.Parallel()
b := Bundle{}
assert.Equal(t, "", b.InstructionText("zed"))
})
}
func TestInstructionTextWithRules(t *testing.T) {
t.Run("folds rules after global", func(t *testing.T) {
t.Parallel()
b := Bundle{
Instructions: Instructions{Global: "# Global"},
Rules: []Rule{
{Name: "a", Body: "# Rule A\n\nbe concise"},
{Name: "b", Body: "# Rule B\n\nbe safe"},
},
}
got := b.InstructionTextWithRules("opencode")
assert.Equal(t, "# Global\n\n# Rule A\n\nbe concise\n\n# Rule B\n\nbe safe", got)
})
t.Run("strips rule frontmatter", func(t *testing.T) {
t.Parallel()
b := Bundle{
Instructions: Instructions{Global: "G"},
Rules: []Rule{
{Name: "scoped", Body: "---\nname: scoped\npaths: \"**/*.go\"\n---\n# Go\n\ngofmt"},
},
}
got := b.InstructionTextWithRules("opencode")
assert.Equal(t, "G\n\n# Go\n\ngofmt", got)
assert.NotContains(t, got, "paths:")
assert.NotContains(t, got, "---")
})
t.Run("no rules returns plain instruction text", func(t *testing.T) {
t.Parallel()
b := Bundle{Instructions: Instructions{Global: "G"}}
assert.Equal(t, "G", b.InstructionTextWithRules("opencode"))
})
t.Run("empty global still emits rules", func(t *testing.T) {
t.Parallel()
b := Bundle{Rules: []Rule{{Name: "a", Body: "rule body"}}}
assert.Equal(t, "rule body", b.InstructionTextWithRules("opencode"))
})
t.Run("blank rule bodies are skipped", func(t *testing.T) {
t.Parallel()
b := Bundle{
Instructions: Instructions{Global: "G"},
Rules: []Rule{
{Name: "empty", Body: " \n "},
{Name: "real", Body: "keep"},
},
}
assert.Equal(t, "G\n\nkeep", b.InstructionTextWithRules("opencode"))
})
}
func TestStripFrontmatter(t *testing.T) {
tests := []struct {
name string
in string
want string
}{
{"no frontmatter", "# Title\nbody", "# Title\nbody"},
{"with frontmatter", "---\nname: x\n---\n# Title", "# Title"},
{"unterminated frontmatter left intact", "---\nname: x\nbody", "---\nname: x\nbody"},
{"empty", "", ""},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
t.Parallel()
assert.Equal(t, tt.want, stripFrontmatter(tt.in))
})
}
}
+8
View File
@@ -72,6 +72,14 @@ func LoadFS(fs fsx.FS, root string) (*Bundle, error) {
b.Agents = append(b.Agents, Agent(m))
}
rules, err := loadMarkdownDirFS(fs, filepath.Join(root, "rules"), "")
if err != nil {
return nil, err
}
for _, m := range rules {
b.Rules = append(b.Rules, Rule(m))
}
b.Instructions.PerHarness = map[string]string{}
body, err := readFileIfExistsFS(fs, filepath.Join(root, "instructions", "global.md"))
if err != nil {
+4
View File
@@ -28,6 +28,10 @@ func TestLoad(t *testing.T) {
require.Len(t, b.Agents, 1)
assert.Equal(t, "sample", b.Agents[0].Name)
require.Len(t, b.Rules, 1)
assert.Equal(t, "sample-rule", b.Rules[0].Name)
assert.Contains(t, b.Rules[0].Body, "Always be concise.")
assert.Contains(t, b.Instructions.Global, "Be helpful.")
}
@@ -0,0 +1,3 @@
# Sample Rule
Always be concise.
+39
View File
@@ -35,6 +35,33 @@ type Upstream struct {
type Model struct {
ID string `yaml:"id"`
Alias string `yaml:"alias,omitempty"`
// Context and Output are optional per-model limit overrides (tokens). When
// unset (0), harnesses fall back to DefaultContextLimit / DefaultOutputLimit.
Context int `yaml:"context,omitempty"`
Output int `yaml:"output,omitempty"`
}
// Default per-model limits, applied by harnesses that surface context/output
// limits when a Model doesn't specify its own.
const (
DefaultContextLimit = 200000
DefaultOutputLimit = 8192
)
// ContextLimit returns the model's context window, or DefaultContextLimit if unset.
func (m Model) ContextLimit() int {
if m.Context > 0 {
return m.Context
}
return DefaultContextLimit
}
// OutputLimit returns the model's max output tokens, or DefaultOutputLimit if unset.
func (m Model) OutputLimit() int {
if m.Output > 0 {
return m.Output
}
return DefaultOutputLimit
}
type MCPRegistry struct {
@@ -43,6 +70,7 @@ type MCPRegistry struct {
type MCPServer struct {
Env map[string]string `yaml:"env,omitempty"`
Headers map[string]string `yaml:"headers,omitempty"`
Name string `yaml:"name"`
Command string `yaml:"command,omitempty"`
URL string `yaml:"url,omitempty"`
@@ -64,6 +92,16 @@ type Agent struct {
Path string
}
// Rule is a topic-scoped instruction fragment (e.g. ~/.claude/rules/go.md).
// Claude Code auto-loads a directory of these; harnesses without a native rules
// directory receive the bodies folded into their global instructions file.
type Rule struct {
Name string
Description string
Body string
Path string
}
type Instructions struct {
PerHarness map[string]string
Global string
@@ -76,6 +114,7 @@ type Bundle struct {
Profile Profile
Skills []Skill
Agents []Agent
Rules []Rule
MCP MCPRegistry
}
+25 -3
View File
@@ -93,6 +93,7 @@ func runImport(cmd *cobra.Command, reg *adapter.Registry, root, home string, pic
}
seenSkills := map[string]bool{}
seenAgents := map[string]bool{}
seenRules := map[string]bool{}
seenMCP := map[string]bool{}
var instructions []string
@@ -121,6 +122,14 @@ func runImport(cmd *cobra.Command, reg *adapter.Registry, root, home string, pic
seenAgents[key] = true
bundle.Agents = append(bundle.Agents, a)
}
for _, r := range res.Rules {
key := r.Name + "|" + r.Body
if seenRules[key] {
continue
}
seenRules[key] = true
bundle.Rules = append(bundle.Rules, r)
}
for _, m := range res.MCP {
if seenMCP[m.Name] {
continue
@@ -153,8 +162,8 @@ func runImport(cmd *cobra.Command, reg *adapter.Registry, root, home string, pic
return err
}
_, _ = fmt.Fprintf(cmd.OutOrStdout(),
"imported from %v into %s\n skills: %d\n agents: %d\n mcp servers: %d\n instructions: %d source(s)\n",
picked, root, len(bundle.Skills), len(bundle.Agents), len(bundle.MCP.Servers), len(instructions),
"imported from %v into %s\n skills: %d\n agents: %d\n rules: %d\n mcp servers: %d\n instructions: %d source(s)\n",
picked, root, len(bundle.Skills), len(bundle.Agents), len(bundle.Rules), len(bundle.MCP.Servers), len(instructions),
)
return nil
}
@@ -172,7 +181,7 @@ const importedProfileBody = "# harness-sync profile \xe2\x80\x94 generated by in
"models: []\n"
func writeCanonical(root string, b *canonical.Bundle, picked []string) error {
for _, sub := range []string{"profiles", "skills", "agents", "instructions"} {
for _, sub := range []string{"profiles", "skills", "agents", "rules", "instructions"} {
if err := os.MkdirAll(filepath.Join(root, sub), 0o750); err != nil {
return err
}
@@ -233,6 +242,19 @@ func writeCanonical(root string, b *canonical.Bundle, picked []string) error {
return err
}
}
for _, r := range b.Rules {
rel := r.Path
if rel == "" {
rel = safeFilename(r.Name) + ".md"
}
path := filepath.Join(root, "rules", rel)
if err := os.MkdirAll(filepath.Dir(path), 0o750); err != nil {
return err
}
if err := os.WriteFile(path, []byte(r.Body), 0o600); err != nil {
return err
}
}
if b.Instructions.Global != "" {
if err := os.WriteFile(filepath.Join(root, "instructions", "global.md"),
[]byte(b.Instructions.Global), 0o600); err != nil {
+28
View File
@@ -53,6 +53,34 @@ func TestInitImportWritesCanonical(t *testing.T) {
require.NoError(t, err)
}
func TestInitImportsRules(t *testing.T) {
root := t.TempDir()
home := t.TempDir()
reg := adapter.NewRegistry()
reg.Register(&importableAdapter{
name: "stub",
res: &adapter.ImportResult{
Rules: []canonical.Rule{
{Name: "go", Body: "# Go\n\ngofmt", Path: "go.md"},
{Name: "py", Body: "# Py\n\ntypes", Path: "py.md"},
},
},
})
cmd := NewInit(reg)
cmd.SetArgs([]string{"--root", root, "--home", home, "--from", "stub", "--no-prompt"})
require.NoError(t, cmd.Execute())
assert.FileExists(t, filepath.Join(root, "rules", "go.md"))
assert.FileExists(t, filepath.Join(root, "rules", "py.md"))
// Round-trips back through the loader.
b, err := canonical.Load(root)
require.NoError(t, err)
require.Len(t, b.Rules, 2)
}
func makeStubReg() *adapter.Registry {
reg := adapter.NewRegistry()
reg.Register(&importableAdapter{
+7 -2
View File
@@ -17,11 +17,15 @@ func TestInitApplyDiffCycle(t *testing.T) {
home := t.TempDir()
root := filepath.Join(home, ".config", "harness-sync")
// Fake a claude-code install with one skill
// Fake a claude-code install with one skill and one rule
require.NoError(t, os.MkdirAll(filepath.Join(home, ".claude", "skills", "hi"), 0o750))
require.NoError(t, os.WriteFile(
filepath.Join(home, ".claude", "skills", "hi", "SKILL.md"),
[]byte("---\nname: hi\n---\nbody"), 0o600))
require.NoError(t, os.MkdirAll(filepath.Join(home, ".claude", "rules"), 0o750))
require.NoError(t, os.WriteFile(
filepath.Join(home, ".claude", "rules", "go.md"),
[]byte("# Go Rules\n\ngofmt always"), 0o600))
run := func(args ...string) ([]byte, error) {
cmd := exec.Command(bin, args...)
@@ -33,6 +37,7 @@ func TestInitApplyDiffCycle(t *testing.T) {
require.NoError(t, err, string(out))
assert.FileExists(t, filepath.Join(root, "config.yaml"))
assert.FileExists(t, filepath.Join(root, "skills", "hi", "SKILL.md"))
assert.FileExists(t, filepath.Join(root, "rules", "go.md"))
// apply may produce conflicts on a freshly imported tree (because the
// claude-code adapter merges into existing settings.json which differs
@@ -85,7 +90,7 @@ func TestDetectListsAllAdapters(t *testing.T) {
// None should be detected in an empty HOME
s := string(out)
for _, name := range []string{"claude-code", "crush", "kilo", "opencode", "goose", "cagent", "zed"} {
for _, name := range []string{"claude-code", "crush", "kilo", "opencode", "pi", "goose", "cagent", "zed"} {
assert.Contains(t, s, name)
}
assert.Contains(t, s, "not detected")