nitter/src/api/timeline.nim

70 lines
2.1 KiB
Nim
Raw Normal View History

2019-09-20 23:08:30 +00:00
import httpclient, asyncdispatch, htmlparser, strformat
2019-09-06 01:37:12 +00:00
import sequtils, strutils, json, xmltree, uri
2019-09-13 20:24:58 +00:00
import ".."/[types, parser, parserutils, formatters, query]
2019-09-20 13:03:18 +00:00
import utils, consts, media, search
2019-09-06 01:37:12 +00:00
2019-09-19 00:23:22 +00:00
proc finishTimeline*(json: JsonNode; query: Query; after, agent: string): Future[Timeline] {.async.} =
2019-09-20 13:03:18 +00:00
result = getResult[Tweet](json, query, after)
if json == nil: return
2019-09-06 01:37:12 +00:00
if json["new_latent_count"].to(int) == 0: return
if not json.hasKey("items_html"): return
let
html = parseHtml(json["items_html"].to(string))
thread = parseThread(html)
vidsFut = getVideos(thread, agent)
pollFut = getPolls(thread, agent)
cardFut = getCards(thread, agent)
await all(vidsFut, pollFut, cardFut)
result.content = thread.content
proc getTimeline*(username, after, agent: string): Future[Timeline] {.async.} =
let headers = newHttpHeaders({
"Accept": jsonAccept,
"Referer": $(base / username),
"User-Agent": agent,
"X-Twitter-Active-User": "yes",
"X-Requested-With": "XMLHttpRequest",
"Accept-Language": lang
})
var params = toSeq({
"include_available_features": "1",
"include_entities": "1",
"include_new_items_bar": "false",
"reset_error_state": "false"
})
if after.len > 0:
params.add {"max_position": after}
let json = await fetchJson(base / (timelineUrl % username) ? params, headers)
2019-09-19 00:23:22 +00:00
result = await finishTimeline(json, Query(), after, agent)
2019-09-06 01:37:12 +00:00
proc getProfileAndTimeline*(username, agent, after: string): Future[(Profile, Timeline)] {.async.} =
let headers = newHttpHeaders({
"authority": "twitter.com",
"accept": htmlAccept,
"referer": "https://twitter.com/" & username,
"accept-language": lang
})
var url = base / username
if after.len > 0:
url = url ? {"max_position": after}
let
html = await fetchHtml(url, headers)
timeline = parseTimeline(html.select("#timeline > .stream-container"), after)
profile = parseTimelineProfile(html)
vidsFut = getVideos(timeline, agent)
pollFut = getPolls(timeline, agent)
cardFut = getCards(timeline, agent)
await all(vidsFut, pollFut, cardFut)
result = (profile, timeline)