removed name from cdr and it should compile on go1.0.x now

This commit is contained in:
Radu Ioan Fericean
2013-05-23 11:36:09 +03:00
parent 83ef5b6d6f
commit 62511ee9e3
4 changed files with 18 additions and 22 deletions

View File

@@ -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)
}

View File

@@ -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"

View File

@@ -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

View File

@@ -24,7 +24,6 @@ import (
type CDR interface {
New([]byte) (CDR, error)
GetName() string
GetDirection() string
GetOrigId() string
GetSubject() string