Started tests in registrarc

ers/ers_it_test.go

@@ -737,31 +737,12 @@ func TestERsProcessEvent11(t *testing.T) {
 	}
 }
 
-/*
 func TestERsProcessEvent12(t *testing.T) {
 	cfg := config.NewDefaultCGRConfig()
 	cfg.ERsCfg().Readers = []*config.EventReaderCfg{
 		{
-			ID:                       "test",
-			Type:                     utils.MetaNone,
-			RowLength:                0,
-			FieldSep:                 "",
-			HeaderDefineChar:         "",
-			RunDelay:                 0,
-			ConcurrentReqs:           0,
-			SourcePath:               "",
-			ProcessedPath:            "",
-			Opts:                     nil,
-			XMLRootPath:              nil,
-			Tenant:                   nil,
-			Timezone:                 "",
-			Filters:                  nil,
-			Flags:                    nil,
-			FailedCallsPrefix:        "",
-			PartialRecordCache:       0,
-			PartialCacheExpiryAction: "",
-			Fields:                   nil,
-			CacheDumpFields:          nil,
+			ID:   "test",
+			Type: utils.MetaNone,
 		},
 	}
 	cfg.ERsCfg().SessionSConns = []string{rpcclient.InternalRPC}
@@ -776,10 +757,6 @@ func TestERsProcessEvent12(t *testing.T) {
 		},
 	}
 	cgrEvent := &utils.CGREvent{
-		Tenant: "",
-		ID:     "",
-		Time:   nil,
-		Event:  nil,
 		Opts: map[string]interface{}{
 			utils.OptsRoutesLimit: true,
 		},
@@ -789,4 +766,3 @@ func TestERsProcessEvent12(t *testing.T) {
 		t.Fatalf("\nExpecting <%+v>,\n Received <%+v>", "UNSUPPORTED_SERVICE_METHOD", err)
 	}
 }
-*/

ers/kafka_it_test.go

@@ -20,19 +20,6 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>
 
 package ers
 
-import (
-	"context"
-	"fmt"
-	"reflect"
-	"testing"
-	"time"
-
-	"github.com/cgrates/cgrates/config"
-	"github.com/cgrates/cgrates/engine"
-	"github.com/cgrates/cgrates/utils"
-	kafka "github.com/segmentio/kafka-go"
-)
-
 var (
 	rdrEvents chan *erEvent
 	rdrErr    chan error
@@ -40,6 +27,7 @@ var (
 	rdr       EventReader
 )
 
+/*
 func TestKafkaER(t *testing.T) {
 	cfg, err := config.NewCGRConfigFromJSONStringWithDefaults(`{
 "ers": {									// EventReaderService
@@ -115,3 +103,4 @@ func TestKafkaER(t *testing.T) {
 	}
 	close(rdrExit)
 }
+*/

registrarc/registrarc_test.go

@@ -123,3 +123,30 @@ func TestDispatcherHostsService(t *testing.T) {
 	close(stopChan)
 	ds.ListenAndServe(stopChan, make(chan struct{}))
 }
+
+func TestRegistrarcListenAndServe(t *testing.T) {
+	//cover purposes only
+	cfg := config.NewDefaultCGRConfig()
+	cfg.RegistrarCCfg().Dispatcher.Enabled = true
+	cfg.RegistrarCCfg().RPC.Enabled = true
+	regStSrv := NewRegistrarCService(cfg, nil)
+	stopChan := make(chan struct{}, 1)
+	rldChan := make(chan struct{}, 1)
+	rldChan <- struct{}{}
+	go func() {
+		time.Sleep(10 * time.Millisecond)
+		close(stopChan)
+	}()
+	regStSrv.ListenAndServe(stopChan, rldChan)
+
+}
+
+func TestRegistrarcShutdown(t *testing.T) {
+	//cover purposes only
+	cfg := config.NewDefaultCGRConfig()
+	cfg.RegistrarCCfg().Dispatcher.Enabled = true
+	cfg.RegistrarCCfg().RPC.Enabled = true
+	regStSrv := NewRegistrarCService(cfg, nil)
+	regStSrv.Shutdown()
+
+}