websocket support

pkg/discovery/device.go

@@ -3,6 +3,7 @@ package discovery
 import (
 	"context"
 	"fmt"
+	"strings"
 	"time"
 
 	mqtt "github.com/eclipse/paho.mqtt.golang"
@@ -47,6 +48,16 @@ func (d *Device) Open(ctx context.Context) (mgrpc.MgRPC, error) {
 		}
 		return mgrpc.Serve(ctx, c), nil
 	}
+	if strings.HasPrefix(d.uri, "ws://") || strings.HasPrefix(d.uri, "wss://") {
+		c, err := mgrpc.New(ctx, d.uri,
+			mgrpc.UseWebSocket(),
+		)
+		if err != nil {
+			return nil, fmt.Errorf("establishing rpc channel: %w", err)
+		}
+		ll.Info().Str("channel_protocol", "http").Msg("connected to device")
+		return c, nil
+	}
 	c, err := mgrpc.New(ctx, d.uri,
 		mgrpc.UseHTTPPost(),
 		mgrpc.CodecOptions(

pkg/discovery/discovery.go

@@ -81,6 +81,7 @@ func (d *Discoverer) AddDeviceByAddress(ctx context.Context, addr string, opts .
 	}
 	switch u.Scheme {
 	case "http", "https":
+	case "ws", "wss":
 	default:
 		return nil, fmt.Errorf("unsupported URI scheme %q", u.Scheme)
 	}