7 Commits

7 changed files with 87 additions and 51 deletions

View File

@ -3,7 +3,7 @@
A Microsoft reward automator, designed to work headless on any server. A Microsoft reward automator, designed to work headless on any server.
Using a discord webhook or SQL to log points everyday. 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) ## If you're using docker (way easier)
to use docker, run to use docker, run
@ -12,17 +12,17 @@ sudo docker build .
#copy the build id #copy the build id
sudo docker run -ti --name MsRewards [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 sudo docker start MsRewards
``` ```
## Other configuration ## 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 :
![B96F2F6D-7257-4F12-BFA7-0BEC3FB72993](https://user-images.githubusercontent.com/74496300/172872979-05396b6b-b682-471a-b71b-41602d816504.jpeg) ![B96F2F6D-7257-4F12-BFA7-0BEC3FB72993](https://user-images.githubusercontent.com/74496300/172872979-05396b6b-b682-471a-b71b-41602d816504.jpeg)
You have to use the default worldlist (`sudo apt install wfrench`). The language is french by default, but you can change it if you want. 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.
You can add a link to a website where content is only the link of the monthly fidelity card. You can add a link to a website where content is only the link of the monthly fidelity card.

39
V5.py
View File

@ -15,9 +15,8 @@ def printf(e):
printf2(str(e), _mail) printf2(str(e), _mail)
# TODO # TODO
# handle "panda"'s error: error while logging in preventing some task to be done # handle "panda"'s error: error while logging in preventing some task to be done SadPanda.svg
# check that each card worked (lot of misses lately) -- test that -- don't crash at least # check that each card worked (lot of misses lately) -- test that -- don't crash at least
# Fix l'affichage du compteur de custom_sleep
# create a webdriver # create a webdriver
@ -85,9 +84,8 @@ def log_error(error, ldriver=driver, log=FULL_LOG):
file = File("screenshot.png") file = File("screenshot.png")
embed.set_image(url="attachment://screenshot.png") embed.set_image(url="attachment://screenshot.png")
embed.set_footer(text=_mail) embed.set_footer(text=_mail)
webhookFailure.send(embed=embed, file=file) webhookFailure.send(embed=embed, username="error", file=file, avatar_url = AVATAR_URL)
webhookFailure.send(file=File("page.html")) 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 # close the tab currently on and go back to the one first, or the one specified
@ -103,7 +101,7 @@ def play_quiz2(override=10) -> None:
printf("starting play_quiz2") printf("starting play_quiz2")
for j in range(override): for j in range(override):
try: try:
rgpd_popup(driver) # rgpd_popup(driver)
custom_sleep(uniform(3, 5)) custom_sleep(uniform(3, 5))
page_html = driver.page_source page_html = driver.page_source
secret_answer = search('IG:"([^"]+)"', page_html)[1] # variable used to calculate offset secret_answer = search('IG:"([^"]+)"', page_html)[1] # variable used to calculate offset
@ -137,7 +135,7 @@ def play_quiz8():
printf(f"play_quiz8 : start, override : {override}") printf(f"play_quiz8 : start, override : {override}")
try: try:
counter = 0 counter = 0
rgpd_popup(driver) # rgpd_popup(driver)
for _ in range(override): for _ in range(override):
custom_sleep(uniform(3, 5)) custom_sleep(uniform(3, 5))
correct_answers = [] correct_answers = []
@ -184,7 +182,7 @@ def play_quiz4(override=None):
for i in range(override): for i in range(override):
custom_sleep(uniform(3, 5)) custom_sleep(uniform(3, 5))
txt = driver.page_source txt = driver.page_source
rgpd_popup(driver) # rgpd_popup(driver)
answer_option = search('correctAnswer":"([^"]+)', txt)[1] answer_option = search('correctAnswer":"([^"]+)', txt)[1]
answer_option = answer_option.replace("\\u0027", "'") # replace Unicode weird symbols answer_option = answer_option.replace("\\u0027", "'") # replace Unicode weird symbols
try: try:
@ -234,7 +232,7 @@ def all_cards(): # return to the main page and closes all other tabs
driver.get("https://www.bing.com/rewardsapp/flyout") driver.get("https://www.bing.com/rewardsapp/flyout")
reset(part2) reset(part2)
def daily_cards(): # cartes de la premiere partie (renouvelées chaque jours). def daily_cards(): # cartes de la premiere partie (renouvelée chaque jour).
try: try:
# make sure that the daily area is expanded # 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] row_element = driver.find_elements(By.CSS_SELECTOR, f'[class="i-h rw-sh fp_row"]')[0]
@ -308,7 +306,7 @@ def all_cards(): # return to the main page and closes all other tabs
try : try :
#top_cards() #top_cards()
print("top card not working really well right now. Disableing them") print("top card not working really well right now. They are currently disabled")
except Exception as e: except Exception as e:
log_error(e) log_error(e)
@ -368,7 +366,7 @@ def try_play(nom="inconnu"):
if "bt_PollRadio" in driver.page_source: if "bt_PollRadio" in driver.page_source:
try: try:
printf("Poll detected") printf("Poll detected")
rgpd_popup(driver) #rgpd_popup(driver)
do_poll() do_poll()
printf("Poll succeeded") printf("Poll succeeded")
except Exception as e: except Exception as e:
@ -384,12 +382,12 @@ def try_play(nom="inconnu"):
elif search("([0-9]) de ([0-9]) finalisée", driver.page_source): elif search("([0-9]) de ([0-9]) finalisée", driver.page_source):
printf("fidélité") printf("fidélité")
rgpd_popup(driver) #rgpd_popup(driver)
fidelity() fidelity()
else: else:
printf(f"rien à faire sur la page {nom}") printf(f"rien à faire sur la page {nom}")
rgpd_popup(driver) # rgpd_popup(driver)
custom_sleep(uniform(3, 5)) custom_sleep(uniform(3, 5))
@ -468,14 +466,18 @@ def login(ldriver):
printf("Timeout error occurred. \"normal\"....., maybe because of mismatch date ? ") 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 log_error("Timeout error occurred. \"normal\"....., maybe because of mismatch date ?", ldriver, True) # TODO check this hypothesis
else: else:
log_error(e) log_error(e, ldriver)
custom_sleep(20) # TODO : remplacer par un wait_element wait_until_visible(By.CSS_SELECTOR, '[data-bi-id="sh-sharedshell-rewards"]', 20, ldriver)
if ("account.microsoft.com" in ldriver.current_url) : if ("account.microsoft.com" in ldriver.current_url) :
ldriver.get("https://bing.com") ldriver.get("https://bing.com")
custom_sleep(5) custom_sleep(5)
ldriver.refresh() ldriver.refresh()
rgpd_popup(ldriver) rgpd_popup(ldriver) # Ultra important
ldriver.get("https://www.bing.com/rewardsapp/flyout") ldriver.get("https://www.bing.com/rewardsapp/flyout")
#if "SadPanda.svg" in ldriver.page_source :
# log_error('test SadPanda before', ldriver)
# driver.execute_script("location.reload(true);")
# log_error('test SadPanda after', ldriver)
if not('>Tableau de bord' in ldriver.page_source): if not('>Tableau de bord' in ldriver.page_source):
try : try :
ldriver.find_element(By.CSS_SELECTOR, "[h='ID=RewardsFlyout,2.1']").click() ldriver.find_element(By.CSS_SELECTOR, "[h='ID=RewardsFlyout,2.1']").click()
@ -847,7 +849,7 @@ def daily_routine(custom = False):
def dev(): def dev():
pass log_error("test")
def CustomStart(Credentials): def CustomStart(Credentials):
@ -930,6 +932,9 @@ elif UNBAN:
elif POINTS_FILE != "": elif POINTS_FILE != "":
save_points_from_file(POINTS_FILE) save_points_from_file(POINTS_FILE)
else: else:
if UPDATE_VERSION != "None":
if DISCORD_ENABLED_ERROR:
webhookFailure.send(f"Updated to {UPDATE_VERSION}")
for cred in Credentials: for cred in Credentials:
_mail = cred[0] _mail = cred[0]
_password = cred[1] _password = cred[1]

View File

@ -10,9 +10,16 @@ parser.add_argument(
help="Choose a file", help="Choose a file",
type=argparse.FileType('r') type=argparse.FileType('r')
) )
parser.add_argument(
"-m",
"--manual",
help="add point manually do database",
dest="manual",
action="store_true"
)
args = parser.parse_args() args = parser.parse_args()
MANUAL = args.manual
config_path = "./user_data/config.cfg" config_path = "./user_data/config.cfg"
config = configparser.ConfigParser() config = configparser.ConfigParser()
@ -47,26 +54,39 @@ def ban_account(name: str, pts = 0):
def update_pts(name: str, pts = 0): def update_pts(name: str, pts = 0):
pass pass
if not MANUAL :
print("ajouter un compte : 1\nban un compte : 2") print("ajouter un compte : 1\nban un compte : 2")
i = input() i = input()
if i == "1": if i == "1":
if args.file : if args.file :
l =[x.split(",")[0].split("@")[0] for x in args.file.readlines()] l =[x.split(",")[0].split("@")[0] for x in args.file.readlines()]
endroit = input("ou est le bot ? ") endroit = input("ou est le bot ? ")
proprio = input("qui est le proprio ? ") proprio = input("qui est le proprio ? ")
for name in l : for name in l :
add_account(name, endroit, proprio)
else :
name = input("quel est le nom ? ").split("@")[0]
endroit = input("ou est le bot ? ")
proprio = input("qui est le proprio ? ")
add_account(name, endroit, proprio) add_account(name, endroit, proprio)
else : elif i == '2':
name = input("quel est le nom ? ").split("@")[0] name = input("quel est le compte qui a été ban ? ")
endroit = input("ou est le bot ? ") pts = input("il avait combien de points ? ")
proprio = input("qui est le proprio ? ") ban_account(name, pts)
add_account(name, endroit, proprio)
elif i == '2':
name = input("quel est le compte qui a été ban ? ")
pts = input("il avait combien de points ? ")
ban_account(name, pts)
mydb.commit() mydb.commit()
mycursor.close() mycursor.close()
mydb.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)

View File

@ -154,31 +154,32 @@ def proxy() :
edit_config_txt("port",port) edit_config_txt("port",port)
def check_update(): def check_update(args):
try : try :
latest = requests.get("https://api.github.com/repos/piair338/MsRewards/releases").json()[0]["tag_name"] latest = requests.get("https://api.github.com/repos/piair338/MsRewards/releases").json()[0]["tag_name"]
latest = parse_version(latest) latest = parse_version(latest)
except Exception as e : except Exception as e :
print(e) print(e)
return () return (args)
f = open("./version", 'r') f = open("./version", 'r')
txt = f.readlines()[0].replace("\n","") txt = f.readlines()[0].replace("\n","")
f.close() f.close()
cur = parse_version(txt) cur = parse_version(txt)
if not (cur < latest) : if not (cur < latest) :
print("Already up to date.") print("Already up to date.")
return(args)
else : else :
print(f"updating to {latest}") print(f"updating to {latest}")
os.system("git reset --hard") os.system("git reset --hard")
os.system("git pull") os.system("git pull")
os.system("python3 -m pip install -r requirements.txt > update.result") os.system("python3 -m pip install -r requirements.txt > update.result")
print(f"updated to {latest}") print(f"updated to {latest}")
return(args + f" --version {latest}")
LogPath = config["PATH"]["logpath"] LogPath = config["PATH"]["logpath"]
if LogPath == "/your/path/to/loginandpass.csv" : if LogPath == "/your/path/to/loginandpass.csv" :
setup() setup()
else : else :
args = " ".join(sys.argv[1::]) args = " ".join(sys.argv[1::])
check_update() args = check_update(args)
os.system("python3 V5.py " + args) os.system("python3 V5.py " + args)

View File

@ -81,6 +81,12 @@ parser.add_argument(
default="None" 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() args = parser.parse_args()
CUSTOM_START = args.override CUSTOM_START = args.override
@ -93,7 +99,7 @@ if CUSTOM_START :
VNC_ENABLED = args.vnc != "None" VNC_ENABLED = args.vnc != "None"
VNC_PORT = args.vnc VNC_PORT = args.vnc
POINTS_FILE = args.points_file POINTS_FILE = args.points_file
UPDATE_VERSION = args.update_version
# global variables used later in the code # global variables used later in the code
LINUX_HOST = platform == "linux" # if the computer running this program is Linux, it allow more things LINUX_HOST = platform == "linux" # if the computer running this program is Linux, it allow more things
START_TIME = time() START_TIME = time()
@ -125,6 +131,10 @@ DISCORD_SUCCESS_LINK = config["DISCORD"]["successlink"]
DISCORD_ERROR_LINK = config["DISCORD"]["errorlink"] DISCORD_ERROR_LINK = config["DISCORD"]["errorlink"]
DISCORD_ENABLED_ERROR = config["DISCORD"]["DiscordErrorEnabled"] == "True" DISCORD_ENABLED_ERROR = config["DISCORD"]["DiscordErrorEnabled"] == "True"
DISCORD_ENABLED_SUCCESS = config["DISCORD"]["DiscordSuccessEnabled"]== "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: if DISCORD_ENABLED_ERROR:
webhookFailure = Webhook.from_url(DISCORD_ERROR_LINK, adapter=RequestsWebhookAdapter()) webhookFailure = Webhook.from_url(DISCORD_ERROR_LINK, adapter=RequestsWebhookAdapter())

View File

@ -31,5 +31,5 @@ usr = root
pwd = password pwd = password
[OTHER] [OTHER]
avatar = https://cdn.discordapp.com/icons/793934298977009674/d8055bccef6eca4855c349e808d0d788.webp
ipv6 = False ipv6 = False

View File

@ -1 +1 @@
v5.2.5 v5.5.2