From 9f1adfb7505f33fdebe37f34d2fb31cdb039d1e2 Mon Sep 17 00:00:00 2001 From: DanB Date: Thu, 27 Apr 2017 20:49:45 +0200 Subject: [PATCH] Updating radigo for udp/tcp connections, initial radius agent looping packets back --- agents/radagent.go | 14 +++++++++++++- glide.lock | 2 +- 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/agents/radagent.go b/agents/radagent.go index aff97b8c4..374ded580 100644 --- a/agents/radagent.go +++ b/agents/radagent.go @@ -50,10 +50,22 @@ type RadiusAgent struct { } func (ra *RadiusAgent) handleAuth(req *radigo.Packet) (rpl *radigo.Packet, err error) { + utils.Logger.Debug(fmt.Sprintf("RadiusAgent handleAuth, received request: %+v", req)) + rpl = req.Reply() + rpl.Code = radigo.AccessAccept + for _, avp := range req.AVPs { + rpl.AVPs = append(rpl.AVPs, avp) + } return } func (ra *RadiusAgent) handleAcct(req *radigo.Packet) (rpl *radigo.Packet, err error) { + utils.Logger.Debug(fmt.Sprintf("RadiusAgent handleAcct, received req: %+v", req)) + rpl = req.Reply() + rpl.Code = radigo.AccountingResponse + for _, avp := range req.AVPs { + rpl.AVPs = append(rpl.AVPs, avp) + } return } @@ -66,7 +78,7 @@ func (ra *RadiusAgent) ListenAndServe() (err error) { } }() go func() { - utils.Logger.Info(fmt.Sprintf(" Start listening for acct requests on <%s>", ra.cgrCfg.RadiusAgentCfg().ListenAcct)) + utils.Logger.Info(fmt.Sprintf(" Start listening for acct req on <%s>", ra.cgrCfg.RadiusAgentCfg().ListenAcct)) if err := ra.rsAcct.ListenAndServe(); err != nil { errListen <- err } diff --git a/glide.lock b/glide.lock index 0f91516f3..eca4ca084 100644 --- a/glide.lock +++ b/glide.lock @@ -18,7 +18,7 @@ imports: - name: github.com/cgrates/osipsdagram version: 3d6beed663452471dec3ca194137a30d379d9e8f - name: github.com/cgrates/radigo - version: b0690a5c829349f3c1bb0973f422788b870a9acc + version: 244e1809979396730f907f96819ce86fcafb0c81 - name: github.com/cgrates/rpcclient version: dddae42e9344e877627cd4b7aba075d63b452c0b - name: github.com/ChrisTrenkamp/goxpath