pkg/loop: wait from chain family

Author: jmank88

pkg/loop/internal/goplugin/plugin_service.go

@@ -261,6 +261,16 @@ func (s *PluginService[P, S]) WaitCtx(ctx context.Context) error {
 	}
 }
 
+// Wait waits for the service to start up until it receives the stop signal.
+func (s *PluginService[P, S]) Wait() error {
+	select {
+	case <-s.serviceCh:
+		return nil
+	case <-s.stopCh:
+		return fmt.Errorf("service was stoped while waiting: %w", context.Canceled)
+	}
+}
+
 // XXXTestHook returns a TestPluginService.
 // It must only be called once, and before Start.
 func (s *PluginService[P, S]) XXXTestHook() TestPluginService[P, S] {

pkg/loop/relayer_service.go

@@ -43,10 +43,16 @@ func NewRelayerService(lggr logger.Logger, grpcOpts GRPCOpts, cmd func() *exec.C
 }
 
 func (r *RelayerService) EVM() (types.EVMService, error) {
+	if err := r.Wait(); err != nil {
+		return nil, err
+	}
 	return r.Service.EVM()
 }
 
 func (r *RelayerService) TON() (types.TONService, error) {
+	if err := r.Wait(); err != nil {
+		return nil, err
+	}
 	return r.Service.TON()
 }