Merge branch 'qemu' into qemu-capabilities

Author: sjmiller609

cmd/api/api/cp.go

@@ -419,4 +419,3 @@ func (s *ApiService) handleCopyFrom(ctx context.Context, ws *websocket.Conn, ins
 	}
 	return bytesReceived, nil
 }
-

cmd/api/main.go

@@ -23,6 +23,7 @@ import (
 	"github.com/onkernel/hypeman/cmd/api/api"
 	"github.com/onkernel/hypeman/cmd/api/config"
 	"github.com/onkernel/hypeman/lib/guest"
+	"github.com/onkernel/hypeman/lib/hypervisor/qemu"
 	"github.com/onkernel/hypeman/lib/instances"
 	mw "github.com/onkernel/hypeman/lib/middleware"
 	"github.com/onkernel/hypeman/lib/oapi"
@@ -125,6 +126,11 @@ func run() error {
 	}
 	logger.Info("KVM access verified")
 
+	// Check if QEMU is available (optional - only warn if not present)
+	if _, err := (&qemu.Starter{}).GetBinaryPath(nil, ""); err != nil {
+		logger.Warn("QEMU not available - QEMU hypervisor will not work", "error", err)
+	}
+
 	// Validate log rotation config
 	var logMaxSize datasize.ByteSize
 	if err := logMaxSize.UnmarshalText([]byte(app.Config.LogMaxSize)); err != nil {

lib/instances/exec_test.go

@@ -22,7 +22,7 @@ func waitForExecAgent(ctx context.Context, mgr *manager, instanceID string, time
 	deadline := time.Now().Add(timeout)
 	for time.Now().Before(deadline) {
 		logs, err := collectLogs(ctx, mgr, instanceID, 100)
-		if err == nil && strings.Contains(logs, "[exec-agent] listening on vsock port 2222") {
+		if err == nil && strings.Contains(logs, "[guest-agent] listening on vsock port 2222") {
 			return nil
 		}
 		time.Sleep(500 * time.Millisecond)

lib/instances/manager.go

@@ -264,7 +264,7 @@ func (m *manager) RotateLogs(ctx context.Context, maxBytes int64, maxFiles int)
 			m.paths.InstanceHypemanLog(inst.Id),
 		}
 		for _, logPath := range logPaths {
-		if err := rotateLogIfNeeded(logPath, maxBytes, maxFiles); err != nil {
+			if err := rotateLogIfNeeded(logPath, maxBytes, maxFiles); err != nil {
 				lastErr = err // Continue with other logs, but track error
 			}
 		}

lib/instances/network_test.go

@@ -110,7 +110,7 @@ func TestCreateInstanceWithNetwork(t *testing.T) {
 
 	// Wait for exec agent to be ready
 	t.Log("Waiting for exec agent...")
-	err = waitForLogMessage(ctx, manager, inst.Id, "[exec-agent] listening", 10*time.Second)
+	err = waitForLogMessage(ctx, manager, inst.Id, "[guest-agent] listening", 10*time.Second)
 	require.NoError(t, err, "Exec agent should be listening")
 	t.Log("Exec agent is ready")