module Turnir::Client

Extended Modules

Defined in:

turnir/client/client.cr
turnir/client/vk_client.cr

Constant Summary

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)}
STREAMS_STATUS_MAP = Hash(String, Stream).new
STREAMS_STATUS_MAP_MUTEX = Mutex.new

Instance Method Summary

Instance Method Detail

def clear_messages(client_type : ClientType) #

[View source]
def clear_streams_for_client(client_type : ClientType) #

[View source]
def client_auto_stopper #

[View source]
def disconnect_streams_for_client(client_type : ClientType) #

[View source]
def ensure_client_running(client_type : ClientType) #

[View source]
def get_connections_statuses #

[View source]
def get_messages(client_type : ClientType, channel : String, since : Int64, text_filter : String) #

[View source]
def get_stream_status(stream_name : String) : ConnectionStatus #

[View source]
def log(msg) #

[View source]
def on_subscribe(client : ClientType, channel : String) #

[View source]
def stream_activity_checker #

[View source]
def subscribe_to_channel(client_type : ClientType, channel_name : String) #

[View source]
def subscribe_to_channel_if_not_subscribed(client_type : ClientType, channel_name : String) : ConnectionStatus #

[View source]