From d9279c08cc21819453eb02200643c1507cb118b5 Mon Sep 17 00:00:00 2001 From: KoheiYamashita Date: Fri, 20 Feb 2026 11:00:40 +0900 Subject: [PATCH] fix: fix CI failures - gradlew permission and Go formatting Co-Authored-By: Claude Opus 4.6 --- android/gradlew | 0 pkg/agent/ratelimit.go | 6 +++--- pkg/channels/websocket.go | 1 - pkg/heartbeat/service_test.go | 16 ++++++++-------- pkg/mcp/manager.go | 2 +- pkg/utils/media.go | 6 +++--- 6 files changed, 15 insertions(+), 16 deletions(-) mode change 100644 => 100755 android/gradlew diff --git a/android/gradlew b/android/gradlew old mode 100644 new mode 100755 diff --git a/pkg/agent/ratelimit.go b/pkg/agent/ratelimit.go index 940babc6d..4a5133ea5 100644 --- a/pkg/agent/ratelimit.go +++ b/pkg/agent/ratelimit.go @@ -11,9 +11,9 @@ type rateLimiter struct { maxToolCallsPerMinute int maxRequestsPerMinute int - mu sync.Mutex - toolCallTimes []time.Time - requestTimes []time.Time + mu sync.Mutex + toolCallTimes []time.Time + requestTimes []time.Time } func newRateLimiter(maxToolCalls, maxRequests int) *rateLimiter { diff --git a/pkg/channels/websocket.go b/pkg/channels/websocket.go index 67b376d8a..0c029d399 100644 --- a/pkg/channels/websocket.go +++ b/pkg/channels/websocket.go @@ -263,4 +263,3 @@ func (c *WebSocketChannel) readPump(conn *websocket.Conn, clientID, chatID strin c.HandleMessage(senderID, chatID, content, media, metadata) } } - diff --git a/pkg/heartbeat/service_test.go b/pkg/heartbeat/service_test.go index 9dce0c292..b55f3e601 100644 --- a/pkg/heartbeat/service_test.go +++ b/pkg/heartbeat/service_test.go @@ -16,7 +16,7 @@ func TestExecuteHeartbeat_Async(t *testing.T) { } defer os.RemoveAll(tmpDir) - hs := NewHeartbeatService(tmpDir, tmpDir,30, true) + hs := NewHeartbeatService(tmpDir, tmpDir, 30, true) hs.stopChan = make(chan struct{}) // Enable for testing asyncCalled := false @@ -54,7 +54,7 @@ func TestExecuteHeartbeat_Error(t *testing.T) { } defer os.RemoveAll(tmpDir) - hs := NewHeartbeatService(tmpDir, tmpDir,30, true) + hs := NewHeartbeatService(tmpDir, tmpDir, 30, true) hs.stopChan = make(chan struct{}) // Enable for testing hs.SetHandler(func(prompt, channel, chatID string) *tools.ToolResult { @@ -92,7 +92,7 @@ func TestExecuteHeartbeat_Silent(t *testing.T) { } defer os.RemoveAll(tmpDir) - hs := NewHeartbeatService(tmpDir, tmpDir,30, true) + hs := NewHeartbeatService(tmpDir, tmpDir, 30, true) hs.stopChan = make(chan struct{}) // Enable for testing hs.SetHandler(func(prompt, channel, chatID string) *tools.ToolResult { @@ -130,7 +130,7 @@ func TestHeartbeatService_StartStop(t *testing.T) { } defer os.RemoveAll(tmpDir) - hs := NewHeartbeatService(tmpDir, tmpDir,1, true) + hs := NewHeartbeatService(tmpDir, tmpDir, 1, true) err = hs.Start() if err != nil { @@ -149,7 +149,7 @@ func TestHeartbeatService_Disabled(t *testing.T) { } defer os.RemoveAll(tmpDir) - hs := NewHeartbeatService(tmpDir, tmpDir,1, false) + hs := NewHeartbeatService(tmpDir, tmpDir, 1, false) if hs.enabled != false { t.Error("Expected service to be disabled") @@ -166,7 +166,7 @@ func TestExecuteHeartbeat_NilResult(t *testing.T) { } defer os.RemoveAll(tmpDir) - hs := NewHeartbeatService(tmpDir, tmpDir,30, true) + hs := NewHeartbeatService(tmpDir, tmpDir, 30, true) hs.stopChan = make(chan struct{}) // Enable for testing hs.SetHandler(func(prompt, channel, chatID string) *tools.ToolResult { @@ -188,7 +188,7 @@ func TestLogPath(t *testing.T) { } defer os.RemoveAll(tmpDir) - hs := NewHeartbeatService(tmpDir, tmpDir,30, true) + hs := NewHeartbeatService(tmpDir, tmpDir, 30, true) // Write a log entry hs.log("INFO", "Test log entry") @@ -208,7 +208,7 @@ func TestHeartbeatFilePath(t *testing.T) { } defer os.RemoveAll(tmpDir) - hs := NewHeartbeatService(tmpDir, tmpDir,30, true) + hs := NewHeartbeatService(tmpDir, tmpDir, 30, true) // Trigger default template creation hs.buildPrompt() diff --git a/pkg/mcp/manager.go b/pkg/mcp/manager.go index efd2a0c74..9e9915c20 100644 --- a/pkg/mcp/manager.go +++ b/pkg/mcp/manager.go @@ -19,7 +19,7 @@ import ( // ServerInstance manages a connected MCP server session. type ServerInstance struct { session *sdkmcp.ClientSession - done chan struct{} // closed when session ends; created once per session + done chan struct{} // closed when session ends; created once per session tools []*sdkmcp.Tool lastUsed time.Time crashes []time.Time // track crash times for rate limiting diff --git a/pkg/utils/media.go b/pkg/utils/media.go index 15afa4b24..0c77594b0 100644 --- a/pkg/utils/media.go +++ b/pkg/utils/media.go @@ -48,9 +48,9 @@ func EncodeFileToDataURL(path string) string { } if info.Size() > maxImageFileSize { logger.WarnCF("media", "Image file too large, skipping", map[string]interface{}{ - "path": path, - "size_mb": info.Size() / (1024 * 1024), - "max_mb": maxImageFileSize / (1024 * 1024), + "path": path, + "size_mb": info.Size() / (1024 * 1024), + "max_mb": maxImageFileSize / (1024 * 1024), }) return "" }