Revamp port forwarding to support UDP

Signed-off-by: Balaji Vijayakumar <kuttibalaji.v6@gmail.com>

.github/workflows/test.yml

@@ -16,6 +16,7 @@ on:
     - "**.md"
 env:
   LIMACTL_CREATE_ARGS: ""
+  LIMA_GRPC_PORT_FORWARDER: true
 
 jobs:
   lints:

cmd/lima-guestagent/daemon_linux.go

@@ -9,6 +9,7 @@ import (
 	"github.com/lima-vm/lima/pkg/guestagent"
 	"github.com/lima-vm/lima/pkg/guestagent/api/server"
 	"github.com/lima-vm/lima/pkg/guestagent/serialport"
+	"github.com/lima-vm/lima/pkg/portfwdserver"
 	"github.com/mdlayher/vsock"
 	"github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
@@ -91,5 +92,5 @@ func daemonAction(cmd *cobra.Command, _ []string) error {
 		l = socketL
 		logrus.Infof("serving the guest agent on %q", socket)
 	}
-	return server.StartServer(l, &server.GuestServer{Agent: agent})
+	return server.StartServer(l, &server.GuestServer{Agent: agent, TunnelS: portfwdserver.NewTunnelServer()})
 }

pkg/guestagent/api/client/client.go

@@ -2,6 +2,7 @@ package client
 
 import (
 	"context"
+	"math"
 	"net"
 
 	"github.com/lima-vm/lima/pkg/guestagent/api"
@@ -16,6 +17,10 @@ type GuestAgentClient struct {
 
 func NewGuestAgentClient(dialFn func(ctx context.Context) (net.Conn, error)) (*GuestAgentClient, error) {
 	opts := []grpc.DialOption{
+		grpc.WithDefaultCallOptions(
+			grpc.MaxCallRecvMsgSize(math.MaxInt64),
+			grpc.MaxCallSendMsgSize(math.MaxInt64),
+		),
 		grpc.WithContextDialer(func(ctx context.Context, _ string) (net.Conn, error) {
 			return dialFn(ctx)
 		}),
@@ -59,3 +64,11 @@ func (c *GuestAgentClient) Inotify(ctx context.Context) (api.GuestService_PostIn
 	}
 	return inotify, nil
 }
+
+func (c *GuestAgentClient) Tunnel(ctx context.Context) (api.GuestService_TunnelClient, error) {
+	stream, err := c.cli.Tunnel(ctx)
+	if err != nil {
+		return nil, err
+	}
+	return stream, nil
+}

pkg/guestagent/api/guestservice.pb.desc

@@ -1,5 +1,5 @@
 
-�
+�
 guestservice.protogoogle/protobuf/empty.protogoogle/protobuf/timestamp.proto"0
 Info(
 local_ports
 (2.IPPortR
@@ -8,15 +8,23 @@ localPorts"
 time
 
(2.google.protobuf.TimestampRtime3
 local_ports_added (2.IPPortRlocalPortsAdded7
 local_ports_removed (2.IPPortRlocalPortsRemoved
-errors (	Rerrors",
-IPPort
-ip
 
(	Rip
-port 
(Rport"X
+errors (	Rerrors"H
+IPPort
+protocol
 
(	Rprotocol
+ip 
(	Rip
+port 
(Rport"X
 Inotify
 
 mount_path
 
(	R	mountPath.
-time 
(2.google.protobuf.TimestampRtime2�

+time 
(2.google.protobuf.TimestampRtime"�

+TunnelMessage
+id
 
(	Rid
+protocol 
(	Rprotocol
+data 
(Rdata
+	guestAddr 
(	R	guestAddr$
+udpTargetAddr 
(	RudpTargetAddr2�

 GuestService(
 GetInfo.google.protobuf.Empty.Info-
 	GetEvents.google.protobuf.Empty.Event0
1
-PostInotify.Inotify.google.protobuf.Empty(
B!Zgithub.com/lima-vm/lima/pkg/apibproto3
+PostInotify.Inotify.google.protobuf.Empty(
,
+Tunnel.TunnelMessage.TunnelMessage(
0
B!Zgithub.com/lima-vm/lima/pkg/apibproto3

pkg/guestagent/api/guestservice.proto

@@ -8,6 +8,8 @@ service GuestService {
   rpc GetInfo(google.protobuf.Empty) returns (Info);
   rpc GetEvents(google.protobuf.Empty) returns (stream Event);
   rpc PostInotify(stream Inotify) returns (google.protobuf.Empty);
+
+  rpc Tunnel(stream TunnelMessage) returns (stream TunnelMessage);
 }
 
 message Info {
@@ -22,11 +24,20 @@ message Event {
 }
 
 message IPPort {
-  string ip = 1;
-  int32 port = 2;
+  string protocol = 1; //tcp, udp
+  string ip = 2;
+  int32 port = 3;
 }
 
 message Inotify {
   string mount_path = 1;
   google.protobuf.Timestamp time = 2;
 }
+
+message TunnelMessage {
+  string id = 1;
+  string protocol = 2; //tcp, udp
+  bytes data = 3;
+  string guestAddr = 4;
+  string udpTargetAddr = 5;
+}