Force load of deployer topic

cmd/server/server.go

@@ -23,6 +23,11 @@ import (
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/reflection"
 	"gopkg.daemonl.com/envconf"
+
+	// Forces the Deployer topic to be in the global registry for later lookup.
+	// This should be replaced with a dynamic lookup when we build one in
+	// pentops
+	_ "github.com/pentops/o5-deploy-aws/gen/o5/deployer/v1/deployer_tpb"
 )
 
 var Version string
@@ -130,11 +135,6 @@ func runServe(ctx context.Context) error {
 		return err
 	}
 
-	err = types.LoadProtoFromFile("./pentops-o5.binpb")
-	if err != nil {
-		return err
-	}
-
 	db, err := openDatabase(ctx)
 	if err != nil {
 		return err

dynamictype/registry.go

@@ -59,9 +59,15 @@ func NewTypeRegistry() *TypeRegistry {
 }
 
 func (r *TypeRegistry) FindMessageByName(field protoreflect.FullName) (protoreflect.MessageType, error) {
+	var descriptor protoreflect.MessageDescriptor
 	descriptor, ok := r.messages[string(field)]
+
 	if !ok {
-		return nil, fmt.Errorf("couldn't find message by name: %s", field)
+		td, err := protoregistry.GlobalTypes.FindMessageByName(field)
+		if err != nil {
+			return nil, fmt.Errorf("couldn't find message by name: %s", field)
+		}
+		descriptor = td.Descriptor()
 	}
 
 	msg := dynamicpb.NewMessageType(descriptor)