refactor(adapters): extract common helpers + fix kilo native schema

internal/adapters/crush/crush.go

@@ -6,6 +6,7 @@ import (
 	"path/filepath"
 
 	"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/render"
 )
@@ -72,67 +73,11 @@ func (a *Adapter) Render(b *canonical.Bundle) (*adapter.FileSet, error) {
 }
 
 func renderConfig(b *canonical.Bundle) ([]byte, error) {
-	providers := make([]map[string]any, 0, len(b.Profile.Upstreams)+1)
-
-	// Gateway as primary provider.
-	if b.Profile.Gateway.URL != "" {
-		gw := map[string]any{
-			"id":       "harness-sync-gateway",
-			"name":     "harness-sync gateway",
-			"base_url": b.Profile.Gateway.URL,
-			"api_key":  b.Profile.Gateway.Token,
-		}
-		models := 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["alias"] = m.Alias
-			}
-			models = append(models, entry)
-		}
-		if len(models) > 0 {
-			gw["models"] = models
-		}
-		providers = append(providers, gw)
-	}
-
-	for _, up := range b.Profile.Upstreams {
-		p := map[string]any{"id": up.Name, "name": up.Name}
-		if up.BaseURL != "" {
-			p["base_url"] = up.BaseURL
-		}
-		if up.APIKey != "" {
-			p["api_key"] = up.APIKey
-		}
-		providers = append(providers, p)
-	}
-
-	mcp := map[string]any{}
-	for _, s := range b.MCP.Servers {
-		entry := map[string]any{}
-		if s.Command != "" {
-			entry["command"] = s.Command
-		}
-		if len(s.Args) > 0 {
-			entry["args"] = s.Args
-		}
-		if s.URL != "" {
-			entry["url"] = s.URL
-		}
-		if s.Transport != "" {
-			entry["transport"] = s.Transport
-		}
-		if len(s.Env) > 0 {
-			entry["env"] = s.Env
-		}
-		mcp[s.Name] = entry
-	}
-
 	out := map[string]any{
-		"providers":     providers,
+		"providers":     common.BuildProviders(&b.Profile),
 		"default_model": b.Profile.Gateway.DefaultModel,
 	}
-	if len(mcp) > 0 {
+	if mcp := common.BuildMCPMap(&b.MCP); len(mcp) > 0 {
 		out["mcpServers"] = mcp
 	}
 	return render.JSON(out)

internal/adapters/crush/import.go

@@ -1,49 +1,17 @@
 package crush
 
 import (
-	"encoding/json"
-	"os"
 	"path/filepath"
 
 	"github.com/lukaszraczylo/harness-sync/internal/adapter"
-	"github.com/lukaszraczylo/harness-sync/internal/canonical"
+	"github.com/lukaszraczylo/harness-sync/internal/adapter/common"
 )
 
-type crushMCPEntry struct { //nolint:govet // fieldalignment: map+slice+3 strings irreducible
-	Env       map[string]string `json:"env"`
-	Args      []string          `json:"args"`
-	Command   string            `json:"command"`
-	URL       string            `json:"url"`
-	Transport string            `json:"transport"`
-}
-
-type crushConfig struct {
-	MCPServers map[string]crushMCPEntry `json:"mcpServers"`
-}
-
 func importFrom(home string) (*adapter.ImportResult, error) {
 	cfgPath := filepath.Join(home, ".config", "crush", "crush.json")
-	body, err := os.ReadFile(cfgPath)
-	if os.IsNotExist(err) {
-		return &adapter.ImportResult{}, nil
-	}
+	servers, err := common.ImportMCPFromJSONFile(cfgPath, "mcpServers")
 	if err != nil {
 		return nil, err
 	}
-
-	var doc crushConfig
-	_ = json.Unmarshal(body, &doc)
-
-	res := &adapter.ImportResult{}
-	for nm, v := range doc.MCPServers {
-		res.MCP = append(res.MCP, canonical.MCPServer{
-			Name:      nm,
-			Command:   v.Command,
-			Args:      v.Args,
-			URL:       v.URL,
-			Transport: v.Transport,
-			Env:       v.Env,
-		})
-	}
-	return res, nil
+	return &adapter.ImportResult{MCP: servers}, nil
 }