nyoungo
18b2c04006
- Go service bridging deepseek.de/es/fr V4 models behind an OpenAI-compatible API - /v1/chat/completions, /v1/responses, /v1/messages (Anthropic) with tool calling - web admin console: dashboard, models/sites, keys, proxies, Turnstile, playground, live logs - Turnstile solvers: solver API / local browser via CDP / manual cookie import - MIT license, README with screenshots, Dockerfile and Makefile
40 lines
717 B
Go
40 lines
717 B
Go
package api
|
|
|
|
import (
|
|
"sync"
|
|
"time"
|
|
)
|
|
|
|
// limiter is a simple fixed one-minute window counter per API key.
|
|
type limiter struct {
|
|
mu sync.Mutex
|
|
window time.Time
|
|
counts map[string]int
|
|
}
|
|
|
|
func newLimiter() *limiter {
|
|
return &limiter{counts: map[string]int{}, window: time.Now().Truncate(time.Minute)}
|
|
}
|
|
|
|
func (l *limiter) allow(key string) bool {
|
|
return l.allowWithLimit(key, 0)
|
|
}
|
|
|
|
func (l *limiter) allowWithLimit(key string, limit int) bool {
|
|
if limit <= 0 {
|
|
return true
|
|
}
|
|
l.mu.Lock()
|
|
defer l.mu.Unlock()
|
|
now := time.Now().Truncate(time.Minute)
|
|
if now.After(l.window) {
|
|
l.window = now
|
|
l.counts = map[string]int{}
|
|
}
|
|
if l.counts[key] >= limit {
|
|
return false
|
|
}
|
|
l.counts[key]++
|
|
return true
|
|
}
|