132 lines
3.6 KiB
Nim
132 lines
3.6 KiB
Nim
# SPDX-License-Identifier: AGPL-3.0-only
|
|
import asyncdispatch, times, json, random, strutils, tables
|
|
import types
|
|
|
|
# max requests at a time per account to avoid race conditions
|
|
const
|
|
maxConcurrentReqs = 5
|
|
dayInSeconds = 24 * 60 * 60
|
|
|
|
var
|
|
accountPool: seq[GuestAccount]
|
|
enableLogging = false
|
|
|
|
template log(str) =
|
|
if enableLogging: echo "[accounts] ", str
|
|
|
|
proc getPoolJson*(): JsonNode =
|
|
var
|
|
list = newJObject()
|
|
totalReqs = 0
|
|
totalPending = 0
|
|
reqsPerApi: Table[string, int]
|
|
|
|
let now = epochTime().int
|
|
|
|
for account in accountPool:
|
|
totalPending.inc(account.pending)
|
|
list[account.id] = %*{
|
|
"apis": newJObject(),
|
|
"pending": account.pending,
|
|
}
|
|
|
|
for api in account.apis.keys:
|
|
let obj = %*{}
|
|
if account.apis[api].limited:
|
|
obj["limited"] = %true
|
|
|
|
if account.apis[api].reset > now.int:
|
|
obj["remaining"] = %account.apis[api].remaining
|
|
|
|
list[account.id]["apis"][$api] = obj
|
|
|
|
if "remaining" notin obj:
|
|
continue
|
|
|
|
let
|
|
maxReqs =
|
|
case api
|
|
of Api.search: 50
|
|
of Api.photoRail: 180
|
|
of Api.userTweets, Api.userTweetsAndReplies, Api.userMedia,
|
|
Api.userRestId, Api.userScreenName,
|
|
Api.tweetDetail, Api.tweetResult,
|
|
Api.list, Api.listTweets, Api.listMembers, Api.listBySlug: 500
|
|
reqs = maxReqs - account.apis[api].remaining
|
|
|
|
reqsPerApi[$api] = reqsPerApi.getOrDefault($api, 0) + reqs
|
|
totalReqs.inc(reqs)
|
|
|
|
return %*{
|
|
"amount": accountPool.len,
|
|
"requests": totalReqs,
|
|
"pending": totalPending,
|
|
"apis": reqsPerApi,
|
|
"accounts": list
|
|
}
|
|
|
|
proc rateLimitError*(): ref RateLimitError =
|
|
newException(RateLimitError, "rate limited")
|
|
|
|
proc isLimited(account: GuestAccount; api: Api): bool =
|
|
if account.isNil:
|
|
return true
|
|
|
|
if api in account.apis:
|
|
let limit = account.apis[api]
|
|
|
|
if limit.limited and (epochTime().int - limit.limitedAt) > dayInSeconds:
|
|
account.apis[api].limited = false
|
|
log "resetting limit, api: " & $api & ", id: " & $account.id
|
|
|
|
return limit.limited or (limit.remaining <= 10 and limit.reset > epochTime().int)
|
|
else:
|
|
return false
|
|
|
|
proc isReady(account: GuestAccount; api: Api): bool =
|
|
not (account.isNil or account.pending > maxConcurrentReqs or account.isLimited(api))
|
|
|
|
proc release*(account: GuestAccount; used=false; invalid=false) =
|
|
if account.isNil: return
|
|
if invalid:
|
|
log "discarding invalid account: " & account.id
|
|
|
|
let idx = accountPool.find(account)
|
|
if idx > -1: accountPool.delete(idx)
|
|
elif used:
|
|
dec account.pending
|
|
|
|
proc getGuestAccount*(api: Api): Future[GuestAccount] {.async.} =
|
|
for i in 0 ..< accountPool.len:
|
|
if result.isReady(api): break
|
|
release(result)
|
|
result = accountPool.sample()
|
|
|
|
if not result.isNil and result.isReady(api):
|
|
inc result.pending
|
|
else:
|
|
log "no accounts available for API: " & $api
|
|
raise rateLimitError()
|
|
|
|
proc setRateLimit*(account: GuestAccount; api: Api; remaining, reset: int) =
|
|
# avoid undefined behavior in race conditions
|
|
if api in account.apis:
|
|
let limit = account.apis[api]
|
|
if limit.reset >= reset and limit.remaining < remaining:
|
|
return
|
|
if limit.reset == reset and limit.remaining >= remaining:
|
|
account.apis[api].remaining = remaining
|
|
return
|
|
|
|
account.apis[api] = RateLimit(remaining: remaining, reset: reset)
|
|
|
|
proc initAccountPool*(cfg: Config; accounts: JsonNode) =
|
|
enableLogging = cfg.enableDebug
|
|
|
|
for account in accounts:
|
|
accountPool.add GuestAccount(
|
|
id: account{"user", "id_str"}.getStr,
|
|
oauthToken: account{"oauth_token"}.getStr,
|
|
oauthSecret: account{"oauth_token_secret"}.getStr,
|
|
)
|