Having an issue with connection dropping a few times a day.

[the-jolley-boy]

I was unsure if this was a bug or not, my assumption is something to do with the server it is run on but I want to get a second opinion if possible.

Server used:

Windows Server 2016
Build 14393.rs1_release.220429-1732
64gb Ram
16 Core

The code is really simple and can be found below with a couple things marked "REDACTED" for privacy.

import socketio
import asyncio
import aiohttp
import psycopg2
from psycopg2 import sql

async def main():
    try:
        sio = socketio.AsyncClient(logger=True, engineio_logger=True)
        await sio.connect('https://skinport.com/', transports=['websocket'])
        await sio.emit('saleFeedJoin', {'currency': 'CAD', 'locale': 'en', 'appid': 730})

        wanted = ["9191","9139","10318","9140","9124","10255","10318","18296","20699","60771","55047","55084","55046","55045","9164","9161","9141"]

        @sio.on('saleFeed')
        async def on_message(data):

            eventType = data.get("eventType")
            print(eventType)

            # Gathering what I need for the enbeds from the dict
            marketName = data["sales"][0]["marketName"]
            url = "https://skinport.com/item/" + str(data["sales"][0]["url"]) + "/" + str(data["sales"][0]["saleId"])
            lock = data["sales"][0]["lock"]
            deal = round((1 - (int(data["sales"][0]["salePrice"])/int(data["sales"][0]["suggestedPrice"]))) * 100, 2)
            stickers = data["sales"][0]["stickers"]
            itemid = data["sales"][0]["itemId"]
            pattern = data["sales"][0]["pattern"]
            finish = data["sales"][0]["finish"]
            img = "https://community.cloudflare.steamstatic.com/economy/image/" + data["sales"][0]["image"]
            
            sale = str(data["sales"][0]["salePrice"])
            if len(sale) > 2:
                saleNoCents = sale[:-2]
            else:
                saleNoCents = 0
            salePrice = sale[:-2] + "." + sale[-2:]
            
            if data["sales"][0]["wear"]:
                wear = round(data["sales"][0]["wear"], 6)
            else:
                wear = data["sales"][0]["wear"]
            exterior = data["sales"][0]["exterior"]
            if exterior == "Factory New":
                exterior = "FN"
            if exterior == "Minimal Wear":
                exterior = "MW"
            if exterior == "Field-Tested":
                exterior = "FT"
            if exterior == "Well-Worn":
                exterior = "WW"
            if exterior == "Battle-Scarred":
                exterior = "BS"
            if exterior == "None":
                exterior = "NA"

            # Sold Channel
            if eventType == "sold":
                async with aiohttp.ClientSession() as s:
                    webhook = Webhook.from_url('REDACTED', session=s)

                    embed = discord.Embed(title=marketName + " Sold", description="PRICE: " + str(salePrice), url=url, color=0x000000)
                    embed.add_field(name="Deal %", value=str(deal), inline=True)
                    embed.add_field(name="Wear | Float", value=str(exterior) + " | " + str(wear), inline=True)
                    embed.add_field(name="Locked Until", value=str(lock), inline=True)
                    embed.add_field(name="Pattern", value=str(pattern), inline=True)
                    embed.set_thumbnail(url=img)

                    await webhook.send(embed=embed)

            # Listed Channel
            if eventType == "listed":
                async with aiohttp.ClientSession() as s:
                    webhook = Webhook.from_url('REDACTED', session=s)

                    embed = discord.Embed(title=marketName + " Listed", description="PRICE: " + str(salePrice), url=url, color=0x000000)
                    embed.add_field(name="Deal %", value=str(deal), inline=True)
                    embed.add_field(name="Wear | Float", value=str(exterior) + " | " + str(wear), inline=True)
                    embed.add_field(name="Locked Until", value=str(lock), inline=True)
                    embed.add_field(name="Pattern", value=str(pattern), inline=True)
                    embed.set_thumbnail(url=img)

                    await webhook.send(embed=embed)

            # What I Am Looking For Channel
            if eventType == "listed" and any(x in str(itemid) for x in wanted):
                async with aiohttp.ClientSession() as s:
                    webhook = Webhook.from_url('REDACTED', session=s)

                    embed = discord.Embed(title=marketName + " Listed", description="PRICE: " + str(salePrice), url=url, color=0x000000)
                    embed.add_field(name="Deal %", value=str(deal), inline=True)
                    embed.add_field(name="Wear | Float", value=str(exterior) + " | " + str(wear), inline=True)
                    embed.add_field(name="Locked Until", value=str(lock), inline=True)
                    embed.add_field(name="Pattern", value=str(pattern), inline=True)
                    embed.set_thumbnail(url=img)

                    await webhook.send(embed=embed)

            # What I Am Looking For Channel Sold
            if eventType == "sold" and any(x in str(itemid) for x in wanted):
                async with aiohttp.ClientSession() as s:
                    webhook = Webhook.from_url('REDACTED', session=s)

                    embed = discord.Embed(title=marketName + " Sold", description="PRICE: " + str(salePrice), url=url, color=0x000000)
                    embed.add_field(name="Deal %", value=str(deal), inline=True)
                    embed.add_field(name="Wear | Float", value=str(exterior) + " | " + str(wear), inline=True)
                    embed.add_field(name="Locked Until", value=str(lock), inline=True)
                    embed.add_field(name="Pattern", value=str(pattern), inline=True)
                    embed.set_thumbnail(url=img)

                    await webhook.send(embed=embed)

            # Listed + Good Deal Channel
            if eventType == "listed" and deal >= 25 and int(saleNoCents) > 4:
                async with aiohttp.ClientSession() as s:
                    webhook = REDACTED', session=s)

                    embed = discord.Embed(title=marketName + " Listed", description="PRICE: " + str(salePrice), url=url, color=0x000000)
                    embed.add_field(name="Deal %", value=str(deal), inline=True)
                    embed.add_field(name="Wear | Float", value=str(exterior) + " | " + str(wear), inline=True)
                    embed.add_field(name="Locked Until", value=str(lock), inline=True)
                    embed.add_field(name="Pattern", value=str(pattern), inline=True)
                    embed.set_thumbnail(url=img)

                    await webhook.send(embed=embed)

    except KeyboardInterrupt:
        await sio.disconnect()

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

The error I get back I have looked in the bug reports and online and can't seem to pinpoint what is wrong with my code, if it is anything. I run my code in a python venv to avoid potential issues there. The error I get running the sio logger can be found below.

Server sent unexpected packet WSMsgType.CLOSED data None, aborting
Waiting for write loop task to end
Exiting write loop task
Engine.IO connection dropped
Connection failed, new attempt in 0.63 seconds
Exiting read loop task
Task was destroyed but it is pending!
task: <Task pending name='Task-2931' coro=<AsyncClient._handle_reconnect() running at C:\Users\Administrator\venvcsgo\lib\site-packages\socketio\asyncio_client.py:470> wait_for=<Future pending cb=[Task.task_wakeup()]>>
Task was destroyed but it is pending!
task: <Task pending name='Task-2932' coro=<Event.wait() running at C:\Users\Administrator\AppData\Local\Programs\Python\Python310\lib\asyncio\locks.py:213> wait_for=<Future pending cb=[Task.task_wakeup()]> cb=[_release_waiter(<Future pendi...ask_wakeup()]>)() at C:\Users\Administrator\AppData\Local\Programs\Python\Python310\lib\asyncio\tasks.py:387]>

[miguelgrinberg]

The problem is that the server is closing your connection for some reason. Is this server under your control? You may need to look on the server logs to get more clues.

[miguelgrinberg]

The client should normally reconnect on its own, your log even shows that it attempted to reconnect. But without knowing which server this is I can't really do much. Maybe ask whoever maintains the server to explain why you are being disconnected?

[the-jolley-boy]

I could try but chances are they won't say much. Asked around and other had the same issue so what I am going to do it just run a try/except to reconnect each time it drops.

[the-jolley-boy]

https://github.com/socketio/socket.io/releases/tag/4.6.2 dev says this is the socketio version they are using

[hydrohd]

@the-jolley-boy did you ever figure this problem out? I am having a similar issue with my client. We are also running the client on a windows server.

[the-jolley-boy]

@hydrohd I did not in terms of continuing to use async with it. I have not fully tried to remake my script without it, but someone else who was using similar code before said once he changed to a non async script it worked without any issues. I know that may not help you but in terms for getting my async script to work I just re-establish the connection every x time which my not be a perfect fix but for my usage it works well.