style: fix gofmt formatting across all affected files
Adds missing trailing newlines, fixes indentation alignment, removes
extra blank lines, and corrects import ordering. Fixes CI qa format
check failures blocking all open PRs.
Files fixed:
- pkg/rag/{ingest,ollama,qdrant,query}.go (missing trailing newline)
- internal/cmd/rag/cmd_ingest.go (extra blank lines)
- internal/cmd/security/cmd_jobs.go (var alignment)
- internal/cmd/security/cmd_security.go (extra blank line)
- internal/core-ide/claude_bridge.go (indentation)
- internal/variants/core_ide.go (import ordering)
- pkg/ansible/{modules,ssh}.go (whitespace)
- pkg/build/buildcmd/cmd_release.go (var alignment)
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
parent
2899347aed
commit
1911a88c6f
12 changed files with 16 additions and 20 deletions
|
|
@ -169,5 +169,3 @@ func IngestFile(ctx context.Context, filePath, collectionName string) (int, erro
|
|||
|
||||
return rag.IngestFile(ctx, qdrantClient, ollamaClient, collectionName, filePath, rag.DefaultChunkConfig())
|
||||
}
|
||||
|
||||
|
||||
|
|
|
|||
|
|
@ -12,10 +12,10 @@ import (
|
|||
)
|
||||
|
||||
var (
|
||||
jobsTargets []string
|
||||
jobsTargets []string
|
||||
jobsIssueRepo string
|
||||
jobsDryRun bool
|
||||
jobsCopies int
|
||||
jobsDryRun bool
|
||||
jobsCopies int
|
||||
)
|
||||
|
||||
func addJobsCommand(parent *cli.Command) {
|
||||
|
|
|
|||
|
|
@ -203,7 +203,6 @@ func buildTargetRepo(target string) (*repos.Repo, string) {
|
|||
return &repos.Repo{Name: parts[1]}, target
|
||||
}
|
||||
|
||||
|
||||
// AlertSummary holds aggregated alert counts.
|
||||
type AlertSummary struct {
|
||||
Critical int
|
||||
|
|
|
|||
|
|
@ -78,7 +78,7 @@ func (cb *ClaudeBridge) connectToMCP() {
|
|||
log.Printf("Claude bridge MCP read error: %v", err)
|
||||
break
|
||||
}
|
||||
select {
|
||||
select {
|
||||
case cb.broadcast <- message:
|
||||
default:
|
||||
log.Printf("Claude bridge: broadcast channel full, dropping message")
|
||||
|
|
|
|||
|
|
@ -18,8 +18,8 @@ import (
|
|||
|
||||
// CLI commands available via IPC
|
||||
_ "github.com/host-uk/core/internal/cmd/ai"
|
||||
_ "github.com/host-uk/core/internal/cmd/dev"
|
||||
_ "github.com/host-uk/core/internal/cmd/deploy"
|
||||
_ "github.com/host-uk/core/internal/cmd/dev"
|
||||
_ "github.com/host-uk/core/internal/cmd/php"
|
||||
_ "github.com/host-uk/core/internal/cmd/rag"
|
||||
)
|
||||
|
|
|
|||
|
|
@ -22,7 +22,7 @@ func (e *Executor) executeModule(ctx context.Context, host string, client *SSHCl
|
|||
oldPass := client.becomePass
|
||||
|
||||
client.SetBecome(true, task.BecomeUser, "")
|
||||
|
||||
|
||||
defer client.SetBecome(oldBecome, oldUser, oldPass)
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -175,7 +175,6 @@ func (c *SSHClient) Connect(ctx context.Context) error {
|
|||
return log.E("ssh.Connect", fmt.Sprintf("ssh connect %s", addr), err)
|
||||
}
|
||||
|
||||
|
||||
c.client = ssh.NewClient(sshConn, chans, reqs)
|
||||
return nil
|
||||
}
|
||||
|
|
@ -300,11 +299,11 @@ func (c *SSHClient) Upload(ctx context.Context, local io.Reader, remote string,
|
|||
|
||||
// Use cat to write the file (simpler than SCP)
|
||||
writeCmd := fmt.Sprintf("cat > %q && chmod %o %q", remote, mode, remote)
|
||||
|
||||
|
||||
// If become is needed, we construct a command that reads password then content from stdin
|
||||
// But we need to be careful with handling stdin for sudo + cat.
|
||||
// We'll use a session with piped stdin.
|
||||
|
||||
|
||||
session2, err := c.client.NewSession()
|
||||
if err != nil {
|
||||
return log.E("ssh.Upload", "new session for write", err)
|
||||
|
|
|
|||
|
|
@ -14,10 +14,10 @@ import (
|
|||
|
||||
// Flag variables for release command
|
||||
var (
|
||||
releaseVersion string
|
||||
releaseDraft bool
|
||||
releasePrerelease bool
|
||||
releaseGoForLaunch bool
|
||||
releaseVersion string
|
||||
releaseDraft bool
|
||||
releasePrerelease bool
|
||||
releaseGoForLaunch bool
|
||||
)
|
||||
|
||||
var releaseCmd = &cli.Command{
|
||||
|
|
|
|||
|
|
@ -213,4 +213,4 @@ func IngestFile(ctx context.Context, qdrant *QdrantClient, ollama *OllamaClient,
|
|||
}
|
||||
|
||||
return len(points), nil
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -117,4 +117,4 @@ func (o *OllamaClient) VerifyModel(ctx context.Context) error {
|
|||
// Model returns the configured embedding model name.
|
||||
func (o *OllamaClient) Model() string {
|
||||
return o.config.Model
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -222,4 +222,4 @@ func valueToGo(v *qdrant.Value) any {
|
|||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -160,4 +160,4 @@ func FormatResultsJSON(results []QueryResult) string {
|
|||
}
|
||||
sb.WriteString("]")
|
||||
return sb.String()
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue