mirror of
https://gitea.augustin64.fr/piair/MsRewards-Reborn.git
synced 2025-06-25 10:53:58 +02:00
Compare commits
14 Commits
Author | SHA1 | Date | |
---|---|---|---|
f8f3ff2382 | |||
024b556f5e | |||
b4c9204bf2 | |||
f810f0ee3c | |||
afac7e9539 | |||
ae12c18270 | |||
dfd51bc040 | |||
12a6968ee0 | |||
8726785dc8 | |||
e9f629dee4 | |||
c9a838d368 | |||
808916ddd3 | |||
c51c463338 | |||
a22d1e6ddb |
@ -3,7 +3,7 @@
|
||||
|
||||
A Microsoft reward automator, designed to work headless on any server.
|
||||
Using a discord webhook or SQL to log points everyday.
|
||||
Using Selenium and geckodriver.
|
||||
Using Selenium and Geckodriver.
|
||||
|
||||
## If you're using docker (way easier)
|
||||
to use docker, run
|
||||
@ -12,14 +12,14 @@ sudo docker build .
|
||||
#copy the build id
|
||||
sudo docker run -ti --name MsRewards [build id]
|
||||
```
|
||||
Then, fill the config and start the programm everydays with
|
||||
Then, fill the config and start the program everyday with
|
||||
```
|
||||
sudo docker start MsRewards
|
||||
```
|
||||
|
||||
## Other configuration
|
||||
|
||||
To use the database, I recommand MySql, Create a database with the name you want and create a table `daily`, like the one from the image :
|
||||
To use the database, I recommend MySql, Create a database with the name you want and create a table `daily`, like the one from the image :
|
||||

|
||||
|
||||
You have to use the default world list (`sudo apt install wfrench`). The language is french by default, but you can change it if you want.
|
||||
|
514
V5.py
514
V5.py
@ -5,19 +5,15 @@ from modules.config import *
|
||||
from modules.tools import *
|
||||
from modules.error import *
|
||||
from modules.driver_tools import *
|
||||
import modules.globals as g
|
||||
|
||||
global driver
|
||||
driver = None
|
||||
global _mail, _password, _otp, display
|
||||
|
||||
# TODO : replace by a better print (with logging, cf https://realpython.com/python-logging/)
|
||||
def printf(e):
|
||||
printf2(str(e), _mail)
|
||||
driver = g.driver
|
||||
display = g.display
|
||||
|
||||
|
||||
# TODO
|
||||
# handle "panda"'s error: error while logging in preventing some task to be done
|
||||
# check that each card worked (lot of misses lately) -- test that -- don't crash at least
|
||||
# Fix l'affichage du compteur de custom_sleep
|
||||
# handle "panda"'s error: error while logging in preventing some task to be done SadPanda.svg:
|
||||
|
||||
|
||||
# create a webdriver
|
||||
@ -44,11 +40,11 @@ def firefox_driver(mobile=False, headless=False):
|
||||
if mobile :
|
||||
options.set_preference("general.useragent.override", MOBILE_USER_AGENT)
|
||||
driver = webdriver.Firefox(options=options)
|
||||
driver.set_window_size(1070 + hash(_mail)%20 , 1900 + hash(_password + "salt")%10) # mobile resolution are crazy high now, right ?
|
||||
driver.set_window_size(1070 + hash(g._mail)%20 , 1900 + hash(g._password + "salt")%10) # mobile resolution are crazy high now, right ?
|
||||
else :
|
||||
options.set_preference("general.useragent.override", PC_USER_AGENT)
|
||||
driver = webdriver.Firefox(options=options)
|
||||
driver.set_window_size(1900 + hash(_mail)%20 , 1070 + hash(_password + "salt")%10)
|
||||
driver.set_window_size(1900 + hash(g._mail)%20 , 1070 + hash(g._password + "salt")%10)
|
||||
return(driver)
|
||||
|
||||
|
||||
@ -84,10 +80,9 @@ def log_error(error, ldriver=driver, log=FULL_LOG):
|
||||
)
|
||||
file = File("screenshot.png")
|
||||
embed.set_image(url="attachment://screenshot.png")
|
||||
embed.set_footer(text=_mail)
|
||||
webhookFailure.send(embed=embed, file=file)
|
||||
webhookFailure.send(file=File("page.html"))
|
||||
|
||||
embed.set_footer(text=g._mail)
|
||||
webhookFailure.send(embed=embed, username="error", file=file, avatar_url = AVATAR_URL)
|
||||
webhookFailure.send(username="error", file=File("page.html"), avatar_url = AVATAR_URL)
|
||||
|
||||
|
||||
# close the tab currently on and go back to the one first, or the one specified
|
||||
@ -103,7 +98,7 @@ def play_quiz2(override=10) -> None:
|
||||
printf("starting play_quiz2")
|
||||
for j in range(override):
|
||||
try:
|
||||
rgpd_popup(driver)
|
||||
# rgpd_popup(driver)
|
||||
custom_sleep(uniform(3, 5))
|
||||
page_html = driver.page_source
|
||||
secret_answer = search('IG:"([^"]+)"', page_html)[1] # variable used to calculate offset
|
||||
@ -137,9 +132,9 @@ def play_quiz8():
|
||||
printf(f"play_quiz8 : start, override : {override}")
|
||||
try:
|
||||
counter = 0
|
||||
rgpd_popup(driver)
|
||||
# rgpd_popup(driver)
|
||||
for _ in range(override):
|
||||
custom_sleep(uniform(3, 5))
|
||||
sleep(uniform(3, 5))
|
||||
correct_answers = []
|
||||
for i in range(1,9):
|
||||
try :
|
||||
@ -156,10 +151,10 @@ def play_quiz8():
|
||||
try:
|
||||
answer_elem = driver.find_element(By.ID, answer_id)
|
||||
answer_elem.click()
|
||||
custom_sleep(1)
|
||||
sleep(1)
|
||||
except exceptions.NoSuchElementException :
|
||||
driver.refresh()
|
||||
custom_sleep(10)
|
||||
sleep(10)
|
||||
answer_elem = driver.find_element(By.ID, answer_id)
|
||||
answer_elem.click()
|
||||
except ElementClickInterceptedException :
|
||||
@ -184,7 +179,7 @@ def play_quiz4(override=None):
|
||||
for i in range(override):
|
||||
custom_sleep(uniform(3, 5))
|
||||
txt = driver.page_source
|
||||
rgpd_popup(driver)
|
||||
# rgpd_popup(driver)
|
||||
answer_option = search('correctAnswer":"([^"]+)', txt)[1]
|
||||
answer_option = answer_option.replace("\\u0027", "'") # replace Unicode weird symbols
|
||||
try:
|
||||
@ -215,160 +210,135 @@ def do_poll():
|
||||
printf("do_poll : end")
|
||||
|
||||
|
||||
# finds all task to do, and launch them
|
||||
def all_cards(): # return to the main page and closes all other tabs
|
||||
def reset(part2=False):
|
||||
if len(driver.window_handles) == 1:
|
||||
driver.get("https://www.bing.com/rewardsapp/flyout")
|
||||
if part2:
|
||||
row_element = driver.find_elements(By.CSS_SELECTOR, f'[class="i-h rw-sh fp_row"]')[1]
|
||||
expanded = row_element.get_attribute("aria-expanded")
|
||||
if expanded != "true":
|
||||
row_element.click()
|
||||
else:
|
||||
def all_cards():
|
||||
driver.get("https://rewards.bing.com")
|
||||
liste = driver.find_elements(By.CLASS_NAME, "c-card-content")
|
||||
custom_sleep(2)
|
||||
try :
|
||||
promo()
|
||||
except Exception as e:
|
||||
#printf(format_error(e))
|
||||
printf("no promo card")
|
||||
|
||||
for i in range(len(liste)):
|
||||
printf(f"carte {i}")
|
||||
try :
|
||||
checked = ("mee-icon-AddMedium" in liste[i].get_attribute("innerHTML"))
|
||||
except StaleElementReferenceException :
|
||||
liste = driver.find_elements(By.CLASS_NAME, "c-card-content")
|
||||
printf(f"staled, {len(liste)}")
|
||||
checked = ("mee-icon-AddMedium" in liste[i].get_attribute("innerHTML"))
|
||||
if checked:
|
||||
custom_sleep(3)
|
||||
driver.execute_script("arguments[0].scrollIntoView();", liste[i])
|
||||
liste[i].click()
|
||||
if len(driver.window_handles) > 1 :
|
||||
driver.switch_to.window(driver.window_handles[1])
|
||||
printf(f"fermeture : {driver.current_url}")
|
||||
driver.close()
|
||||
driver.switch_to.window(driver.window_handles[0])
|
||||
if driver.current_url != "https://www.bing.com/rewardsapp/flyout":
|
||||
driver.get("https://www.bing.com/rewardsapp/flyout")
|
||||
reset(part2)
|
||||
|
||||
def daily_cards(): # cartes de la premiere partie (renouvelées chaque jours).
|
||||
try_play()
|
||||
close_tab(driver.window_handles[1])
|
||||
try :
|
||||
# make sure that the daily area is expanded
|
||||
row_element = driver.find_elements(By.CSS_SELECTOR, f'[class="i-h rw-sh fp_row"]')[0]
|
||||
expanded = row_element.get_attribute("aria-expanded")
|
||||
if expanded != "true":
|
||||
row_element.click()
|
||||
for i in range(3):
|
||||
custom_sleep(uniform(3, 5))
|
||||
driver.refresh()
|
||||
liste = driver.find_elements(By.CLASS_NAME, "c-card-content")
|
||||
if ("mee-icon-AddMedium" in liste[i].get_attribute("innerHTML")) :
|
||||
printf(f"carte {i} not okay. Retrying.")
|
||||
liste[i].click()
|
||||
driver.switch_to.window(driver.window_handles[1])
|
||||
try_play()
|
||||
close_tab(driver.window_handles[1])
|
||||
except :
|
||||
pass
|
||||
else :
|
||||
try :
|
||||
titre = "Placeholder"
|
||||
elm = driver.find_elements(By.CLASS_NAME, 'promo_cont')
|
||||
elm[i].click()
|
||||
sleep(1)
|
||||
titre = driver.title
|
||||
try_play(titre)
|
||||
sleep(1)
|
||||
reset()
|
||||
printf(f"DailyCard {titre} ok")
|
||||
welcome_tour(liste[i])
|
||||
except Exception as e:
|
||||
log_error(f"all_cards card {titre} error ({format_error(e)})")
|
||||
"""
|
||||
try : # devrait renvoyer vrai si la carte i est faite ou pas, a l'aide su symbole en haut a droite de la carte
|
||||
elm = driver.find_element(By.XPATH, f"/html/body/div/div/div[3]/div[2]/div[1]/div[2]/div/div[{i+1}]/a/div/div[2]/div[1]/div[2]/div")
|
||||
if not ("correctCircle" in elm.get_attribute("innerHTML")):
|
||||
printf(f"missed card {i}")
|
||||
try_play(titre)
|
||||
sleep(3)
|
||||
reset()
|
||||
except Exception as e :
|
||||
printf(format_error(e) + "probablement ok - check card")
|
||||
# if it fail, it's probably okay -> when all three card are done, the pannel fold
|
||||
"""
|
||||
except Exception as e:
|
||||
log_error(e)
|
||||
print(format_error(e))
|
||||
log_error("no new windows", driver)
|
||||
custom_sleep(3)
|
||||
|
||||
def weekly_cards():
|
||||
# make sure that the weekly area is expanded
|
||||
row_element = driver.find_elements(By.CSS_SELECTOR, f'[class="i-h rw-sh fp_row"]')[1]
|
||||
expanded = row_element.get_attribute("aria-expanded")
|
||||
if expanded != "true":
|
||||
row_element.click()
|
||||
|
||||
for i in range(20): # Should raise an error whene there is no card left
|
||||
printf("début de l'une des cartes")
|
||||
elm = driver.find_elements(By.CLASS_NAME, 'promo_cont')
|
||||
def welcome_tour(elm):
|
||||
try :
|
||||
elm[0].click()
|
||||
except Exception as e :
|
||||
print(f"{e} + {driver.current_url}")
|
||||
break
|
||||
driver.find_element(By.CSS_SELECTOR, '[class="welcome-tour-next-button c-call-to-action c-glyph"]').click()
|
||||
except :
|
||||
pass
|
||||
driver.find_element(By.CSS_SELECTOR, '[class="quiz-link gray-button c-call-to-action c-glyph f-lightweight"]').click()
|
||||
sleep(5)
|
||||
driver.find_element(By.CSS_SELECTOR, '[class="c-glyph glyph-cancel"]').click()
|
||||
elm.click()
|
||||
driver.find_element(By.CSS_SELECTOR, '[class="quiz-link gray-button c-call-to-action c-glyph f-lightweight"]').click()
|
||||
sleep(5)
|
||||
driver.find_element(By.CSS_SELECTOR, '[class="c-glyph glyph-cancel"]').click()
|
||||
elm.click()
|
||||
driver.find_element(By.CSS_SELECTOR, '[class="quiz-link gray-button c-call-to-action c-glyph f-lightweight"]').click()
|
||||
sleep(5)
|
||||
driver.find_element(By.CSS_SELECTOR, '[class="c-glyph glyph-cancel"]').click()
|
||||
|
||||
def spotify():
|
||||
custom_sleep(5)
|
||||
driver.find_element(By.CSS_SELECTOR, '[data-bi-id="spotify-premium gratuit"]').click()
|
||||
custom_sleep(5)
|
||||
close_tab(driver.window_handles[1])
|
||||
|
||||
def promo():
|
||||
elm = driver.find_element(By.ID, "promo-item")
|
||||
while elm:
|
||||
driver.execute_script("arguments[0].click();", elm)
|
||||
custom_sleep(3)
|
||||
if len(driver.window_handles) > 1 :
|
||||
driver.switch_to.window(driver.window_handles[len(driver.window_handles)-1])
|
||||
sleep(1)
|
||||
titre = driver.title
|
||||
printf(f"carte {titre} en cours")
|
||||
try_play(titre)
|
||||
reset(True)
|
||||
sleep(1)
|
||||
#try:
|
||||
# findall('href="([^<]+)" title=""', driver.page_source)[3] # return error if there is no cards left to do
|
||||
#except:
|
||||
# break
|
||||
|
||||
def top_cards():
|
||||
for _ in range(2):
|
||||
try_play()
|
||||
close_tab(driver.window_handles[1])
|
||||
else :
|
||||
try :
|
||||
driver.find_element(By.XPATH, "/html/body/div/div/div[3]/div[1]/div/div[1]/div[2]").click()
|
||||
reset()
|
||||
except Exception as e:
|
||||
printf(format_error(e))
|
||||
break
|
||||
|
||||
try :
|
||||
#top_cards()
|
||||
print("top card not working really well right now. Disableing them")
|
||||
except Exception as e:
|
||||
log_error(e)
|
||||
|
||||
try:
|
||||
daily_cards()
|
||||
print("daily card")
|
||||
except Exception as e:
|
||||
log_error(e)
|
||||
|
||||
try :
|
||||
weekly_cards()
|
||||
print("weekly card")
|
||||
except Exception as e:
|
||||
log_error(e)
|
||||
|
||||
spotify()
|
||||
except :
|
||||
log_error("no new windows", driver)
|
||||
custom_sleep(3)
|
||||
|
||||
# Find out which type of action to do
|
||||
def try_play(nom="inconnu"):
|
||||
rgpd_popup(driver)
|
||||
printf("try_play en cours")
|
||||
|
||||
if (nom=="inconnu"):
|
||||
nom = driver.title
|
||||
def play(number):
|
||||
if number == 8 or number == 9:
|
||||
try:
|
||||
printf(f"\033[96m Quiz 8 detected on {nom} \033[0m")
|
||||
printf(f"\033[96mQuiz 8 detected on `{nom}` \033[0m")
|
||||
play_quiz8()
|
||||
printf(f"\033[92m Quiz 8 succeeded on {nom} \033[0m")
|
||||
printf(f"\033[92mQuiz 8 succeeded on `{nom}` \033[0m")
|
||||
custom_sleep(uniform(3, 5))
|
||||
except Exception as e:
|
||||
printf(f"fail of PlayQuiz 8. Aborted {e} \033[0m")
|
||||
|
||||
elif number == 5 or number == 4:
|
||||
try:
|
||||
printf(f"\033[96m Quiz 4 detected on {nom} \033[0m")
|
||||
printf(f"\033[96mQuiz 4 detected on `{nom}` \033[0m")
|
||||
play_quiz4()
|
||||
printf(f"\033[92m Quiz 4 succeeded on {nom} \033[0m")
|
||||
printf(f"\033[92mQuiz 4 succeeded on `{nom}` \033[0m")
|
||||
custom_sleep(uniform(3, 5))
|
||||
except Exception as e:
|
||||
printf(f"fail of PlayQuiz 4. Aborted {e} \033[0m")
|
||||
printf(f"Fail of PlayQuiz 4. Aborted {e} \033[0m")
|
||||
|
||||
elif number == 3 or number == 2:
|
||||
try:
|
||||
printf(f"\033[96m Quiz 2 detected on {nom}\033[0m")
|
||||
printf(f"\033[96mQuiz 2 detected on `{nom}`\033[0m")
|
||||
play_quiz2()
|
||||
printf(f"\033[92m Quiz 2 succeeded on {nom}\033[0m")
|
||||
printf(f"\033[92mQuiz 2 succeeded on `{nom}`\033[0m")
|
||||
except Exception as e:
|
||||
printf(f"fail of PlayQuiz 2. Aborted {e}")
|
||||
else:
|
||||
log_error("There is an error. rqAnswerOption present in page but no action to do. skipping.")
|
||||
|
||||
try:
|
||||
if wait_until_visible(By.ID, "rqStartQuiz", 5, driver):
|
||||
custom_sleep(3)
|
||||
driver.find_element(By.ID, "rqStartQuiz").click() # start the quiz
|
||||
answer_number = driver.page_source.count("rqAnswerOption")
|
||||
play(answer_number)
|
||||
|
||||
else :
|
||||
raise (NameError("going to next part"))
|
||||
except Exception as e: # if there is no start button, an error is thrown
|
||||
if "bt_PollRadio" in driver.page_source:
|
||||
try:
|
||||
printf("Poll detected")
|
||||
rgpd_popup(driver)
|
||||
do_poll()
|
||||
printf("Poll succeeded")
|
||||
except Exception as e:
|
||||
@ -384,154 +354,93 @@ def try_play(nom="inconnu"):
|
||||
|
||||
elif search("([0-9]) de ([0-9]) finalisée", driver.page_source):
|
||||
printf("fidélité")
|
||||
rgpd_popup(driver)
|
||||
fidelity()
|
||||
|
||||
else:
|
||||
printf(f"rien à faire sur la page {nom}")
|
||||
rgpd_popup(driver)
|
||||
custom_sleep(uniform(3, 5))
|
||||
|
||||
|
||||
# login() tries to login to your Microsoft account.
|
||||
# it uses global variable _mail and _password to login
|
||||
def login(ldriver):
|
||||
def pwd_login():
|
||||
# Login with password or with cookies.
|
||||
# The driver should be in the same state on both case
|
||||
def pwd_login(ldriver):
|
||||
printf("pwd_login : start")
|
||||
ldriver.get("https://login.live.com")
|
||||
custom_sleep(2)
|
||||
wait_until_visible(By.ID, "i0116", browser = ldriver)
|
||||
mail_elem = ldriver.find_element(By.ID, "i0116")
|
||||
send_keys_wait(mail_elem, _mail)
|
||||
send_keys_wait(mail_elem, g._mail)
|
||||
mail_elem.send_keys(Keys.ENTER)
|
||||
custom_sleep(2)
|
||||
wait_until_visible(By.ID, "i0118", browser = ldriver)
|
||||
pwd_elem = ldriver.find_element(By.ID, "i0118")
|
||||
send_keys_wait(pwd_elem, _password)
|
||||
send_keys_wait(pwd_elem, g._password)
|
||||
pwd_elem.send_keys(Keys.ENTER)
|
||||
custom_sleep(2)
|
||||
# 2FA
|
||||
if "Entrez le code de sécurité" in ldriver.page_source :
|
||||
try :
|
||||
a2f_elem = ldriver.find_element(By.ID, "idTxtBx_SAOTCC_OTC")
|
||||
a2f_elem.send_keys(_otp.now())
|
||||
a2f_elem.send_keys(g._otp.now())
|
||||
a2f_elem.send_keys(Keys.ENTER)
|
||||
except Exception as e :
|
||||
log_error(e)
|
||||
custom_sleep(5)
|
||||
|
||||
|
||||
def cookie_login(ldriver):
|
||||
printf("cookies_login : start")
|
||||
ldriver.get("https://login.live.com")
|
||||
try :
|
||||
load_cookies(ldriver)
|
||||
except FileNotFoundError :
|
||||
printf("No cookies file Found.")
|
||||
return(False)
|
||||
ldriver.refresh()
|
||||
return(True)
|
||||
|
||||
|
||||
# Accept all cookies question, and check if the account is locked
|
||||
def login_part_2(ldriver, cookies = False):
|
||||
custom_sleep(5)
|
||||
if ('Abuse' in ldriver.current_url) :
|
||||
log_error("account suspended")
|
||||
raise Banned()
|
||||
save_cookies(driver, _mail)
|
||||
for id in ["KmsiCheckboxField","iLooksGood", "idSIButton9", "iCancel"]:
|
||||
if cookies:
|
||||
save_cookies(ldriver)
|
||||
for id in ["KmsiCheckboxField", "id__0", "iLooksGood", "idSIButton9", "iCancel"]:
|
||||
if get_domain(ldriver) == "account.microsoft.com":
|
||||
break
|
||||
try:
|
||||
ldriver.find_element(By.ID, id).click()
|
||||
restart = True
|
||||
except Exception as e:
|
||||
pass
|
||||
|
||||
try :
|
||||
body_elem = ldriver.find_element(By.TAG_NAME, "body") # in case of any random popup
|
||||
body_elem.send_keys(Keys.ENTER)
|
||||
except :
|
||||
pass
|
||||
printf("login completed - going to MsRewards")
|
||||
custom_sleep(uniform(3,5))
|
||||
ldriver.get("https://www.bing.com/rewardsapp/flyout")
|
||||
custom_sleep(uniform(3,5))
|
||||
for i in [f'[title="Rejoindre maintenant"]', f'[title="Rejoindre"]', f'[title="Join now"]'] :
|
||||
try:
|
||||
ldriver.find_element(By.CSS_SELECTOR, i).click() # depend of the language of the page
|
||||
except:
|
||||
printf(f"element {i} not found")
|
||||
wait_until_visible(By.CSS_SELECTOR, '[data-bi-id="sh-sharedshell-home"]', 20, ldriver)
|
||||
ldriver.get("https://www.bing.com")
|
||||
rgpd_popup(ldriver)
|
||||
custom_sleep(uniform(3,5))
|
||||
ldriver.get("https://www.bing.com/rewardsapp/flyout")
|
||||
try:
|
||||
ldriver.find_element(By.CSS_SELECTOR, '[title="Rejoindre maintenant"]').click() # depend of the language of the page
|
||||
except:
|
||||
printf(f"unlock test: fail, probably normal")
|
||||
|
||||
printf('on MsRewards')
|
||||
|
||||
def cookie_login():
|
||||
ldriver.get("https://login.live.com")
|
||||
try :
|
||||
load_cookies(ldriver, _mail)
|
||||
except FileNotFoundError :
|
||||
printf("Creating cookies file")
|
||||
return(False)
|
||||
try :
|
||||
ldriver.refresh()
|
||||
except WebDriverException as e: # This error occurs at random time. Don't really know why
|
||||
if "Reached error page: about:neterror?e=netTimeout" in str(e):
|
||||
printf("Timeout error occurred. \"normal\"....., maybe because of mismatch date ? ")
|
||||
log_error("Timeout error occurred. \"normal\"....., maybe because of mismatch date ?", ldriver, True) # TODO check this hypothesis
|
||||
rgpd_popup(ldriver)
|
||||
ldriver.get("https://account.microsoft.com/")
|
||||
if wait_until_visible(By.CSS_SELECTOR, '[data-bi-id="sh-sharedshell-home"]', 30, ldriver) :
|
||||
return(True) #the account logging was successful
|
||||
else :
|
||||
log_error(e)
|
||||
custom_sleep(20) # TODO : remplacer par un wait_element
|
||||
if ("account.microsoft.com" in ldriver.current_url) :
|
||||
ldriver.get("https://bing.com")
|
||||
custom_sleep(5)
|
||||
log_error("Error during login. Trying to refresh")
|
||||
ldriver.refresh()
|
||||
rgpd_popup(ldriver)
|
||||
ldriver.get("https://www.bing.com/rewardsapp/flyout")
|
||||
if not('>Tableau de bord' in ldriver.page_source):
|
||||
try :
|
||||
ldriver.find_element(By.CSS_SELECTOR, "[h='ID=RewardsFlyout,2.1']").click()
|
||||
custom_sleep(5)
|
||||
if "bing.com" in ldriver.current_url :
|
||||
rgpd_popup(ldriver)
|
||||
ldriver.get("https://www.bing.com/rewardsapp/flyout")
|
||||
if ('>Tableau de bord' in ldriver.page_source) :
|
||||
return(True)
|
||||
else :
|
||||
printf("error during the connection. Trying something else")
|
||||
except Exception as e:
|
||||
log_error(f"not connected 5 - error {e}", ldriver)
|
||||
if not('>Tableau de bord' in ldriver.page_source):
|
||||
try :
|
||||
ldriver.find_element(By.XPATH, "/html/body/div/div/div/div/div[2]/a").click()
|
||||
custom_sleep(5)
|
||||
except Exception as e:
|
||||
log_error(f"erreur not connected 6{e}", ldriver)
|
||||
return(False)
|
||||
if "bing.com" in ldriver.current_url :
|
||||
rgpd_popup(ldriver)
|
||||
ldriver.get("https://www.bing.com/rewardsapp/flyout")
|
||||
if ('>Tableau de bord' in ldriver.page_source) :
|
||||
return(True)
|
||||
else :
|
||||
log_error("not connected 6", ldriver)
|
||||
return(False)
|
||||
return(True)
|
||||
return(wait_until_visible(By.CSS_SELECTOR, '[data-bi-id="sh-sharedshell-home"]', 30, ldriver))
|
||||
|
||||
if ('account.live.com' in ldriver.current_url):
|
||||
log_error("error 1", ldriver, True)
|
||||
ldriver.refresh()
|
||||
log_error("error 2", ldriver, True)
|
||||
ldriver.get("https://bing.com")
|
||||
ldriver.refresh()
|
||||
rgpd_popup(ldriver)
|
||||
log_error("error 3", ldriver, True)
|
||||
sleep(5)
|
||||
return(True)
|
||||
|
||||
printf("cookies plus valides ?")
|
||||
return(False)
|
||||
|
||||
# login() tries to login to your Microsoft account.
|
||||
# it uses global variable g._mail and g._password to login
|
||||
def login(ldriver):
|
||||
try :
|
||||
if cookie_login():
|
||||
return (ldriver.current_window_handle)
|
||||
pwd_login() #mobile login in never called. TODO : check if it's bad.
|
||||
return(ldriver.current_window_handle)
|
||||
success_cookies = cookie_login(ldriver)
|
||||
if not success_cookies:
|
||||
pwd_login(ldriver)
|
||||
login_part_2(ldriver, not success_cookies)
|
||||
ldriver.get("https://rewards.bing.com/")
|
||||
except Banned:
|
||||
raise Banned()
|
||||
except Exception as e:
|
||||
log_error(e)
|
||||
ldriver.quit()
|
||||
|
||||
|
||||
return(False)
|
||||
|
||||
|
||||
# Makes 30 search as PC Edge
|
||||
@ -557,9 +466,7 @@ def bing_pc_search(override=randint(35, 40)):
|
||||
sleep(3)
|
||||
send_keys_wait(driver.find_element(By.ID, "sb_form_q"), word)
|
||||
driver.find_element(By.ID, "sb_form_q").send_keys(Keys.ENTER)
|
||||
|
||||
custom_sleep(uniform(5, 20))
|
||||
|
||||
custom_sleep(uniform(3, 7))
|
||||
try:
|
||||
driver.find_element(By.ID, "sb_form_q").clear()
|
||||
except Exception as e:
|
||||
@ -571,7 +478,6 @@ def bing_pc_search(override=randint(35, 40)):
|
||||
log_error(f"clear la barre de recherche - {format_error(e)}")
|
||||
|
||||
|
||||
|
||||
# Unban an account, called with -u parameter. You will need a phone number
|
||||
def unban() -> None:
|
||||
driver.find_element(By.ID, "StartAction").click()
|
||||
@ -605,23 +511,24 @@ def unban() -> None:
|
||||
# Sends points to database, discord and whatever service you want
|
||||
def log_points(account="unknown"):
|
||||
def get_points():
|
||||
driver.get("https://www.bing.com/rewardsapp/flyout")
|
||||
regex1 = '<a href="https://rewards\.bing\.com/" title="((.{1,3}),(.{1,3})) points" target="_blank"'
|
||||
driver.get("https://rewards.bing.com")
|
||||
custom_sleep(1)
|
||||
if "/proofs/" in driver.current_url:
|
||||
for id in ["KmsiCheckboxField","iLooksGood", "idSIButton9", "iCancel"]:
|
||||
try:
|
||||
point = search(regex1, driver.page_source)[1].replace(",", "")
|
||||
|
||||
driver.find_element(By.ID, id).click()
|
||||
restart = True
|
||||
except Exception as e:
|
||||
elem = driver.find_element(By.CSS_SELECTOR, '[title="Microsoft Rewards"]')
|
||||
elem.click()
|
||||
custom_sleep(5)
|
||||
driver.switch_to.window(driver.window_handles[len(driver.window_handles) - 1])
|
||||
custom_sleep(uniform(5,7))
|
||||
pass
|
||||
wait_until_visible(By.CSS_SELECTOR, 'span[mee-element-ready="$ctrl.loadCounterAnimation()"]', browser=driver)
|
||||
try :
|
||||
point = search('availablePoints":([\d]+)', driver.page_source)[1]
|
||||
except :
|
||||
point = search('availablePoints\":([\d]+)', driver.page_source)[1]
|
||||
except Exception as e:
|
||||
sleep(5)
|
||||
log_error(f"Dev error, checking why it doesn't work (waited a bit, is this still white ?) {format_error(e)}", driver, True)
|
||||
driver.refresh()
|
||||
sleep(5)
|
||||
point = search('availablePoints":([\d]+)', driver.page_source)[1]
|
||||
point = search('availablePoints\":([\d]+)', driver.page_source)[1]
|
||||
return(point)
|
||||
|
||||
for _ in range (3):
|
||||
@ -675,7 +582,8 @@ def fidelity():
|
||||
try :
|
||||
choix = driver.find_element(By.CSS_SELECTOR, 'div[class="pull-left spacer-48-bottom punchcard-row"]') # pull-left spacer-48-bottom punchcard-row? USELESS ?
|
||||
except : # tentative de fix
|
||||
driver.refresh()
|
||||
driver.execute_script("location.reload(true);")
|
||||
wait_until_visible(By.CSS_SELECTOR, 'div[class="pull-left spacer-48-bottom punchcard-row"]', browser=driver)
|
||||
choix = driver.find_element(By.CSS_SELECTOR, 'div[class="pull-left spacer-48-bottom punchcard-row"]')
|
||||
answer_number = search("([0-9]) of ([0-9]) completed", driver.page_source)
|
||||
if answer_number is None:
|
||||
@ -717,60 +625,6 @@ def fidelity():
|
||||
log_error(e)
|
||||
|
||||
|
||||
def mobile_login_pwd(error):
|
||||
try:
|
||||
# TODO
|
||||
# seems fine, check if there are no issues NO
|
||||
mot = choice(Liste_de_mot).replace(" ","+")
|
||||
mobile_driver.get(f"https://www.bing.com/search?q={mot}")
|
||||
rgpd_popup(mobile_driver)
|
||||
printf("start of Mobile login")
|
||||
try :
|
||||
mobile_driver.find_element(By.ID, "mHamburger").click()
|
||||
except Exception as e :
|
||||
elm = mobile_driver.find_element(By.ID, "mHamburger")
|
||||
mobile_driver.execute_script("arguments[0].scrollIntoView();", elm)
|
||||
mobile_driver.find_element(By.ID, "mHamburger").click()
|
||||
|
||||
wait_until_visible(By.ID, "hb_s", browser=mobile_driver)
|
||||
mobile_driver.find_element(By.ID, "hb_s").click()
|
||||
wait_until_visible(By.ID, "i0116", browser=mobile_driver)
|
||||
mail_elem = mobile_driver.find_element(By.ID, "i0116")
|
||||
send_keys_wait(mail_elem, _mail)
|
||||
mail_elem.send_keys(Keys.ENTER)
|
||||
wait_until_visible(By.ID, "i0118", browser=mobile_driver)
|
||||
pwd_elem = mobile_driver.find_element(By.ID, "i0118")
|
||||
send_keys_wait(pwd_elem, _password)
|
||||
pwd_elem.send_keys(Keys.ENTER)
|
||||
custom_sleep(uniform(1, 2))
|
||||
if "Entrez le code de sécurité" in driver.page_source :
|
||||
try :
|
||||
a2f_elem = mobile_driver.find_element(By.ID, "idTxtBx_SAOTCC_OTC")
|
||||
a2f_elem.send_keys(_otp.now())
|
||||
a2f_elem.send_keys(Keys.ENTER)
|
||||
except Exception as e :
|
||||
log_error(e)
|
||||
custom_sleep(uniform(1, 2))
|
||||
for i in ["KmsiCheckboxField", "iLooksGood", "idSIButton9"]:
|
||||
try:
|
||||
mobile_driver.find_element(By.ID,i ).click()
|
||||
except Exception as e:
|
||||
pass
|
||||
|
||||
printf("end of Mobile login")
|
||||
|
||||
except Exception as e:
|
||||
error += 1
|
||||
if error <= 3:
|
||||
printf(f"failure on mobile_login. Retrying({error}/3), {e}")
|
||||
custom_sleep(uniform(5, 10))
|
||||
mobile_login_pwd(error)
|
||||
else:
|
||||
log_error(f"login impossible 3 fois de suite. {e}", mobile_driver)
|
||||
mobile_driver.quit()
|
||||
return(True)
|
||||
|
||||
|
||||
def mobile_alert_popup():
|
||||
try:
|
||||
alert = mobile_driver.switch_to.alert
|
||||
@ -796,7 +650,7 @@ def bing_mobile_search(override=randint(22, 25)):
|
||||
mot = choice(Liste_de_mot)
|
||||
send_keys_wait(mobile_driver.find_element(By.ID, "sb_form_q"), mot)
|
||||
mobile_driver.find_element(By.ID, "sb_form_q").send_keys(Keys.ENTER)
|
||||
custom_sleep(uniform(5, 20))
|
||||
custom_sleep(uniform(3, 7))
|
||||
mobile_alert_popup() # check for alert (asking for position or for allowing notifications)
|
||||
mobile_driver.find_element(By.ID, "sb_form_q").clear()
|
||||
except Exception as e:
|
||||
@ -841,20 +695,20 @@ def daily_routine(custom = False):
|
||||
|
||||
|
||||
try:
|
||||
log_points(_mail)
|
||||
log_points(g._mail)
|
||||
except Exception as e:
|
||||
log_error(e)
|
||||
|
||||
|
||||
def dev():
|
||||
pass
|
||||
input("paused")
|
||||
|
||||
|
||||
def CustomStart(Credentials):
|
||||
global START_TIME
|
||||
if not LINUX_HOST :
|
||||
raise NameError('You need to be on linux to do that, due to the utilisation of a module named enquieries, sorry.')
|
||||
global driver, _mail, _password, p, _otp
|
||||
global driver, p
|
||||
|
||||
system("clear") # clear from previous command to allow a clean choice
|
||||
actions = ["tout", "daily", "pc", "mobile", "log_points","fidelity", "dev"]
|
||||
@ -863,10 +717,10 @@ def CustomStart(Credentials):
|
||||
START_TIME = time() # Reset timer to the start of the actions
|
||||
|
||||
for cred in liste:
|
||||
_mail = cred[0]
|
||||
_password = cred[1]
|
||||
g._mail = cred[0]
|
||||
g._password = cred[1]
|
||||
if len(cred) == 3:
|
||||
_otp = TOTP(cred[2])
|
||||
g._otp = TOTP(cred[2])
|
||||
|
||||
driver = firefox_driver()
|
||||
driver.implicitly_wait(3)
|
||||
@ -902,13 +756,12 @@ def CustomStart(Credentials):
|
||||
break
|
||||
if not "tout" in Actions:
|
||||
try:
|
||||
log_points(_mail)
|
||||
log_points(g._mail)
|
||||
except Exception as e:
|
||||
printf(f"CustomStart {e}")
|
||||
driver.close()
|
||||
|
||||
|
||||
|
||||
if VNC_ENABLED :
|
||||
display = SmartDisplay(backend="xvnc", size=(2160, 2160), rfbport=VNC_PORT, color_depth=24)
|
||||
else :
|
||||
@ -919,7 +772,7 @@ display.start()
|
||||
if CUSTOM_START:
|
||||
CustomStart(Credentials)
|
||||
elif UNBAN:
|
||||
_mail, _password = select_accounts(False)[0]
|
||||
g._mail, g._password = select_accounts(False)[0]
|
||||
driver = firefox_driver()
|
||||
try :
|
||||
login(driver)
|
||||
@ -930,17 +783,18 @@ elif UNBAN:
|
||||
elif POINTS_FILE != "":
|
||||
save_points_from_file(POINTS_FILE)
|
||||
else:
|
||||
if UPDATE_VERSION != "None":
|
||||
if DISCORD_ENABLED_ERROR:
|
||||
webhookFailure.send(f"Updated to {UPDATE_VERSION}", username="UPDATE", avatar_url="https://cdn-icons-png.flaticon.com/512/1688/1688988.png")
|
||||
for cred in Credentials:
|
||||
_mail = cred[0]
|
||||
_password = cred[1]
|
||||
g._mail = cred[0]
|
||||
g._password = cred[1]
|
||||
if len(cred) == 3:
|
||||
_otp = TOTP(cred[2])
|
||||
printf("\n\n")
|
||||
printf(_mail)
|
||||
g._otp = TOTP(cred[2])
|
||||
custom_sleep(1)
|
||||
printf("début du driver")
|
||||
printf("Début du driver.")
|
||||
driver = firefox_driver()
|
||||
printf("driver demarré")
|
||||
printf("Driver demarré.")
|
||||
driver.implicitly_wait(3)
|
||||
try:
|
||||
daily_routine()
|
||||
@ -949,11 +803,11 @@ else:
|
||||
printf(f"finis. attente de {round(attente/60)}min")
|
||||
custom_sleep(attente)
|
||||
except KeyboardInterrupt:
|
||||
printf("canceled. Closing driver and display.")
|
||||
printf("Canceled. Closing driver and display.")
|
||||
driver.quit()
|
||||
display.stop()
|
||||
except Exception as e:
|
||||
printf(f"error not catched. skipping this account. {e}")
|
||||
printf(f"Error not catched. Skipping this account. {e}")
|
||||
driver.quit()
|
||||
|
||||
display.stop()
|
||||
|
24
database.py
24
database.py
@ -10,9 +10,16 @@ parser.add_argument(
|
||||
help="Choose a file",
|
||||
type=argparse.FileType('r')
|
||||
)
|
||||
parser.add_argument(
|
||||
"-m",
|
||||
"--manual",
|
||||
help="add point manually do database",
|
||||
dest="manual",
|
||||
action="store_true"
|
||||
)
|
||||
|
||||
args = parser.parse_args()
|
||||
|
||||
MANUAL = args.manual
|
||||
|
||||
config_path = "./user_data/config.cfg"
|
||||
config = configparser.ConfigParser()
|
||||
@ -47,7 +54,7 @@ def ban_account(name: str, pts = 0):
|
||||
def update_pts(name: str, pts = 0):
|
||||
pass
|
||||
|
||||
|
||||
if not MANUAL :
|
||||
print("ajouter un compte : 1\nban un compte : 2")
|
||||
i = input()
|
||||
if i == "1":
|
||||
@ -70,3 +77,16 @@ elif i == '2':
|
||||
mydb.commit()
|
||||
mycursor.close()
|
||||
mydb.close()
|
||||
else :
|
||||
import modules.db as datab
|
||||
config_path = f"{path.abspath(path.dirname(path.dirname( __file__ )))}/MsRewards/user_data/config.cfg"
|
||||
print(config_path)
|
||||
config = configparser.ConfigParser()
|
||||
config.read(config_path)
|
||||
sql_usr = config["SQL"]["usr"]
|
||||
sql_pwd = config["SQL"]["pwd"]
|
||||
sql_host = config["SQL"]["host"]
|
||||
sql_database = config["SQL"]["database"]
|
||||
account_name = input("compte ? ")
|
||||
points = int(input("points ? "))
|
||||
datab.add_to_database(account_name, points, sql_host, sql_usr, sql_pwd, sql_database)
|
9
main.py
9
main.py
@ -154,31 +154,32 @@ def proxy() :
|
||||
edit_config_txt("port",port)
|
||||
|
||||
|
||||
def check_update():
|
||||
def check_update(args):
|
||||
try :
|
||||
latest = requests.get("https://api.github.com/repos/piair338/MsRewards/releases").json()[0]["tag_name"]
|
||||
latest = parse_version(latest)
|
||||
except Exception as e :
|
||||
print(e)
|
||||
return ()
|
||||
return (args)
|
||||
f = open("./version", 'r')
|
||||
txt = f.readlines()[0].replace("\n","")
|
||||
f.close()
|
||||
cur = parse_version(txt)
|
||||
if not (cur < latest) :
|
||||
print("Already up to date.")
|
||||
return(args)
|
||||
else :
|
||||
print(f"updating to {latest}")
|
||||
os.system("git reset --hard")
|
||||
os.system("git pull")
|
||||
os.system("python3 -m pip install -r requirements.txt > update.result")
|
||||
print(f"updated to {latest}")
|
||||
|
||||
return(args + f" --version {latest}")
|
||||
|
||||
LogPath = config["PATH"]["logpath"]
|
||||
if LogPath == "/your/path/to/loginandpass.csv" :
|
||||
setup()
|
||||
else :
|
||||
args = " ".join(sys.argv[1::])
|
||||
check_update()
|
||||
args = check_update(args)
|
||||
os.system("python3 V5.py " + args)
|
||||
|
@ -81,6 +81,12 @@ parser.add_argument(
|
||||
default="None"
|
||||
)
|
||||
|
||||
parser.add_argument(
|
||||
"--version",
|
||||
help="display a message on discord to tell that the bot have been updated",
|
||||
dest="update_version",
|
||||
default="None"
|
||||
)
|
||||
args = parser.parse_args()
|
||||
|
||||
CUSTOM_START = args.override
|
||||
@ -93,7 +99,7 @@ if CUSTOM_START :
|
||||
VNC_ENABLED = args.vnc != "None"
|
||||
VNC_PORT = args.vnc
|
||||
POINTS_FILE = args.points_file
|
||||
|
||||
UPDATE_VERSION = args.update_version
|
||||
# global variables used later in the code
|
||||
LINUX_HOST = platform == "linux" # if the computer running this program is Linux, it allow more things
|
||||
START_TIME = time()
|
||||
@ -125,6 +131,10 @@ DISCORD_SUCCESS_LINK = config["DISCORD"]["successlink"]
|
||||
DISCORD_ERROR_LINK = config["DISCORD"]["errorlink"]
|
||||
DISCORD_ENABLED_ERROR = config["DISCORD"]["DiscordErrorEnabled"] == "True"
|
||||
DISCORD_ENABLED_SUCCESS = config["DISCORD"]["DiscordSuccessEnabled"]== "True"
|
||||
try :
|
||||
AVATAR_URL = config["OTHER"]["avatar"]== "True"
|
||||
except :
|
||||
AVATAR_URL = "https://cdn.discordapp.com/icons/793934298977009674/d8055bccef6eca4855c349e808d0d788.webp"
|
||||
|
||||
if DISCORD_ENABLED_ERROR:
|
||||
webhookFailure = Webhook.from_url(DISCORD_ERROR_LINK, adapter=RequestsWebhookAdapter())
|
||||
|
@ -1,6 +1,7 @@
|
||||
from modules.imports import *
|
||||
from modules.config import *
|
||||
|
||||
from modules.tools import *
|
||||
import modules.globals as g
|
||||
|
||||
def setup_proxy(ip, port, options, socks=False) :
|
||||
PROXY = f"{ip}:{port}"
|
||||
@ -25,12 +26,12 @@ def rgpd_popup(driver) -> None:
|
||||
pass
|
||||
|
||||
# save webdriver cookies
|
||||
def save_cookies(driver, _mail):
|
||||
pickle.dump(driver.get_cookies(), open(f"{'/'.join(__file__.split('/')[:-2])}/user_data/cookies/{_mail}.pkl", "wb"))
|
||||
def save_cookies(driver):
|
||||
pickle.dump(driver.get_cookies(), open(f"{'/'.join(__file__.split('/')[:-2])}/user_data/cookies/{g._mail}.pkl", "wb"))
|
||||
|
||||
# load cookies previously saved to the driver
|
||||
def load_cookies(driver, _mail):
|
||||
cookies = pickle.load(open(f"{'/'.join(__file__.split('/')[:-2])}/user_data/cookies/{_mail}.pkl", "rb"))
|
||||
def load_cookies(driver):
|
||||
cookies = pickle.load(open(f"{'/'.join(__file__.split('/')[:-2])}/user_data/cookies/{g._mail}.pkl", "rb"))
|
||||
for cookie in cookies:
|
||||
driver.add_cookie(cookie)
|
||||
|
||||
@ -52,6 +53,8 @@ def send_keys_wait(element, keys):
|
||||
def wait_until_visible(search_by: str, identifier: str, timeout = 20, browser = None) -> None:
|
||||
try :
|
||||
WebDriverWait(browser, timeout).until(EC.visibility_of_element_located((search_by,identifier)), "element not found")
|
||||
return(True)
|
||||
except TimeoutException as e:
|
||||
print(f"element not found after {timeout}s")
|
||||
printf(f"element not found after {timeout}s")
|
||||
return(False)
|
||||
|
||||
|
5
modules/globals.py
Normal file
5
modules/globals.py
Normal file
@ -0,0 +1,5 @@
|
||||
driver = None
|
||||
_mail = '_mail temp'
|
||||
_password = '_password temp'
|
||||
_otp = '_otp temp'
|
||||
display = None
|
@ -14,7 +14,7 @@ from selenium.webdriver.firefox.options import Options
|
||||
from selenium.webdriver.support.ui import WebDriverWait
|
||||
from selenium.webdriver.support import expected_conditions as EC
|
||||
from selenium.webdriver.support.ui import Select
|
||||
from selenium.common.exceptions import WebDriverException, TimeoutException, NoSuchElementException, ElementClickInterceptedException
|
||||
from selenium.common.exceptions import WebDriverException, TimeoutException, NoSuchElementException, ElementClickInterceptedException, StaleElementReferenceException
|
||||
|
||||
from pyotp import TOTP
|
||||
from pyvirtualdisplay import Display
|
||||
|
@ -1,18 +1,22 @@
|
||||
from modules.imports import *
|
||||
from modules.config import *
|
||||
|
||||
import modules.globals as g
|
||||
|
||||
# add the time arround the text given in [text]&
|
||||
def Timer(text: str, mail: str) -> str:
|
||||
return(f"[{mail} - {datetime.today().strftime('%d-%m-%Y')} - {timedelta(seconds = round(float(time() - START_TIME)))}] " + str(text))
|
||||
def Timer(text: str) -> str:
|
||||
return(f"[{g._mail.split('@')[0]} - {datetime.today().strftime('%d/%m')} - {timedelta(seconds = round(float(time() - START_TIME)))}] " + str(text))
|
||||
|
||||
|
||||
# replace the function print, with more options
|
||||
# [txt] : string, [driver] : selenium webdriver
|
||||
def printf2(txt, mail, LOG = LOG):
|
||||
print(Timer(txt, mail))
|
||||
def printf(txt):
|
||||
print(Timer(txt))
|
||||
|
||||
|
||||
# return current page domain
|
||||
def get_domain(driver):
|
||||
return(driver.current_url.split("/")[2])
|
||||
|
||||
|
||||
# check if the user is using IPV4 using ipify.org
|
||||
# [driver] : selenium webdriver
|
||||
@ -26,7 +30,6 @@ def check_ipv4(driver):
|
||||
return False
|
||||
|
||||
|
||||
|
||||
def custom_sleep(temps):
|
||||
try :
|
||||
if FAST and temps > 50:
|
||||
|
@ -31,5 +31,5 @@ usr = root
|
||||
pwd = password
|
||||
|
||||
[OTHER]
|
||||
|
||||
avatar = https://cdn.discordapp.com/icons/793934298977009674/d8055bccef6eca4855c349e808d0d788.webp
|
||||
ipv6 = False
|
Reference in New Issue
Block a user