initialize.py 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512
  1. import argparse
  2. import configparser
  3. import logging
  4. import os.path
  5. import subprocess
  6. import sys
  7. import time
  8. import shutil
  9. import json
  10. from .auth import login
  11. from .downloader import start_single, start_multiple
  12. from .logger import log_seperator, supports_color, log_info_blue, log_info_green, log_warn, log_error, log_whiteline, log_plain
  13. from .settings import settings
  14. script_version = "2.5.6@master"
  15. python_version = sys.version.split(' ')[0]
  16. bool_values = {'True', 'False'}
  17. def check_ffmpeg():
  18. try:
  19. FNULL = open(os.devnull, 'w')
  20. subprocess.call(["ffmpeg"], stdout=FNULL, stderr=subprocess.STDOUT)
  21. return True
  22. except OSError as e:
  23. return False
  24. def check_pyinstalive():
  25. try:
  26. FNULL = open(os.devnull, 'w')
  27. subprocess.call(["pyinstalive"], stdout=FNULL, stderr=subprocess.STDOUT)
  28. return True
  29. except OSError as e:
  30. return False
  31. def check_config_validity(config):
  32. try:
  33. has_thrown_errors = False
  34. settings.username = config.get('pyinstalive', 'username')
  35. settings.password = config.get('pyinstalive', 'password')
  36. try:
  37. settings.show_cookie_expiry = config.get('pyinstalive', 'show_cookie_expiry').title()
  38. if not settings.show_cookie_expiry in bool_values:
  39. log_warn("Invalid or missing setting detected for 'show_cookie_expiry', using default value (True)")
  40. settings.show_cookie_expiry = 'true'
  41. has_thrown_errors = True
  42. except:
  43. log_warn("Invalid or missing setting detected for 'show_cookie_expiry', using default value (True)")
  44. settings.show_cookie_expiry = 'true'
  45. has_thrown_errors = True
  46. try:
  47. settings.clear_temp_files = config.get('pyinstalive', 'clear_temp_files').title()
  48. if not settings.clear_temp_files in bool_values:
  49. log_warn("Invalid or missing setting detected for 'clear_temp_files', using default value (True)")
  50. settings.clear_temp_files = 'true'
  51. has_thrown_errors = True
  52. except:
  53. log_warn("Invalid or missing setting detected for 'clear_temp_files', using default value (True)")
  54. settings.clear_temp_files = 'true'
  55. has_thrown_errors = True
  56. try:
  57. settings.save_replays = config.get('pyinstalive', 'save_replays').title()
  58. if not settings.save_replays in bool_values:
  59. log_warn("Invalid or missing setting detected for 'save_replays', using default value (True)")
  60. settings.save_replays = 'true'
  61. has_thrown_errors = True
  62. except:
  63. log_warn("Invalid or missing setting detected for 'save_replays', using default value (True)")
  64. settings.save_replays = 'true'
  65. has_thrown_errors = True
  66. try:
  67. settings.save_lives = config.get('pyinstalive', 'save_lives').title()
  68. if not settings.save_lives in bool_values:
  69. log_warn("Invalid or missing setting detected for 'save_lives', using default value (True)")
  70. settings.save_lives = 'true'
  71. has_thrown_errors = True
  72. except:
  73. log_warn("Invalid or missing setting detected for 'save_lives', using default value (True)")
  74. settings.save_lives = 'true'
  75. has_thrown_errors = True
  76. try:
  77. settings.log_to_file = config.get('pyinstalive', 'log_to_file').title()
  78. if not settings.log_to_file in bool_values:
  79. log_warn("Invalid or missing setting detected for 'log_to_file', using default value (False)")
  80. settings.log_to_file = 'False'
  81. has_thrown_errors = True
  82. except:
  83. log_warn("Invalid or missing setting detected for 'log_to_file', using default value (False)")
  84. settings.log_to_file = 'False'
  85. has_thrown_errors = True
  86. try:
  87. settings.run_at_start = config.get('pyinstalive', 'run_at_start').replace("\\", "\\\\")
  88. if not settings.run_at_start:
  89. settings.run_at_start = "None"
  90. except:
  91. log_warn("Invalid or missing settings detected for 'run_at_start', using default value (empty)")
  92. settings.run_at_start = "None"
  93. has_thrown_errors = True
  94. try:
  95. settings.run_at_finish = config.get('pyinstalive', 'run_at_finish').replace("\\", "\\\\")
  96. if not settings.run_at_finish:
  97. settings.run_at_finish = "None"
  98. except:
  99. log_warn("Invalid or missing settings detected for 'run_at_finish', using default value (empty)")
  100. settings.run_at_finish = "None"
  101. has_thrown_errors = True
  102. try:
  103. settings.save_comments = config.get('pyinstalive', 'save_comments').title()
  104. wide_build = sys.maxunicode > 65536
  105. if sys.version.split(' ')[0].startswith('2') and settings.save_comments == "True" and not wide_build:
  106. log_warn("Your Python 2 build does not support wide unicode characters.")
  107. log_warn("This means characters such as emojis will not be saved.")
  108. has_thrown_errors = True
  109. else:
  110. if not settings.show_cookie_expiry in bool_values:
  111. log_warn("Invalid or missing setting detected for 'save_comments', using default value (False)")
  112. settings.save_comments = 'false'
  113. has_thrown_errors = True
  114. except:
  115. log_warn("Invalid or missing setting detected for 'save_comments', using default value (False)")
  116. settings.save_comments = 'false'
  117. has_thrown_errors = True
  118. try:
  119. settings.save_path = config.get('pyinstalive', 'save_path')
  120. if (os.path.exists(settings.save_path)):
  121. pass
  122. else:
  123. log_warn("Invalid or missing setting detected for 'save_path', falling back to path: {:s}".format(os.getcwd()))
  124. settings.save_path = os.getcwd()
  125. has_thrown_errors = True
  126. if not settings.save_path.endswith('/'):
  127. settings.save_path = settings.save_path + '/'
  128. except:
  129. log_warn("Invalid or missing setting detected for 'save_path', falling back to path: {:s}".format(os.getcwd()))
  130. settings.save_path = os.getcwd()
  131. has_thrown_errors = True
  132. if has_thrown_errors:
  133. log_seperator()
  134. return True
  135. except Exception as e:
  136. print(str(e))
  137. return False
  138. def show_info(config):
  139. if os.path.exists('pyinstalive.ini'):
  140. try:
  141. config.read('pyinstalive.ini')
  142. except Exception as e:
  143. log_error("Could not read configuration file: {:s}".format(str(e)))
  144. log_seperator()
  145. else:
  146. new_config()
  147. sys.exit(1)
  148. if not check_config_validity(config):
  149. log_warn("Config file is not valid, some information may be inaccurate.")
  150. log_whiteline()
  151. cookie_files = []
  152. cookie_from_config = ''
  153. try:
  154. for file in os.listdir(os.getcwd()):
  155. if file.endswith(".json"):
  156. with open(file) as data_file:
  157. try:
  158. json_data = json.load(data_file)
  159. if (json_data.get('created_ts')):
  160. cookie_files.append(file)
  161. except Exception as e:
  162. pass
  163. if settings.username == file.replace(".json", ''):
  164. cookie_from_config = file
  165. except Exception as e:
  166. log_warn("Could not check for cookie files: {:s}".format(str(e)))
  167. log_whiteline()
  168. log_info_green("To see all the available arguments, use the -h argument.")
  169. log_whiteline()
  170. log_info_green("PyInstaLive version: {:s}".format(script_version))
  171. log_info_green("Python version: {:s}".format(python_version))
  172. if not check_ffmpeg():
  173. log_error("FFmpeg framework: Not found")
  174. else:
  175. log_info_green("FFmpeg framework: Available")
  176. if (len(cookie_from_config) > 0):
  177. log_info_green("Cookie files: {:s} ({:s} matches config user)".format(str(len(cookie_files)), cookie_from_config))
  178. elif len(cookie_files) > 0:
  179. log_info_green("Cookie files: {:s}".format(str(len(cookie_files))))
  180. else:
  181. log_warn("Cookie files: None found")
  182. log_info_green("CLI supports color: {:s}".format(str(supports_color()[0])))
  183. log_info_green("File to run at start: {:s}".format(settings.run_at_start))
  184. log_info_green("File to run at finish: {:s}".format(settings.run_at_finish))
  185. log_whiteline()
  186. if os.path.exists('pyinstalive.ini'):
  187. log_info_green("Config file:")
  188. log_whiteline()
  189. with open('pyinstalive.ini') as f:
  190. for line in f:
  191. log_plain(" {:s}".format(line.rstrip()))
  192. else:
  193. log_error("Config file: Not found")
  194. log_whiteline()
  195. log_info_green("End of PyInstaLive information screen.")
  196. log_seperator()
  197. def new_config():
  198. try:
  199. if os.path.exists('pyinstalive.ini'):
  200. log_info_green("A configuration file is already present:")
  201. log_whiteline()
  202. with open('pyinstalive.ini') as f:
  203. for line in f:
  204. log_plain(" {:s}".format(line.rstrip()))
  205. log_whiteline()
  206. log_info_green("To create a default config file, delete 'pyinstalive.ini' and run this script again.")
  207. log_seperator()
  208. else:
  209. try:
  210. log_warn("Could not find configuration file, creating a default one...")
  211. config_template = """
  212. [pyinstalive]
  213. username = johndoe
  214. password = grapefruits
  215. save_path = {:s}
  216. show_cookie_expiry = true
  217. clear_temp_files = false
  218. save_lives = true
  219. save_replays = true
  220. run_at_start =
  221. run_at_finish =
  222. save_comments = false
  223. log_to_file = false
  224. """.format(os.getcwd())
  225. config_file = open("pyinstalive.ini", "w")
  226. config_file.write(config_template.strip())
  227. config_file.close()
  228. log_warn("Edit the created 'pyinstalive.ini' file and run this script again.")
  229. log_seperator()
  230. sys.exit(0)
  231. except Exception as e:
  232. log_error("Could not create default config file: {:s}".format(str(e)))
  233. log_warn("You must manually create and edit it with the following template: ")
  234. log_whiteline()
  235. for line in config_template.strip().splitlines():
  236. log_plain(" {:s}".format(line.rstrip()))
  237. log_whiteline()
  238. log_warn("Save it as 'pyinstalive.ini' and run this script again.")
  239. log_seperator()
  240. except Exception as e:
  241. log_error("An error occurred: {:s}".format(str(e)))
  242. log_warn("If you don't have a configuration file, manually create and edit one with the following template:")
  243. log_whiteline()
  244. log_plain(config_template)
  245. log_whiteline()
  246. log_warn("Save it as 'pyinstalive.ini' and run this script again.")
  247. log_seperator()
  248. def clean_download_dir():
  249. dir_delcount = 0
  250. error_count = 0
  251. lock_count = 0
  252. log_info_green('Cleaning up temporary files and folders...')
  253. try:
  254. if sys.version.split(' ')[0].startswith('2'):
  255. directories = (os.walk(settings.save_path).next()[1])
  256. files = (os.walk(settings.save_path).next()[2])
  257. else:
  258. directories = (os.walk(settings.save_path).__next__()[1])
  259. files = (os.walk(settings.save_path).__next__()[2])
  260. for directory in directories:
  261. if directory.endswith('_downloads'):
  262. if not any(filename.endswith('.lock') for filename in os.listdir(settings.save_path + directory)):
  263. try:
  264. shutil.rmtree(settings.save_path + directory)
  265. dir_delcount += 1
  266. except Exception as e:
  267. log_error("Could not remove temp folder: {:s}".format(str(e)))
  268. error_count += 1
  269. else:
  270. lock_count += 1
  271. log_seperator()
  272. log_info_green('The cleanup has finished.')
  273. if dir_delcount == 0 and error_count == 0 and lock_count == 0:
  274. log_info_green('No folders were removed.')
  275. log_seperator()
  276. return
  277. log_info_green('Folders removed: {:d}'.format(dir_delcount))
  278. log_info_green('Locked folders: {:d}'.format(lock_count))
  279. log_info_green('Errors: {:d}'.format(error_count))
  280. log_seperator()
  281. except KeyboardInterrupt as e:
  282. log_seperator()
  283. log_warn("The cleanup has been aborted.")
  284. if dir_delcount == 0 and error_count == 0 and lock_count == 0:
  285. log_info_green('No folders were removed.')
  286. log_seperator()
  287. return
  288. log_info_green('Folders removed: {:d}'.format(dir_delcount))
  289. log_info_green('Locked folders: {:d}'.format(lock_count))
  290. log_info_green('Errors: {:d}'.format(error_count))
  291. log_seperator()
  292. def run():
  293. logging.disable(logging.CRITICAL)
  294. config = configparser.ConfigParser()
  295. parser = argparse.ArgumentParser(description="You are running PyInstaLive {:s} using Python {:s}".format(script_version, python_version))
  296. parser.add_argument('-u', '--username', dest='username', type=str, required=False, help="Instagram username to login with.")
  297. parser.add_argument('-p', '--password', dest='password', type=str, required=False, help="Instagram password to login with.")
  298. parser.add_argument('-r', '--record', dest='download', type=str, required=False, help="The username of the user whose livestream or replay you want to save.")
  299. parser.add_argument('-d', '--download', dest='download', type=str, required=False, help="The username of the user whose livestream or replay you want to save.")
  300. parser.add_argument('-i', '--info', dest='info', action='store_true', help="View information about PyInstaLive.")
  301. parser.add_argument('-c', '--config', dest='config', action='store_true', help="Create a default configuration file if it doesn't exist.")
  302. parser.add_argument('-nr', '--noreplays', dest='noreplays', action='store_true', help="When used, do not check for any available replays.")
  303. parser.add_argument('-nl', '--nolives', dest='nolives', action='store_true', help="When used, do not check for any available livestreams.")
  304. parser.add_argument('-cl', '--clean', dest='clean', action='store_true', help="PyInstaLive will clean the current download folder of all leftover files.")
  305. parser.add_argument('-df', '--downloadfollowing', dest='downloadfollowing', action='store_true', help="PyInstaLive will check for available livestreams and replays from users the account used to login follows.")
  306. # Workaround to 'disable' argument abbreviations
  307. parser.add_argument('--usernamx', help=argparse.SUPPRESS, metavar='IGNORE')
  308. parser.add_argument('--passworx', help=argparse.SUPPRESS, metavar='IGNORE')
  309. parser.add_argument('--recorx', help=argparse.SUPPRESS, metavar='IGNORE')
  310. parser.add_argument('--infx', help=argparse.SUPPRESS, metavar='IGNORE')
  311. parser.add_argument('--confix', help=argparse.SUPPRESS, metavar='IGNORE')
  312. parser.add_argument('--noreplayx', help=argparse.SUPPRESS, metavar='IGNORE')
  313. parser.add_argument('--cleax', help=argparse.SUPPRESS, metavar='IGNORE')
  314. parser.add_argument('--downloadfollowinx', help=argparse.SUPPRESS, metavar='IGNORE')
  315. parser.add_argument('-cx', help=argparse.SUPPRESS, metavar='IGNORE')
  316. parser.add_argument('-nx', help=argparse.SUPPRESS, metavar='IGNORE')
  317. parser.add_argument('-dx', help=argparse.SUPPRESS, metavar='IGNORE')
  318. args, unknown_args = parser.parse_known_args()
  319. try:
  320. config.read('pyinstalive.ini')
  321. settings.log_to_file = config.get('pyinstalive', 'log_to_file').title()
  322. if not settings.log_to_file in bool_values:
  323. settings.log_to_file = 'False'
  324. elif settings.log_to_file == "True":
  325. if args.download:
  326. settings.user_to_download = args.download
  327. try:
  328. with open("pyinstalive{:s}.log".format("_" + settings.user_to_download if len(settings.user_to_download) > 0 else ".default"),"a+") as f:
  329. f.write("\n")
  330. f.close()
  331. except:
  332. pass
  333. except Exception as e:
  334. settings.log_to_file = 'False'
  335. pass # Pretend nothing happened
  336. log_seperator()
  337. log_info_blue('PYINSTALIVE (SCRIPT V{:s} - PYTHON V{:s}) - {:s}'.format(script_version, python_version, time.strftime('%I:%M:%S %p')))
  338. log_seperator()
  339. if unknown_args:
  340. log_error("The following invalid argument(s) were provided: ")
  341. log_whiteline()
  342. log_info_blue(' ' + ' '.join(unknown_args))
  343. log_whiteline()
  344. if (supports_color()[1] == True):
  345. log_info_green("'pyinstalive -h' can be used to display command help.")
  346. else:
  347. log_plain("pyinstalive -h can be used to display command help.")
  348. log_seperator()
  349. exit(1)
  350. if (args.info) or (not
  351. args.username and not
  352. args.password and not
  353. args.download and not
  354. args.downloadfollowing and not
  355. args.info and not
  356. args.config and not
  357. args.noreplays and not
  358. args.nolives and not
  359. args.clean):
  360. show_info(config)
  361. sys.exit(0)
  362. if (args.config):
  363. new_config()
  364. sys.exit(0)
  365. if os.path.exists('pyinstalive.ini'):
  366. try:
  367. config.read('pyinstalive.ini')
  368. except Exception:
  369. log_error("Could not read configuration file.")
  370. log_seperator()
  371. else:
  372. new_config()
  373. sys.exit(1)
  374. if check_config_validity(config):
  375. try:
  376. if (args.clean):
  377. clean_download_dir()
  378. sys.exit(0)
  379. if not check_ffmpeg():
  380. log_error("Could not find ffmpeg, the script will now exit. ")
  381. log_seperator()
  382. sys.exit(1)
  383. if (args.noreplays):
  384. settings.save_replays = "False"
  385. if (args.nolives):
  386. settings.save_lives = "False"
  387. if settings.save_lives == "False" and settings.save_replays == "False":
  388. log_warn("Script will not run because both live and replay saving is disabled.")
  389. log_seperator()
  390. sys.exit(1)
  391. if not args.download and not args.downloadfollowing:
  392. log_warn("Neither argument -d or -df was passed. Please use one of the two and try again.")
  393. log_seperator()
  394. sys.exit(1)
  395. if args.download and args.downloadfollowing:
  396. log_warn("You can't pass both the -d and -df arguments. Please use one of the two and try again.")
  397. log_seperator()
  398. sys.exit(1)
  399. if (args.username is not None) and (args.password is not None):
  400. api = login(args.username, args.password, settings.show_cookie_expiry, True)
  401. elif (args.username is not None) or (args.password is not None):
  402. log_warn("Missing --username or --password argument, falling back to configuration file...")
  403. if (not len(settings.username) > 0) or (not len(settings.password) > 0):
  404. log_error("Username or password are missing. Please check your configuration file and try again.")
  405. log_seperator()
  406. sys.exit(1)
  407. else:
  408. api = login(settings.username, settings.password, settings.show_cookie_expiry, False)
  409. else:
  410. if (not len(settings.username) > 0) or (not len(settings.password) > 0):
  411. log_error("Username or password are missing. Please check your configuration file and try again.")
  412. log_seperator()
  413. sys.exit(1)
  414. else:
  415. api = login(settings.username, settings.password, settings.show_cookie_expiry, False)
  416. if args.download and not args.downloadfollowing:
  417. start_single(api, args.download, settings)
  418. if not args.download and args.downloadfollowing:
  419. if check_pyinstalive():
  420. start_multiple(api, settings, "pyinstalive")
  421. else:
  422. log_warn("You probably ran PyInstaLive as a script module with the -m argument.")
  423. log_warn("PyInstaLive should be properly installed when using the -df argument.")
  424. log_seperator()
  425. if python_version[0] == 3:
  426. start_multiple(api, settings, "python3 -m pyinstalive")
  427. else:
  428. start_multiple(api, settings, "python -m pyinstalive")
  429. except Exception as e:
  430. log_error("Could not finish pre-download checks: {:s}".format(str(e)))
  431. log_seperator()
  432. except KeyboardInterrupt as ee:
  433. log_warn("Pre-download checks have been aborted, exiting...")
  434. log_seperator()
  435. else:
  436. log_error("The configuration file is not valid. Please double-check and try again.")
  437. log_seperator()
  438. sys.exit(1)