proxy: add missing file

rpc: add new helper tests

proxy/api.go

@@ -0,0 +1,16 @@
+package proxy
+
+import (
+	"context"
+
+	radio "github.com/R-a-dio/valkyrie"
+	"github.com/R-a-dio/valkyrie/util/eventstream"
+)
+
+func (srv *Server) MetadataStream(ctx context.Context) (eventstream.Stream[radio.ProxyMetadataEvent], error) {
+	return srv.events.metaStream.SubStream(ctx), nil
+}
+
+func (srv *Server) SourceStream(ctx context.Context) (eventstream.Stream[radio.ProxySourceEvent], error) {
+	return srv.events.sourceStream.SubStream(ctx), nil
+}

rpc/helpers_test.go

@@ -112,5 +112,15 @@ func TestRoundtrip(tt *testing.T) {
 		return assert.EqualExportedValues(tt, in, out)
 	}))
 
+	toAndFrom(tt, p, a, "proxy-metadata-event", toProtoProxyMetadataEvent, fromProtoProxyMetadataEvent)
+	toAndFrom(tt, p, a, "proxy-source-event", toProtoProxySourceEvent, fromProtoProxySourceEvent)
+
 	p.TestingRun(tt)
 }
+
+func toAndFrom[A any, B any](t *testing.T, p *gopter.Properties, a *arbitrary.Arbitraries, name string, to func(A) B, from func(B) A) {
+	p.Property(name, a.ForAll(func(in A) bool {
+		out := from(to(in))
+		return assert.EqualExportedValues(t, in, out)
+	}))
+}