From 62511ee9e34979b79eb247bd78025bf0cb5bd1f5 Mon Sep 17 00:00:00 2001 From: Radu Ioan Fericean Date: Thu, 23 May 2013 11:36:09 +0300 Subject: [PATCH] removed name from cdr and it should compile on go1.0.x now --- cdrs/cdrs.go | 30 ++++++++++++++++-------------- cdrs/fscdr.go | 7 +------ cmd/cgr-rater/cgr-rater.go | 2 +- rater/cdr.go | 1 - 4 files changed, 18 insertions(+), 22 deletions(-) diff --git a/cdrs/cdrs.go b/cdrs/cdrs.go index f5ee379eb..e2cb0ab5a 100644 --- a/cdrs/cdrs.go +++ b/cdrs/cdrs.go @@ -20,40 +20,42 @@ package cdrs import ( "fmt" + "github.com/cgrates/cgrates/config" "github.com/cgrates/cgrates/mediator" "github.com/cgrates/cgrates/rater" - "github.com/cgrates/cgrates/config" "io/ioutil" "net/http" ) var ( - Logger = rater.Logger - cfg *config.CGRConfig // Share the configuration with the rest of the package + Logger = rater.Logger + cfg *config.CGRConfig // Share the configuration with the rest of the package + storage rater.DataStorage + medi *mediator.Mediator ) -type CDRS struct { - loggerDb rater.DataStorage - medi *mediator.Mediator -} - -func (cdrs *CDRS) cdrHandler(w http.ResponseWriter, r *http.Request) { +func cdrHandler(w http.ResponseWriter, r *http.Request) { body, _ := ioutil.ReadAll(r.Body) if fsCdr, err := new(FSCdr).New(body); err == nil { - cdrs.loggerDb.SetCdr(fsCdr) - cdrs.medi.MediateCdrFromDB(fsCdr.GetAccount(), cdrs.loggerDb) + storage.SetCdr(fsCdr) + medi.MediateCdrFromDB(fsCdr.GetAccount(), storage) } else { Logger.Err(fmt.Sprintf("Could not create CDR entry: %v", err)) } } -func New(storage rater.DataStorage, mediator *mediator.Mediator) *CDRS { - return &CDRS{storage, mediator} +type CDRS struct{} + +func New(s rater.DataStorage, m *mediator.Mediator, c *config.CGRConfig) *CDRS { + storage = s + medi = m + cfg = c + return &CDRS{} } func (cdrs *CDRS) StartCapturingCDRs() { if cfg.CDRSfsJSONEnabled { - http.HandleFunc("/freeswitch_json", cdrs.cdrHandler) + http.HandleFunc("/freeswitch_json", cdrHandler) } http.ListenAndServe(cfg.CDRSListen, nil) } diff --git a/cdrs/fscdr.go b/cdrs/fscdr.go index 4672d3867..66717d6d4 100644 --- a/cdrs/fscdr.go +++ b/cdrs/fscdr.go @@ -26,7 +26,6 @@ import ( "time" ) - const ( // Freswitch event property names CDR_MAP = "variables" @@ -43,9 +42,8 @@ const ( PARK_TIME = "start_stamp" START_TIME = "answer_stamp" END_TIME = "end_stamp" - NAME = "unused" USERNAME = "user_name" - FS_IP = "sip_local_network_addr" + FS_IP = "sip_local_network_addr" ) type FSCdr map[string]string @@ -67,9 +65,6 @@ func (fsCdr FSCdr) New(body []byte) (rater.CDR, error) { return nil, err } -func (fsCdr FSCdr) GetName() string { - return fsCdr[NAME] -} func (fsCdr FSCdr) GetDirection() string { //TODO: implement direction return "OUT" diff --git a/cmd/cgr-rater/cgr-rater.go b/cmd/cgr-rater/cgr-rater.go index 480b8773c..fef0a7a89 100644 --- a/cmd/cgr-rater/cgr-rater.go +++ b/cmd/cgr-rater/cgr-rater.go @@ -320,7 +320,7 @@ func main() { if cfg.CDRServerEnabled { rater.Logger.Info("Starting CGRateS CDR Server.") - cs := cdrs.New(loggerDb, medi) + cs := cdrs.New(loggerDb, medi, cfg) go cs.StartCapturingCDRs() } <-exitChan diff --git a/rater/cdr.go b/rater/cdr.go index 0424db5d2..db2d2b106 100644 --- a/rater/cdr.go +++ b/rater/cdr.go @@ -24,7 +24,6 @@ import ( type CDR interface { New([]byte) (CDR, error) - GetName() string GetDirection() string GetOrigId() string GetSubject() string