From d12f40fb36ff09a9d7ceb3c6d314697fae48e551 Mon Sep 17 00:00:00 2001 From: BroodjeAap Date: Mon, 19 Dec 2022 21:04:36 +0000 Subject: [PATCH] added echo filter for testing purposes --- scraping.go | 14 ++++++++++++++ scraping_test.go | 20 ++++++++++++++++++++ 2 files changed, 34 insertions(+) diff --git a/scraping.go b/scraping.go index c3ca97e..5d65367 100644 --- a/scraping.go +++ b/scraping.go @@ -76,6 +76,11 @@ func processFilters(filters []Filter, web *Web, watch *Watch, debug bool, schedu getCronDebugResult(filter) continue } + if filter.Type == "echo" { + getFilterResultEcho(filter) + processedMap[filter.ID] = true + continue + } if len(filter.Parents) == 0 && !debug { continue } @@ -221,6 +226,10 @@ func getFilterResult(filters []Filter, filter *Filter, watch *Watch, web *Web, d } } } + case filter.Type == "echo": + { + getFilterResultEcho(filter) + } default: filter.log("getFilterResult called with filter.Type == '", filter.Type, "'") } @@ -895,3 +904,8 @@ func getFilterResultLua(filter *Filter) { }, ) } + +func getFilterResultEcho(filter *Filter) { + log.Println(filter.Var1) + filter.Results = append(filter.Results, filter.Var1) +} diff --git a/scraping_test.go b/scraping_test.go index 8d330e7..521cd6c 100644 --- a/scraping_test.go +++ b/scraping_test.go @@ -1235,3 +1235,23 @@ func TestFilterLuaLogs(t *testing.T) { t.Errorf("Unexpected log message: '%s'", filter.Logs[0]) } } + +func TestEchoFilter(t *testing.T) { + helloWorld := "Hello World!" + filters := []Filter{ + { + ID: 0, + Name: "Echo", + Type: "echo", + Var1: helloWorld, + }, + } + filter1 := &filters[0] + connections := []FilterConnection{} + buildFilterTree(filters, connections) + processFilters(filters, nil, nil, false, nil) + + if !reflect.DeepEqual(filter1.Results, []string{helloWorld}) { + t.Errorf("%s did not match %s", helloWorld, filter1.Results) + } +}