Added filejson_test.go in ers

ers/filejson_test.go

@@ -0,0 +1,191 @@
+/*
+Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
+Copyright (C) ITsysCOM GmbH
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation, either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program.  If not, see <http://www.gnu.org/licenses/>
+*/
+
+package ers
+
+import (
+	"reflect"
+	"sync"
+	"testing"
+	"time"
+
+	"github.com/cgrates/cgrates/utils"
+
+	"github.com/cgrates/cgrates/config"
+)
+
+func TestNewJSONFileER(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	expected := &JSONFileER{
+		RWMutex:   sync.RWMutex{},
+		cgrCfg:    cfg,
+		cfgIdx:    0,
+		fltrS:     nil,
+		rdrEvents: nil,
+		rdrError:  nil,
+		rdrExit:   nil,
+		conReqs:   nil,
+	}
+	cfg.ERsCfg().Readers[0].ConcurrentReqs = 1
+	cfg.ERsCfg().Readers[0].SourcePath = "/"
+	result, err := NewJSONFileER(cfg, cfgIdx, nil, nil, nil, nil)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	result.(*JSONFileER).conReqs = nil
+	if !reflect.DeepEqual(result, expected) {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
+	}
+}
+
+func TestFileJSONConfig(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	cfg.ERsCfg().Readers[cfgIdx] = &config.EventReaderCfg{
+		ID:               utils.MetaDefault,
+		Type:             utils.MetaNone,
+		FieldSep:         ",",
+		HeaderDefineChar: ":",
+		RunDelay:         0,
+		ConcurrentReqs:   1024,
+		SourcePath:       "/var/spool/cgrates/ers/in",
+		ProcessedPath:    "/var/spool/cgrates/ers/out",
+		XMLRootPath:      utils.HierarchyPath{utils.EmptyString},
+		Tenant:           nil,
+		Timezone:         utils.EmptyString,
+		Filters:          []string{},
+		Flags:            utils.FlagsWithParams{},
+		Fields:           []*config.FCTemplate{},
+	}
+	rdr := &JSONFileER{
+		cgrCfg: cfg,
+		cfgIdx: cfgIdx,
+	}
+	expected := &config.EventReaderCfg{
+		ID:               utils.MetaDefault,
+		Type:             utils.MetaNone,
+		FieldSep:         ",",
+		HeaderDefineChar: ":",
+		RunDelay:         0,
+		ConcurrentReqs:   1024,
+		SourcePath:       "/var/spool/cgrates/ers/in",
+		ProcessedPath:    "/var/spool/cgrates/ers/out",
+		XMLRootPath:      utils.HierarchyPath{utils.EmptyString},
+		Tenant:           nil,
+		Timezone:         utils.EmptyString,
+		Filters:          []string{},
+		Flags:            utils.FlagsWithParams{},
+		Fields:           []*config.FCTemplate{},
+	}
+	result := rdr.Config()
+	if !reflect.DeepEqual(result, expected) {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, result)
+	}
+}
+
+func TestFileJSONServeErrTimeDuration0(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	rdr, err := NewJSONFileER(cfg, cfgIdx, nil, nil, nil, nil)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	rdr.Config().RunDelay = time.Duration(0)
+	result := rdr.Serve()
+	if !reflect.DeepEqual(result, nil) {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, result)
+	}
+}
+
+func TestFileJSONServeErrTimeDurationNeg1(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	rdr, err := NewJSONFileER(cfg, cfgIdx, nil, nil, nil, nil)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	rdr.Config().RunDelay = time.Duration(-1)
+	expected := "no such file or directory"
+	err = rdr.Serve()
+	if err == nil || err.Error() != expected {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err)
+	}
+}
+
+func TestFileJSONServeTimeDefault(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	rdr, err := NewJSONFileER(cfg, cfgIdx, nil, nil, nil, nil)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	rdr.Config().RunDelay = time.Duration(1)
+	result := rdr.Serve()
+	if !reflect.DeepEqual(result, nil) {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, result)
+	}
+}
+
+func TestFileJSONServeTimeDefaultChanExit(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	rdrExit := make(chan struct{}, 1)
+	rdr, err := NewJSONFileER(cfg, cfgIdx, nil, nil, nil, rdrExit)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	rdrExit <- struct{}{}
+	rdr.Config().RunDelay = time.Duration(1)
+	result := rdr.Serve()
+	if !reflect.DeepEqual(result, nil) {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, result)
+	}
+}
+
+/*
+func TestFileJSONServeTimeDefaultReadDir(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	rdrExit := make(chan struct{}, 1)
+	rdr, err := NewJSONFileER(cfg, cfgIdx, nil, nil, nil, rdrExit)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	rdr.Config().RunDelay = time.Duration(1)
+	rdr.(*JSONFileER).rdrDir = "/var/spool/cgrates/ers/in"
+	result := rdr.Serve()
+	if !reflect.DeepEqual(result, nil) {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, result)
+	}
+}
+*/
+
+func TestFileJSONProcessFile(t *testing.T) {
+	cfg := config.NewDefaultCGRConfig()
+	cfgIdx := 0
+	rdr, err := NewJSONFileER(cfg, cfgIdx, nil, nil, nil, nil)
+	if err != nil {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", nil, err)
+	}
+	expected := "open : no such file or directory"
+	err2 := rdr.(*JSONFileER).processFile("", "")
+	if err2 == nil || err2.Error() != expected {
+		t.Errorf("\nExpected <%+v>, \nReceived <%+v>", expected, err2)
+	}
+}