From 299c659e13a89bc9326041261d689fa6e133d496 Mon Sep 17 00:00:00 2001
From: Tripon Alexandru-Ionut <alexandru.tripon@itsyscom.com>
Date: Thu, 11 Apr 2019 14:54:51 +0300
Subject: [PATCH] Added cache dispatcher test

---
 apier/v1/dispatcher_it_test.go | 21 +++++++++++++++++++++
 1 file changed, 21 insertions(+)

diff --git a/apier/v1/dispatcher_it_test.go b/apier/v1/dispatcher_it_test.go
index 2397b2655..21e2bee39 100644
--- a/apier/v1/dispatcher_it_test.go
+++ b/apier/v1/dispatcher_it_test.go
@@ -31,6 +31,7 @@ import (
 	"github.com/cgrates/cgrates/config"
 	"github.com/cgrates/cgrates/engine"
 	"github.com/cgrates/cgrates/utils"
+	"github.com/cgrates/ltcache"
 )
 
 var (
@@ -52,11 +53,13 @@ var sTestsDispatcher = []func(t *testing.T){
 	testDispatcherSSetDispatcherProfile,
 	testDispatcherSGetDispatcherProfileIDs,
 	testDispatcherSUpdateDispatcherProfile,
+	testDispatcherSGetDispatcherProfileCache,
 	testDispatcherSRemDispatcherProfile,
 
 	testDispatcherSSetDispatcherHost,
 	testDispatcherSGetDispatcherHostIDs,
 	testDispatcherSUpdateDispatcherHost,
+	testDispatcherSGetDispatcherHostCache,
 	testDispatcherSRemDispatcherHost,
 
 	testDispatcherSKillEngine,
@@ -196,6 +199,15 @@ func testDispatcherSUpdateDispatcherProfile(t *testing.T) {
 	}
 }
 
+func testDispatcherSGetDispatcherProfileCache(t *testing.T) {
+	var rcvStats map[string]*ltcache.CacheStats
+	if err := dispatcherRPC.Call(utils.CacheSv1GetCacheStats, nil, &rcvStats); err != nil {
+		t.Error(err)
+	} else if rcvStats[utils.CacheDispatcherProfiles].Items != 1 {
+		t.Errorf("Expecting: 1 DispatcherProfiles, received: %+v", rcvStats[utils.CacheDispatcherProfiles])
+	}
+}
+
 func testDispatcherSRemDispatcherProfile(t *testing.T) {
 	var result string
 	if err := dispatcherRPC.Call(utils.ApierV1RemoveDispatcherProfile,
@@ -302,6 +314,15 @@ func testDispatcherSUpdateDispatcherHost(t *testing.T) {
 	}
 }
 
+func testDispatcherSGetDispatcherHostCache(t *testing.T) {
+	var rcvStats map[string]*ltcache.CacheStats
+	if err := dispatcherRPC.Call(utils.CacheSv1GetCacheStats, nil, &rcvStats); err != nil {
+		t.Error(err)
+	} else if rcvStats[utils.CacheDispatcherHosts].Items != 0 {
+		t.Errorf("Expecting: 0 DispatcherProfiles, received: %+v", rcvStats[utils.CacheDispatcherProfiles])
+	}
+}
+
 func testDispatcherSRemDispatcherHost(t *testing.T) {
 	var result string
 	if err := dispatcherRPC.Call(utils.ApierV1RemoveDispatcherHost,