From 08df9258a532b653c243e077e82491dbe62ad854 Mon Sep 17 00:00:00 2001 From: Philipp Tanlak Date: Sat, 23 Sep 2023 17:41:57 +0200 Subject: refactor scraper into modules --- modules/ratelimit/ratelimit_test.go | 45 +++++++++++++++++++++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 modules/ratelimit/ratelimit_test.go (limited to 'modules/ratelimit/ratelimit_test.go') diff --git a/modules/ratelimit/ratelimit_test.go b/modules/ratelimit/ratelimit_test.go new file mode 100644 index 0000000..c166371 --- /dev/null +++ b/modules/ratelimit/ratelimit_test.go @@ -0,0 +1,45 @@ +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +package ratelimit_test + +import ( + "testing" + "time" + + "github.com/philippta/flyscrape" + "github.com/philippta/flyscrape/modules/followlinks" + "github.com/philippta/flyscrape/modules/ratelimit" + "github.com/philippta/flyscrape/modules/starturl" + "github.com/stretchr/testify/require" +) + +func TestRatelimit(t *testing.T) { + scraper := flyscrape.NewScraper() + scraper.LoadModule(&starturl.Module{URL: "http://www.example.com/"}) + scraper.LoadModule(&followlinks.Module{}) + scraper.LoadModule(&ratelimit.Module{ + Rate: 100, + }) + + scraper.SetTransport(flyscrape.MockTransport(200, `foo`)) + + var times []time.Time + scraper.OnRequest(func(req *flyscrape.Request) { + times = append(times, time.Now()) + }) + + start := time.Now() + + scraper.Run() + + first := times[0].Add(-10 * time.Millisecond) + second := times[1].Add(-20 * time.Millisecond) + + require.Less(t, first.Sub(start), 2*time.Millisecond) + require.Less(t, second.Sub(start), 2*time.Millisecond) + + require.Less(t, start.Sub(first), 2*time.Millisecond) + require.Less(t, start.Sub(second), 2*time.Millisecond) +} -- cgit v1.2.3