Skip to content

Commit

Permalink
Fixed the missing x amount of posts
Browse files Browse the repository at this point in the history
  • Loading branch information
UltimaHoarder committed Oct 10, 2020
1 parent 45f7102 commit 8acd4f7
Show file tree
Hide file tree
Showing 2 changed files with 36 additions and 28 deletions.
32 changes: 18 additions & 14 deletions modules/onlyfans.py
Original file line number Diff line number Diff line change
Expand Up @@ -435,27 +435,31 @@ def process_mass_messages(message, limit):
link2 = f"https://onlyfans.com/api2/v2/stories/highlights/{item['id']}?app-token={app_token}"
master_set.append(link2)
master_set2 = main_helper.assign_session(master_set, sessions)
media_set = []
media_set = {}
media_set["set"] = []
media_set["found"] = False
count = len(master_set2)
max_attempts = 100
for attempt in list(range(max_attempts)):
print("Scrape Attempt: "+str(attempt+1)+"/"+str(max_attempts))
media_set2 = pool.starmap(media_scraper, product(
master_set2, [sessions], [formatted_directories], [username], [api_type]))
media_set.extend(media_set2)
if count > 0:
faulty = [x for x in media_set2 if not x]
if not faulty:
print("Found: "+api_type)
break
else:
num = len(faulty)*100
print("Missing "+str(num)+" Posts... Retrying...")
master_set2 = main_helper.restore_missing_data(
master_set2, media_set2)
else:
print("No "+api_type+" Found.")
media_set["set"].extend(media_set2)
faulty = [x for x in media_set2 if not x]
if not faulty:
print("Found: "+api_type)
media_set["found"] = True
break
else:
if count < 2:
break
num = len(faulty)*100
print("Missing "+str(num)+" Posts... Retrying...")
master_set2 = main_helper.restore_missing_data(
master_set2, media_set2)
if not media_set["found"]:
print("No "+api_type+" Found.")
media_set = media_set["set"]
main_helper.delete_empty_directories(api_directory)
media_set = [x for x in media_set]
media_set = main_helper.format_media_set(media_set)
Expand Down
32 changes: 18 additions & 14 deletions modules/starsavn.py
Original file line number Diff line number Diff line change
Expand Up @@ -289,27 +289,31 @@ def prepare_scraper(sessions, site_name, item):
str(item["id"])
master_set.append(link2)
master_set2 = main_helper.assign_session(master_set, sessions)
media_set = []
media_set = {}
media_set["set"] = []
media_set["found"] = False
count = len(master_set2)
max_attempts = 100
for attempt in list(range(max_attempts)):
print("Scrape Attempt: "+str(attempt+1)+"/"+str(max_attempts))
media_set2 = pool.starmap(media_scraper, product(
master_set2, [sessions], [formatted_directories], [username], [api_type]))
media_set.extend(media_set2)
if count > 0:
faulty = [x for x in media_set2 if not x]
if not faulty:
print("Found: "+api_type)
break
else:
num = len(faulty)*100
print("Missing "+str(num)+" Posts... Retrying...")
master_set2 = main_helper.restore_missing_data(
master_set2, media_set2)
else:
print("No "+api_type+" Found.")
media_set["set"].extend(media_set2)
faulty = [x for x in media_set2 if not x]
if not faulty:
print("Found: "+api_type)
media_set["found"] = True
break
else:
if count < 2:
break
num = len(faulty)*100
print("Missing "+str(num)+" Posts... Retrying...")
master_set2 = main_helper.restore_missing_data(
master_set2, media_set2)
if not media_set["found"]:
print("No "+api_type+" Found.")
media_set = media_set["set"]
main_helper.delete_empty_directories(api_directory)
media_set = [x for x in media_set]
media_set = main_helper.format_media_set(media_set)
Expand Down

0 comments on commit 8acd4f7

Please sign in to comment.