import praw
from tornado.simple_httpclient import HTTPTimeoutError
from tornado.httpclient import HTTPClientError
from tornado.websocket import (
    WebSocketHandler,
    websocket_connect,
    WebSocketError,
    WebSocketClosedError,
)
import asyncio
import json
import datetime
import time

print('Starting Bot')

config = {
    'thread': 'ta535s1hq2je'
}

agent = '[REDACTED]'
r = praw.Reddit(client_id='[REDACTED]',
                client_secret="[REDACTED]",password='[REDACTED]',
                user_agent=agent,username='[REDACTED]')

livecounting = r.live(config['thread'])

def get_info():
    return r.request(
        method = 'GET',
        path = 'live/{}/about.js'.format(config['thread'])
    )

lc_info = get_info()

async def handle_message(message):
    # Handling for commands, irrelevant

async def ws_handler():
    global r
    try:
        conn = await websocket_connect(lc_info['data']['websocket_url'])
    except HTTPClientError as er:
        print("Client_Error: {}\nResponse: {}".format(er.code,er.response))
        r = praw.Reddit(client_id='[REDACTED]',
                client_secret="[REDACTED]",password='[REDACTED]',
                user_agent=agent,username='[REDACTED]')
        asyncio.sleep(1)
        return
    print('Connected')
    counter = 0
    # Message handling

async def loop():
    while True:
        try:
            await ws_handler()
        except HTTPTimeoutError:
            print("Time_out_Error")
            pass
        lc_info = get_info()
        print(lc_info['data']['websocket_url'])

asyncio.new_event_loop().run_until_complete(loop())