From 097ac9a89315522694dc3af3023f9ba4812ebe82 Mon Sep 17 00:00:00 2001
From: andronache <andrei.andronache@itsyscom.com>
Date: Wed, 3 Mar 2021 14:29:58 +0200
Subject: [PATCH] Tests for ers/partial_csv.go

---
 ers/kafka_it_test.go       | 15 ++++++++++++--
 ers/partial_csv_it_test.go | 41 ++++++++++++++++++++++++++++++++++++++
 2 files changed, 54 insertions(+), 2 deletions(-)

diff --git a/ers/kafka_it_test.go b/ers/kafka_it_test.go
index 9948ea566..6c710f587 100644
--- a/ers/kafka_it_test.go
+++ b/ers/kafka_it_test.go
@@ -20,6 +20,19 @@ 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
@@ -27,7 +40,6 @@ var (
 	rdr       EventReader
 )
 
-/*
 func TestKafkaER(t *testing.T) {
 	cfg, err := config.NewCGRConfigFromJSONStringWithDefaults(`{
 "ers": {									// EventReaderService
@@ -103,4 +115,3 @@ func TestKafkaER(t *testing.T) {
 	}
 	close(rdrExit)
 }
-*/
diff --git a/ers/partial_csv_it_test.go b/ers/partial_csv_it_test.go
index 40100aa8b..4eb8d2a0d 100644
--- a/ers/partial_csv_it_test.go
+++ b/ers/partial_csv_it_test.go
@@ -474,3 +474,44 @@ func TestPartialCSVServe4(t *testing.T) {
 		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
 	}
 }
+
+func TestPartialCSVProcessFile(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	fltr := &engine.FilterS{}
+	testStruct := &PartialCSVFileER{
+		cgrCfg:    cfg,
+		cfgIdx:    0,
+		fltrS:     fltr,
+		cache:     nil,
+		rdrDir:    "/var/spool/cgrates/ers/in",
+		rdrEvents: nil,
+		rdrError:  nil,
+		rdrExit:   make(chan struct{}, 1),
+		conReqs:   nil,
+	}
+	err := testStruct.processFile("", "")
+	if err == nil || err.Error() != "open : no such file or directory" {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", "open : no such file or directory", err)
+	}
+}
+
+func TestPartialCSVProcessFile2(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	fltr := &engine.FilterS{}
+	testStruct := &PartialCSVFileER{
+		cgrCfg:    cfg,
+		cfgIdx:    0,
+		fltrS:     fltr,
+		cache:     nil,
+		rdrDir:    "/var/spool/cgrates/ers/in",
+		rdrEvents: nil,
+		rdrError:  nil,
+		rdrExit:   make(chan struct{}, 1),
+		conReqs:   make(chan struct{}, 1),
+	}
+	testStruct.conReqs <- struct{}{}
+	err := testStruct.processFile("", "")
+	if err == nil || err.Error() != "open : no such file or directory" {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", "open : no such file or directory", err)
+	}
+}