Support for fallback guest agent

Signed-off-by: Balaji Vijayakumar <[email protected]>

cmd/lima-guestagent/daemon_linux.go

@@ -32,6 +32,8 @@ var (
 	vSockPort = 0
 
 	virtioPort = "/dev/virtio-ports/" + filenames.VirtioPort
+
+	socket = "/run/lima-guestagent.sock"
 )
 
 func daemonAction(cmd *cobra.Command, _ []string) error {
@@ -88,6 +90,16 @@ func daemonAction(cmd *cobra.Command, _ []string) error {
 		}
 		l = vsockL
 		logrus.Infof("serving the guest agent on vsock port: %d", vSockPort)
+	} else {
+		socketL, err := net.Listen("unix", socket)
+		if err != nil {
+			return err
+		}
+		if err := os.Chmod(socket, 0o777); err != nil {
+			return err
+		}
+		l = socketL
+		logrus.Infof("serving the guest agent on %q", socket)
 	}
 	return srv.Serve(l)
 }

pkg/hostagent/hostagent.go

@@ -604,6 +604,29 @@ func (a *HostAgent) createClient(_ context.Context) (guestagentclient.GuestAgent
 	return guestagentclient.NewGuestAgentClient(a.driver.GuestAgentConn)
 }
 
+func (a *HostAgent) getDriverConnOrFallback(ctx context.Context) (net.Conn, error) {
+	conn, err := a.driver.GuestAgentConn(ctx)
+	if err != nil {
+		retry := 0
+		for retry < 2 {
+			var d net.Dialer
+			conn, err = d.DialContext(ctx, "unix", filepath.Join(a.instDir, filenames.GuestAgentSock))
+			if err != nil {
+				//Forward ssh sock and create connection
+				localUnix := filepath.Join(a.instDir, filenames.GuestAgentSock)
+				remoteUnix := "/run/lima-guestagent.sock"
+				if err := forwardSSH(context.Background(), a.sshConfig, a.sshLocalPort, localUnix, remoteUnix, verbCancel, false); err != nil {
+					return nil, err
+				}
+				retry = retry + 1
+			}
+			return conn, err
+		}
+		return nil, errors.New("unable to create guestagent fallback connection")
+	}
+	return conn, nil
+}
+
 func (a *HostAgent) processGuestAgentEvents(ctx context.Context, client guestagentclient.GuestAgentClient) error {
 	info, err := client.Info(ctx)
 	if err != nil {