This repository has been archived by the owner on Nov 6, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 108
/
main.py
181 lines (163 loc) · 8.23 KB
/
main.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
# -*- coding: utf-8 -*-
# main.py
"""
@author: Maxime Dréan.
Github: https://github.com/maximedrn
Telegram: https://t.me/maximedrn
"""
# Utils functions for GUI and CLI.
from app.utils.func import cls, exit
from app.utils.colors import RED, YELLOW, RESET
from app.utils.const import FIRST_PAGE, ENTER, SECOND_PAGE, \
PASSWORD, RECOVERY_PHRASE, PRIVATE_KEY, USER_DATA, PROFILE, \
ALL_DONE, STARTING_VALUE
# Utils functions for user choices.
from app.utils.user import choose_wallet, read_file, perform_action, \
recaptcha_solver, choose_browser, data_file, number
# Common functions for the metadata file.
from app.common.reader import Reader
from app.common.structure import Structure
from app.common.save import Save
# Services functions for Upload/Sale process.
from app.services.webdriver import download_browser, Webdriver
from app.services.wallets.wallet import Wallet
from app.services.processes.login import Login
# Python default imports.
from datetime import datetime, timedelta
from os.path import dirname, abspath
from random import randint
from time import sleep
from os import chdir
def login(wallet: object, browser: int, browser_path: str,
wallet_name: str, solver: int):
"""Login to a specific wallet then to OpenSea."""
while True:
web = None # Prevent Exception.
try: # Try to start a webdriver.
web = Webdriver(browser, browser_path,
wallet_name, wallet, solver)
except Exception as error:
print(f'{RED}Something went wrong with '
f'your webdriver.\n{error}{RESET}')
try: # Try to login to a wallet and OpenSea.
wallet.init_wallet(web) # Send web instance.
if wallet.login() and Login(web, wallet).login():
return web # Stop the while loop.
except Exception: # Stop the browser.
web.quit() if web is not None else None
def process(action: list, solver: int, key: str, structure: object,
save: object, web: object, wallet: object, recaptcha: object,
reader: object, delete: object, starting: int = 0) -> int:
"""Begin the upload, listing or both, or any process."""
if 1 in action: # Initialize the Upload class.
from app.services.processes.upload import Upload
upload = Upload(solver, key, structure, save, web,
wallet, recaptcha)
if 2 in action: # Initialize the Sale class.
from app.services.processes.sale import check_price, Sale
sale = Sale(structure, save, web, wallet)
if 3 in action: # Send the object to the class.
delete.init(structure, web)
nft_number, time = 0, (datetime.now( # Time in 6 hours.
) + timedelta(hours=6)).strftime('%Y-%m-%d %H:%M:%S')
# Proceed to the Upload or Sale process in a loop.
for nft_number in range(starting, reader.length_file):
if datetime.now().strftime('%Y-%m-%d %H:%M:%S') > time:
break # Restart the process to prevent signature.
if nft_number % 10 == 0 and nft_number != starting:
web.driver.get('data:,') # Go to an empty page and wait
sleep(randint(2, 5)) # between 2 and 5 seconds to ease the RAM.
print(f'\nNFT n°{nft_number + 1}/{reader.length_file}:')
if not structure.get_data(nft_number):
continue # Data is not well structured.
success = None # Prevent "referenced before assignment" error.
if 1 in action: # Upload part.
success = upload.upload() # Get the result of the upload.
if (2 in action and success) or action == [2]: # Sale part.
# Check the price validity by sending price and blockchain.
if check_price(structure.price, structure.blockchain):
sale.sale() # Process to listing of the NFT.
if 3 in action: # Delete part.
delete.delete() # Delete the NFT.
web.quit() # Stop the webdriver and return the next NFT.
return nft_number if nft_number + 1 < reader.length_file else None
def user() -> tuple:
"""Ask different informations to the user."""
# What the action the user wants to do.
action = perform_action()
file = data_file() # Metadata file to read.
starting = number(STARTING_VALUE)
wallet_name = choose_wallet() # Choose a wallet.
# Ask what solver the user wants to use.
solver, key = recaptcha_solver() if 1 in action else ('', '')
# Ask what browser the user wants to use
# if the Coinbase Wallet is not selected.
browser = 0 if wallet_name == 'Coinbase Wallet' else choose_browser()
if browser != 2: # User wallet credentials.
password = read_file('password', PASSWORD)
recovery_phrase = read_file('recovery_phrase', RECOVERY_PHRASE)
private_key = read_file('private_key', PRIVATE_KEY)
else: # Ask for the User Data folder and profile name.
recovery_phrase = (read_file(
'user_data', USER_DATA), read_file('profile', PROFILE))
password = read_file('password', PASSWORD)
private_key = read_file('private_key', PRIVATE_KEY)
return wallet_name, password, recovery_phrase, private_key, \
action, solver, key, browser, file, starting
def main(wallet_name: str, password: str, recovery_phrase: str,
private_key: str, file: str, action: list, solver: int,
key: str, duplicate_instance: bool = False) -> tuple:
"""Initialize default classes for the bot."""
# Initialize the wallet by sending credentials.
wallet = Wallet(wallet_name, password, recovery_phrase, private_key)
# Initialize the Reader class by sending the file to read.
reader = Reader(file)
# Initialize the Structure class by sending the action.
structure = Structure(action, reader)
save = Save(structure) # Initialize the Save class.
# Initialize the solver by sending which
# solver to use and an API key if it is necessary.
recaptcha, delete = None, None
if duplicate_instance: # reCAPTCHA Bypasser.
from base64 import b64decode # Decode the content and
from pickle import loads # get the class instance.
recaptcha = loads(b64decode(bytes(key, 'utf-8')))
elif 1 in action:
from app.services.solvers.solver import Solver
recaptcha = Solver(solver, key)
recaptcha.init_solver() # Send web instance.
elif 3 in action:
from app.services.processes.delete import Delete
delete = Delete() # Initialize the Delete class.
return wallet, reader, structure, save, recaptcha, delete
if __name__ == '__main__':
try:
chdir(dirname(abspath(__file__))) # Move to the actual path.
cls() # Clear console.
print(FIRST_PAGE) # License, author and version.
input(ENTER) # Press enter to continue.
cls() # Clear console.
print(SECOND_PAGE) # License and author.
# Get user informations and choices.
wallet_name, password, recovery_phrase, private_key, \
action, solver, key, browser, file, starting = user()
cls() # Clear console.
browser_path = download_browser(browser) # Download the webdriver.
# Initialize the default classes for the bot.
wallet, reader, structure, save, recaptcha, delete = main(
wallet_name, password, recovery_phrase, private_key,
file, action, solver, key)
cls() # Clear console.
while True: # It does several processes every 12 hours.
starting = process(action, solver, key, structure, save, login(
wallet, browser, browser_path, wallet_name, solver), wallet,
recaptcha, reader, delete, starting) # Start the process.
if starting == None: # This is the end of the process.
break # Stop everything.
print(f'{YELLOW}\nRestarting the webdriver.\n{RESET}')
print(ALL_DONE) # Script stops, all done.
except KeyboardInterrupt:
print(f'\n\n{YELLOW}The program has been '
f'stopped by the user.{RESET}')
except Exception as error:
print(f'{RED}Something went wrong.{RESET}\n{error}')