mirror of
https://github.com/diamondburned/arikawa.git
synced 2024-12-01 03:03:48 +00:00
77 lines
2.1 KiB
Go
77 lines
2.1 KiB
Go
package rate
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"strconv"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
// https://github.com/bwmarrin/discordgo/blob/master/ratelimit_test.go
|
|
|
|
func mockRequest(t *testing.T, l *Limiter, path string, headers http.Header) {
|
|
if err := l.Acquire(context.Background(), path); err != nil {
|
|
t.Fatal("Failed to acquire lock:", err)
|
|
}
|
|
|
|
if err := l.Release(path, headers); err != nil {
|
|
t.Fatal("Failed to release lock:", err)
|
|
}
|
|
}
|
|
|
|
// This test takes ~2 seconds to run
|
|
func TestRatelimitReset(t *testing.T) {
|
|
l := NewLimiter()
|
|
|
|
headers := http.Header{}
|
|
headers.Set("X-RateLimit-Remaining", "0")
|
|
headers.Set("X-RateLimit-Reset",
|
|
strconv.FormatInt(time.Now().Add(time.Second*2).Unix(), 10))
|
|
headers.Set("Date", time.Now().Format(time.RFC850))
|
|
|
|
sent := time.Now()
|
|
mockRequest(t, l, "/guilds/99/channels", headers)
|
|
mockRequest(t, l, "/guilds/55/channels", headers)
|
|
mockRequest(t, l, "/guilds/66/channels", headers)
|
|
|
|
// call it again
|
|
mockRequest(t, l, "/guilds/99/channels", headers)
|
|
mockRequest(t, l, "/guilds/55/channels", headers)
|
|
mockRequest(t, l, "/guilds/66/channels", headers)
|
|
|
|
// We hit the same endpoint 2 times, so we should only be ratelimited 2
|
|
// second and always less than 4 seconds (unless you're on a stoneage
|
|
// computer or using swap or something...)
|
|
if time.Since(sent) >= time.Second && time.Since(sent) < time.Second*4 {
|
|
t.Log("OK", time.Since(sent))
|
|
} else {
|
|
t.Error("Did not ratelimit correctly, got:", time.Since(sent))
|
|
}
|
|
}
|
|
|
|
// This test takes ~1 seconds to run
|
|
func TestRatelimitGlobal(t *testing.T) {
|
|
l := NewLimiter()
|
|
|
|
headers := http.Header{}
|
|
headers.Set("X-RateLimit-Global", "1.002")
|
|
// Reset for approx 1 seconds from now
|
|
headers.Set("Retry-After", "1000")
|
|
|
|
sent := time.Now()
|
|
|
|
// This should trigger a global ratelimit
|
|
mockRequest(t, l, "/guilds/99/channels", headers)
|
|
time.Sleep(time.Millisecond * 100)
|
|
|
|
// This shouldn't go through in less than 1 second
|
|
mockRequest(t, l, "/guilds/55/channels", headers)
|
|
|
|
if time.Since(sent) >= time.Second && time.Since(sent) < time.Second*2 {
|
|
t.Log("OK", time.Since(sent))
|
|
} else {
|
|
t.Error("Did not ratelimit correctly, got:", time.Since(sent))
|
|
}
|
|
}
|