move templates

internal/messaging/clients/client.go

@@ -11,7 +11,3 @@ import (
 type Client interface {
  Call(ctx context.Context, request protoreflect.ProtoMessage, opts ...grpc.CallOption) (protoreflect.ProtoMessage, types.MessageType, error)
 }
-
-func ServiceNameToRequestType(serviceName string) types.MessageType {
- return types.MessageType(serviceName + ".Request")
-}

internal/messaging/service_registry.go

@@ -43,7 +43,7 @@ func NewServiceRegistry(supportedServices SupportedServices, logger *zap.Sugared
  logStr := "\nSupported services:\n"
  for _, serviceName := range supportedServices.ServiceNames {
  logStr += serviceName + "\n"
- services[clients.ServiceNameToRequestType(serviceName)] = &service{name: serviceName}
+ services[types.ServiceNameToRequestMessageType(serviceName)] = &service{name: serviceName}
  }
  logStr += "\n"
  logger.Info(logStr)
@@ -67,6 +67,7 @@ func (s *serviceRegistry) RegisterServices(rpcClient *client.RPCClient) {
  s.rpcClient = rpcClient
  }
 }
+
 func (s *serviceRegistry) GetService(requestType types.MessageType) (Service, bool) {
  s.lock.RLock()
  defer s.lock.RUnlock()

internal/messaging/types/types.go

@@ -47,6 +47,10 @@ func (m MessageType) Category() MessageCategory {
  return Unknown
 }
 
+func ServiceNameToRequestMessageType(serviceName string) MessageType {
+ return MessageType(serviceName + ".Request")
+}
+
 // Message is the message format used for communication between the messenger and the service
 type Message struct {
  Type MessageType `json:"msgtype"`