Anydoc / anydoc parser engine (push) Canceled after 0s
App / Format, vet, test, and build (push) Canceled after 0s
CLI / test (macos-latest / go 1.26) (push) Canceled after 0s
CLI / test (ubuntu-latest / go 1.26) (push) Canceled after 0s
CLI / test (windows-latest / go 1.26) (push) Canceled after 0s
Build and Push Docker Image / build-ui (push) Canceled after 0s
Build and Push Docker Image / build-docreader (push) Canceled after 0s
Build and Push Docker Image / build-sandbox (push) Canceled after 0s
Build and Push Docker Image / build-app (amd64, linux/amd64, ubuntu-latest) (push) Canceled after 0s
Build and Push Docker Image / build-app (arm64, linux/arm64, ubuntu-24.04-arm) (push) Canceled after 0s
DocReader / Python tests and Go client tests (push) Canceled after 0s
Build & Publish (dsh-weknora) / Typecheck, test, pack (push) Canceled after 0s
Build & Publish (dsh-weknora) / End-to-end inside dsh (pinned) (push) Canceled after 0s
Build & Publish (dsh-weknora) / End-to-end inside dsh (latest, advisory) (push) Canceled after 0s
Frontend / Test, type-check, and build (push) Canceled after 0s
Go Lint Cache / warm lint cache (.) (push) Canceled after 0s
Go Lint Cache / warm lint cache (cli) (push) Canceled after 0s
Go Lint Cache / warm lint cache (client) (push) Canceled after 0s
Build & Publish (mcp-server) / Test (Python 3.10) (push) Canceled after 0s
Build & Publish (mcp-server) / Test (Python 3.11) (push) Canceled after 0s
Build & Publish (mcp-server) / Test (Python 3.12) (push) Canceled after 0s
Build & Publish (mcp-server) / Test (Python 3.13) (push) Canceled after 0s
Build and Push Docker Image / merge (push) Canceled after 0s
Build & Publish (dsh-weknora) / Publish to npm (push) Canceled after 0s
Build & Publish (mcp-server) / Build sdist + wheel (push) Canceled after 0s
Build & Publish (mcp-server) / Publish to PyPI (push) Canceled after 0s
42 lines
899 B
Go
42 lines
899 B
Go
package ratelimit
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestLocalLimiterAllowsWithinBudget(t *testing.T) {
|
|
l := New(nil, "test:", time.Minute, "inst")
|
|
ctx := context.Background()
|
|
const max = 3
|
|
for i := 0; i < max; i++ {
|
|
if !l.Allow(ctx, "k1", max) {
|
|
t.Fatalf("request %d should be allowed", i+1)
|
|
}
|
|
}
|
|
if l.Allow(ctx, "k1", max) {
|
|
t.Fatal("request over budget should be denied")
|
|
}
|
|
}
|
|
|
|
func TestLocalLimiterIndependentKeys(t *testing.T) {
|
|
l := New(nil, "test:", time.Minute, "inst")
|
|
ctx := context.Background()
|
|
if !l.Allow(ctx, "a", 1) {
|
|
t.Fatal("first key should be allowed")
|
|
}
|
|
if !l.Allow(ctx, "b", 1) {
|
|
t.Fatal("second key should be allowed")
|
|
}
|
|
}
|
|
|
|
func TestAllowSkipsWhenMaxZero(t *testing.T) {
|
|
l := New(nil, "test:", time.Minute, "inst")
|
|
for i := 0; i < 100; i++ {
|
|
if !l.Allow(context.Background(), "k", 0) {
|
|
t.Fatal("max<=0 should always allow")
|
|
}
|
|
}
|
|
}
|