From e51eed46e7d56abd9d86167d80fe08156d5ce2f3 Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Thu, 5 Dec 2024 17:56:15 +0200 Subject: [PATCH] Revise analyzers integration test --- data/conf/samples/analyzers_doc/cgrates.json | 50 --- general_tests/analyzers_doc_it_test.go | 433 +++++-------------- 2 files changed, 114 insertions(+), 369 deletions(-) delete mode 100644 data/conf/samples/analyzers_doc/cgrates.json diff --git a/data/conf/samples/analyzers_doc/cgrates.json b/data/conf/samples/analyzers_doc/cgrates.json deleted file mode 100644 index 8ba034963..000000000 --- a/data/conf/samples/analyzers_doc/cgrates.json +++ /dev/null @@ -1,50 +0,0 @@ -{ - -"general": { - "reply_timeout": "30s" -}, - -"logger": { - "level": 7 -}, - -"listen": { - "rpc_json": ":2012", - "rpc_gob": ":2013", - "http": ":2080" -}, - -"data_db": { - "db_type": "redis", - "db_name": "10" -}, - -"stor_db": { - "db_password": "CGRateS.org" -}, - -"admins": { - "enabled": true -}, - -"attributes": { - "enabled": true, - "prefix_indexed_fields":["*req.Destination", "*req.Account"], - "opts":{ - "*processRuns": [ - { - "Tenant": "cgrates.org", - "FilterIDs": [], - "Value": 2 - } - ] - } -}, - -"analyzers":{ - "enabled": true, - "db_path": "/tmp/analyzers" -} - -} - \ No newline at end of file diff --git a/general_tests/analyzers_doc_it_test.go b/general_tests/analyzers_doc_it_test.go index a4e3a3440..79ec8911e 100644 --- a/general_tests/analyzers_doc_it_test.go +++ b/general_tests/analyzers_doc_it_test.go @@ -23,8 +23,6 @@ package general_tests import ( "fmt" - "os" - "path" "reflect" "sort" "testing" @@ -33,109 +31,127 @@ import ( "github.com/cgrates/birpc" "github.com/cgrates/birpc/context" "github.com/cgrates/cgrates/analyzers" - "github.com/cgrates/cgrates/config" "github.com/cgrates/cgrates/engine" "github.com/cgrates/cgrates/utils" ) -var ( - anzDocCfgPath string - anzDocCfg *config.CGRConfig - anzDocRPC *birpc.Client - timeVar string // will be used to query results based on date - - sTestsAnzDoc = []func(t *testing.T){ - testAnzDocInitCfg, - testAnzDocFlushDBs, - testAnzDocStartEngine, - testAnzDocRPCConn, - - /* - Generate traffic. The following API methods will be stored in the blevesearch db: - - 2 * CoreSv1.Status - - 5 * AttributeSv1.SetAttributeProfile - - 1 * AttributeSv1.GetAttributeProfiles - - 3 * AttributeSv1.ProcessEvent - - ? * CacheSv1.ReloadCache - */ - testAnzDocCoreSStatus, - testPopulateTimeVariable, - testAnzDocSetAttributeProfiles, - testAnzDocCheckAttributeProfiles, - testAnzDocAttributeSProcessEvent, - testAnzDocCoreSStatus, - // make queries to the AnalyzerS db using only HeaderFilters - testAnzDocQueryWithHeaderFilters, - // make queries to the AnalyzerS db using only ContentFilters - testAnzDocQueryWithContentFiltersFilters, - // make queries to the AnalyzerS db using a combination of both types of filters - testAnzDocQuery, - testAnzDocKillEngine, - } -) - func TestAnzDocIT(t *testing.T) { - for _, stest := range sTestsAnzDoc { - t.Run("TestAnzDocIT", stest) + switch *utils.DBType { + case utils.MetaInternal: + case utils.MetaMySQL, utils.MetaMongo, utils.MetaPostgres: + t.SkipNow() + default: + t.Fatal("unsupported dbtype value") } + jsonCfg := fmt.Sprintf(`{ +"admins": { + "enabled": true +}, +"attributes": { + "enabled": true, + "prefix_indexed_fields": ["*req.Destination", "*req.Account"], + "opts": { + "*processRuns": [{ + "Tenant": "cgrates.org", + "FilterIDs": [], + "Value": 2 + }] + } +}, +"analyzers": { + "enabled": true, + "db_path": "%s" } +}`, t.TempDir()) + ng := engine.TestEngine{ + ConfigJSON: jsonCfg, + DBCfg: engine.InternalDBCfg, + Encoding: *utils.Encoding, + } + client, _ := ng.Run(t) -func testAnzDocFlushDBs(t *testing.T) { - if err := engine.InitDataDB(anzDocCfg); err != nil { - t.Fatal(err) + status := func(t *testing.T) { + t.Helper() + var status map[string]any + if err := client.Call(context.Background(), utils.CoreSv1Status, utils.TenantWithAPIOpts{}, &status); err != nil { + t.Error(err) + } } - if err := engine.InitStorDB(anzDocCfg); err != nil { - t.Fatal(err) - } -} -func testAnzDocStartEngine(t *testing.T) { - if _, err := engine.StopStartEngine(anzDocCfgPath, *utils.WaitRater); err != nil { - t.Fatal(err) - } -} + //Generate traffic. + status(t) //1*CoreSv1.Status -func testAnzDocInitCfg(t *testing.T) { - var err error - if err := os.RemoveAll("/tmp/analyzers/"); err != nil { - t.Fatal(err) - } - if err = os.MkdirAll("/tmp/analyzers/", 0700); err != nil { - t.Fatal(err) - } - anzDocCfgPath = path.Join(*utils.DataDir, "conf", "samples", "analyzers_doc") - anzDocCfg, err = config.NewCGRConfigFromPath(context.Background(), anzDocCfgPath) - if err != nil { - t.Error(err) - } -} - -func testAnzDocRPCConn(t *testing.T) { - anzDocRPC = engine.NewRPCClient(t, anzDocCfg.ListenCfg(), *utils.Encoding) -} - -func testAnzDocKillEngine(t *testing.T) { - if err := engine.KillEngine(100); err != nil { - t.Error(err) - } - if err := os.RemoveAll(anzDocCfg.AnalyzerSCfg().DBPath); err != nil { - t.Fatal(err) - } -} - -func testAnzDocCoreSStatus(t *testing.T) { - var status map[string]any - if err := anzDocRPC.Call(context.Background(), utils.CoreSv1Status, utils.TenantWithAPIOpts{}, &status); err != nil { - return - } -} - -func testPopulateTimeVariable(t *testing.T) { time.Sleep(time.Second) - timeVar = time.Now().UTC().Format("2006-01-02T15:04:05Z07:00") + timeVar := time.Now().UTC().Format("2006-01-02T15:04:05Z07:00") + + setAttrProfiles(t, client) // 5*AdminSv1.SetAttributeProfiles + getAttrProfiles(t, client) // 1*AdminSv1.GetAttributeProfiles + attrProcessEvents(t, client) // 3*AttributeSv1.ProcessEvent + status(t) //1*CoreSv1.Status (2 total) + + time.Sleep(100 * time.Millisecond) + + // HeaderFilters only queries. + anzStringQuery(t, client, 5, `+RequestMethod:"AdminSv1.SetAttributeProfile"`) + anzStringQuery(t, client, 1, `+RequestMethod:"AdminSv1.GetAttributeProfiles"`) + anzStringQuery(t, client, 3, `+RequestMethod:"AttributeSv1.ProcessEvent"`) + anzStringQuery(t, client, 2, `+RequestMethod:"CoreSv1.Status"`) + anzStringQuery(t, client, 5, `+RequestMethod:"CacheSv1.ReloadCache"`) + anzStringQuery(t, client, 11, `-RequestMethod:"CacheSv1.ReloadCache"`) + anzStringQuery(t, client, 6, `+RequestMethod:"/AdminSv1.*/"`) // regex + + // Query results that happen before a given time. + headerFltr := `+RequestStartTime:<"%s"` + headerFltr = fmt.Sprintf(headerFltr, timeVar) + anzStringQuery(t, client, 1, headerFltr) + + // ContentFilters only queries. + anzStringQuery(t, client, 2, `+RequestID:<=2 -RequestMethod:"CacheSv1.ReloadCache"`) + anzStringQuery(t, client, 5, "", "*string:~*hdr.RequestMethod:AdminSv1.SetAttributeProfile") + anzStringQuery(t, client, 1, "", "*string:~*hdr.RequestMethod:AdminSv1.GetAttributeProfiles") + anzStringQuery(t, client, 3, "", "*string:~*hdr.RequestMethod:AttributeSv1.ProcessEvent") + anzStringQuery(t, client, 2, "", "*string:~*hdr.RequestMethod:CoreSv1.Status") + anzStringQuery(t, client, 5, "", "*string:~*hdr.RequestMethod:CacheSv1.ReloadCache") + anzStringQuery(t, client, 6, "", "*prefix:~*hdr.RequestMethod:AdminSv1.") + + // Query results that happen before a given time + contentFltr := "*lt:~*hdr.RequestStartTime:%s" + contentFltr = fmt.Sprintf(contentFltr, timeVar) + anzStringQuery(t, client, 1, "", contentFltr) + + anzStringQuery(t, client, 7, "", "*lte:~*hdr.RequestID:2") + anzStringQuery(t, client, -1, "", "*gt:~*hdr.RequestDuration:1ms") + anzStringQuery(t, client, 1, `+RequestMethod:"AttributeSv1.ProcessEvent"`, "*notstring:~*rep.Event.Cost:0") + anzStringQuery(t, client, 1, `+RequestMethod:"CoreSv1.Status"`, "*gt:~*rep.goroutines:55") } -func testAnzDocSetAttributeProfiles(t *testing.T) { +// anzStringQuery sends an AnalyzerSv1.StringQuery request. First filter represents +// the HeaderFilters parameter, while the rest are the ContentFilters. Checks if the +// result contains the expected amount of matches (wantRC). +func anzStringQuery(t *testing.T, client *birpc.Client, wantRC int, filters ...string) { + t.Helper() + var headerFilters string + var contentFilters []string + if len(filters) > 0 { + headerFilters = filters[0] + contentFilters = filters[1:] + } + var result []map[string]any + if err := client.Call(context.Background(), utils.AnalyzerSv1StringQuery, + &analyzers.QueryArgs{ + HeaderFilters: headerFilters, + ContentFilters: contentFilters, + }, &result); err != nil { + t.Error(err) + } else if len(result) != wantRC && wantRC != -1 { + t.Errorf("AnalyzerSv1.StringQuery: len(result)=%d, want %d\n%s", len(result), wantRC, utils.ToJSON(result)) + } else if wantRC == -1 && len(result) < 1 { + t.Errorf("AnalyzerSv1.StringQuery: len(result)=%d, want >0\n%s", len(result), utils.ToJSON(result)) + } + +} + +func setAttrProfiles(t *testing.T, client *birpc.Client) { attributeProfiles := []*engine.APIAttributeProfileWithAPIOpts{ { APIAttributeProfile: &engine.APIAttributeProfile{ @@ -238,19 +254,16 @@ func testAnzDocSetAttributeProfiles(t *testing.T) { }, }, } - var reply string for _, attributeProfile := range attributeProfiles { - if err := anzDocRPC.Call(context.Background(), utils.AdminSv1SetAttributeProfile, + if err := client.Call(context.Background(), utils.AdminSv1SetAttributeProfile, attributeProfile, &reply); err != nil { t.Error(err) - } else if reply != utils.OK { - t.Error(err) } } } -func testAnzDocCheckAttributeProfiles(t *testing.T) { +func getAttrProfiles(t *testing.T, client *birpc.Client) { expectedAttributeProfiles := []*engine.APIAttributeProfile{ { ID: "ATTR_1001", @@ -344,7 +357,7 @@ func testAnzDocCheckAttributeProfiles(t *testing.T) { }, } var replyAttributeProfiles []*engine.APIAttributeProfile - if err := anzDocRPC.Call(context.Background(), utils.AdminSv1GetAttributeProfiles, + if err := client.Call(context.Background(), utils.AdminSv1GetAttributeProfiles, &utils.ArgsItemIDs{ Tenant: "cgrates.org", }, &replyAttributeProfiles); err != nil { @@ -360,7 +373,7 @@ func testAnzDocCheckAttributeProfiles(t *testing.T) { } } -func testAnzDocAttributeSProcessEvent(t *testing.T) { +func attrProcessEvents(t *testing.T, client *birpc.Client) { eventCall1001to1002 := &utils.CGREvent{ Tenant: "cgrates.org", ID: "call1001to1002", @@ -421,7 +434,7 @@ func testAnzDocAttributeSProcessEvent(t *testing.T) { } expectedReply := `{"AlteredFields":[{"MatchedProfileID":"cgrates.org:ATTR_1001","Fields":["*req.RequestType"]}],"Tenant":"cgrates.org","ID":"call1001to1002","Event":{"Account":"1001","AnswerTime":"2013-11-07T08:42:28Z","Category":"call","Cost":1.01,"Destination":"1002","OriginHost":"192.168.1.1","OriginID":"abcdef","RequestType":"*rated","RunID":"*default","SetupTime":"2013-11-07T08:42:25Z","Subject":"1001","Tenant":"cgrates.org","ToR":"*voice","Usage":10000000000},"APIOpts":{}}` var rplyEv engine.AttrSProcessEventReply - if err := anzDocRPC.Call(context.Background(), utils.AttributeSv1ProcessEvent, + if err := client.Call(context.Background(), utils.AttributeSv1ProcessEvent, eventCall1001to1002, &rplyEv); err != nil { t.Error(err) } else if jsonReply := utils.ToJSON(rplyEv); jsonReply != expectedReply { @@ -429,7 +442,7 @@ func testAnzDocAttributeSProcessEvent(t *testing.T) { expectedReply, jsonReply) } expectedReply = `{"AlteredFields":[{"MatchedProfileID":"cgrates.org:ATTR_PRF_11","Fields":["*req.Cost"]},{"MatchedProfileID":"cgrates.org:ATTR_1101","Fields":["*req.RequestType"]}],"Tenant":"cgrates.org","ID":"call1011to1002","Event":{"Account":"1101","AnswerTime":"2013-11-07T08:42:35Z","Category":"call","Cost":"0","Destination":"1002","OriginHost":"192.168.1.1","OriginID":"ghijkl","RequestType":"*prepaid","RunID":"*default","SetupTime":"2013-11-07T08:42:28Z","Subject":"1101","Tenant":"cgrates.org","ToR":"*voice","Usage":15000000000},"APIOpts":{}}` - if err := anzDocRPC.Call(context.Background(), utils.AttributeSv1ProcessEvent, + if err := client.Call(context.Background(), utils.AttributeSv1ProcessEvent, eventCall1101to1002, &rplyEv); err != nil { t.Error(err) } else if jsonReply := utils.ToJSON(rplyEv); jsonReply != expectedReply { @@ -437,229 +450,11 @@ func testAnzDocAttributeSProcessEvent(t *testing.T) { expectedReply, jsonReply) } expectedReply = `{"AlteredFields":[{"MatchedProfileID":"cgrates.org:ATTR_PRF_11","Fields":["*req.Cost"]},{"MatchedProfileID":"cgrates.org:ATTR_1102","Fields":["*req.RequestType"]}],"Tenant":"cgrates.org","ID":"call1102to1001","Event":{"Account":"1102","AnswerTime":"2013-11-07T08:42:42Z","Category":"call","Cost":"0","Destination":"1001","OriginHost":"192.168.1.1","OriginID":"uvwxyz","RequestType":"*pseudoprepaid","RunID":"*default","SetupTime":"2013-11-07T08:42:35Z","Subject":"1102","Tenant":"cgrates.org","ToR":"*voice","Usage":20000000000},"APIOpts":{}}` - if err := anzDocRPC.Call(context.Background(), utils.AttributeSv1ProcessEvent, + if err := client.Call(context.Background(), utils.AttributeSv1ProcessEvent, eventCall1102to1001, &rplyEv); err != nil { t.Error(err) } else if jsonReply := utils.ToJSON(rplyEv); jsonReply != expectedReply { t.Errorf("expected: <%+v>, \nreceived: <%+v>", expectedReply, jsonReply) } - -} - -func testAnzDocQueryWithHeaderFilters(t *testing.T) { - time.Sleep(500 * time.Millisecond) - var result []map[string]any - - // Query results for the AdminSv1.SetAttributeProfile request method using HeaderFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestMethod:"AdminSv1.SetAttributeProfile"`, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 5 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for the AdminSv1.GetAttributeProfiles request method using HeaderFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestMethod:"AdminSv1.GetAttributeProfiles"`, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 1 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for the AttributeSv1.ProcessEvent request method using HeaderFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestMethod:"AttributeSv1.ProcessEvent"`, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 3 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for the CoreSv1.Status request method using HeaderFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestMethod:"CoreSv1.Status"`, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 2 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for the CacheSv1.ReloadCache request method using HeaderFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestMethod:"CacheSv1.ReloadCache"`, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 5 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for all the request methods except CacheSv1.ReloadCache using HeaderFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `-RequestMethod:"CacheSv1.ReloadCache"`, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 11 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query all results for the requests made to the AdminS service using regular expressions - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestMethod:"/AdminSv1.*/"`, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 6 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results that happen before a given time - headerFltr := `+RequestStartTime:<"%s"` - headerFltr = fmt.Sprintf(headerFltr, timeVar) - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: headerFltr, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 1 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for API calls with RequestID smaller or equal to 2 - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestID:<=2 -RequestMethod:"CacheSv1.ReloadCache"`, - ContentFilters: []string{}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 2 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } -} - -func testAnzDocQueryWithContentFiltersFilters(t *testing.T) { - var result []map[string]any - // Query results for the AdminSv1.SetAttributeProfile request method using ContentFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{"*string:~*hdr.RequestMethod:AdminSv1.SetAttributeProfile"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 5 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for the AdminSv1.GetAttributeProfile request method using ContentFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{"*string:~*hdr.RequestMethod:AdminSv1.GetAttributeProfiles"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 1 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for the AttributeSv1.ProcessEvent request method using ContentFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{"*string:~*hdr.RequestMethod:AttributeSv1.ProcessEvent"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 3 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for the CoreSv1.Status request method using ContentFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{"*string:~*hdr.RequestMethod:CoreSv1.Status"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 2 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for the CacheSv1.ReloadCache request method using ContentFilters - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{"*string:~*hdr.RequestMethod:CacheSv1.ReloadCache"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 5 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query all results for the requests made to the AdminS service using prefix filter - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{"*prefix:~*hdr.RequestMethod:AdminSv1."}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 6 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results that happen before a given time - contentFltr := "*lt:~*hdr.RequestStartTime:%s" - contentFltr = fmt.Sprintf(contentFltr, timeVar) - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{contentFltr}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 1 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for API calls with RequestID smaller or equal to 2 - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{"*lte:~*hdr.RequestID:2"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 7 { - fmt.Println(len(result)) - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Query results for API calls with with an execution duration longer than 30ms - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: "", - ContentFilters: []string{"*gt:~*hdr.RequestDuration:10ms"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) == 0 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } -} - -func testAnzDocQuery(t *testing.T) { - var result []map[string]any - - // Get results for AttributeSv1.ProcessEvent request replies whose events have a non-null cost - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestMethod:"AttributeSv1.ProcessEvent"`, - ContentFilters: []string{"*notstring:~*rep.Event.Cost:0"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 1 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } - - // Get results for CoreSv1.Status request replies that state a higher number of goroutines than 46 - if err := anzDocRPC.Call(context.Background(), utils.AnalyzerSv1StringQuery, &analyzers.QueryArgs{ - HeaderFilters: `+RequestMethod:"CoreSv1.Status"`, - ContentFilters: []string{"*gt:~*rep.goroutines:46"}, - }, &result); err != nil { - t.Error(err) - } else if len(result) != 1 { - t.Errorf("Unexpected result: %s", utils.ToJSON(result)) - } }