opencode/picoclaw
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixed the format

Browse source
This commit is contained in:
mrigangha 2026-05-07 12:37:38 +00:00
parent 6544bebdd1
commit 2f732984a6
2 changed files with 90 additions and 89 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
pkg/pid/pidfile.go
View file

@ -6,11 +6,13 @@ import (
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" "fmt"
"net"
"net/http" "net/http"
"os" "os"
"path/filepath" "path/filepath"
"sync" "sync"
"time" "time"
"strconv"
"github.com/sipeed/picoclaw/pkg/config" "github.com/sipeed/picoclaw/pkg/config"
"github.com/sipeed/picoclaw/pkg/logger" "github.com/sipeed/picoclaw/pkg/logger"
@ -50,7 +52,7 @@ func generateToken() string {
// then verifies the reported PID matches expectedPID to confirm the process // then verifies the reported PID matches expectedPID to confirm the process
// is actually a picoclaw gateway and not a foreign service on the same port. // is actually a picoclaw gateway and not a foreign service on the same port.
func isGatewayAlive(host string, port int, expectedPID int) bool { func isGatewayAlive(host string, port int, expectedPID int) bool {
url := fmt.Sprintf("http://%s:%d/health", host, port) url := "http://" + net.JoinHostPort(host, strconv.Itoa(port)) + "/health"
client := &http.Client{Timeout: 2 * time.Second} client := &http.Client{Timeout: 2 * time.Second}
resp, err := client.Get(url) resp, err := client.Get(url)
if err != nil { if err != nil {
@ -94,7 +96,7 @@ func WritePidFile(homePath, host string, port int) (*PidFileData, error) {
// PID file on a shared volume, the host's PID 1 (init) would // PID file on a shared volume, the host's PID 1 (init) would
// pass the isProcessRunning check, blocking new gateway starts. // pass the isProcessRunning check, blocking new gateway starts.
// Treat recorded PID 1 as always stale. // Treat recorded PID 1 as always stale.
if data.PID != 1 && isProcessRunning(data.PID) && isGatewayAlive(data.Host, data.Port, data.PID){ if data.PID != 1 && isProcessRunning(data.PID) && isGatewayAlive(data.Host, data.Port, data.PID) {
return nil, fmt.Errorf("gateway is already running (PID: %d, version: %s)", data.PID, data.Version) return nil, fmt.Errorf("gateway is already running (PID: %d, version: %s)", data.PID, data.Version)
} }
logger.Warnf("not running (PID: %d) so will remove the pid file: %s", data.PID, pidPath) logger.Warnf("not running (PID: %d) so will remove the pid file: %s", data.PID, pidPath)

167
pkg/pid/pidfile_test.go
View file

@ -1,14 +1,14 @@
package pid package pid
import ( import (
"encoding/json" "encoding/json"
"net" "net"
"net/http" "net/http"
"net/http/httptest" "net/http/httptest"
"os" "os"
"path/filepath" "path/filepath"
"strconv" "strconv"
"testing" "testing"
) )
// tmpDir returns a clean temporary directory for a test. // tmpDir returns a clean temporary directory for a test.
@ -55,98 +55,97 @@ func TestPidFilePath(t *testing.T) {
} }
} }
// verifies that an unrelated service on the recorded port is not mistaken for the gateway. // verifies that an unrelated service on the recorded port is not mistaken for the gateway.
func TestWritePidFileHealthPIDMismatch(t *testing.T) { func TestWritePidFileHealthPIDMismatch(t *testing.T) {
mux := http.NewServeMux() mux := http.NewServeMux()
mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) { mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json") w.Header().Set("Content-Type", "application/json")
// Return PID 99999 — does not match the PID file entry // Return PID 99999 — does not match the PID file entry
json.NewEncoder(w).Encode(map[string]any{"pid": 99999, "status": "ok"}) json.NewEncoder(w).Encode(map[string]any{"pid": 99999, "status": "ok"})
}) })
srv := httptest.NewServer(mux) srv := httptest.NewServer(mux)
defer srv.Close() defer srv.Close()
host, portStr, _ := net.SplitHostPort(srv.Listener.Addr().String()) host, portStr, _ := net.SplitHostPort(srv.Listener.Addr().String())
port, _ := strconv.Atoi(portStr) port, _ := strconv.Atoi(portStr)
dir := tmpDir(t) dir := tmpDir(t)
foreign := PidFileData{ foreign := PidFileData{
PID: os.Getpid(), // real running PID so it reaches isGatewayAlive PID: os.Getpid(), // real running PID so it reaches isGatewayAlive
Token: "deadbeef12345678deadbeef12345678", Token: "deadbeef12345678deadbeef12345678",
Port: port, Port: port,
Host: host, Host: host,
} }
raw, _ := json.MarshalIndent(foreign, "", " ") raw, _ := json.MarshalIndent(foreign, "", " ")
os.WriteFile(filepath.Join(dir, pidFileName), raw, 0o600) os.WriteFile(filepath.Join(dir, pidFileName), raw, 0o600)
// Should succeed — health PID (99999) != PID file PID (os.Getpid()) = not our gateway // Should succeed — health PID (99999) != PID file PID (os.Getpid()) = not our gateway
data, err := WritePidFile(dir, "127.0.0.1", 18790) data, err := WritePidFile(dir, "127.0.0.1", 18790)
if err != nil { if err != nil {
t.Fatalf("WritePidFile should treat health PID mismatch as stale, got error: %v", err) t.Fatalf("WritePidFile should treat health PID mismatch as stale, got error: %v", err)
} }
if data.PID != os.Getpid() { if data.PID != os.Getpid() {
t.Errorf("PID = %d, want %d", data.PID, os.Getpid()) t.Errorf("PID = %d, want %d", data.PID, os.Getpid())
} }
} }
// verifies that isGatewayAlive uses the host from the PID file instead of hardcoding localhost. // verifies that isGatewayAlive uses the host from the PID file instead of hardcoding localhost.
func TestWritePidFileNonLocalhostHost(t *testing.T) { func TestWritePidFileNonLocalhostHost(t *testing.T) {
if !isProcessRunning(os.Getppid()) { if !isProcessRunning(os.Getppid()) {
t.Skip("skipping: parent process not running in this environment") t.Skip("skipping: parent process not running in this environment")
} }
mux := http.NewServeMux() mux := http.NewServeMux()
mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) { mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json") w.Header().Set("Content-Type", "application/json")
// Return parent PID — matches the PID file entry // Return parent PID — matches the PID file entry
json.NewEncoder(w).Encode(map[string]any{"pid": os.Getppid(), "status": "ok"}) json.NewEncoder(w).Encode(map[string]any{"pid": os.Getppid(), "status": "ok"})
}) })
srv := httptest.NewServer(mux) srv := httptest.NewServer(mux)
defer srv.Close() defer srv.Close()
host, portStr, _ := net.SplitHostPort(srv.Listener.Addr().String()) host, portStr, _ := net.SplitHostPort(srv.Listener.Addr().String())
port, _ := strconv.Atoi(portStr) port, _ := strconv.Atoi(portStr)
dir := tmpDir(t) dir := tmpDir(t)
foreign := PidFileData{ foreign := PidFileData{
PID: os.Getppid(), // parent PID — real, running, but not us PID: os.Getppid(), // parent PID — real, running, but not us
Token: "deadbeef12345678deadbeef12345678", Token: "deadbeef12345678deadbeef12345678",
Port: port, Port: port,
Host: host, Host: host,
} }
raw, _ := json.MarshalIndent(foreign, "", " ") raw, _ := json.MarshalIndent(foreign, "", " ")
os.WriteFile(filepath.Join(dir, pidFileName), raw, 0o600) os.WriteFile(filepath.Join(dir, pidFileName), raw, 0o600)
// Should block — PID exists, health responds with matching PID on non-localhost host // Should block — PID exists, health responds with matching PID on non-localhost host
_, err := WritePidFile(dir, "127.0.0.1", 18790) _, err := WritePidFile(dir, "127.0.0.1", 18790)
if err == nil { if err == nil {
t.Fatal("WritePidFile should block startup when gateway is genuinely alive on non-localhost host") t.Fatal("WritePidFile should block startup when gateway is genuinely alive on non-localhost host")
} }
} }
// verifies that a foreign process reusing a crashed gateway's PID is treated as stale.
//verifies that a foreign process reusing a crashed gateway's PID is treated as stale.
func TestWritePidFileForeignPIDReuse(t *testing.T) { func TestWritePidFileForeignPIDReuse(t *testing.T) {
dir := tmpDir(t) dir := tmpDir(t)
// PID 1 (init/systemd) is always running but won't respond on port 19999 // PID 1 (init/systemd) is always running but won't respond on port 19999
foreign := PidFileData{ foreign := PidFileData{
PID: 1, PID: 1,
Token: "deadbeef12345678deadbeef12345678", Token: "deadbeef12345678deadbeef12345678",
Port: 19999, // nothing listening here Port: 19999, // nothing listening here
Host: "127.0.0.1", Host: "127.0.0.1",
} }
raw, _ := json.MarshalIndent(foreign, "", " ") raw, _ := json.MarshalIndent(foreign, "", " ")
os.WriteFile(filepath.Join(dir, pidFileName), raw, 0o600) os.WriteFile(filepath.Join(dir, pidFileName), raw, 0o600)
// Should succeed — foreign PID reuse should be treated as stale // Should succeed — foreign PID reuse should be treated as stale
data, err := WritePidFile(dir, "127.0.0.1", 18790) data, err := WritePidFile(dir, "127.0.0.1", 18790)
if err != nil { if err != nil {
t.Fatalf("WritePidFile should treat foreign PID as stale, got error: %v", err) t.Fatalf("WritePidFile should treat foreign PID as stale, got error: %v", err)
} }
if data.PID != os.Getpid() { if data.PID != os.Getpid() {
t.Errorf("PID = %d, want %d", data.PID, os.Getpid()) t.Errorf("PID = %d, want %d", data.PID, os.Getpid())
} }
} }
// TestWritePidFile creates a PID file and verifies its contents. // TestWritePidFile creates a PID file and verifies its contents.