From ab2b05dbde255fc229588692b1370b2721cd415a Mon Sep 17 00:00:00 2001
From: DanB <danb@cgrates.org>
Date: Fri, 31 Jul 2015 09:12:25 +0200
Subject: [PATCH] Adding CDRs posted information to CDRC, fixes #132

---
 cdrc/cdrc.go | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/cdrc/cdrc.go b/cdrc/cdrc.go
index df8804938..a99976f42 100644
--- a/cdrc/cdrc.go
+++ b/cdrc/cdrc.go
@@ -258,6 +258,7 @@ func (self *Cdrc) processFile(filePath string) error {
 		return fmt.Errorf("Unsupported CDR format: %s", self.cdrFormat)
 	}
 	procRowNr := 0
+	cdrsPosted := 0
 	timeStart := time.Now()
 	for {
 		cdrs, err := recordsProcessor.ProcessNextRecord()
@@ -279,6 +280,8 @@ func (self *Cdrc) processFile(filePath string) error {
 				engine.Logger.Err(fmt.Sprintf("<Cdrc> Failed sending CDR, %+v, error: %s", storedCdr, err.Error()))
 			} else if reply != "OK" {
 				engine.Logger.Err(fmt.Sprintf("<Cdrc> Received unexpected reply for CDR, %+v, reply: %s", storedCdr, reply))
+			} else {
+				cdrsPosted += 1
 			}
 		}
 	}
@@ -288,7 +291,7 @@ func (self *Cdrc) processFile(filePath string) error {
 		engine.Logger.Err(err.Error())
 		return err
 	}
-	engine.Logger.Info(fmt.Sprintf("Finished processing %s, moved to %s. Total records processed: %d, run duration: %s",
-		fn, newPath, procRowNr, time.Now().Sub(timeStart)))
+	engine.Logger.Info(fmt.Sprintf("Finished processing %s, moved to %s. Total records processed: %d, CDRs posted: %d, run duration: %s",
+		fn, newPath, procRowNr, cdrsPosted, time.Now().Sub(timeStart)))
 	return nil
 }