Test

Dockerfile

@@ -0,0 +1,16 @@
+# Read the doc: https://huggingface.co/docs/hub/spaces-sdks-docker
+# you will also find guides on how best to write your Dockerfile
+
+FROM python:3.9
+
+RUN useradd -m -u 1000 user
+USER user
+ENV PATH="/home/user/.local/bin:$PATH"
+
+WORKDIR /app
+
+COPY --chown=user ./requirements.txt requirements.txt
+RUN pip install --no-cache-dir --upgrade -r requirements.txt
+
+COPY --chown=user . /app
+CMD ["uvicorn", "bot_with_api:app", "--host", "0.0.0.0", "--port", "7860"]

Pb2/DEcwHisPErMsG_pb2.py

@@ -0,0 +1,42 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# NO CHECKED-IN PROTOBUF GENCODE
+# source: DecodeWhisperMsg.proto
+# Protobuf Python Version: 6.30.0
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import runtime_version as _runtime_version
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+_runtime_version.ValidateProtobufRuntimeVersion(
+    _runtime_version.Domain.PUBLIC,
+    6,
+    30,
+    0,
+    '',
+    'DecodeWhisperMsg.proto'
+)
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x16\x44\x65\x63odeWhisperMsg.proto\"\xa8\x02\n\rDecodeWhisper\x12$\n\x04\x44\x61ta\x18\x05 \x01(\x0b\x32\x16.DecodeWhisper.Nested1\x1a\xf0\x01\n\x07Nested1\x12\x0b\n\x03uid\x18\x01 \x01(\x04\x12\x0f\n\x07\x43hat_ID\x18\x02 \x01(\x04\x12\x11\n\tchat_type\x18\x03 \x01(\x05\x12\x0b\n\x03msg\x18\x04 \x01(\t\x12/\n\x07\x44\x65tails\x18\t \x01(\x0b\x32\x1e.DecodeWhisper.Nested1.Nested2\x12\x35\n\rPlatform_Info\x18\r \x01(\x0b\x32\x1e.DecodeWhisper.Nested1.Nested3\x1a\x1b\n\x07Nested2\x12\x10\n\x08Nickname\x18\x01 \x01(\t\x1a\"\n\x07Nested3\x12\x17\n\x0fprofile_pic_url\x18\x01 \x01(\tb\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'DecodeWhisperMsg_pb2', _globals)
+if not _descriptor._USE_C_DESCRIPTORS:
+  DESCRIPTOR._loaded_options = None
+  _globals['_DECODEWHISPER']._serialized_start=27
+  _globals['_DECODEWHISPER']._serialized_end=323
+  _globals['_DECODEWHISPER_NESTED1']._serialized_start=83
+  _globals['_DECODEWHISPER_NESTED1']._serialized_end=323
+  _globals['_DECODEWHISPER_NESTED1_NESTED2']._serialized_start=260
+  _globals['_DECODEWHISPER_NESTED1_NESTED2']._serialized_end=287
+  _globals['_DECODEWHISPER_NESTED1_NESTED3']._serialized_start=289
+  _globals['_DECODEWHISPER_NESTED1_NESTED3']._serialized_end=323
+# @@protoc_insertion_point(module_scope)

Pb2/Fo_pb2.py

@@ -0,0 +1,28 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# source: Friends.proto
+# Protobuf Python Version: 4.25.1
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rFriends.proto\"\"\n\x06\x46riend\x12\n\n\x02ID\x18\x01 \x01(\x03\x12\x0c\n\x04Name\x18\x03 \x01(\t\"#\n\x07\x46riends\x12\x18\n\x07\x66ield_1\x18\x01 \x03(\x0b\x32\x07.Friendb\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'Friends_pb2', _globals)
+if _descriptor._USE_C_DESCRIPTORS == False:
+  DESCRIPTOR._options = None
+  _globals['_FRIEND']._serialized_start=17
+  _globals['_FRIEND']._serialized_end=51
+  _globals['_FRIENDS']._serialized_start=53
+  _globals['_FRIENDS']._serialized_end=88
+# @@protoc_insertion_point(module_scope)

Pb2/GenWhisperMsg_pb2.py

@@ -0,0 +1,48 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# NO CHECKED-IN PROTOBUF GENCODE
+# source: GenWhisperMsg.proto
+# Protobuf Python Version: 6.30.0
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import runtime_version as _runtime_version
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+_runtime_version.ValidateProtobufRuntimeVersion(
+    _runtime_version.Domain.PUBLIC,
+    6,
+    30,
+    0,
+    '',
+    'GenWhisperMsg.proto'
+)
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13GenWhisperMsg.proto\"\x85\x06\n\nGenWhisper\x12\x0c\n\x04type\x18\x01 \x01(\x05\x12!\n\x04\x64\x61ta\x18\x02 \x01(\x0b\x32\x13.GenWhisper.Nested2\x1a\xc5\x05\n\x07Nested2\x12\x0b\n\x03uid\x18\x01 \x01(\x04\x12\x0f\n\x07\x63hat_id\x18\x02 \x01(\x04\x12\x11\n\tchat_type\x18\x03 \x01(\x05\x12\x0b\n\x03msg\x18\x04 \x01(\t\x12\x11\n\ttimestamp\x18\x05 \x01(\x03\x12+\n\x06\x66ield9\x18\t \x01(\x0b\x32\x1b.GenWhisper.Nested2.Nested9\x12\x10\n\x08language\x18\n \x01(\t\x12-\n\x07\x66ield13\x18\r \x01(\x0b\x32\x1c.GenWhisper.Nested2.Nested13\x12\x31\n\x0b\x65mpty_field\x18\x0e \x01(\x0b\x32\x1c.GenWhisper.Nested2.Nested14\x12\x11\n\tCelebrity\x18\x10 \x01(\x04\x1a\n\n\x08Nested14\x1a\xff\x01\n\x07Nested9\x12\x10\n\x08Nickname\x18\x01 \x01(\t\x12\x11\n\tavatar_id\x18\x02 \x01(\x03\x12\x11\n\tbanner_id\x18\x03 \x01(\x03\x12\x0c\n\x04rank\x18\x04 \x01(\x05\x12\r\n\x05\x62\x61\x64ge\x18\x05 \x01(\x05\x12\x11\n\tClan_Name\x18\x08 \x01(\t\x12\x0f\n\x07\x66ield10\x18\n \x01(\x05\x12\x17\n\x0fglobal_rank_pos\x18\x0b \x01(\x05\x12\x30\n\x07\x66ield13\x18\r \x01(\x0b\x32\x1f.GenWhisper.Nested2.NestedBadge\x12\x30\n\x07\x66ield14\x18\x0e \x01(\x0b\x32\x1f.GenWhisper.Nested2.NestedPrime\x1a\x1c\n\x0bNestedBadge\x12\r\n\x05value\x18\x01 \x01(\x05\x1aH\n\x0bNestedPrime\x12\x11\n\tprime_uid\x18\x01 \x01(\x05\x12\x13\n\x0bprime_level\x18\x02 \x01(\x05\x12\x11\n\tprime_hex\x18\x03 \x01(\t\x1a?\n\x08Nested13\x12\x0b\n\x03url\x18\x01 \x01(\t\x12\x10\n\x08url_type\x18\x02 \x01(\x05\x12\x14\n\x0curl_platform\x18\x03 \x01(\x05\x62\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'GenWhisperMsg_pb2', _globals)
+if not _descriptor._USE_C_DESCRIPTORS:
+  DESCRIPTOR._loaded_options = None
+  _globals['_GENWHISPER']._serialized_start=24
+  _globals['_GENWHISPER']._serialized_end=797
+  _globals['_GENWHISPER_NESTED2']._serialized_start=88
+  _globals['_GENWHISPER_NESTED2']._serialized_end=797
+  _globals['_GENWHISPER_NESTED2_NESTED14']._serialized_start=360
+  _globals['_GENWHISPER_NESTED2_NESTED14']._serialized_end=370
+  _globals['_GENWHISPER_NESTED2_NESTED9']._serialized_start=373
+  _globals['_GENWHISPER_NESTED2_NESTED9']._serialized_end=628
+  _globals['_GENWHISPER_NESTED2_NESTEDBADGE']._serialized_start=630
+  _globals['_GENWHISPER_NESTED2_NESTEDBADGE']._serialized_end=658
+  _globals['_GENWHISPER_NESTED2_NESTEDPRIME']._serialized_start=660
+  _globals['_GENWHISPER_NESTED2_NESTEDPRIME']._serialized_end=732
+  _globals['_GENWHISPER_NESTED2_NESTED13']._serialized_start=734
+  _globals['_GENWHISPER_NESTED2_NESTED13']._serialized_end=797
+# @@protoc_insertion_point(module_scope)

Pb2/MajoRLoGinrEq_pb2.py

@@ -0,0 +1,28 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# source: MajorLoginReq.proto
+# Protobuf Python Version: 4.25.1
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13MajorLoginReq.proto\"\xfa\n\n\nMajorLogin\x12\x12\n\nevent_time\x18\x03 \x01(\t\x12\x11\n\tgame_name\x18\x04 \x01(\t\x12\x13\n\x0bplatform_id\x18\x05 \x01(\x05\x12\x16\n\x0e\x63lient_version\x18\x07 \x01(\t\x12\x17\n\x0fsystem_software\x18\x08 \x01(\t\x12\x17\n\x0fsystem_hardware\x18\t \x01(\t\x12\x18\n\x10telecom_operator\x18\n \x01(\t\x12\x14\n\x0cnetwork_type\x18\x0b \x01(\t\x12\x14\n\x0cscreen_width\x18\x0c \x01(\r\x12\x15\n\rscreen_height\x18\r \x01(\r\x12\x12\n\nscreen_dpi\x18\x0e \x01(\t\x12\x19\n\x11processor_details\x18\x0f \x01(\t\x12\x0e\n\x06memory\x18\x10 \x01(\r\x12\x14\n\x0cgpu_renderer\x18\x11 \x01(\t\x12\x13\n\x0bgpu_version\x18\x12 \x01(\t\x12\x18\n\x10unique_device_id\x18\x13 \x01(\t\x12\x11\n\tclient_ip\x18\x14 \x01(\t\x12\x10\n\x08language\x18\x15 \x01(\t\x12\x0f\n\x07open_id\x18\x16 \x01(\t\x12\x14\n\x0copen_id_type\x18\x17 \x01(\t\x12\x13\n\x0b\x64\x65vice_type\x18\x18 \x01(\t\x12\'\n\x10memory_available\x18\x19 \x01(\x0b\x32\r.GameSecurity\x12\x14\n\x0c\x61\x63\x63\x65ss_token\x18\x1d \x01(\t\x12\x17\n\x0fplatform_sdk_id\x18\x1e \x01(\x05\x12\x1a\n\x12network_operator_a\x18) \x01(\t\x12\x16\n\x0enetwork_type_a\x18* \x01(\t\x12\x1c\n\x14\x63lient_using_version\x18\x39 \x01(\t\x12\x1e\n\x16\x65xternal_storage_total\x18< \x01(\x05\x12\"\n\x1a\x65xternal_storage_available\x18= \x01(\x05\x12\x1e\n\x16internal_storage_total\x18> \x01(\x05\x12\"\n\x1ainternal_storage_available\x18? \x01(\x05\x12#\n\x1bgame_disk_storage_available\x18@ \x01(\x05\x12\x1f\n\x17game_disk_storage_total\x18\x41 \x01(\x05\x12%\n\x1d\x65xternal_sdcard_avail_storage\x18\x42 \x01(\x05\x12%\n\x1d\x65xternal_sdcard_total_storage\x18\x43 \x01(\x05\x12\x10\n\x08login_by\x18I \x01(\x05\x12\x14\n\x0clibrary_path\x18J \x01(\t\x12\x12\n\nreg_avatar\x18L \x01(\x05\x12\x15\n\rlibrary_token\x18M \x01(\t\x12\x14\n\x0c\x63hannel_type\x18N \x01(\x05\x12\x10\n\x08\x63pu_type\x18O \x01(\x05\x12\x18\n\x10\x63pu_architecture\x18Q \x01(\t\x12\x1b\n\x13\x63lient_version_code\x18S \x01(\t\x12\x14\n\x0cgraphics_api\x18V \x01(\t\x12\x1d\n\x15supported_astc_bitset\x18W \x01(\r\x12\x1a\n\x12login_open_id_type\x18X \x01(\x05\x12\x18\n\x10\x61nalytics_detail\x18Y \x01(\x0c\x12\x14\n\x0cloading_time\x18\\ \x01(\r\x12\x17\n\x0frelease_channel\x18] \x01(\t\x12\x12\n\nextra_info\x18^ \x01(\t\x12 \n\x18\x61ndroid_engine_init_flag\x18_ \x01(\r\x12\x0f\n\x07if_push\x18\x61 \x01(\x05\x12\x0e\n\x06is_vpn\x18\x62 \x01(\x05\x12\x1c\n\x14origin_platform_type\x18\x63 \x01(\t\x12\x1d\n\x15primary_platform_type\x18\x64 \x01(\t\"5\n\x0cGameSecurity\x12\x0f\n\x07version\x18\x06 \x01(\x05\x12\x14\n\x0chidden_value\x18\x08 \x01(\x04\x62\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'MajorLoginReq_pb2', _globals)
+if _descriptor._USE_C_DESCRIPTORS == False:
+  DESCRIPTOR._options = None
+  _globals['_MAJORLOGIN']._serialized_start=24
+  _globals['_MAJORLOGIN']._serialized_end=1426
+  _globals['_GAMESECURITY']._serialized_start=1428
+  _globals['_GAMESECURITY']._serialized_end=1481
+# @@protoc_insertion_point(module_scope)

Pb2/MajoRLoGinrEs_pb2.py

@@ -0,0 +1,36 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# NO CHECKED-IN PROTOBUF GENCODE
+# source: MajorLoginRes.proto
+# Protobuf Python Version: 6.30.0
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import runtime_version as _runtime_version
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+_runtime_version.ValidateProtobufRuntimeVersion(
+    _runtime_version.Domain.PUBLIC,
+    6,
+    30,
+    0,
+    '',
+    'MajorLoginRes.proto'
+)
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13MajorLoginRes.proto\"|\n\rMajorLoginRes\x12\x13\n\x0b\x61\x63\x63ount_uid\x18\x01 \x01(\x04\x12\x0e\n\x06region\x18\x02 \x01(\t\x12\r\n\x05token\x18\x08 \x01(\t\x12\x0b\n\x03url\x18\n \x01(\t\x12\x11\n\ttimestamp\x18\x15 \x01(\x03\x12\x0b\n\x03key\x18\x16 \x01(\x0c\x12\n\n\x02iv\x18\x17 \x01(\x0c\x62\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'MajorLoginRes_pb2', _globals)
+if not _descriptor._USE_C_DESCRIPTORS:
+  DESCRIPTOR._loaded_options = None
+  _globals['_MAJORLOGINRES']._serialized_start=23
+  _globals['_MAJORLOGINRES']._serialized_end=147
+# @@protoc_insertion_point(module_scope)

Pb2/PorTs_pb2.py

@@ -0,0 +1,36 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# NO CHECKED-IN PROTOBUF GENCODE
+# source: GetLoginDataRes.proto
+# Protobuf Python Version: 6.30.0
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import runtime_version as _runtime_version
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+_runtime_version.ValidateProtobufRuntimeVersion(
+    _runtime_version.Domain.PUBLIC,
+    6,
+    30,
+    0,
+    '',
+    'GetLoginDataRes.proto'
+)
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x15GetLoginDataRes.proto\"\xa4\x01\n\x0cGetLoginData\x12\x12\n\nAccountUID\x18\x01 \x01(\x04\x12\x0e\n\x06Region\x18\x03 \x01(\t\x12\x13\n\x0b\x41\x63\x63ountName\x18\x04 \x01(\t\x12\x16\n\x0eOnline_IP_Port\x18\x0e \x01(\t\x12\x0f\n\x07\x43lan_ID\x18\x14 \x01(\x03\x12\x16\n\x0e\x41\x63\x63ountIP_Port\x18  \x01(\t\x12\x1a\n\x12\x43lan_Compiled_Data\x18\x37 \x01(\tb\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'GetLoginDataRes_pb2', _globals)
+if not _descriptor._USE_C_DESCRIPTORS:
+  DESCRIPTOR._loaded_options = None
+  _globals['_GETLOGINDATA']._serialized_start=26
+  _globals['_GETLOGINDATA']._serialized_end=190
+# @@protoc_insertion_point(module_scope)

Pb2/Team_msg_pb2.py

@@ -0,0 +1,48 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# NO CHECKED-IN PROTOBUF GENCODE
+# source: Team_msg.proto
+# Protobuf Python Version: 6.30.0
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import runtime_version as _runtime_version
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+_runtime_version.ValidateProtobufRuntimeVersion(
+    _runtime_version.Domain.PUBLIC,
+    6,
+    30,
+    0,
+    '',
+    'Team_msg.proto'
+)
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0eTeam_msg.proto\"\x94\x06\n\x0eGenTeamWhisper\x12\x0c\n\x04type\x18\x01 \x01(\x05\x12%\n\x04\x64\x61ta\x18\x02 \x01(\x0b\x32\x17.GenTeamWhisper.Nested2\x1a\xcc\x05\n\x07Nested2\x12\x0b\n\x03uid\x18\x01 \x01(\x03\x12\x0f\n\x07\x63hat_id\x18\x02 \x01(\x03\x12\x0b\n\x03msg\x18\x04 \x01(\t\x12\x11\n\ttimestamp\x18\x05 \x01(\x03\x12\x11\n\tchat_type\x18\x07 \x01(\x05\x12\r\n\x05title\x18\x08 \x01(\x05\x12/\n\x06\x66ield9\x18\t \x01(\x0b\x32\x1f.GenTeamWhisper.Nested2.Nested9\x12\x10\n\x08language\x18\n \x01(\t\x12\x31\n\x07\x66ield13\x18\r \x01(\x0b\x32 .GenTeamWhisper.Nested2.Nested13\x12\x35\n\x0b\x65mpty_field\x18\x0e \x01(\x0b\x32 .GenTeamWhisper.Nested2.Nested14\x1a\n\n\x08Nested14\x1a\xf2\x02\n\x07Nested9\x12\x10\n\x08Nickname\x18\x01 \x01(\t\x12\x11\n\tavatar_id\x18\x02 \x01(\x03\x12\x0c\n\x04rank\x18\x04 \x01(\x05\x12\r\n\x05\x62\x61\x64ge\x18\x05 \x01(\x05\x12\x11\n\tClan_Name\x18\x08 \x01(\t\x12\x0f\n\x07\x66ield10\x18\n \x01(\x05\x12\x17\n\x0fglobal_rank_pos\x18\x0b \x01(\x05\x12?\n\nbadge_info\x18\r \x01(\x0b\x32+.GenTeamWhisper.Nested2.Nested9.NestedBadge\x12?\n\nprime_info\x18\x0e \x01(\x0b\x32+.GenTeamWhisper.Nested2.Nested9.NestedPrime\x1a\x1c\n\x0bNestedBadge\x12\r\n\x05value\x18\x01 \x01(\x05\x1aH\n\x0bNestedPrime\x12\x11\n\tprime_uid\x18\x01 \x01(\x05\x12\x13\n\x0bprime_level\x18\x02 \x01(\x05\x12\x11\n\tprime_hex\x18\x03 \x01(\t\x1a\x33\n\x08Nested13\x12\x10\n\x08url_type\x18\x02 \x01(\x05\x12\x15\n\rcurl_platform\x18\x03 \x01(\x05\x62\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'Team_msg_pb2', _globals)
+if not _descriptor._USE_C_DESCRIPTORS:
+  DESCRIPTOR._loaded_options = None
+  _globals['_GENTEAMWHISPER']._serialized_start=19
+  _globals['_GENTEAMWHISPER']._serialized_end=807
+  _globals['_GENTEAMWHISPER_NESTED2']._serialized_start=91
+  _globals['_GENTEAMWHISPER_NESTED2']._serialized_end=807
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED14']._serialized_start=371
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED14']._serialized_end=381
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED9']._serialized_start=384
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED9']._serialized_end=754
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED9_NESTEDBADGE']._serialized_start=652
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED9_NESTEDBADGE']._serialized_end=680
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED9_NESTEDPRIME']._serialized_start=682
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED9_NESTEDPRIME']._serialized_end=754
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED13']._serialized_start=756
+  _globals['_GENTEAMWHISPER_NESTED2_NESTED13']._serialized_end=807
+# @@protoc_insertion_point(module_scope)

Pb2/sQ_pb2.py

@@ -0,0 +1,38 @@
+# -*- coding: utf-8 -*-
+# Generated by the protocol buffer compiler.  DO NOT EDIT!
+# NO CHECKED-IN PROTOBUF GENCODE
+# source: recieved_chat.proto
+# Protobuf Python Version: 6.30.0
+"""Generated protocol buffer code."""
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import descriptor_pool as _descriptor_pool
+from google.protobuf import runtime_version as _runtime_version
+from google.protobuf import symbol_database as _symbol_database
+from google.protobuf.internal import builder as _builder
+_runtime_version.ValidateProtobufRuntimeVersion(
+    _runtime_version.Domain.PUBLIC,
+    6,
+    30,
+    0,
+    '',
+    'recieved_chat.proto'
+)
+# @@protoc_insertion_point(imports)
+
+_sym_db = _symbol_database.Default()
+
+
+
+
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x13recieved_chat.proto\"\x80\x01\n\rrecieved_chat\x12\x13\n\x0bpacket_type\x18\x04 \x01(\x03\x12&\n\x07\x64\x65tails\x18\x05 \x01(\x0b\x32\x15.recieved_chat.nested\x1a\x32\n\x06nested\x12\x12\n\nplayer_uid\x18\x01 \x01(\x03\x12\x14\n\x0cteam_session\x18\x0e \x01(\tb\x06proto3')
+
+_globals = globals()
+_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'recieved_chat_pb2', _globals)
+if not _descriptor._USE_C_DESCRIPTORS:
+  DESCRIPTOR._loaded_options = None
+  _globals['_RECIEVED_CHAT']._serialized_start=24
+  _globals['_RECIEVED_CHAT']._serialized_end=152
+  _globals['_RECIEVED_CHAT_NESTED']._serialized_start=102
+  _globals['_RECIEVED_CHAT_NESTED']._serialized_end=152
+# @@protoc_insertion_point(module_scope)

api.py

@@ -0,0 +1,420 @@
+# ============================================
+# PRODUCTION API WITH WEBSOCKET - api.py
+# Real-time team updates, no JSON storage
+# ============================================
+
+from flask import Flask, request, jsonify
+from flask_cors import CORS
+from flask_sock import Sock
+import queue
+import json
+import time
+
+app = Flask(__name__)
+CORS(app)
+sock = Sock(app)
+
+command_queue = queue.Queue()
+
+# WebSocket clients list
+websocket_clients = []
+
+# ============================================
+# WEBSOCKET - Real-time Team Updates
+# ============================================
+
+@sock.route('/ws')
+def websocket(ws):
+    """WebSocket connection for real-time updates"""
+    print(f"[WS] Client connected")
+    websocket_clients.append(ws)
+    
+    try:
+        # Send initial team status
+        team_status = get_live_team_status()
+        ws.send(json.dumps({
+            'type': 'initial',
+            'data': team_status
+        }))
+        
+        # Keep connection alive
+        while True:
+            # Receive messages from client (optional)
+            message = ws.receive(timeout=30)
+            if message:
+                data = json.loads(message)
+                
+                # Handle client requests
+                if data.get('type') == 'get_team':
+                    team_status = get_live_team_status()
+                    ws.send(json.dumps({
+                        'type': 'team_update',
+                        'data': team_status
+                    }))
+    
+    except Exception as e:
+        print(f"[WS] Client disconnected: {e}")
+    
+    finally:
+        if ws in websocket_clients:
+            websocket_clients.remove(ws)
+        print(f"[WS] Client removed")
+
+
+def broadcast_team_update(event_type, data):
+    """Broadcast team updates to all connected WebSocket clients"""
+    
+    # DEBUG: Log what we're sending
+    if event_type in ['member_joined', 'member_left']:
+        player = data.get('player', {})
+        print(f"[WS→] {event_type}: {player.get('name')} (UID: {player.get('uid')})")
+    
+    message = json.dumps({
+        'type': event_type,
+        'data': data,
+        'timestamp': time.time()
+    }, ensure_ascii=False)  # Important for Unicode characters
+    
+    disconnected = []
+    sent_count = 0
+    
+    for client in websocket_clients:
+        try:
+            client.send(message)
+            sent_count += 1
+        except Exception as e:
+            print(f"[WS→] Failed to send to client: {e}")
+            disconnected.append(client)
+    
+    if sent_count > 0:
+        print(f"[WS→] Sent to {sent_count} client(s)")
+    
+    # Remove disconnected clients
+    for client in disconnected:
+        if client in websocket_clients:
+            websocket_clients.remove(client)
+
+
+# ============================================
+# JOIN TEAM API
+# ============================================
+
+@app.route('/join', methods=['GET', 'POST'])
+def join_team():
+    """Join a team using teamcode"""
+    try:
+        if request.method == 'GET':
+            teamcode = request.args.get('teamcode')
+        else:
+            data = request.get_json(silent=True)
+            teamcode = data.get('teamcode') if data else None
+        
+        if not teamcode:
+            return jsonify({
+                'success': False,
+                'message': 'teamcode is required'
+            }), 400
+        
+        command_queue.put({
+            'type': 'join',
+            'teamcode': teamcode
+        })
+        
+        return jsonify({
+            'success': True,
+            'message': 'Join command queued',
+            'teamcode': teamcode
+        })
+        
+    except Exception as e:
+        return jsonify({
+            'success': False,
+            'message': str(e)
+        }), 500
+
+
+# ============================================
+# EMOTE API
+# ============================================
+
+@app.route('/emote', methods=['POST'])
+def send_emote():
+    """Send emote to players (bot must be in team)"""
+    try:
+        data = request.get_json(silent=True)
+        if not data:
+            return jsonify({
+                'success': False,
+                'message': 'JSON body required'
+            }), 400
+        
+        uids = data.get('uids')
+        emote_code = data.get('emote_code')
+        
+        if not emote_code:
+            return jsonify({
+                'success': False,
+                'message': 'emote_code is required'
+            }), 400
+        
+        if not isinstance(uids, list) or len(uids) == 0:
+            return jsonify({
+                'success': False,
+                'message': 'uids must be a non-empty array'
+            }), 400
+        
+        if len(uids) > 5:
+            return jsonify({
+                'success': False,
+                'message': 'Maximum 5 UIDs allowed per request'
+            }), 400
+        
+        # Check if bot is in team (LIVE CHECK)
+        team_status = get_live_team_status()
+        if not team_status['in_team']:
+            return jsonify({
+                'success': False,
+                'message': 'Bot is not in any team. Join a team first.',
+                'in_team': False
+            }), 400
+        
+        # Queue emote command
+        command_queue.put({
+            'type': 'emote',
+            'uids': uids,
+            'emote_code': emote_code
+        })
+        
+        return jsonify({
+            'success': True,
+            'message': f'Emote queued for {len(uids)} player(s)',
+            'uids': uids,
+            'emote_code': emote_code,
+            'in_team': True
+        })
+        
+    except Exception as e:
+        return jsonify({
+            'success': False,
+            'message': str(e)
+        }), 500
+
+
+# ============================================
+# EMOTE ALL TEAM MEMBERS
+# ============================================
+
+@app.route('/emote/team', methods=['POST'])
+def emote_team():
+    """Send emote to all team members"""
+    try:
+        data = request.get_json(silent=True)
+        if not data:
+            return jsonify({
+                'success': False,
+                'message': 'JSON body required'
+            }), 400
+        
+        emote_code = data.get('emote_code')
+        
+        if not emote_code:
+            return jsonify({
+                'success': False,
+                'message': 'emote_code is required'
+            }), 400
+        
+        # Get LIVE team status
+        team_status = get_live_team_status()
+        if not team_status['in_team']:
+            return jsonify({
+                'success': False,
+                'message': 'Bot is not in any team',
+                'in_team': False
+            }), 400
+        
+        if not team_status.get('members'):
+            return jsonify({
+                'success': False,
+                'message': 'No team members found',
+                'in_team': True
+            }), 400
+        
+        uids = [m['uid'] for m in team_status['members']]
+        
+        # Queue emote for all members
+        command_queue.put({
+            'type': 'emote',
+            'uids': uids,
+            'emote_code': emote_code
+        })
+        
+        return jsonify({
+            'success': True,
+            'message': f'Emote queued for all {len(uids)} team members',
+            'uids': uids,
+            'emote_code': emote_code,
+            'team_size': len(uids)
+        })
+        
+    except Exception as e:
+        return jsonify({
+            'success': False,
+            'message': str(e)
+        }), 500
+
+
+# ============================================
+# GET TEAM MEMBERS - LIVE DATA
+# ============================================
+
+@app.route('/team/members', methods=['GET'])
+def get_team_members():
+    """Get current team members - LIVE from memory, not JSON"""
+    try:
+        team_status = get_live_team_status()
+        
+        # Bot is NOT in team
+        if not team_status['in_team']:
+            return jsonify({
+                'success': False,
+                'message': 'Bot is not in any team',
+                'in_team': False,
+                'members': [],
+                'total_members': 0
+            })
+        
+        # Bot IS in team - return LIVE data
+        return jsonify({
+            'success': True,
+            'message': 'Team members retrieved',
+            'in_team': True,
+            'total_members': team_status['total_members'],
+            'leader_uid': team_status['leader_uid'],
+            'members': team_status['members']
+        })
+        
+    except Exception as e:
+        return jsonify({
+            'success': False,
+            'message': str(e)
+        }), 500
+
+
+# ============================================
+# BOT STATUS
+# ============================================
+
+@app.route('/status', methods=['GET'])
+def bot_status():
+    """Get bot connection status"""
+    try:
+        from main import online_writer, whisper_writer, key, iv, region
+        
+        connections = {
+            'online': online_writer is not None,
+            'chat': whisper_writer is not None,
+            'authenticated': key is not None and iv is not None,
+            'region': region
+        }
+        
+        team_status = get_live_team_status()
+        
+        return jsonify({
+            'success': True,
+            'bot_online': connections['online'] and connections['chat'],
+            'connections': connections,
+            'team': team_status,
+            'queue_size': command_queue.qsize(),
+            'ws_clients': len(websocket_clients)
+        })
+        
+    except ImportError:
+        return jsonify({
+            'success': False,
+            'message': 'Bot not running',
+            'bot_online': False
+        }), 503
+
+
+# ============================================
+# HOME / API INFO
+# ============================================
+
+@app.route('/', methods=['GET'])
+def home():
+    """API documentation"""
+    return jsonify({
+        'name': 'FF Emote Bot API',
+        'version': '2.0',
+        'status': 'online',
+        'websocket': 'ws://host:5000/ws',
+        'endpoints': {
+            'POST /join': 'Join team - Body: {"teamcode": "ABC123"}',
+            'POST /emote': 'Send emote - Body: {"uids": ["123"], "emote_code": "909000001"}',
+            'POST /emote/team': 'Emote all team - Body: {"emote_code": "909000001"}',
+            'GET /team/members': 'Get team members (LIVE)',
+            'GET /status': 'Bot status',
+            'WS /ws': 'WebSocket for real-time updates'
+        }
+    })
+
+
+# ============================================
+# HELPER FUNCTIONS - LIVE DATA FROM MEMORY
+# ============================================
+
+def get_live_team_status():
+    """Get LIVE team status from bot memory (not JSON file)"""
+    try:
+        from main import team_collection_active, team_members_data, current_team_leader
+        
+        # Check if bot is actually in a team RIGHT NOW
+        in_team = team_collection_active and len(team_members_data) > 0
+        
+        if not in_team:
+            return {
+                'in_team': False,
+                'total_members': 0,
+                'leader_uid': None,
+                'members': []
+            }
+        
+        return {
+            'in_team': True,
+            'total_members': len(team_members_data),
+            'leader_uid': str(current_team_leader) if current_team_leader else None,
+            'members': team_members_data
+        }
+    except:
+        return {
+            'in_team': False,
+            'total_members': 0,
+            'leader_uid': None,
+            'members': []
+        }
+
+
+# ============================================
+# RUN SERVER
+# ============================================
+
+if __name__ == '__main__':
+    print("""
+╔══════════════════════════════════════════════╗
+║   FF Emote Bot API - Production v2.0         ║
+║   with WebSocket Support                     ║
+╚══════════════════════════════════════════════╝
+
+📡 HTTP API: http://0.0.0.0:5000
+🔌 WebSocket: ws://0.0.0.0:5000/ws
+
+Endpoints:
+  • POST /join           - Join team
+  • POST /emote          - Send emote (requires team)
+  • POST /emote/team     - Emote all team members
+  • GET  /team/members   - Get team info (LIVE)
+  • GET  /status         - Bot status
+  • WS   /ws             - Real-time updates
+
+    """)
+    app.run(host='0.0.0.0', port=7860, debug=False)

bot_with_api.py

@@ -0,0 +1,174 @@
+# ============================================
+# PRODUCTION BOT WITH API - bot_with_api.py
+# Clean command processing, no excess logs
+# ============================================
+
+import asyncio
+import threading
+from api import app, command_queue
+import sys
+
+# ============================================
+# COMMAND PROCESSOR - Clean & Efficient
+# ============================================
+
+async def process_api_commands():
+    """Process commands from API queue - production version"""
+    while True:
+        try:
+            if not command_queue.empty():
+                command = command_queue.get_nowait()
+                
+                if command['type'] == 'join':
+                    await handle_join(command)
+                
+                elif command['type'] == 'emote':
+                    await handle_emote(command)
+            
+            await asyncio.sleep(0.1)
+        
+        except Exception as e:
+            print(f"[API ERROR] {e}")
+            await asyncio.sleep(1)
+
+
+# ============================================
+# JOIN HANDLER
+# ============================================
+
+async def handle_join(command):
+    """Handle join team command"""
+    teamcode = command['teamcode']
+    
+    try:
+        from main import online_writer, key, iv
+        from xC4 import GenJoinSquadsPacket
+        
+        if not online_writer:
+            print(f"[JOIN] Failed - Bot not connected")
+            return
+        
+        if not key or not iv:
+            print(f"[JOIN] Failed - No encryption keys")
+            return
+        
+        packet = await GenJoinSquadsPacket(teamcode, key, iv)
+        online_writer.write(packet)
+        await online_writer.drain()
+        
+        print(f"[JOIN] ✓ Team: {teamcode}")
+        
+    except Exception as e:
+        print(f"[JOIN] ✗ Error: {e}")
+
+
+# ============================================
+# EMOTE HANDLER - Only works if in team
+# ============================================
+
+async def handle_emote(command):
+    """Handle emote command - checks team status first"""
+    uids = command['uids']
+    emote_code = command['emote_code']
+    
+    try:
+        from main import online_writer, key, iv, region, team_collection_active, team_members_data
+        from xC4 import Emote_k
+        
+        # Check if bot is in team
+        if not team_collection_active or len(team_members_data) == 0:
+            print(f"[EMOTE] ✗ Bot not in team - Skipped")
+            return
+        
+        if not online_writer or not key or not iv or not region:
+            print(f"[EMOTE] ✗ Bot not ready")
+            return
+        
+        success = 0
+        failed = 0
+        
+        for uid in uids:
+            try:
+                packet = await Emote_k(
+                    int(uid), 
+                    int(emote_code), 
+                    key, 
+                    iv,
+                    region
+                )
+                
+                online_writer.write(packet)
+                await online_writer.drain()
+                success += 1
+                
+                await asyncio.sleep(0.3)  # Rate limit
+                
+            except Exception as e:
+                failed += 1
+        
+        if success > 0:
+            print(f"[EMOTE] ✓ Sent: {success}/{len(uids)} | Code: {emote_code}")
+        if failed > 0:
+            print(f"[EMOTE] ✗ Failed: {failed}")
+        
+    except Exception as e:
+        print(f"[EMOTE] ✗ Error: {e}")
+
+
+# ============================================
+# FLASK SERVER THREAD
+# ============================================
+
+def run_flask():
+    """Run Flask in separate thread"""
+    app.run(host='0.0.0.0', port=7860, debug=False, use_reloader=False)
+
+
+# ============================================
+# MAIN RUNNER
+# ============================================
+
+async def run_bot_with_api():
+    """Main function - runs bot + API together"""
+    
+    # Start Flask API
+    flask_thread = threading.Thread(target=run_flask, daemon=True)
+    flask_thread.start()
+    print("[API] Started on http://0.0.0.0:5000")
+    
+    # Start command processor
+    api_processor = asyncio.create_task(process_api_commands())
+    
+    # Start main bot
+    try:
+        from main import StarTinG
+        
+        print("[BOT] Starting...")
+        bot_task = asyncio.create_task(StarTinG())
+        
+        await asyncio.gather(api_processor, bot_task)
+    
+    except ImportError as e:
+        print(f"[ERROR] Could not import bot: {e}")
+        print("[API] Running in API-only mode...")
+        await api_processor
+
+
+# ============================================
+# ENTRY POINT
+# ============================================
+
+if __name__ == '__main__':
+    print("""
+╔══════════════════════════════════════════════╗
+║      FF Emote Bot - Production Mode          ║
+╚══════════���═══════════════════════════════════╝
+
+Starting services...
+    """)
+    
+    try:
+        asyncio.run(run_bot_with_api())
+    except KeyboardInterrupt:
+        print("\n[SHUTDOWN] Stopping...")
+        sys.exit(0)

main.py

@@ -0,0 +1,869 @@
+import requests , os , psutil , sys , jwt , pickle , json , binascii , time , urllib3 , base64 , datetime , re , socket , threading , ssl , pytz , aiohttp
+from protobuf_decoder.protobuf_decoder import Parser
+from xC4 import * ; from xHeaders import *
+from datetime import datetime
+from google.protobuf.timestamp_pb2 import Timestamp
+from concurrent.futures import ThreadPoolExecutor
+from threading import Thread
+from Pb2 import DEcwHisPErMsG_pb2 , MajoRLoGinrEs_pb2 , PorTs_pb2 , MajoRLoGinrEq_pb2 , sQ_pb2 , Team_msg_pb2
+from cfonts import render, say
+
+
+#EMOTES BY MatrixCoder 
+
+urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)  
+
+# Global variables for API access - FILE START में
+online_writer = None
+whisper_writer = None
+key = None
+iv = None
+region = None
+
+# बाकी सब कुछ वैसा ही रहने दें...
+
+# ... rest of your existing global variables
+spam_room = False
+spammer_uid = None
+spam_chat_id = None
+spam_uid = None
+Spy = False
+Chat_Leave = False
+
+# Add to main.py at top with other globals:
+team_members_data = []
+team_history = []
+current_team_leader = None
+team_collection_active = False
+last_member_update = None
+previous_team_state = set()
+previous_team_uids = set()  # Track previous state
+####################################
+
+
+Hr = {
+    'User-Agent': "Dalvik/2.1.0 (Linux; U; Android 11; ASUS_Z01QD Build/PI)",
+    'Connection': "Keep-Alive",
+    'Accept-Encoding': "gzip",
+    'Content-Type': "application/x-www-form-urlencoded",
+    'Expect': "100-continue",
+    'X-Unity-Version': "2018.4.11f1",
+    'X-GA': "v1 1",
+    'ReleaseVersion': "OB52"}
+
+def get_random_color():
+    colors = [
+        "[FF0000]", "[00FF00]", "[0000FF]", "[FFFF00]", "[FF00FF]", "[00FFFF]", "[FFFFFF]", "[FFA500]",
+        "[A52A2A]", "[800080]", "[000000]", "[808080]", "[C0C0C0]", "[FFC0CB]", "[FFD700]", "[ADD8E6]",
+        "[90EE90]", "[D2691E]", "[DC143C]", "[00CED1]", "[9400D3]", "[F08080]", "[20B2AA]", "[FF1493]",
+        "[7CFC00]", "[B22222]", "[FF4500]", "[DAA520]", "[00BFFF]", "[00FF7F]", "[4682B4]", "[6495ED]",
+        "[5F9EA0]", "[DDA0DD]", "[E6E6FA]", "[B0C4DE]", "[556B2F]", "[8FBC8F]", "[2E8B57]", "[3CB371]",
+        "[6B8E23]", "[808000]", "[B8860B]", "[CD5C5C]", "[8B0000]", "[FF6347]", "[FF8C00]", "[BDB76B]",
+        "[9932CC]", "[8A2BE2]", "[4B0082]", "[6A5ACD]", "[7B68EE]", "[4169E1]", "[1E90FF]", "[191970]",
+        "[00008B]", "[000080]", "[008080]", "[008B8B]", "[B0E0E6]", "[AFEEEE]", "[E0FFFF]", "[F5F5DC]",
+        "[FAEBD7]"
+    ]
+    return random.choice(colors)
+#
+
+
+
+# ============================================
+# BROADCAST FUNCTION - WebSocket Updates
+# ============================================
+
+def broadcast_team_change(event_type, team_data):
+    """Broadcast team changes to WebSocket clients with data validation"""
+    try:
+        # Validate data before sending
+        if event_type in ['member_joined', 'member_left']:
+            player = team_data.get('player', {})
+            
+            # Ensure all required fields exist
+            validated_player = {
+                'uid': str(player.get('uid', 'unknown')),
+                'name': player.get('name', 'Unknown'),
+                'region': player.get('region', 'UNK'),
+                'level': int(player.get('level', 0)),
+                'character': str(player.get('character', 'Unknown')),
+                'position': player.get('position', 'Member')
+            }
+            
+            team_data['player'] = validated_player
+            
+            # Debug log
+            print(f"[WS-PREP] {event_type}: {validated_player['name']} (Level {validated_player['level']})")
+        
+        from api import broadcast_team_update
+        broadcast_team_update(event_type, team_data)
+    except Exception as e:
+        print(f"[WS-ERROR] Failed to broadcast: {e}")
+
+
+# ============================================
+# TEAM COLLECTION WITH STATE MANAGEMENT
+# ============================================
+
+async def collect_team_members_dynamic(packet_type, parsed_data):
+    """Team collection with proper state management and WebSocket broadcasting"""
+    global team_members_data, current_team_leader, team_collection_active
+    global last_member_update, previous_team_uids
+    
+    try:
+        if packet_type != '0500_LARGE':
+            return False
+        
+        new_members = []
+        
+        # Leader detection
+        if '1' in parsed_data and parsed_data['1'].get('data'):
+            leader_uid = parsed_data['1']['data']
+            if leader_uid != current_team_leader:
+                current_team_leader = leader_uid
+            
+            leader_info = await extract_complete_player_info(parsed_data, leader_uid, "Leader")
+            if leader_info and leader_info['name'] != "Player_Unknown":
+                if not any(m['uid'] == str(leader_uid) for m in new_members):
+                    new_members.append(leader_info)
+
+        # Deep scan
+        deep_players = await deep_scan_for_players(parsed_data)
+        for player in deep_players:
+            if not any(m['uid'] == player['uid'] for m in new_members):
+                new_members.append(player)
+
+        # Field structures
+        if '5' in parsed_data and 'data' in parsed_data['5']:
+            squad_data = parsed_data['5']['data']
+            field6_players = await extract_from_field_structure_fixed(squad_data)
+            for player in field6_players:
+                if not any(m['uid'] == player['uid'] for m in new_members):
+                    new_members.append(player)
+
+            # Nested
+            if '3' in squad_data and 'data' in squad_data['3']:
+                nested_data = squad_data['3']['data']
+                nested_players = await extract_from_field_structure_fixed(nested_data)
+                for player in nested_players:
+                    if not any(m['uid'] == player['uid'] for m in new_members):
+                        new_members.append(player)
+
+        # ========== STATE CHANGE DETECTION ==========
+        current_uids = set(m['uid'] for m in new_members)
+        
+        # Detect JOINED players
+        joined = current_uids - previous_team_uids
+        if joined:
+            for uid in joined:
+                player = next((m for m in new_members if m['uid'] == uid), None)
+                if player:
+                    print(f"[TEAM] + {player['name']} joined")
+                    
+                    # Broadcast join event with COMPLETE data
+                    broadcast_team_change('member_joined', {
+                        'player': {
+                            'uid': player['uid'],
+                            'name': player['name'],
+                            'region': player['region'],
+                            'level': player['level'],
+                            'character': player.get('character', 'Unknown'),
+                            'position': player['position']
+                        },
+                        'total_members': len(current_uids)
+                    })
+        
+        # Detect LEFT/KICKED players
+        left = previous_team_uids - current_uids
+        if left:
+            for uid in left:
+                old_player = next((m for m in team_members_data if m['uid'] == uid), None)
+                if old_player:
+                    print(f"[TEAM] - {old_player['name']} left")
+                    
+                    # Broadcast leave event with COMPLETE data
+                    broadcast_team_change('member_left', {
+                        'player': {
+                            'uid': old_player['uid'],
+                            'name': old_player['name'],
+                            'region': old_player['region'],
+                            'level': old_player['level'],
+                            'character': old_player.get('character', 'Unknown'),
+                            'position': old_player['position']
+                        },
+                        'total_members': len(current_uids)
+                    })
+        
+        # Update global state with ONLY current members
+        team_members_data.clear()
+        team_members_data.extend(new_members)
+        previous_team_uids = current_uids
+        
+        # Update team status
+        if len(new_members) > 0:
+            if not team_collection_active:
+                print(f"[TEAM] ✓ Joined team ({len(new_members)} members)")
+                
+                # Broadcast team joined with COMPLETE member data
+                broadcast_team_change('team_joined', {
+                    'in_team': True,
+                    'total_members': len(new_members),
+                    'leader_uid': str(current_team_leader) if current_team_leader else None,
+                    'members': [
+                        {
+                            'uid': m['uid'],
+                            'name': m['name'],
+                            'region': m['region'],
+                            'level': m['level'],
+                            'character': m.get('character', 'Unknown'),
+                            'position': m['position']
+                        }
+                        for m in new_members
+                    ]
+                })
+            
+            team_collection_active = True
+            last_member_update = datetime.now()
+            return True
+        else:
+            # No members found - bot left team
+            if team_collection_active:
+                print(f"[TEAM] ✗ Left team")
+                
+                # Broadcast team left
+                broadcast_team_change('team_left', {
+                    'in_team': False,
+                    'total_members': 0,
+                    'members': []
+                })
+            
+            team_collection_active = False
+            team_members_data.clear()
+            previous_team_uids.clear()
+            current_team_leader = None
+        
+        return False
+        
+    except:
+        return False
+
+
+async def extract_complete_player_info(parsed_data, uid, position="Member"):
+    """Extract player info - Better name detection"""
+    try:
+        player_info = {
+            'uid': str(uid),
+            'name': None,  # Will be set below
+            'region': 'UNK',
+            'level': 0,
+            'position': position,
+            'character': 'Unknown',
+            'timestamp': datetime.now().isoformat()
+        }
+        
+        def find_player_details(obj, target_uid, depth=0):
+            if depth > 5:
+                return None
+                
+            if isinstance(obj, dict):
+                if ('1' in obj and obj['1'].get('data') == target_uid):
+                    details = {}
+                    
+                    if '2' in obj and isinstance(obj['2'].get('data'), str):
+                        name = obj['2']['data']
+                        if name and len(name) > 1 and not name.isdigit():
+                            details['name'] = name
+                    
+                    if '3' in obj and isinstance(obj['3'].get('data'), str):
+                        details['region'] = obj['3']['data']
+                    
+                    if '5' in obj and isinstance(obj['5'].get('data'), int):
+                        details['level'] = obj['5']['data']
+                    
+                    if '6' in obj and isinstance(obj['6'].get('data'), (int, str)):
+                        details['character'] = str(obj['6']['data'])
+                    
+                    return details
+                
+                for key, value in obj.items():
+                    if isinstance(value, dict):
+                        result = find_player_details(value, target_uid, depth+1)
+                        if result:
+                            return result
+                    elif isinstance(value, list):
+                        for item in value:
+                            if isinstance(item, dict):
+                                result = find_player_details(item, target_uid, depth+1)
+                                if result:
+                                    return result
+            return None
+        
+        details = find_player_details(parsed_data, uid)
+        if details:
+            player_info.update(details)
+        
+        # If still no name found, use UID as fallback
+        if not player_info['name']:
+            player_info['name'] = f"Player_{uid}"
+        
+        return player_info
+        
+    except:
+        return None
+
+
+async def deep_scan_for_players(data, path="", depth=0):
+    """Scan for players"""
+    players = []
+    
+    if depth > 6:
+        return players
+        
+    if isinstance(data, dict):
+        if ('1' in data and '2' in data and 
+            isinstance(data['1'].get('data'), (int, str)) and
+            isinstance(data['2'].get('data'), str)):
+            
+            uid = data['1']['data']
+            name = data['2']['data']
+            
+            if (name and 
+                name != "Player_Unknown" and 
+                not name.startswith("Player_") and
+                not name.isdigit() and
+                len(name) > 1):
+                
+                player = {
+                    'uid': str(uid),
+                    'name': name,
+                    'region': data['3']['data'] if '3' in data and isinstance(data['3'].get('data'), str) else 'UNK',
+                    'level': data['5']['data'] if '5' in data and isinstance(data['5'].get('data'), int) else 0,
+                    'character': str(data['6']['data']) if '6' in data and isinstance(data['6'].get('data'), (int, str)) else 'Unknown',
+                    'position': 'Leader' if str(uid) == str(current_team_leader) else 'Member',
+                    'timestamp': datetime.now().isoformat()
+                }
+                players.append(player)
+        
+        for key, value in data.items():
+            if isinstance(value, (dict, list)):
+                nested_players = await deep_scan_for_players(value, f"{path}.{key}", depth+1)
+                players.extend(nested_players)
+    
+    elif isinstance(data, list):
+        for item in data:
+            if isinstance(item, (dict, list)):
+                nested_players = await deep_scan_for_players(item, f"{path}[]", depth+1)
+                players.extend(nested_players)
+    
+    return players
+
+
+async def extract_from_field_structure_fixed(squad_data):
+    """Extract from field structure"""
+    players = []
+    
+    try:
+        if '6' in squad_data and 'data' in squad_data['6']:
+            player_data = squad_data['6']['data']
+            if isinstance(player_data, dict) and '1' in player_data and '2' in player_data:
+                uid = player_data['1'].get('data')
+                name = player_data['2'].get('data')
+                
+                if uid and isinstance(name, str) and len(name) > 1 and not name.isdigit():
+                    player = {
+                        'uid': str(uid),
+                        'name': name,
+                        'region': player_data['3']['data'] if '3' in player_data and isinstance(player_data['3'].get('data'), str) else 'UNK',
+                        'level': player_data['5']['data'] if '5' in player_data and isinstance(player_data['5'].get('data'), int) else 0,
+                        'character': str(player_data['6']['data']) if '6' in player_data and isinstance(player_data['6'].get('data'), (int, str)) else 'Unknown',
+                        'position': 'Leader' if str(uid) == str(current_team_leader) else 'Member',
+                        'timestamp': datetime.now().isoformat()
+                    }
+                    players.append(player)
+        
+        for pos in ['1', '2', '3', '4', '7', '8']:
+            if pos in squad_data and 'data' in squad_data[pos]:
+                player_data = squad_data[pos]['data']
+                if isinstance(player_data, dict) and '1' in player_data and '2' in player_data:
+                    uid = player_data['1'].get('data')
+                    name = player_data['2'].get('data')
+                    
+                    if uid and isinstance(name, str) and len(name) > 1 and not name.isdigit():
+                        player = {
+                            'uid': str(uid),
+                            'name': name,
+                            'region': player_data['3']['data'] if '3' in player_data and isinstance(player_data['3'].get('data'), str) else 'UNK',
+                            'level': player_data['5']['data'] if '5' in player_data and isinstance(player_data['5'].get('data'), int) else 0,
+                            'character': str(player_data['6']['data']) if '6' in player_data and isinstance(player_data['6'].get('data'), (int, str)) else 'Unknown',
+                            'position': 'Leader' if str(uid) == str(current_team_leader) else 'Member',
+                            'timestamp': datetime.now().isoformat()
+                        }
+                        players.append(player)
+                        
+    except:
+        pass
+    
+    return players
+
+
+
+async def encrypted_proto(encoded_hex):
+    key = b'Yg&tc%DEuh6%Zc^8'
+    iv = b'6oyZDr22E3ychjM%'
+    cipher = AES.new(key, AES.MODE_CBC, iv)
+    padded_message = pad(encoded_hex, AES.block_size)
+    encrypted_payload = cipher.encrypt(padded_message)
+    return encrypted_payload
+
+async def GeNeRaTeAccEss(uid , password):
+    url = "https://100067.connect.garena.com/oauth/guest/token/grant"
+    headers = {
+        "Host": "100067.connect.garena.com",
+        "User-Agent": (await Ua()),
+        "Content-Type": "application/x-www-form-urlencoded",
+        "Accept-Encoding": "gzip, deflate, br",
+        "Connection": "close"}
+    data = {
+        "uid": uid,
+        "password": password,
+        "response_type": "token",
+        "client_type": "2",
+        "client_secret": "2ee44819e9b4598845141067b281621874d0d5d7af9d8f7e00c1e54715b7d1e3",
+        "client_id": "100067"}
+    async with aiohttp.ClientSession() as session:
+        async with session.post(url, headers=Hr, data=data) as response:
+            if response.status != 200: return "Failed to get access token"
+            data = await response.json()
+            open_id = data.get("open_id")
+            access_token = data.get("access_token")
+            return (open_id, access_token) if open_id and access_token else (None, None)
+
+async def EncRypTMajoRLoGin(open_id, access_token):
+    major_login = MajoRLoGinrEq_pb2.MajorLogin()
+    major_login.event_time = str(datetime.now())[:-7]
+    major_login.game_name = "free fire"
+    major_login.platform_id = 1
+    major_login.client_version = "1.120.2"
+    major_login.system_software = "Android OS 9 / API-28 (PQ3B.190801.10101846/G9650ZHU2ARC6)"
+    major_login.system_hardware = "Handheld"
+    major_login.telecom_operator = "Verizon"
+    major_login.network_type = "WIFI"
+    major_login.screen_width = 1920
+    major_login.screen_height = 1080
+    major_login.screen_dpi = "280"
+    major_login.processor_details = "ARM64 FP ASIMD AES VMH | 2865 | 4"
+    major_login.memory = 3003
+    major_login.gpu_renderer = "Adreno (TM) 640"
+    major_login.gpu_version = "OpenGL ES 3.1 v1.46"
+    major_login.unique_device_id = "Google|34a7dcdf-a7d5-4cb6-8d7e-3b0e448a0c57"
+    major_login.client_ip = "223.191.51.89"
+    major_login.language = "en"
+    major_login.open_id = open_id
+    major_login.open_id_type = "4"
+    major_login.device_type = "Handheld"
+    memory_available = major_login.memory_available
+    memory_available.version = 55
+    memory_available.hidden_value = 81
+    major_login.access_token = access_token
+    major_login.platform_sdk_id = 1
+    major_login.network_operator_a = "Verizon"
+    major_login.network_type_a = "WIFI"
+    major_login.client_using_version = "7428b253defc164018c604a1ebbfebdf"
+    major_login.external_storage_total = 36235
+    major_login.external_storage_available = 31335
+    major_login.internal_storage_total = 2519
+    major_login.internal_storage_available = 703
+    major_login.game_disk_storage_available = 25010
+    major_login.game_disk_storage_total = 26628
+    major_login.external_sdcard_avail_storage = 32992
+    major_login.external_sdcard_total_storage = 36235
+    major_login.login_by = 3
+    major_login.library_path = "/data/app/com.dts.freefireth-YPKM8jHEwAJlhpmhDhv5MQ==/lib/arm64"
+    major_login.reg_avatar = 1
+    major_login.library_token = "5b892aaabd688e571f688053118a162b|/data/app/com.dts.freefireth-YPKM8jHEwAJlhpmhDhv5MQ==/base.apk"
+    major_login.channel_type = 3
+    major_login.cpu_type = 2
+    major_login.cpu_architecture = "64"
+    major_login.client_version_code = "2019116753"
+    major_login.graphics_api = "OpenGLES2"
+    major_login.supported_astc_bitset = 16383
+    major_login.login_open_id_type = 4
+    major_login.analytics_detail = b"FwQVTgUPX1UaUllDDwcWCRBpWAUOUgsvA1snWlBaO1kFYg=="
+    major_login.loading_time = 13564
+    major_login.release_channel = "android"
+    major_login.extra_info = "KqsHTymw5/5GB23YGniUYN2/q47GATrq7eFeRatf0NkwLKEMQ0PK5BKEk72dPflAxUlEBir6Vtey83XqF593qsl8hwY="
+    major_login.android_engine_init_flag = 110009
+    major_login.if_push = 1
+    major_login.is_vpn = 1
+    major_login.origin_platform_type = "4"
+    major_login.primary_platform_type = "4"
+    string = major_login.SerializeToString()
+    return  await encrypted_proto(string)
+
+async def MajorLogin(payload):
+    url = "https://loginbp.ggblueshark.com/MajorLogin"
+    ssl_context = ssl.create_default_context()
+    ssl_context.check_hostname = False
+    ssl_context.verify_mode = ssl.CERT_NONE
+    async with aiohttp.ClientSession() as session:
+        async with session.post(url, data=payload, headers=Hr, ssl=ssl_context) as response:
+            if response.status == 200: return await response.read()
+            return None
+
+async def GetLoginData(base_url, payload, token):
+    url = f"{base_url}/GetLoginData"
+    ssl_context = ssl.create_default_context()
+    ssl_context.check_hostname = False
+    ssl_context.verify_mode = ssl.CERT_NONE
+    Hr['Authorization']= f"Bearer {token}"
+    async with aiohttp.ClientSession() as session:
+        async with session.post(url, data=payload, headers=Hr, ssl=ssl_context) as response:
+            if response.status == 200: return await response.read()
+            return None
+
+async def DecRypTMajoRLoGin(MajoRLoGinResPonsE):
+    proto = MajoRLoGinrEs_pb2.MajorLoginRes()
+    proto.ParseFromString(MajoRLoGinResPonsE)
+    return proto
+
+async def DecRypTLoGinDaTa(LoGinDaTa):
+    proto = PorTs_pb2.GetLoginData()
+    proto.ParseFromString(LoGinDaTa)
+    return proto
+
+async def DecodeWhisperMessage(hex_packet):
+    packet = bytes.fromhex(hex_packet)
+    proto = DEcwHisPErMsG_pb2.DecodeWhisper()
+    proto.ParseFromString(packet)
+    return proto
+
+async def decode_team_packet(hex_packet):
+    packet = bytes.fromhex(hex_packet)
+    proto = sQ_pb2.recieved_chat()
+    proto.ParseFromString(packet)
+    return proto
+
+async def xAuThSTarTuP(TarGeT, token, timestamp, key, iv):
+    uid_hex = hex(TarGeT)[2:]
+    uid_length = len(uid_hex)
+    encrypted_timestamp = await DecodE_HeX(timestamp)
+    encrypted_account_token = token.encode().hex()
+    encrypted_packet = await EnC_PacKeT(encrypted_account_token, key, iv)
+    encrypted_packet_length = hex(len(encrypted_packet) // 2)[2:]
+    if uid_length == 9: headers = '0000000'
+    elif uid_length == 8: headers = '00000000'
+    elif uid_length == 10: headers = '000000'
+    elif uid_length == 7: headers = '000000000'
+    else: print('Unexpected length') ; headers = '0000000'
+    return f"0115{headers}{uid_hex}{encrypted_timestamp}00000{encrypted_packet_length}{encrypted_packet}"
+
+async def cHTypE(H):
+    if not H: return 'Squid'
+    elif H == 1: return 'CLan'
+    elif H == 2: return 'PrivaTe'
+
+async def SEndMsG(H , message , Uid , chat_id , key , iv):
+    TypE = await cHTypE(H)
+    if TypE == 'Squid': msg_packet = await xSEndMsgsQ(message , chat_id , key , iv)
+    elif TypE == 'CLan': msg_packet = await xSEndMsg(message , 1 , chat_id , chat_id , key , iv)
+    elif TypE == 'PrivaTe': msg_packet = await xSEndMsg(message , 2 , Uid , Uid , key , iv)
+    return msg_packet
+
+async def SEndPacKeT(OnLinE , ChaT , TypE , PacKeT):
+    if TypE == 'ChaT' and ChaT: whisper_writer.write(PacKeT) ; await whisper_writer.drain()
+    elif TypE == 'OnLine': online_writer.write(PacKeT) ; await online_writer.drain()
+    else: return 'UnsoPorTed TypE ! >> ErrrroR (:():)' 
+
+async def TcPOnLine(ip, port, key_val, iv_val, AutHToKen, reconnect_delay=0.5):
+    global online_writer, key, iv, team_members_data, current_team_leader
+    global team_collection_active, previous_team_uids
+    
+    key = key_val
+    iv = iv_val
+    
+    while True:
+        try:
+            # Reset team state on new connection
+            team_members_data = []
+            current_team_leader = None
+            team_collection_active = False
+            previous_team_uids = set()
+            
+            reader, writer = await asyncio.open_connection(ip, int(port))
+            online_writer = writer
+            print(f"[ONLINE] Connected to {ip}:{port}")
+            
+            bytes_payload = bytes.fromhex(AutHToKen)
+            online_writer.write(bytes_payload)
+            await online_writer.drain()
+            
+            while True:
+                data2 = await reader.read(9999)
+                if not data2: break
+
+                packet_hex = data2.hex()
+                
+                # Team collection
+                if packet_hex.startswith('0500') and len(packet_hex) > 1000:
+                    try:
+                        decoded = await DeCode_PackEt(packet_hex[10:])
+                        parsed = json.loads(decoded)
+                        await collect_team_members_dynamic('0500_LARGE', parsed)
+                    except:
+                        pass
+                
+                # Your existing chat code
+                if data2.hex().startswith('0500') and len(data2.hex()) > 1000:
+                    try:
+                        packet = await DeCode_PackEt(data2.hex()[10:])
+                        packet = json.loads(packet)
+                        OwNer_UiD, CHaT_CoDe, SQuAD_CoDe = await GeTSQDaTa(packet)
+
+                        JoinCHaT = await AutH_Chat(3, OwNer_UiD, CHaT_CoDe, key, iv)
+                        await SEndPacKeT(whisper_writer, online_writer, 'ChaT', JoinCHaT)
+                    except:
+                        pass
+
+            online_writer.close()
+            await online_writer.wait_closed()
+            online_writer = None
+            
+            # Broadcast disconnect
+            if team_collection_active:
+                print(f"[TEAM] ✗ Disconnected from team")
+                broadcast_team_change('team_left', {
+                    'in_team': False,
+                    'total_members': 0,
+                    'members': []
+                })
+            
+            # Reset state on disconnect
+            team_members_data = []
+            current_team_leader = None
+            team_collection_active = False
+            previous_team_uids = set()
+
+        except Exception as e:
+            print(f"[ERROR] {ip}:{port} - {e}")
+            online_writer = None
+            
+            # Reset state on error
+            team_members_data = []
+            current_team_leader = None
+            team_collection_active = False
+            previous_team_uids = set()
+            
+        await asyncio.sleep(reconnect_delay)
+
+async def TcPChaT(ip, port, AutHToKen, key_val, iv_val, LoGinDaTaUncRypTinG, ready_event, region_val, reconnect_delay=0.5):
+    global spam_room, whisper_writer, spammer_uid, spam_chat_id, spam_uid, online_writer, chat_id, XX, uid, Spy, data2, Chat_Leave
+    global region  # API access के लिए
+    
+    # Update global variables for API
+    region = region_val
+    
+    print(region, 'TCP CHAT')
+    
+    while True:
+        try:
+            reader, writer = await asyncio.open_connection(ip, int(port))
+            whisper_writer = writer
+            print(f"[CHAT] Connected to {ip}:{port}")  # Debug message
+            
+            bytes_payload = bytes.fromhex(AutHToKen)
+            whisper_writer.write(bytes_payload)
+            await whisper_writer.drain()
+            ready_event.set()
+            
+            if LoGinDaTaUncRypTinG.Clan_ID:
+                clan_id = LoGinDaTaUncRypTinG.Clan_ID
+                clan_compiled_data = LoGinDaTaUncRypTinG.Clan_Compiled_Data
+                print('\n - TarGeT BoT in CLan ! ')
+                print(f' - Clan Uid > {clan_id}')
+                print(f' - BoT ConnEcTed WiTh CLan ChaT SuccEssFuLy ! ')
+                pK = await AuthClan(clan_id, clan_compiled_data, key_val, iv_val)
+                if whisper_writer:
+                    whisper_writer.write(pK)
+                    await whisper_writer.drain()
+                    
+            while True:
+                data = await reader.read(9999)
+                if not data: break
+
+                if data.hex().startswith("120000"):
+                    msg = await DeCode_PackEt(data.hex()[10:])
+                    chatdata = json.loads(msg)
+                    try:
+                        response = await DecodeWhisperMessage(data.hex()[10:])
+                        uid = response.Data.uid
+                        chat_id = response.Data.Chat_ID
+                        XX = response.Data.chat_type
+                        inPuTMsG = response.Data.msg.lower()
+                    except:
+                        response = None
+
+                    if response:
+                        if inPuTMsG.startswith(("/5")):
+                            try:
+                                dd = chatdata['5']['data']['16']
+                                print('msg in private')
+                                message = f"[B][C]{get_random_color()}\n\nAccepT My Invitation FasT\n\n"
+                                P = await SEndMsG(response.Data.chat_type, message, uid, chat_id, key_val, iv_val)
+                                await SEndPacKeT(whisper_writer, online_writer, 'ChaT', P)
+                                PAc = await OpEnSq(key_val, iv_val, region_val)
+                                await SEndPacKeT(whisper_writer, online_writer, 'OnLine', PAc)
+                                C = await cHSq(5, uid, key_val, iv_val, region_val)
+                                await asyncio.sleep(0.5)
+                                await SEndPacKeT(whisper_writer, online_writer, 'OnLine', C)
+                                V = await SEnd_InV(5, uid, key_val, iv_val, region_val)
+                                await asyncio.sleep(0.5)
+                                await SEndPacKeT(whisper_writer, online_writer, 'OnLine', V)
+                                E = await ExiT(None, key_val, iv_val)
+                                await asyncio.sleep(3)
+                                await SEndPacKeT(whisper_writer, online_writer, 'OnLine', E)
+                            except:
+                                print('msg in squad')
+
+                        if inPuTMsG.startswith('/x/'):
+                            CodE = inPuTMsG.split('/x/')[1]
+                            try:
+                                dd = chatdata['5']['data']['16']
+                                print('msg in private')
+                                EM = await GenJoinSquadsPacket(CodE, key_val, iv_val)
+                                await SEndPacKeT(whisper_writer, online_writer, 'OnLine', EM)
+                            except:
+                                print('msg in squad')
+
+                        if inPuTMsG.startswith('/solo'):
+                            leave = await ExiT(uid, key_val, iv_val)
+                            await SEndPacKeT(whisper_writer, online_writer, 'OnLine', leave)
+
+                        if inPuTMsG.strip().startswith('/s'):
+                            EM = await FS(key_val, iv_val)
+                            await SEndPacKeT(whisper_writer, online_writer, 'OnLine', EM)
+
+                        if inPuTMsG.strip().startswith('!e'):
+                            try:
+                                dd = chatdata['5']['data']['16']
+                                print('msg in private')
+                                message = f"[B][C]{get_random_color()}\n\nCommand Available OnLy In SQuaD ! \n\n"
+                                P = await SEndMsG(response.Data.chat_type, message, uid, chat_id, key_val, iv_val)
+                                await SEndPacKeT(whisper_writer, online_writer, 'ChaT', P)
+                            except:
+                                print('msg in squad')
+                                parts = inPuTMsG.strip().split()
+                                print(response.Data.chat_type, uid, chat_id)
+                                message = f'[B][C]{get_random_color()}\nACITVE TarGeT -> {xMsGFixinG(uid)}\n'
+                                P = await SEndMsG(response.Data.chat_type, message, uid, chat_id, key_val, iv_val)
+                                uid2 = uid3 = uid4 = uid5 = None
+                                s = False
+                                try:
+                                    uid = int(parts[1])
+                                    uid2 = int(parts[2])
+                                    uid3 = int(parts[3])
+                                    uid4 = int(parts[4])
+                                    uid5 = int(parts[5])
+                                    idT = int(parts[5])
+                                except ValueError as ve:
+                                    print("ValueError:", ve)
+                                    s = True
+                                except Exception:
+                                    idT = len(parts) - 1
+                                    idT = int(parts[idT])
+                                    print(idT)
+                                    print(uid)
+                                if not s:
+                                    try:
+                                        await SEndPacKeT(whisper_writer, online_writer, 'ChaT', P)
+                                        H = await Emote_k(uid, idT, key_val, iv_val, region_val)
+                                        await SEndPacKeT(whisper_writer, online_writer, 'OnLine', H)
+                                        if uid2:
+                                            H = await Emote_k(uid2, idT, key_val, iv_val, region_val)
+                                            await SEndPacKeT(whisper_writer, online_writer, 'OnLine', H)
+                                        if uid3:
+                                            H = await Emote_k(uid3, idT, key_val, iv_val, region_val)
+                                            await SEndPacKeT(whisper_writer, online_writer, 'OnLine', H)
+                                        if uid4:
+                                            H = await Emote_k(uid4, idT, key_val, iv_val, region_val)
+                                            await SEndPacKeT(whisper_writer, online_writer, 'OnLine', H)
+                                        if uid5:
+                                            H = await Emote_k(uid5, idT, key_val, iv_val, region_val)
+                                            await SEndPacKeT(whisper_writer, online_writer, 'OnLine', H)
+                                    except Exception as e:
+                                        pass
+
+
+            whisper_writer.close()
+            await whisper_writer.wait_closed()
+            whisper_writer = None
+
+        except Exception as e:
+            print(f"ErroR {ip}:{port} - {e}")
+            whisper_writer = None
+        await asyncio.sleep(reconnect_delay)
+
+async def MaiiiinE():
+    Uid, Pw = '4214594434','AE39055DB186EB71CADBAA70CD00764240E18B4742D0E16588C01E927FD85C2C'
+
+    open_id, access_token = await GeNeRaTeAccEss(Uid, Pw)
+    if not open_id or not access_token:
+        print("ErroR - InvaLid AccounT")
+        return None
+
+    PyL = await EncRypTMajoRLoGin(open_id, access_token)
+    MajoRLoGinResPonsE = await MajorLogin(PyL)
+    if not MajoRLoGinResPonsE:
+        print("TarGeT AccounT => BannEd / NoT ReGisTeReD ! ")
+        return None
+
+    MajoRLoGinauTh = await DecRypTMajoRLoGin(MajoRLoGinResPonsE)
+    UrL = MajoRLoGinauTh.url
+    print(UrL)
+    region_val = MajoRLoGinauTh.region
+
+    ToKen = MajoRLoGinauTh.token
+    TarGeT = MajoRLoGinauTh.account_uid
+    key_val = MajoRLoGinauTh.key
+    iv_val = MajoRLoGinauTh.iv
+    timestamp = MajoRLoGinauTh.timestamp
+
+    LoGinDaTa = await GetLoginData(UrL, PyL, ToKen)
+    if not LoGinDaTa:
+        print("ErroR - GeTinG PorTs From LoGin DaTa !")
+        return None
+        
+    LoGinDaTaUncRypTinG = await DecRypTLoGinDaTa(LoGinDaTa)
+    OnLinePorTs = LoGinDaTaUncRypTinG.Online_IP_Port
+    ChaTPorTs = LoGinDaTaUncRypTinG.AccountIP_Port
+    OnLineiP, OnLineporT = OnLinePorTs.split(":")
+    ChaTiP, ChaTporT = ChaTPorTs.split(":")
+    acc_name = LoGinDaTaUncRypTinG.AccountName
+    
+    print(ToKen)
+    equie_emote(ToKen, UrL)
+    AutHToKen = await xAuThSTarTuP(int(TarGeT), ToKen, int(timestamp), key_val, iv_val)
+    ready_event = asyncio.Event()
+
+    task1 = asyncio.create_task(TcPChaT(ChaTiP, ChaTporT, AutHToKen, key_val, iv_val, LoGinDaTaUncRypTinG, ready_event, region_val))
+    await ready_event.wait()
+    await asyncio.sleep(1)
+    task2 = asyncio.create_task(TcPOnLine(OnLineiP, OnLineporT, key_val, iv_val, AutHToKen))
+    
+    os.system('clear')
+    print(render('WINTER', colors=['white', 'green'], align='center'))
+    print('')
+    print(f" - BoT STarTinG And OnLine on TarGet : {TarGeT} | BOT NAME : {acc_name}\n")
+    print(f" - BoT sTaTus > GooD | OnLinE ! (:")    
+    print(f" - Subscribe > MatrixCoder | Gaming ! (:")    
+    await asyncio.gather(task1, task2)
+
+async def StarTinG():
+    while True:
+        try:
+            await asyncio.wait_for(MaiiiinE(), timeout=7 * 60 * 60)
+        except asyncio.TimeoutError:
+            print("Token ExpiRed ! , ResTartinG")
+        except Exception as e:
+            print(f"ErroR TcP - {e} => ResTarTinG ...")
+
+if __name__ == '__main__':
+    asyncio.run(StarTinG())

requirements.txt

@@ -0,0 +1,16 @@
+requests
+httpx
+google
+protobuf
+pycryptodome
+psutil
+PyJWT
+urllib3
+protobuf-decoder
+pytz
+aiohttp
+cfonts
+flask_cors
+flask
+flask-sock
+requests

xC4.py

@@ -0,0 +1,378 @@
+# By AbdeeLkarim BesTo
+
+import requests , json , binascii , time , urllib3 , base64 , datetime , re ,socket , threading , random , os , asyncio
+from protobuf_decoder.protobuf_decoder import Parser
+from Crypto.Cipher import AES
+from Crypto.Util.Padding import pad , unpad
+from datetime import datetime
+from google.protobuf.timestamp_pb2 import Timestamp
+
+urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
+
+Key , Iv = bytes([89, 103, 38, 116, 99, 37, 68, 69, 117, 104, 54, 37, 90, 99, 94, 56]) , bytes([54, 111, 121, 90, 68, 114, 50, 50, 69, 51, 121, 99, 104, 106, 77, 37])
+
+async def EnC_AEs(HeX):
+    cipher = AES.new(Key , AES.MODE_CBC , Iv)
+    return cipher.encrypt(pad(bytes.fromhex(HeX), AES.block_size)).hex()
+    
+async def DEc_AEs(HeX):
+    cipher = AES.new(Key , AES.MODE_CBC , Iv)
+    return unpad(cipher.decrypt(bytes.fromhex(HeX)), AES.block_size).hex()
+    
+async def EnC_PacKeT(HeX , K , V): 
+    return AES.new(K , AES.MODE_CBC , V).encrypt(pad(bytes.fromhex(HeX) ,16)).hex()
+    
+async def DEc_PacKeT(HeX , K , V):
+    return unpad(AES.new(K , AES.MODE_CBC , V).decrypt(bytes.fromhex(HeX)) , 16).hex()  
+
+async def EnC_Uid(H , Tp):
+    e , H = [] , int(H)
+    while H:
+        e.append((H & 0x7F) | (0x80 if H > 0x7F else 0)) ; H >>= 7
+    return bytes(e).hex() if Tp == 'Uid' else None
+
+async def EnC_Vr(N):
+    if N < 0: ''
+    H = []
+    while True:
+        BesTo = N & 0x7F ; N >>= 7
+        if N: BesTo |= 0x80
+        H.append(BesTo)
+        if not N: break
+    return bytes(H)
+    
+def DEc_Uid(H):
+    n = s = 0
+    for b in bytes.fromhex(H):
+        n |= (b & 0x7F) << s
+        if not b & 0x80: break
+        s += 7
+    return n
+    
+async def CrEaTe_VarianT(field_number, value):
+    field_header = (field_number << 3) | 0
+    return await EnC_Vr(field_header) + await EnC_Vr(value)
+
+async def CrEaTe_LenGTh(field_number, value):
+    field_header = (field_number << 3) | 2
+    encoded_value = value.encode() if isinstance(value, str) else value
+    return await EnC_Vr(field_header) + await EnC_Vr(len(encoded_value)) + encoded_value
+
+async def CrEaTe_ProTo(fields):
+    packet = bytearray()
+    for field, value in fields.items():
+        if isinstance(value, dict):
+            nested_packet = await CrEaTe_ProTo(value)  # لازم await
+            packet.extend(await CrEaTe_LenGTh(field, nested_packet))
+        elif isinstance(value, int):
+            packet.extend(await CrEaTe_VarianT(field, value))
+        elif isinstance(value, str) or isinstance(value, bytes):
+            packet.extend(await CrEaTe_LenGTh(field, value))
+    return packet
+    
+async def DecodE_HeX(H):
+    R = hex(H) 
+    F = str(R)[2:]
+    if len(F) == 1: F = "0" + F ; return F
+    else: return F
+
+async def Fix_PackEt(parsed_results):
+    result_dict = {}
+    for result in parsed_results:
+        field_data = {}
+        field_data['wire_type'] = result.wire_type
+        if result.wire_type == "varint":
+            field_data['data'] = result.data
+        if result.wire_type == "string":
+            field_data['data'] = result.data
+        if result.wire_type == "bytes":
+            field_data['data'] = result.data
+        elif result.wire_type == 'length_delimited':
+            field_data["data"] = await Fix_PackEt(result.data.results)
+        result_dict[result.field] = field_data
+    return result_dict
+
+async def DeCode_PackEt(input_text):
+    try:
+        parsed_results = Parser().parse(input_text)
+        parsed_results_objects = parsed_results
+        parsed_results_dict = await Fix_PackEt(parsed_results_objects)
+        json_data = json.dumps(parsed_results_dict)
+        return json_data
+    except Exception as e:
+        print(f"error {e}")
+        return None
+                      
+def xMsGFixinG(n):
+    return '🗿'.join(str(n)[i:i + 3] for i in range(0 , len(str(n)) , 3))
+    
+async def Ua():
+    versions = [
+        '4.0.18P6', '4.0.19P7', '4.0.20P1', '4.1.0P3', '4.1.5P2', '4.2.1P8',
+        '4.2.3P1', '5.0.1B2', '5.0.2P4', '5.1.0P1', '5.2.0B1', '5.2.5P3',
+        '5.3.0B1', '5.3.2P2', '5.4.0P1', '5.4.3B2', '5.5.0P1', '5.5.2P3'
+    ]
+    models = [
+        'SM-A125F', 'SM-A225F', 'SM-A325M', 'SM-A515F', 'SM-A725F', 'SM-M215F', 'SM-M325FV',
+        'Redmi 9A', 'Redmi 9C', 'POCO M3', 'POCO M4 Pro', 'RMX2185', 'RMX3085',
+        'moto g(9) play', 'CPH2239', 'V2027', 'OnePlus Nord', 'ASUS_Z01QD',
+    ]
+    android_versions = ['9', '10', '11', '12', '13', '14']
+    languages = ['en-US', 'es-MX', 'pt-BR', 'id-ID', 'ru-RU', 'hi-IN']
+    countries = ['USA', 'MEX', 'BRA', 'IDN', 'RUS', 'IND']
+    version = random.choice(versions)
+    model = random.choice(models)
+    android = random.choice(android_versions)
+    lang = random.choice(languages)
+    country = random.choice(countries)
+    return f"GarenaMSDK/{version}({model};Android {android};{lang};{country};)"
+    
+async def ArA_CoLor():
+    Tp = ["32CD32" , "00BFFF" , "00FA9A" , "90EE90" , "FF4500" , "FF6347" , "FF69B4" , "FF8C00" , "FF6347" , "FFD700" , "FFDAB9" , "F0F0F0" , "F0E68C" , "D3D3D3" , "A9A9A9" , "D2691E" , "CD853F" , "BC8F8F" , "6A5ACD" , "483D8B" , "4682B4", "9370DB" , "C71585" , "FF8C00" , "FFA07A"]
+    return random.choice(Tp)
+    
+async def xBunnEr():
+    bN = [902000126 , 902000154 , 902000003 , 902027018 , 902027027 , 902039014 , 902040027 , 902042011 , 902048021 , 902048018 , 902000027 , 902000078 , 902000013 , 902000093 , 902000100 , 902000117 , 902000111 , 902000151 , 902000207 , 902000203 , 902027016 , 902027018 , 902033016 , 902027018 , 902027018 , 902027018 , 902027018 , 902027018 , 902027018]
+    return random.choice(bN)
+
+async def xSEndMsg(Msg , Tp , Tp2 , id , K , V):
+    feilds = {1: id , 2: Tp2 , 3: Tp, 4: Msg, 5: 1735129800, 7: 2, 9: {1: "xBesTo - C4", 2: int(await xBunnEr()), 3: 901048018, 4: 330, 5: 909034009, 8: "xBesTo - C4", 10: 1, 11: 1, 13: {1: 2}, 14: {1: 12484827014, 2: 8, 3: "\u0010\u0015\b\n\u000b\u0013\f\u000f\u0011\u0004\u0007\u0002\u0003\r\u000e\u0012\u0001\u0005\u0006"}, 12: 0}, 10: "en", 13: {3: 1}}
+    Pk = (await CrEaTe_ProTo(feilds)).hex()
+    Pk = "080112" + await EnC_Uid(len(Pk) // 2, Tp='Uid') + Pk
+    return await GeneRaTePk(Pk, '1201', K, V)
+    
+async def xSEndMsgsQ(Msg , id , K , V):
+    fields = {1: id , 2: id , 4: Msg , 5: 1756580149, 7: 2, 8: 904990072, 9: {1: "xBe4!sTo - C4", 2: await xBunnEr(), 4: 330, 5: 827001005, 8: "xBe4!sTo - C4", 10: 1, 11: 1, 13: {1: 2}, 14: {1: 1158053040, 2: 8, 3: "\u0010\u0015\b\n\u000b\u0015\f\u000f\u0011\u0004\u0007\u0002\u0003\r\u000e\u0012\u0001\u0005\u0006"}}, 10: "en", 13: {2: 2, 3: 1}}
+    Pk = (await CrEaTe_ProTo(fields)).hex()
+    Pk = "080112" + await EnC_Uid(len(Pk) // 2, Tp='Uid') + Pk
+    return await GeneRaTePk(Pk, '1201', K, V)     
+async def AuthClan(CLan_Uid, AuTh, K, V):
+    fields = {1: 3, 2: {1: int(CLan_Uid), 2: 1, 4: str(AuTh)}}
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '1201' , K , V)
+async def AutH_GlobAl(K, V):
+    fields = {
+    1: 3,
+    2: {
+        2: 5,
+        3: "en"
+    }
+    }
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '1215' , K , V)
+
+async def LagSquad(K,V):
+    fields = {
+    1: 15,
+    2: {
+        1: 1124759936,
+        2: 1
+    }
+    }
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '0515' , K , V)
+
+async def GeT_Status(PLayer_Uid , K , V):
+    PLayer_Uid = await EnC_Uid(PLayer_Uid , Tp = 'Uid')
+    if len(PLayer_Uid) == 8: Pk = f'080112080a04{PLayer_Uid}1005'
+    elif len(PLayer_Uid) == 10: Pk = f"080112090a05{PLayer_Uid}1005"
+    return await GeneRaTePk(Pk , '0f15' , K , V)
+           
+async def SPam_Room(Uid , Rm , Nm , K , V):
+    fields = {1: 78, 2: {1: int(Rm), 2: f"[{ArA_CoLor()}]{Nm}", 3: {2: 1, 3: 1}, 4: 330, 5: 1, 6: 201, 10: xBunnEr(), 11: int(Uid), 12: 1}}
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '0e15' , K , V)
+async def GenJoinSquadsPacket(code,  K , V):
+    fields = {}
+    fields[1] = 4
+    fields[2] = {}
+    fields[2][4] = bytes.fromhex("01090a0b121920")
+    fields[2][5] = str(code)
+    fields[2][6] = 6
+    fields[2][8] = 1
+    fields[2][9] = {}
+    fields[2][9][2] = 800
+    fields[2][9][6] = 11
+    fields[2][9][8] = "1.111.1"
+    fields[2][9][9] = 5
+    fields[2][9][10] = 1
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '0515' , K , V)   
+async def GenJoinGlobaL(owner , code , K, V):
+    fields = {
+    1: 4,
+    2: {
+        1: owner,
+        6: 1,
+        8: 1,
+        13: "en",
+        15: code,
+        16: "OR",
+    }
+    }
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '0515' , K , V)
+
+async def FS(K,V,region):
+    fields = {
+            1: 9,
+            2: {
+                1: 13256361202
+            }
+            }
+    if region.lower() == "ind":
+        packet = '0514'
+    elif region.lower() == "bd":
+        packet = "0519"
+    else:
+        packet = "0515"
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , packet , K , V)
+
+
+
+
+#EMOTES BY PARAHEX X CODEX
+async def Emote_k(TarGeT , idT, K, V,region):
+    fields = {
+        1: 21,
+        2: {
+            1: 804266360,
+            2: 909000001,
+            5: {
+                1: TarGeT,
+                3: idT,
+            }
+        }
+    }
+    if region.lower() == "ind":
+        packet = '0514'
+    elif region.lower() == "bd":
+        packet = "0519"
+    else:
+        packet = "0515"
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , packet , K , V)
+
+#EMOTES BY PARAHEX X CODEX
+
+
+async def GeTSQDaTa(D):
+    uid = D['5']['data']['1']['data']
+    chat_code = D["5"]["data"]["17"]["data"]
+    squad_code = D["5"]["data"]["31"]["data"]
+
+
+    return uid, chat_code , squad_code
+
+
+async def AutH_Chat(T , uid, code , K, V):
+    fields = {
+  1: T,
+  2: {
+    1: uid,
+    3: "en",
+    4: str(code)
+  }
+}
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '1215' , K , V)
+async def Msg_Sq(msg, owner, bot, K, V):
+    fields = {
+    1: 1,
+    2: 2,
+    2: {
+        1: bot,
+        2: owner,
+        4: msg,
+        5: 1757799182,
+        7: 2,
+        9: {
+            1: "Fun1w5a2",
+            2: await xBunnEr(),
+            3: 909000024,
+            4: 330,
+            5: 909000024,
+            7: 2,
+            10: 1,
+            11: 1,
+            12: 0,
+            13: {1: 2},
+            14: {
+                1: bot,
+                2: 8,
+                3: "\u0010\u0015\b\n\u000b\u0013\f\u000f\u0011\u0004\u0007\u0002\u0003\r\u000e\u0012\u0001\u0005\u0006"
+            }
+        },
+        10: "ar",
+        13: {3: 1},
+        14: ""
+    }
+}
+    proto_bytes = await CrEaTe_ProTo(fields)
+    return await GeneRaTePk(proto_bytes.hex(), '1215', K, V)
+
+
+async def ghost_pakcet(player_id , secret_code ,K , V):
+    fields = {
+        1: 61,
+        2: {
+            1: int(player_id),  
+            2: {
+                1: int(player_id),  
+                2: int(time.time()),  
+                3: "MR3SKR",
+                5: 12,  
+                6: 9999999,
+                7: 1,
+                8: {
+                    2: 1,
+                    3: 1,
+                },
+                9: 3,
+            },
+            3: secret_code,},}
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '0515' , K , V)
+async def GeneRaTePk(Pk , N , K , V):
+    PkEnc = await EnC_PacKeT(Pk , K , V)
+    _ = await DecodE_HeX(int(len(PkEnc) // 2))
+    if len(_) == 2: HeadEr = N + "000000"
+    elif len(_) == 3: HeadEr = N + "00000"
+    elif len(_) == 4: HeadEr = N + "0000"
+    elif len(_) == 5: HeadEr = N + "000"
+    else: print('ErroR => GeneRatinG ThE PacKeT !! ')
+    return bytes.fromhex(HeadEr + _ + PkEnc)
+async def OpEnSq(K , V,region):
+    fields = {1: 1, 2: {2: "\u0001", 3: 1, 4: 1, 5: "en", 9: 1, 11: 1, 13: 1, 14: {2: 5756, 6: 11, 8: "1.111.5", 9: 2, 10: 4}}}
+    if region.lower() == "ind":
+        packet = '0514'
+    elif region.lower() == "bd":
+        packet = "0519"
+    else:
+        packet = "0515"
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , packet , K , V)
+
+async def cHSq(Nu , Uid , K , V,region):
+    fields = {1: 17, 2: {1: int(Uid), 2: 1, 3: int(Nu - 1), 4: 62, 5: "\u001a", 8: 5, 13: 329}}
+    if region.lower() == "ind":
+        packet = '0514'
+    elif region.lower() == "bd":
+        packet = "0519"
+    else:
+        packet = "0515"
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , packet , K , V)
+
+
+
+async def SEnd_InV(Nu , Uid , K , V,region):
+    
+    fields = {1: 2 , 2: {1: int(Uid) , 2: region , 4: int(Nu)}}
+
+    if region.lower() == "ind":
+        packet = '0514'
+    elif region.lower() == "bd":
+        packet = "0519"
+    else:
+        packet = "0515"
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , packet , K , V)
+
+    
+async def ExiT(idT , K , V):
+    fields = {
+        1: 7,
+        2: {
+            1: idT,
+        }
+        }
+    return await GeneRaTePk((await CrEaTe_ProTo(fields)).hex() , '0515' , K , V) 

xHeaders.py

@@ -0,0 +1,224 @@
+import requests , os , psutil , sys , jwt , pickle , json , binascii , time , urllib3 , base64 , datetime , re ,socket , threading
+from protobuf_decoder.protobuf_decoder import Parser
+from xC4 import *
+from datetime import datetime
+from google.protobuf.timestamp_pb2 import Timestamp
+from concurrent.futures import ThreadPoolExecutor
+from threading import Thread
+
+urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning) 
+
+def ToK():
+    while True:
+        try:
+            r = requests.get('https://tokens-asfufvfshnfkhvbb.francecentral-01.azurewebsites.net/ReQuesT?&type=ToKens')
+            t = r.text
+            i = t.find("ToKens : [")
+            if i != -1:
+                j = t.find("]", i)
+                L = [x.strip(" '\"") for x in t[i+11:j].split(',') if x.strip()]
+                if L:
+                    with open("token.txt", "w") as f:
+                        f.write(random.choice(L))
+        except: pass
+        time.sleep(5 * 60 * 60)
+
+Thread(target=ToK , daemon = True).start()
+
+
+
+def equie_emote(JWT,url):
+    url = f"{url}/ChooseEmote"
+
+    headers = {
+        "Accept-Encoding": "gzip",
+        "Authorization": f"Bearer {JWT}",
+        "Connection": "Keep-Alive",
+        "Content-Type": "application/x-www-form-urlencoded",
+        "Expect": "100-continue",
+        #"Host": "clientbp.ggblueshark.com",
+        "ReleaseVersion": "OB52",
+        "User-Agent": "Dalvik/2.1.0 (Linux; U; Android 9; G011A Build/PI)",
+        "X-GA": "v1 1",
+        "X-Unity-Version": "2018.4.11f1",
+    }
+
+    data = bytes.fromhex("CA F6 83 22 2A 25 C7 BE FE B5 1F 59 54 4D B3 13")
+
+    requests.post(url, headers=headers, data=data)
+
+
+
+
+
+def GeTToK():  
+    with open("token.txt") as f: return f.read().strip()
+    
+def Likes(id):
+    try:
+        text = requests.get(f"https://tokens-asfufvfshnfkhvbb.francecentral-01.azurewebsites.net/ReQuesT?id={id}&type=likes").text
+        get = lambda p: re.search(p, text)
+        name, lvl, exp, lb, la, lg = (get(r).group(1) if get(r) else None for r in 
+            [r"PLayer NamE\s*:\s*(.+)", r"PLayer SerVer\s*:\s*(.+)", r"Exp\s*:\s*(\d+)", 
+             r"LiKes BeFore\s*:\s*(\d+)", r"LiKes After\s*:\s*(\d+)", r"LiKes GiVen\s*:\s*(\d+)"])
+        return name , f"{lvl}" if lvl else None, int(lb) if lb else None, int(la) if la else None, int(lg) if lg else None
+    except: return None, None, None, None, None
+    
+def Requests_SPam(id):
+    Api = requests.get(f'https://tokens-asfufvfshnfkhvbb.francecentral-01.azurewebsites.net/ReQuesT?id={id}&type=spam')        
+    if Api.status_code in [200, 201] and '[SuccessFuLy] -> SenDinG Spam ReQuesTs !' in Api.text: return True
+    else: return False
+
+def GeT_Name(uid , Token):
+    data = bytes.fromhex(EnC_AEs(f"08{EnC_Uid(uid , Tp = 'Uid')}1007"))
+    url = "https://clientbp.common.ggbluefox.com/GetPlayerPersonalShow"
+    headers = {
+        'X-Unity-Version': '2018.4.11f1',
+        'ReleaseVersion': 'OB52',
+        'Content-Type': 'application/x-www-form-urlencoded',
+        'X-GA': 'v1 1',
+        'Authorization': f'Bearer {GeTToK()}',
+        'Content-Length': '16',
+        'User-Agent': 'Dalvik/2.1.0 (Linux; U; Android 7.1.2; ASUS_Z01QD Build/QKQ1.190825.002)',
+        'Host': 'clientbp.ggblueshark.com',
+        'Connection': 'Keep-Alive',
+        'Accept-Encoding': 'gzip'
+    }
+    response = requests.post(url , headers=headers , data=data ,verify=False)
+    if response.status_code == 200 or 201:
+        packet = binascii.hexlify(response.content).decode('utf-8')
+        BesTo_data = json.loads(DeCode_PackEt(packet))      
+        try:
+            a1 = BesTo_data["1"]["data"]["3"]["data"]
+            return a1
+        except: return ''  
+    else: return ''
+            	  	
+def GeT_PLayer_InFo(uid , Token):
+    data = bytes.fromhex(EnC_AEs(f"08{EnC_Uid(uid , Tp = 'Uid')}1007"))
+    url = "https://clientbp.common.ggbluefox.com/GetPlayerPersonalShow"
+    headers = {
+        'X-Unity-Version': '2018.4.11f1',
+        'ReleaseVersion': 'OB52',
+        'Content-Type': 'application/x-www-form-urlencoded',
+        'X-GA': 'v1 1',
+        'Authorization': f'Bearer {GeTToK()}',
+        'Content-Length': '16',
+        'User-Agent': 'Dalvik/2.1.0 (Linux; U; Android 7.1.2; ASUS_Z01QD Build/QKQ1.190825.002)',
+        'Host': 'clientbp.ggblueshark.com',
+        'Connection': 'Keep-Alive',
+        'Accept-Encoding': 'gzip'}
+    response = requests.post(url , headers=headers , data=data ,verify=False)
+    if response.status_code == 200 or 201:
+        packet = binascii.hexlify(response.content).decode('utf-8')
+        BesTo_data =  json.loads(DeCode_PackEt(packet))
+        NoCLan = False   
+        try:        
+            a1 = str(BesTo_data["1"]["data"]["1"]["data"])
+            a2 = BesTo_data["1"]["data"]["21"]["data"]
+            a3 = BesTo_data["1"]["data"]["3"]["data"]
+            player_server = BesTo_data["1"]["data"]["5"]["data"]
+            player_bio = BesTo_data["9"]["data"]["9"]["data"]
+            player_level = BesTo_data["1"]["data"]["6"]["data"]
+            account_date = datetime.fromtimestamp(BesTo_data["1"]["data"]["44"]["data"]).strftime("%I:%M %p - %d/%m/%y")
+            last_login = datetime.fromtimestamp(BesTo_data["1"]["data"]["24"]["data"]).strftime("%I:%M %p - %d/%m/%y")
+            try:
+                clan_id = BesTo_data["6"]["data"]["1"]["data"]
+                clan_name = BesTo_data["6"]["data"]["2"]["data"]
+                clan_leader = BesTo_data["6"]["data"]["3"]["data"]
+                clan_level = BesTo_data["6"]["data"]["4"]["data"]
+                clan_members_num = BesTo_data["6"]["data"]["6"]["data"]
+                clan_leader_name = BesTo_data["7"]["data"]["3"]["data"]                       
+            except:
+                NoCLan = True
+            if NoCLan:
+            	a = f'''
+[b][c][90EE90] [SuccessFully] - Get PLayer s'InFo !
+
+[FFFF00][1] - ProFile InFo :
+[ffffff]	
+ Name : {a3}
+ Uid : {xMsGFixinG(a1)}
+ Likes : {xMsGFixinG(a2)}
+ LeveL : {player_level}
+ Server : {player_server}
+ Bio : {player_bio}
+ Creating : {account_date}
+ LasT LoGin : {last_login}
+ 
+  [90EE90]Dev : C4 Team OfficieL\n'''            
+            	a = a.replace('[i]','')
+            	return a
+            	  	            	            
+            else:            	          	                        
+            	a = f'''
+[b][c][90EE90] [SuccessFully] - Get PLayer s'InFo !
+
+[FFFF00][1] - ProFile InFo :
+[ffffff]	
+ Name : {a3}
+ Uid : {xMsGFixinG(a1)}
+ Likes : {xMsGFixinG(a2)}
+ LeveL : {player_level}
+ Server : {player_server}
+ Bio : {player_bio}
+ Creating : {account_date}
+ LasT LoGin : {last_login}
+
+[b][c][FFFF00][2] - Guild InFo :
+[ffffff]
+ Guild Name : {clan_name}
+ Guild Uid : {xMsGFixinG(clan_id)}
+ Guild LeveL : {clan_level}
+ Guild Members : {clan_members_num}
+ Leader s'Uid : {xMsGFixinG(clan_leader)}
+ Leader s'Name : {clan_leader_name}
+
+  [90EE90]Dev : C4 Team OfficieL\n'''	
+            	a = a.replace('[i]','')    
+            	return a
+                                       
+        except Exception as e:
+           return f'\n[b][c][FFD700]FaiLEd GeTinG PLayer InFo !\n'
+    else:
+        return f'\n[b][c][FFD700]FaiLEd GeTinG PLayer InFo !\n'
+    
+def DeLet_Uid(id , Tok):
+    print(f' Done FuckinG > {id} ')
+    url = 'https://clientbp.common.ggbluefox.com/RemoveFriend'
+    headers = {
+        'X-Unity-Version': '2018.4.11f1',
+        'ReleaseVersion': 'OB52',
+        'Content-Type': 'application/x-www-form-urlencoded',
+        'X-GA': 'v1 1',
+        'Authorization': f'Bearer {Tok}',
+        'Content-Length': '16',
+        'User-Agent': 'Dalvik/2.1.0 (Linux; U; Android 7.1.2; ASUS_Z01QD Build/QKQ1.190825.002)',
+        'Host': 'clientbp.ggblueshark.com',
+        'Connection': 'Keep-Alive',
+        'Accept-Encoding': 'gzip'}
+    data = bytes.fromhex(EnC_AEs(f"08a7c4839f1e10{EnC_Uid(id , Tp = 'Uid')}"))
+    ResPonse = requests.post(url , headers=headers , data=data , verify=False)    
+    if ResPonse.status_code == 400 and 'BR_FRIEND_NOT_SAME_REGION' in ResPonse.text:
+        return f'[b][c]Id : {xMsGFixinG(id)} Not In Same Region !'
+    elif ResPonse.status_code == 200:
+        return f'[b][c]Good Response Done Delete Id : {xMsGFixinG(id)} !'
+    else:
+        return f'[b][c]Erorr !'
+                                                        
+def ChEck_The_Uid(id):
+    Api = requests.get("https://panel-g2ccathtf6gdcmdw.polandcentral-01.azurewebsites.net/Uids")
+    if Api.status_code not in [200, 201]: 
+        return False    
+    lines = Api.text.splitlines()    
+    for i, line in enumerate(lines):
+        if f' - Uid : {id}' in line:
+            expire, status = None, None
+            for sub_line in lines[i:]:
+                if "Expire In" in sub_line: 
+                    expire = re.search(r"Expire In\s*:\s*(.*)", sub_line).group(1).strip()
+                if "Status" in sub_line: 
+                    status = re.search(r"Status\s*:\s*(\w+)", sub_line).group(1)
+                if expire and status: return status, expire
+            return False
+    return False