Control multiple instances at once.

[5t0n1e]

I'm trying to control multiple instances at once but I came across some errors. My current solution for multiple instances is something like this.
My client:

class MyClient(discord.Client):
    def __init__(self):
        super().__init__(captcha_handler=captcha.CaptchaSolver())
        self.ready = False

    async def on_ready(self):
        self.ready = True
        print(f'Logged in as {self.user}')

    async def check_invites(self, invite_codes: list) -> list:
        invites = []
        for invite_code in invite_codes:
            invite = await self.fetch_invite(invite_code)
            invites.append(invite)
        return invites

To create multiple instances:

def create_client():
    i = 0
    while i < len(config['tokens']):
        custom_info['clients'].append(selfbot.MyClient())
        i += 1


def start_client():
    for token in config['tokens']:
        index = int([t for t in range(len(config['tokens'])) if config['tokens'][t] == token][0])
        threading.Thread(target=run_client, args=(custom_info['clients'][index], token)).start()


def run_client(client, token):
    client.run(token)

async def main():
    create_client()
    start_client()
    # below gives an error
    invites = await check_invites()

But then when I try to call a function of MyClient for example check_invites() I get this error:

RuntimeError: Timeout context manager should be used inside a task

If anyone has any ideas on how to control multiple instances at once diffrently or fix this method please let me know.

[TheOnlyWayUp]

Looks interesting, could you post the full traceback?

[TheOnlyWayUp]

Also

def start_client():
    for token in config['tokens']:
        index = int([t for t in range(len(config['tokens'])) if config['tokens'][t] == token][0])
        threading.Thread(target=run_client, args=(custom_info['clients'][index], token)).start()

Is an inefficient and unpythonic way to implement what you want.

def start_client():
    for token in config['tokens']:
        index = config['tokens'].index(token)
        threading.Thread(target=run_client, args=(custom_info['clients'][index], token)).start()

is a bit more pythonic, using enumerate would be the best option.

def start_client():
    for idx, token in enumerate(config['tokens']):
        threading.Thread(target=run_client, args=(custom_info['clients'][idx], token)).start()

[dolfies]

You cannot call methods across event loops like this. Every new thread spawns a new event loop. Instantiating each client in the thread will make things easier for you.

That aside, your code has many bad practices, and I recommend starting with a simpler project (not involving Discord or a complicated async library) to get yourself familiarized with Python better. You may also want to reassess whether you need a user account to accomplish what you're trying to do, as invites can be easily fetched by regular bots.

[5t0n1e]

I had almost no experience with asyncio or asynchronious programming but I came up with a solution. If ur interested I've made some initial bools for every method and made a loop in the on_ready event to trigger the methods from the main event loop with these bools. I don't know if this is really bad code but it works for almost every method. I've also stepped of the threading library because I was getting some issues with combinding threading and asyncio. I'm now using run_in_executor().
Example:

• main.py

def create_client():
    i = 0
    while i < len(config['tokens']):
        custom_info['clients'].append(selfbot.MyClient())
        i += 1

async def start_client():
    loop = asyncio.get_event_loop()
    for idx, token in enumerate(config['tokens']):
        loop.run_in_executor(None, run_client, custom_info['clients'][idx], token)

def run_client(client, token):
    client.run(token)

async def main():
    create_client()
    await start_client()
    custom_info['clients'][0].check_invites_bool = True

• the client:

class MyClient(discord.Client):
    def __init__(self):
        super().__init__(captcha_handler=captcha.CaptchaSolver())
        self.ready = False
        self.fetch_server_members_bool = False
        self.send_ads_bool = False
        self.check_invites_bool = False
        self.join_servers_bool = False
        self.invite_codes = []
        self.invites = []
        self.config_guilds = []
        self.members = []
        self.message = ''
        self.delay = 0

    async def on_ready(self):
        self.ready = True
        print(f'Logged in as {self.user}')
        while self.ready:
            if self.check_invites_bool:
                await self.check_invites()
                print(f'{self.user} Checked all invites')
                self.check_invites_bool = False

    async def check_invites(self):
        for invite_code in self.invite_codes:
            try:
                invite = await self.fetch_invite(invite_code)
                self.invites.append(invite)
            except Exception as exc:
                print(f"Couldn't fetch invite: {invite_code}. Because {exc}...")

The only problem I'm running into atm is that when I'm trying to trigger the member.send() method like this I get another loop error:

Task <Task pending name='discord.py: on_ready' coro=<Client._run_event() running at ...\client.py got Future <Future pending cb=[shield.<locals>._outer_done_callback() at ...\tasks.py attached to a different loop

I've then tried to end the on_ready event with closing the loop but then I have no other way to trigger the send_ads method without running into the first issue. Any ideas on how to find some solution for this?

[dolfies]

You really shouldn't use run_in_executor() here.