Skip to content
This repository has been archived by the owner on Jan 6, 2025. It is now read-only.

implementation offer for tapswap livestream code extraction and submission #163

Open
wants to merge 2 commits into
base: main
Choose a base branch
from
Open

implementation offer for tapswap livestream code extraction and submission #163

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
2f72166
Add condition for chrome options
shamhi Jul 1, 2024
bb20cad
implementation offer for tapswap livestream code extraction and submi…
TemoSulava Jul 7, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
123 changes: 99 additions & 24 deletions bot/core/tapper.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,8 +1,10 @@
import json
import asyncio
from time import time
from time import time, sleep
from random import randint

import yt_dlp

import aiohttp
from aiocfscrape import CloudflareScraper
from aiohttp_proxy import ProxyConnector
Expand All @@ -17,6 +19,12 @@
from bot.exceptions import InvalidSession
from .headers import headers

import pytube
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why is this being imported if it is not being used anywhere?

import pytesseract
import cv2
from PIL import Image
import re


class Tapper:
def __init__(self, tg_client: Client, lock: asyncio.Lock):
Expand Down Expand Up @@ -70,7 +78,8 @@ async def get_auth_url(self, proxy: str | None) -> str:
url='https://app.tapswap.ai/'
))

auth_url = web_view.url.replace('tgWebAppVersion=6.7', 'tgWebAppVersion=7.2')
auth_url = web_view.url.replace(
'tgWebAppVersion=6.7', 'tgWebAppVersion=7.2')

self.user_id = (await self.tg_client.get_me()).id

Expand All @@ -83,14 +92,16 @@ async def get_auth_url(self, proxy: str | None) -> str:
raise error

except Exception as error:
logger.error(f"{self.session_name} | Unknown error during Authorization: {escape_html(error)}")
logger.error(
f"{self.session_name} | Unknown error during Authorization: {escape_html(error)}")
await asyncio.sleep(delay=3)

async def login(self, http_client: aiohttp.ClientSession, auth_url: str, proxy: str) -> tuple[dict[str], str]:
response_text = ''
try:
async with self.lock:
response_text, x_cv, x_touch = login_in_browser(auth_url, proxy=proxy)
response_text, x_cv, x_touch = login_in_browser(
auth_url, proxy=proxy)

response_json = json.loads(response_text)
access_token = response_json.get('access_token', '')
Expand Down Expand Up @@ -160,7 +171,8 @@ async def send_taps(self, http_client: aiohttp.ClientSession, taps: int) -> dict
response_text = ''
try:
timestamp = int(time() * 1000)
content_id = int((timestamp * self.user_id * self.user_id / self.user_id) % self.user_id % self.user_id)
content_id = int((timestamp * self.user_id * self.user_id /
self.user_id) % self.user_id % self.user_id)

json_data = {'taps': taps, 'time': timestamp}

Expand All @@ -185,7 +197,8 @@ async def check_proxy(self, http_client: aiohttp.ClientSession, proxy: Proxy) ->
ip = (await response.json()).get('origin')
logger.info(f"{self.session_name} | Proxy IP: {ip}")
except Exception as error:
logger.error(f"{self.session_name} | Proxy: {proxy} | Error: {escape_html(error)}")
logger.error(
f"{self.session_name} | Proxy: {proxy} | Error: {escape_html(error)}")

async def run(self, proxy: str | None) -> None:
access_token_created_time = 0
Expand All @@ -201,6 +214,50 @@ async def run(self, proxy: str | None) -> None:

auth_url = await self.get_auth_url(proxy=proxy)

async def extract_code_from_frame(frame):
image = Image.fromarray(cv2.cvtColor(frame, cv2.COLOR_BGR2RGB))
text = pytesseract.image_to_string(image)

match = re.search(r'[A-Za-z0-9]{6,}', text)
if match:
return match.group(0)
return None

async def submit_code(http_client, code):
url = "https://api.tapswap.ai/api/player/apply_reward_code"

http_client.headers['Content-Type'] = 'application/json'
payload = {'code': code}
response = await http_client.post(url=url, json=payload)
response_text = await response.text()
if response.status == 401:
print("Unauthorized: Please check the authentication.")
print(
f"Submitted Code: {code}, Response: {response.status}, {response_text}")

async def monitor_youtube_stream(http_client):
youtube_url = "https://www.youtube.com/live/0Sfo3oBkfSU"
ydl_opts = {'format': 'best'}
while True:
try:
with yt_dlp.YoutubeDL(ydl_opts) as ydl:
info_dict = ydl.extract_info(
youtube_url, download=False)
video_url = info_dict['url']
cap = cv2.VideoCapture(video_url)
success, frame = cap.read()
if success:
code = await extract_code_from_frame(frame)
if code:
await submit_code(http_client, code)
await asyncio.sleep(20)
except Exception as e:
logger.error(
f"Error monitoring YouTube stream: {escape_html(e)}")
await asyncio.sleep(20)

await monitor_youtube_stream(http_client)

while True:
try:
if http_client.closed:
Expand All @@ -209,7 +266,8 @@ async def run(self, proxy: str | None) -> None:
proxy_conn.close()

proxy_conn = ProxyConnector().from_url(proxy) if proxy else None
http_client = aiohttp.ClientSession(headers=headers, connector=proxy_conn)
http_client = aiohttp.ClientSession(
headers=headers, connector=proxy_conn)

if time() - access_token_created_time >= 1800:
profile_data, access_token = await self.login(http_client=http_client, auth_url=auth_url, proxy=proxy)
Expand All @@ -225,7 +283,8 @@ async def run(self, proxy: str | None) -> None:
if tap_bot:
bot_earned = profile_data['bot_shares']

logger.success(f"{self.session_name} | Tap bot earned +{bot_earned:,} coins!")
logger.success(
f"{self.session_name} | Tap bot earned +{bot_earned:,} coins!")

balance = profile_data['player']['shares']

Expand All @@ -239,16 +298,19 @@ async def run(self, proxy: str | None) -> None:
claims = profile_data['player']['claims']
if claims:
for task_id in claims:
logger.info(f"{self.session_name} | Sleep 5s before claim <m>{task_id}</m> reward")
logger.info(
f"{self.session_name} | Sleep 5s before claim <m>{task_id}</m> reward")
await asyncio.sleep(delay=5)

status = await self.claim_reward(http_client=http_client, task_id=task_id)
if status is True:
logger.success(f"{self.session_name} | Successfully claim <m>{task_id}</m> reward")
logger.success(
f"{self.session_name} | Successfully claim <m>{task_id}</m> reward")

await asyncio.sleep(delay=1)

taps = randint(a=settings.RANDOM_TAPS_COUNT[0], b=settings.RANDOM_TAPS_COUNT[1])
taps = randint(
a=settings.RANDOM_TAPS_COUNT[0], b=settings.RANDOM_TAPS_COUNT[1])

if active_turbo:
taps += settings.ADD_TAPS_ON_TURBO
Expand Down Expand Up @@ -281,24 +343,28 @@ async def run(self, proxy: str | None) -> None:
if (energy_boost_count > 0
and available_energy < settings.MIN_AVAILABLE_ENERGY
and settings.APPLY_DAILY_ENERGY is True):
logger.info(f"{self.session_name} | Sleep 5s before activating the daily energy boost")
logger.info(
f"{self.session_name} | Sleep 5s before activating the daily energy boost")
await asyncio.sleep(delay=5)

status = await self.apply_boost(http_client=http_client, boost_type="energy")
if status is True:
logger.success(f"{self.session_name} | Energy boost applied")
logger.success(
f"{self.session_name} | Energy boost applied")

await asyncio.sleep(delay=1)

continue

if turbo_boost_count > 0 and settings.APPLY_DAILY_TURBO is True:
logger.info(f"{self.session_name} | Sleep 5s before activating the daily turbo boost")
logger.info(
f"{self.session_name} | Sleep 5s before activating the daily turbo boost")
await asyncio.sleep(delay=5)

status = await self.apply_boost(http_client=http_client, boost_type="turbo")
if status is True:
logger.success(f"{self.session_name} | Turbo boost applied")
logger.success(
f"{self.session_name} | Turbo boost applied")

await asyncio.sleep(delay=1)

Expand All @@ -310,12 +376,14 @@ async def run(self, proxy: str | None) -> None:
if (settings.AUTO_UPGRADE_TAP is True
and balance > tap_prices.get(next_tap_level, 0)
and next_tap_level <= settings.MAX_TAP_LEVEL):
logger.info(f"{self.session_name} | Sleep 5s before upgrade tap to {next_tap_level} lvl")
logger.info(
f"{self.session_name} | Sleep 5s before upgrade tap to {next_tap_level} lvl")
await asyncio.sleep(delay=5)

status = await self.upgrade_boost(http_client=http_client, boost_type="tap")
if status is True:
logger.success(f"{self.session_name} | Tap upgraded to {next_tap_level} lvl")
logger.success(
f"{self.session_name} | Tap upgraded to {next_tap_level} lvl")

await asyncio.sleep(delay=1)

Expand All @@ -330,7 +398,8 @@ async def run(self, proxy: str | None) -> None:

status = await self.upgrade_boost(http_client=http_client, boost_type="energy")
if status is True:
logger.success(f"{self.session_name} | Energy upgraded to {next_energy_level} lvl")
logger.success(
f"{self.session_name} | Energy upgraded to {next_energy_level} lvl")

await asyncio.sleep(delay=1)

Expand All @@ -345,7 +414,8 @@ async def run(self, proxy: str | None) -> None:

status = await self.upgrade_boost(http_client=http_client, boost_type="charge")
if status is True:
logger.success(f"{self.session_name} | Charge upgraded to {next_charge_level} lvl")
logger.success(
f"{self.session_name} | Charge upgraded to {next_charge_level} lvl")

await asyncio.sleep(delay=1)

Expand All @@ -357,10 +427,13 @@ async def run(self, proxy: str | None) -> None:
if not proxy_conn.closed:
proxy_conn.close()

random_sleep = randint(settings.SLEEP_BY_MIN_ENERGY[0], settings.SLEEP_BY_MIN_ENERGY[1])
random_sleep = randint(
settings.SLEEP_BY_MIN_ENERGY[0], settings.SLEEP_BY_MIN_ENERGY[1])

logger.info(f"{self.session_name} | Minimum energy reached: {available_energy}")
logger.info(f"{self.session_name} | Sleep {random_sleep:,}s")
logger.info(
f"{self.session_name} | Minimum energy reached: {available_energy}")
logger.info(
f"{self.session_name} | Sleep {random_sleep:,}s")

await asyncio.sleep(delay=random_sleep)

Expand All @@ -370,11 +443,13 @@ async def run(self, proxy: str | None) -> None:
raise error

except Exception as error:
logger.error(f"{self.session_name} | Unknown error: {escape_html(error)}")
logger.error(
f"{self.session_name} | Unknown error: {escape_html(error)}")
await asyncio.sleep(delay=3)

else:
sleep_between_clicks = randint(a=settings.SLEEP_BETWEEN_TAP[0], b=settings.SLEEP_BETWEEN_TAP[1])
sleep_between_clicks = randint(
a=settings.SLEEP_BETWEEN_TAP[0], b=settings.SLEEP_BETWEEN_TAP[1])

if active_turbo is True:
sleep_between_clicks = 4
Expand Down
6 changes: 4 additions & 2 deletions bot/utils/scripts.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -133,8 +133,10 @@ def escape_html(text: str) -> str:

options.add_argument("--headless")
options.add_argument("--log-level=3")
options.add_argument('--no-sandbox')
options.add_argument('--disable-dev-shm-usage')
if os.name == 'posix':
options.add_argument('--no-sandbox')
options.add_argument('--disable-dev-shm-usage')

driver = None

session_queue = Queue()
Expand Down
Binary file modified requirements.txt
View file
Open in desktop
Binary file not shown.