Update app.py
Browse files
app.py
CHANGED
|
@@ -534,7 +534,7 @@ def simulate_spotify_view(video_id: str, proxy: Proxy, session: requests.Session
|
|
| 534 |
|
| 535 |
|
| 536 |
def simulate_views_background(url: str, platform: str, count: int, delay: int, parallel_processes: int, session: requests.Session = None):
|
| 537 |
-
for _ in range(parallel_processes):
|
| 538 |
asyncio.run(simulate_one_view_process(url, platform, count, delay, session))
|
| 539 |
|
| 540 |
async def simulate_one_view_process(url: str, platform: str, count: int, delay: int, session: requests.Session = None):
|
|
@@ -557,7 +557,7 @@ async def simulate_one_view_process(url: str, platform: str, count: int, delay:
|
|
| 557 |
simulate_twitch_view(video_id, proxy, session)
|
| 558 |
elif platform == "spotify":
|
| 559 |
simulate_spotify_view(video_id, proxy, session)
|
| 560 |
-
await asyncio.sleep(delay)
|
| 561 |
except Exception as e:
|
| 562 |
pass
|
| 563 |
|
|
@@ -608,7 +608,7 @@ async def login(username: str = Form(...), password: str = Form(...), platform:
|
|
| 608 |
return e
|
| 609 |
|
| 610 |
@app.post("/simulate")
|
| 611 |
-
async def simulate(urls: str = Form(...), platform: str = Form(...), count: int = Form(...), delay: int = Form(...), parallel_processes: int = Form(...)
|
| 612 |
try:
|
| 613 |
session = None
|
| 614 |
if os.getenv(f'{platform.upper()}_USER') and os.getenv(f'{platform.upper()}_PASSWORD'):
|
|
|
|
| 534 |
|
| 535 |
|
| 536 |
def simulate_views_background(url: str, platform: str, count: int, delay: int, parallel_processes: int, session: requests.Session = None):
|
| 537 |
+
for _ in range(parallel_processes):
|
| 538 |
asyncio.run(simulate_one_view_process(url, platform, count, delay, session))
|
| 539 |
|
| 540 |
async def simulate_one_view_process(url: str, platform: str, count: int, delay: int, session: requests.Session = None):
|
|
|
|
| 557 |
simulate_twitch_view(video_id, proxy, session)
|
| 558 |
elif platform == "spotify":
|
| 559 |
simulate_spotify_view(video_id, proxy, session)
|
| 560 |
+
await asyncio.sleep(delay)
|
| 561 |
except Exception as e:
|
| 562 |
pass
|
| 563 |
|
|
|
|
| 608 |
return e
|
| 609 |
|
| 610 |
@app.post("/simulate")
|
| 611 |
+
async def simulate(background_tasks: BackgroundTasks, urls: str = Form(...), platform: str = Form(...), count: int = Form(...), delay: int = Form(...), parallel_processes: int = Form(...)):
|
| 612 |
try:
|
| 613 |
session = None
|
| 614 |
if os.getenv(f'{platform.upper()}_USER') and os.getenv(f'{platform.upper()}_PASSWORD'):
|