from ws4py.client.threadedclient import WebSocketClient
import time
from threading import Thread
import json

users = [173527498, 517642755]



class DummyClient(WebSocketClient):

    def opened(self):
        print('Подключен')

    def closed(self, code, reason=None):
        print("Closed down", code, reason)

    def received_message(self, m):
        if len(m) < 1000:
            print(m)
        self.mess_handler(m)

    def mess_handler(self, data):
        try:
            data = json.loads(str(data))
        except:
            print(data)
            #data = json.loads(data.split()[-1])
            pass
        if data['score'] > 1000 * 10e3:
            for user in users:
                self.send_coin(user, data['score'])
            self.sum += data['score']
            print('Отправленно в сумме: ', self.sum/10e2)

    def send_coin(self, user, value):
        print(f'P{self.count} T {user} {value/10}')
        self.send(f'P{self.count} T {user} {value}')
        self.count += 1
        if value > 100000000*10e3:
            self.closed()



ws = [DummyClient('wss://coin-without-bugs.vkforms.ru/channel/10/?vk_access_token_settings=friends&vk_app_id=6915965&vk_are_notifications_enabled=0&vk_is_app_user=1&vk_language=ru&vk_platform=mobile_android&vk_user_id=173527498&sign=Ug7RPPKs6R_D1-2kn5Jy0IShquXaURUDMsIZ2vEthRI&ver=1&upd=1&pass=173527497'),
DummyClient('wss://coin-without-bugs.vkforms.ru/channel/3/?vk_access_token_settings=&vk_app_id=6915965&vk_are_notifications_enabled=0&vk_is_app_user=0&vk_language=ru&vk_platform=desktop_web&vk_user_id=517642755&sign=9TOXvNuJq90DXRRiNCrfWznAGr11bkwvfHMDWCSWiF4&ver=1&upd=1&pass=517642754')]

def sender(sock):
    sock.count = 0
    sock.sum = 0
    sock.connect()
    sock.run_forever()

for sock in ws[:1]:
    print(sock)
    Thread(target=sender, args=[sock]).start()