uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Add *http_post and *http_post_async in ActionS

Browse Source
This commit is contained in:
TeoV
2021-01-25 14:20:44 +02:00
committed by Dan Christian Bogos
parent ba48a5d5d0
commit 3816d07dce
1 changed files with 67 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

67
actions/libactions.go
View File

@@ -22,6 +22,7 @@ import (
"context"
"encoding/json"
"fmt"
"net/http"
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/engine"
@@ -102,6 +103,10 @@ func newActioner(cfg *config.CGRConfig, fltrS *engine.FilterS, dm *engine.DataMa
return &actLog{aCfg}, nil
case utils.CDRLog:
return &actCDRLog{config: cfg, connMgr: connMgr, aCfg: aCfg, filterS: fltrS}, nil
case utils.MetaHTTPPost:
return &actHTTPPost{aCfg: aCfg}, nil
case utils.HttpPostAsync:
return &actHTTPPostAsync{aCfg: aCfg}, nil
default:
return nil, fmt.Errorf("unsupported action type: <%s>", aCfg.Type)
@@ -204,3 +209,65 @@ func (aL *actCDRLog) execute(ctx context.Context, data utils.MapStorage) (err er
return
}
type actHTTPPost struct {
aCfg *engine.APAction
}
func (aL *actHTTPPost) id() string {
return aL.aCfg.ID
}
func (aL *actHTTPPost) cfg() *engine.APAction {
return aL.aCfg
}
// execute implements actioner interface
func (aL *actHTTPPost) execute(ctx context.Context, data utils.MapStorage) (err error) {
var body []byte
if body, err = json.Marshal(data); err != nil {
return
}
var pstr *engine.HTTPPoster
if pstr, err = engine.NewHTTPPoster(config.CgrConfig().GeneralCfg().ReplyTimeout, aL.cfg().Path,
utils.ContentJSON, config.CgrConfig().GeneralCfg().PosterAttempts); err != nil {
return
}
if err = pstr.PostValues(body, make(http.Header)); err != nil && config.CgrConfig().GeneralCfg().FailedPostsDir != utils.MetaNone {
engine.AddFailedPost(aL.cfg().Path, utils.MetaHTTPjson, utils.ActionsPoster+utils.HierarchySep+aL.cfg().Type, body, make(map[string]interface{}))
err = nil
}
return
}
type actHTTPPostAsync struct {
aCfg *engine.APAction
}
func (aL *actHTTPPostAsync) id() string {
return aL.aCfg.ID
}
func (aL *actHTTPPostAsync) cfg() *engine.APAction {
return aL.aCfg
}
// execute implements actioner interface
func (aL *actHTTPPostAsync) execute(ctx context.Context, data utils.MapStorage) (err error) {
var body []byte
if body, err = json.Marshal(data); err != nil {
return
}
var pstr *engine.HTTPPoster
if pstr, err = engine.NewHTTPPoster(config.CgrConfig().GeneralCfg().ReplyTimeout, aL.cfg().Path,
utils.ContentJSON, config.CgrConfig().GeneralCfg().PosterAttempts); err != nil {
return
}
go func() {
err := pstr.PostValues(body, make(http.Header))
if err != nil && config.CgrConfig().GeneralCfg().FailedPostsDir != utils.MetaNone {
engine.AddFailedPost(aL.cfg().Path, utils.MetaHTTPjson, utils.ActionsPoster+utils.HierarchySep+aL.cfg().Type, body, make(map[string]interface{}))
}
}()
return
}