bfbddlmZddlmZddlmZmZddlmZddl m Z Gdde Z dS) )_DICT_VERSION_STATUS)MastodonIllegalArgumentError)_DEFAULT_STREAM_TIMEOUT"_DEFAULT_STREAM_RECONNECT_WAIT_SEC) api_version)MastodonceZdZeddededefdZeddedededdfdZeddededefdZ eddeddedefdZ eddededefd Z ed d ededefd Z ed d d d Z dS)rz1.1.0z1.4.2Fc8|d|||||S)zx Streams events that are relevant to the authorized user, i.e. home timeline and notifications. z/api/v1/streaming/user run_asynctimeoutreconnect_asyncreconnect_async_wait_sec_Mastodon__streamselflistenerr r rrs j/home/feoh/.local/pipx/venvs/mastodon-archive/lib/python3.11/site-packages/mastodon/streaming_endpoints.py stream_userzMastodon.stream_users7 }}5x9^exGbz}{{ {czd}|r|dz }|r|rtd|dz }|||||||S)z Streams public events. Set `local` to True to only get local statuses. Set `remote` to True to only get remote statuses. z/api/v1/streaming/public/localz@Cannot pass both local and remote - use either one or the other.z/remoter )rr) rrr r rrlocalremotebases r stream_publiczMastodon.stream_publicsr*   H D   w23uvvv I D}}T8y'crNf}gg grc8||||||dS)z Streams local public events. This function is deprecated. Please use :ref:`stream_public() ` with parameter `local` set to True instead. T)r r rrr)rrs r stream_localzMastodon.stream_local(s9!!(ibqMemq!rr rrc|drtdd}|r|dz }||d||||||S)z Stream for all public statuses for the hashtag 'tag' seen by the connected instance. Set `local` to True to only get local statuses. #z#Tag parameter should omit leading #z/api/v1/streaming/hashtagrz?tag=r ) startswithrr) rtagrrr r rrrs rstream_hashtagzMastodon.stream_hashtag2s >>#   V./TUU U*   H D}}00300(iY`sB]u}vv vrz2.1.0ch||}|d||||||S)zg Stream events for the current user, restricted to accounts on the given list. z/api/v1/streaming/list?list=r )_Mastodon__unpack_idr)ridrr r rrs r stream_listzMastodon.stream_listAsS   b ! !}}@B@@(V_ipCRmE}FF Frz2.6.0c8|d|||||S)z_ Streams direct message events for the logged-in user, as conversation events. z/api/v1/streaming/directr rrs r stream_directzMastodon.stream_directJs7 }}7Y`gzId|}}} }rz2.5.0ch|dd|d}|dvrdSdS)zd Returns without True if streaming API is okay, False or raises an error otherwise. GETz/api/v1/streaming/healthF)base_url_overrideparse)sOKssuccessT)_Mastodon__api_request_Mastodon__get_streaming_base)rapi_okays rstream_healthyzMastodon.stream_healthyQsO %%e-G[_[t[t[v[vD%EE * * *4urN)__name__ __module__ __qualname__rrrrrrrr$r(r*r2rrrr s['#788.3=TfkGi{{{98{['#78805?VhmIksxAFggg98g ['#788/4>UglHjrrr98r['#788275Ri|A\~ v v v98 v['#78827AXjoKmFFF98F['#78805?VhmIk}}}98} ['7++,+rrN) versionsrerrorsrdefaultsrrutilityr internalsr Internalsr6rrr=s+*****000000QQQQQQQQ ,,,,,,NNNNNyNNNNNr