Turnir::Client

CLIENTS = {ClientType::VKVIDEO => Client.new(ClientType::VKVIDEO, Turnir::Client::VkWebsocket), ClientType::TWITCH => Client.new(ClientType::TWITCH, Turnir::Client::TwitchWebsocket), ClientType::NUUM => Client.new(ClientType::NUUM, Turnir::Client::NuumPolling), ClientType::GOODGAME => Client.new(ClientType::GOODGAME, Turnir::Client::GoodgameWebsocket), ClientType::KICK => Client.new(ClientType::KICK, Turnir::Client::KickClient), ClientType::YOUTUBE => Client.new(ClientType::YOUTUBE, Turnir::Client::YoutubeClient, Turnir::Config::YOUTUBE_INACTIVE_TIMEOUT_MINS.minutes)}

STREAMS_STATUS_MAP = Hash(String, Stream).new

STREAMS_STATUS_MAP_MUTEX = Mutex.new

clear_messages(client_type : ClientType)

clear_streams_for_client(client_type : ClientType)

disconnect_streams_for_client(client_type : ClientType)

ensure_client_running(client_type : ClientType)

get_messages(client_type : ClientType, channel : String, since : Int64, text_filter : String)

get_stream_status(stream_name : String) : ConnectionStatus

log(msg)

on_subscribe(client : ClientType, channel : String)

subscribe_to_channel(client_type : ClientType, channel_name : String)

subscribe_to_channel_if_not_subscribed(client_type : ClientType, channel_name : String) : ConnectionStatus