From 2f7da3702ae4483bb707c5fc47aa76a267a9c045 Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Mon, 26 May 2025 20:58:37 +0300 Subject: [PATCH] remove redundant dm init in test flush helper --- engine/libtest.go | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/engine/libtest.go b/engine/libtest.go index f7dd93bf0..dff7d7acc 100644 --- a/engine/libtest.go +++ b/engine/libtest.go @@ -46,7 +46,7 @@ import ( ) func InitDataDB(cfg *config.CGRConfig) error { - d, err := NewDataDBConn(cfg.DataDbCfg().Type, + dataDB, err := NewDataDBConn(cfg.DataDbCfg().Type, cfg.DataDbCfg().Host, cfg.DataDbCfg().Port, cfg.DataDbCfg().Name, cfg.DataDbCfg().User, cfg.DataDbCfg().Password, cfg.GeneralCfg().DBDataEncoding, @@ -54,14 +54,12 @@ func InitDataDB(cfg *config.CGRConfig) error { if err != nil { return err } - defer d.Close() - dm := NewDataManager(d, cfg, connMgr) - - if err := dm.DataDB().Flush(""); err != nil { + defer dataDB.Close() + if err := dataDB.Flush(""); err != nil { return err } - // Write version before starting - if err := OverwriteDBVersions(dm.dataDB); err != nil { + // Set versions before starting. + if err := OverwriteDBVersions(dataDB); err != nil { return err } return nil