[RSDK-8344] Expose machine internet connectivity

rpc/dialer.go

@@ -23,6 +23,7 @@ import (
 	"golang.org/x/net/proxy"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/connectivity"
 	"google.golang.org/grpc/credentials"
 	"google.golang.org/grpc/credentials/insecure"
 	"google.golang.org/grpc/keepalive"
@@ -61,6 +62,9 @@ type Dialer interface {
 	Close() error
 }
 
+// Unknown is an unknown connectivity state.
+const Unknown connectivity.State = 5
+
 // A ClientConn is a wrapper around the gRPC client connection interface but ensures
 // there is a way to close the connection.
 type ClientConn interface {
@@ -70,6 +74,8 @@ type ClientConn interface {
 	// a PeerConnection.
 	PeerConn() *webrtc.PeerConnection
 	Close() error
+
+	GetState() connectivity.State
 }
 
 // A ClientConnAuthenticator supports instructing a connection to authenticate now.

rpc/wrtc_client_channel.go

@@ -10,6 +10,7 @@ import (
 	grpc_logging "github.com/grpc-ecosystem/go-grpc-middleware/logging"
 	"github.com/viamrobotics/webrtc/v3"
 	"google.golang.org/grpc"
+	"google.golang.org/grpc/connectivity"
 	"google.golang.org/grpc/metadata"
 	"google.golang.org/protobuf/proto"
 	"google.golang.org/protobuf/types/known/durationpb"
@@ -333,6 +334,11 @@ func (ch *webrtcClientChannel) writeReset(stream *webrtcpb.Stream) error {
 	})
 }
 
+// GetState returns the current connectivity state of the channel.
+func (ch *webrtcClientChannel) GetState() connectivity.State {
+	return Unknown
+}
+
 func newClientLoggerFields(fullMethodString string) []any {
 	service := path.Dir(fullMethodString)[1:]
 	method := path.Base(fullMethodString)