𝗡𝗥 𝗖𝗢𝗗𝗘𝗫 𝗕𝗢𝗧𝗦 ⚡

/ban <ᴜɪᴅ> <ᴘᴀssᴡᴏʀᴅ> - ᴇɴᴛᴇʀ ʏᴏᴜʀ ɢᴜᴇsᴛ ᴀᴄᴄᴏᴜɴᴛ ᴜɪᴅ & ᴘᴀssᴡᴏʀᴅ ғᴏʀ ғғ ᴀᴄᴄᴏᴜɴᴛ ʙᴀɴ /access <ᴀᴄᴄᴇss-ᴛᴏᴋᴇɴ> - ᴇɴᴛᴇʀ ʏᴏᴜʀ ᴀᴄᴄᴏᴜɴᴛ ᴀᴄᴄᴇss ᴛᴏᴋᴇɴ ғᴏʀ ғғ ᴀᴄᴄᴏᴜɴᴛ ʙᴀɴ /eat <ᴇᴀᴛ-ᴛᴏᴋᴇɴ> - ᴇɴᴛᴇʀ ʏᴏᴜʀ ᴀᴄᴄᴏᴜɴᴛ ᴇᴀᴛ ᴛᴏᴋᴇɴ ғᴏʀ ғғ ᴀᴄᴄᴏᴜɴᴛ ʙᴀɴ /jwt <ᴊᴡᴛ-ᴛᴏᴋᴇɴ> - ᴇɴᴛᴇʀ ʏᴏᴜʀ ᴀᴄᴄᴏᴜɴᴛ ᴊᴡᴛ ᴛᴏᴋᴇɴ ғᴏʀ ғғ ᴀᴄᴄᴏᴜɴᴛ ʙᴀɴ

/ban <ᴜɪᴅ> <ᴘᴀssᴡᴏʀᴅ> - ᴇɴᴛᴇʀ ʏᴏᴜʀ ɢᴜᴇsᴛ ᴀᴄᴄᴏᴜɴᴛ ᴜɪᴅ & ᴘᴀssᴡᴏʀᴅ ғᴏʀ ғғ ᴀᴄᴄᴏᴜɴᴛ ʙᴀɴ /access <ᴀᴄᴄᴇss-ᴛᴏᴋᴇɴ> - ᴇɴᴛᴇʀ ʏᴏᴜʀ ᴀᴄᴄᴏᴜɴᴛ ᴀᴄᴄᴇss ᴛᴏᴋᴇɴ ғᴏʀ ғғ ᴀᴄᴄᴏᴜɴᴛ ʙᴀɴ /eat <ᴇᴀᴛ-ᴛᴏᴋᴇɴ> - ᴇɴᴛᴇʀ ʏᴏᴜʀ ᴀᴄᴄᴏᴜɴᴛ ᴇᴀᴛ ᴛᴏᴋᴇɴ ғᴏʀ ғғ ᴀᴄᴄᴏᴜɴᴛ ʙᴀɴ /jwt <ᴊᴡᴛ-ᴛᴏᴋᴇɴ> - ᴇɴᴛᴇʀ ʏᴏᴜʀ ᴀᴄᴄᴏᴜɴᴛ ᴊᴡᴛ ᴛᴏᴋᴇɴ ғᴏʀ ғғ ᴀᴄᴄᴏᴜɴᴛ ʙᴀɴ

elif received_msg.startswith("/bundle"):
                        await send_title(chat_id, chat_type)
                        try:
                            bundles = {
                                "midnight-ace": 914048001,
                                "aurora": 914047002,
                                "naruto": 914047001,
                                "paradox": 914044001,
                                "frostfire": 914042001,
                                "rampage": 914000002,
                                "wolf": 914000003,
                                "devil": 914038001,
                                "scorpio": 914039001,
                                "dreamspace": 914051001,
                                "itachi": 914050001,
                            }

                            bundle_list_msg = (
                                "[7ED957][C][B]AVAILABLE BUNDLES\n\n"
                                "[6FA8DC]midnight-ace\n"
                                "[76D7C4]aurora\n"
                                "[C0392B]naruto\n"
                                "[82E0AA]paradox\n"
                                "[D7BDE2]frostfire\n"
                                "[A6ACAF]rampage\n"
                                "[85C1E9]wolf\n"
                                "[E74C3C]devil\n"
                                "[F5B041]scorpio\n"
                                "[FFFFFF]dreamspace\n"
                                "[FFFFFF]itachi"
                            )

                            parts = received_msg.strip().split()

                            if len(parts) != 2:
                                await send_response(bundle_list_msg, uid, chat_id, chat_type)
                                return

                            bundle_name = parts[1].lower()

                            if bundle_name not in bundles:
                                await send_response(bundle_list_msg, uid, chat_id, chat_type)
                                return

                            bundle_id = bundles[bundle_name]

                            # 🔹 1) SEND ANIMATION PACKET
                            anim_packet = await animation_packet(bundle_id, key, iv)
                            if online_writer:
                                online_writer.write(anim_packet)
                                await online_writer.drain()

                            # ⏳ 3 seconds delay
                            await asyncio.sleep(3)

                            # 🔹 2) SEND BUNDLE PACKET
                            bundle_packet_data = await bundle_packet(bundle_id, key, iv)
                            if online_writer:
                                online_writer.write(bundle_packet_data)
                                await online_writer.drain()

                            await send_response(
                                f"[C][B][00FF00]WEARED BUNDLE ✔️ {bundle_name.upper()}",
                                uid, chat_id, chat_type
                            )

                        except Exception as e:
                            print(f"Error in /bundle command: {e}")
                            await send_response(
                                "[C][B][FF0000]Bundle command error",
                                uid, chat_id, chat_type
                            )

async def bundle_packet(bundle_id, key, iv):
    # ---- protobuf fields (same structure as you gave) ----
    fields = {
        1: 88,
        2: {
            1: {
                1: int(bundle_id),
                2: 1
            },
            2: 2
        }
    }

    proto_bytes = await CrEaTe_ProTo(fields)
    packet_hex = proto_bytes.hex()
    encrypted_packet = await encrypt_packet(packet_hex, key, iv)
    packet_length = len(encrypted_packet) // 2
    packet_length_hex = await base_to_hex(packet_length)
    if len(packet_length_hex) == 2:
        header = "0515000000"
    elif len(packet_length_hex) == 3:
        header = "051500000"
    elif len(packet_length_hex) == 4:
        header = "05150000"
    elif len(packet_length_hex) == 5:
        header = "0515000"
    else:
        header = "0515000000"

    final_packet = header + packet_length_hex + encrypted_packet

    return bytes.fromhex(final_packet)

async def animation_packet(bundle_id, key, iv):
    fields = {
        1: 88,
        2: {
            1: {
                1: int(bundle_id),
            }
        }
    }

    proto_bytes = await CrEaTe_ProTo(fields)
    packet_hex = proto_bytes.hex()

    encrypted_packet = await encrypt_packet(packet_hex, key, iv)

    packet_length = len(encrypted_packet) // 2
    packet_length_hex = await base_to_hex(packet_length)

    if len(packet_length_hex) == 2:
        header = "0515000000"
    elif len(packet_length_hex) == 3:
        header = "051500000"
    elif len(packet_length_hex) == 4:
        header = "05150000"
    elif len(packet_length_hex) == 5:
        header = "0515000"
    else:
        header = "0515000000"

    final_packet = header + packet_length_hex + encrypted_packet

    return bytes.fromhex(final_packet)

async def team_chat_startup(player_uid, team_session, key, iv):
    proto = Team_Chat_Startup_pb2.team_chat_startup()
    proto.field1 = 3
    proto.details.uid = player_uid
    proto.details.language = "en"
    proto.details.team_packet = str(team_session)

    packet = proto.SerializeToString().hex()
    encrypted_packet = await encrypt_packet(packet, key, iv)
    packet_length = len(encrypted_packet) // 2
    packet_length_hex = await base_to_hex(packet_length)

    if len(packet_length_hex) == 2:
        final_packet = "1201000000" + packet_length_hex + encrypted_packet
    elif len(packet_length_hex) == 3:
        final_packet = "120100000" + packet_length_hex + encrypted_packet
    elif len(packet_length_hex) == 4:
        final_packet = "12010000" + packet_length_hex + encrypted_packet
    elif len(packet_length_hex) == 5:
        final_packet = "1201000" + packet_length_hex + encrypted_packet
    else:
        print("something went wrong, please check clan startup function.")
    if whisper_writer:  # <--- FIX: Check if writer is available
        whisper_writer.write(bytes.fromhex(final_packet))
        await whisper_writer.drain()