nitter/src/api.nim

133 lines
4.7 KiB
Nim
Raw Normal View History

2021-12-27 01:37:38 +00:00
# SPDX-License-Identifier: AGPL-3.0-only
import asyncdispatch, httpclient, uri, strutils, sequtils, sugar
import packedjson
2020-06-01 00:16:24 +00:00
import types, query, formatters, consts, apiutils, parser
2022-01-26 20:05:23 +00:00
import experimental/parser as newParser
2020-06-01 00:16:24 +00:00
proc getGraphUser*(id: string): Future[User] {.async.} =
if id.len == 0 or id.any(c => not c.isDigit): return
let
variables = %*{"userId": id, "withSuperFollowsUserFields": true}
2022-01-26 16:24:03 +00:00
js = await fetchRaw(graphUser ? {"variables": $variables}, Api.userRestId)
result = parseGraphUser(js)
2021-10-02 08:13:56 +00:00
proc getGraphListBySlug*(name, list: string): Future[List] {.async.} =
2020-06-01 00:16:24 +00:00
let
variables = %*{"screenName": name, "listSlug": list, "withHighlightedLabel": false}
2022-01-05 21:48:45 +00:00
url = graphListBySlug ? {"variables": $variables}
result = parseGraphList(await fetch(url, Api.listBySlug))
2020-06-01 00:16:24 +00:00
2021-10-02 08:13:56 +00:00
proc getGraphList*(id: string): Future[List] {.async.} =
2020-06-01 00:16:24 +00:00
let
variables = %*{"listId": id, "withHighlightedLabel": false}
2022-01-05 21:48:45 +00:00
url = graphList ? {"variables": $variables}
result = parseGraphList(await fetch(url, Api.list))
2020-06-01 00:16:24 +00:00
proc getGraphListMembers*(list: List; after=""): Future[Result[User]] {.async.} =
if list.id.len == 0: return
2022-03-10 13:24:57 +00:00
var
variables = %*{
"listId": list.id,
"withSuperFollowsUserFields": false,
"withBirdwatchPivots": false,
"withDownvotePerspective": false,
"withReactionsMetadata": false,
"withReactionsPerspective": false,
"withSuperFollowsTweetFields": false
}
2022-03-10 13:24:57 +00:00
if after.len > 0:
variables["cursor"] = % after
let url = graphListMembers ? {"variables": $variables}
result = parseGraphListMembers(await fetchRaw(url, Api.listMembers), after)
2020-06-01 00:16:24 +00:00
proc getListTimeline*(id: string; after=""): Future[Timeline] {.async.} =
2021-12-29 07:03:00 +00:00
if id.len == 0: return
2020-06-01 00:16:24 +00:00
let
ps = genParams({"list_id": id, "ranking_mode": "reverse_chronological"}, after)
url = listTimeline ? ps
2022-01-05 21:48:45 +00:00
result = parseTimeline(await fetch(url, Api.timeline), after)
2020-06-01 00:16:24 +00:00
proc getUser*(username: string): Future[User] {.async.} =
if username.len == 0: return
let
ps = genParams({"screen_name": username})
2022-01-16 05:00:11 +00:00
json = await fetchRaw(userShow ? ps, Api.userShow)
result = parseUser(json, username)
proc getUserById*(userId: string): Future[User] {.async.} =
if userId.len == 0: return
let
ps = genParams({"user_id": userId})
2022-01-16 05:00:11 +00:00
json = await fetchRaw(userShow ? ps, Api.userShow)
result = parseUser(json)
2020-06-01 00:16:24 +00:00
proc getTimeline*(id: string; after=""; replies=false): Future[Timeline] {.async.} =
if id.len == 0: return
2020-06-01 00:16:24 +00:00
let
ps = genParams({"userId": id, "include_tweet_replies": $replies}, after)
url = timeline / (id & ".json") ? ps
2022-01-05 21:48:45 +00:00
result = parseTimeline(await fetch(url, Api.timeline), after)
2020-06-01 00:16:24 +00:00
proc getMediaTimeline*(id: string; after=""): Future[Timeline] {.async.} =
if id.len == 0: return
2020-06-01 00:16:24 +00:00
let url = mediaTimeline / (id & ".json") ? genParams(cursor=after)
2022-01-05 21:48:45 +00:00
result = parseTimeline(await fetch(url, Api.timeline), after)
2020-06-01 00:16:24 +00:00
2020-06-16 22:20:34 +00:00
proc getPhotoRail*(name: string): Future[PhotoRail] {.async.} =
if name.len == 0: return
2020-06-16 22:20:34 +00:00
let
ps = genParams({"screen_name": name, "trim_user": "true"},
count="18", ext=false)
url = photoRail ? ps
result = parsePhotoRail(await fetch(url, Api.timeline))
2020-06-01 00:16:24 +00:00
proc getSearch*[T](query: Query; after=""): Future[Result[T]] {.async.} =
when T is User:
2020-06-01 00:16:24 +00:00
const
searchMode = ("result_filter", "user")
parse = parseUsers
2022-01-26 19:27:11 +00:00
fetchFunc = fetchRaw
2020-06-01 00:16:24 +00:00
else:
const
searchMode = ("tweet_search_mode", "live")
parse = parseTimeline
2022-01-26 19:27:11 +00:00
fetchFunc = fetch
2020-06-01 00:16:24 +00:00
let q = genQueryParam(query)
if q.len == 0 or q == emptyQuery:
return Result[T](beginning: true, query: query)
let url = search ? genParams(searchParams & @[("q", q), searchMode], after)
try:
2022-01-26 19:27:11 +00:00
result = parse(await fetchFunc(url, Api.search), after)
result.query = query
except InternalError:
return Result[T](beginning: true, query: query)
2020-06-01 00:16:24 +00:00
proc getTweetImpl(id: string; after=""): Future[Conversation] {.async.} =
let url = tweet / (id & ".json") ? genParams(cursor=after)
2022-01-05 21:48:45 +00:00
result = parseConversation(await fetch(url, Api.tweet), id)
2020-06-01 00:16:24 +00:00
proc getReplies*(id, after: string): Future[Result[Chain]] {.async.} =
result = (await getTweetImpl(id, after)).replies
result.beginning = after.len == 0
proc getTweet*(id: string; after=""): Future[Conversation] {.async.} =
result = await getTweetImpl(id)
if after.len > 0:
result.replies = await getReplies(id, after)
2022-01-23 06:45:01 +00:00
proc getStatus*(id: string): Future[Tweet] {.async.} =
let url = status / (id & ".json") ? genParams()
result = parseStatus(await fetch(url, Api.status))
2020-06-01 00:16:24 +00:00
proc resolve*(url: string; prefs: Prefs): Future[string] {.async.} =
let client = newAsyncHttpClient(maxRedirects=0)
try:
2021-12-20 02:11:12 +00:00
let resp = await client.request(url, HttpHead)
2021-12-27 01:27:49 +00:00
result = resp.headers["location"].replaceUrls(prefs)
2020-06-01 00:16:24 +00:00
except:
discard
finally:
client.close()