auth.py 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. import codecs
  2. import json
  3. import os.path
  4. import datetime
  5. import logger
  6. try:
  7. from instagram_private_api import (
  8. Client, ClientError, ClientLoginError,
  9. ClientCookieExpiredError, ClientLoginRequiredError,
  10. __version__ as client_version)
  11. except ImportError:
  12. import sys
  13. sys.path.append(os.path.join(os.path.dirname(__file__), '..'))
  14. from instagram_private_api import (
  15. Client, ClientError, ClientLoginError,
  16. ClientCookieExpiredError, ClientLoginRequiredError,
  17. __version__ as client_version)
  18. def to_json(python_object):
  19. if isinstance(python_object, bytes):
  20. return {'__class__': 'bytes',
  21. '__value__': codecs.encode(python_object, 'base64').decode()}
  22. raise TypeError(repr(python_object) + ' is not JSON serializable')
  23. def from_json(json_object):
  24. if '__class__' in json_object and json_object['__class__'] == 'bytes':
  25. return codecs.decode(json_object['__value__'].encode(), 'base64')
  26. return json_object
  27. def onlogin_callback(api, settings_file):
  28. cache_settings = api.settings
  29. with open(settings_file, 'w') as outfile:
  30. json.dump(cache_settings, outfile, default=to_json)
  31. logger.log('[I] New auth cookie file was made: {0!s}'.format(settings_file), "GREEN")
  32. def login(username, password, show_cookie_expiry):
  33. device_id = None
  34. try:
  35. settings_file = "credentials.json"
  36. if not os.path.isfile(settings_file):
  37. # settings file does not exist
  38. logger.log('[W] Unable to find auth cookie file: {0!s}'.format(settings_file), "YELLOW")
  39. # login new
  40. api = Client(
  41. username, password,
  42. on_login=lambda x: onlogin_callback(x, settings_file))
  43. else:
  44. with open(settings_file) as file_data:
  45. cached_settings = json.load(file_data, object_hook=from_json)
  46. # logger.log('[I] Using settings file: {0!s}'.format(settings_file), "GREEN")
  47. device_id = cached_settings.get('device_id')
  48. # reuse auth settings
  49. api = Client(
  50. username, password,
  51. settings=cached_settings)
  52. except (ClientCookieExpiredError, ClientLoginRequiredError) as e:
  53. logger.log('[E] ClientCookieExpiredError/ClientLoginRequiredError: {0!s}'.format(e), "RED")
  54. # Login expired
  55. # Do relogin but use default ua, keys and such
  56. api = Client(
  57. username, password,
  58. device_id=device_id,
  59. on_login=lambda x: onlogin_callback(x, settings))
  60. except ClientLoginError as e:
  61. logger.log('[E] ClientLoginError: {0!s}'.format(e), "RED")
  62. sys.exit(9)
  63. except ClientError as e:
  64. logger.log('[E] ClientError: {0!s}'.format(e), "RED")
  65. sys.exit(9)
  66. except Exception as e:
  67. logger.log('[E] Unexpected Exception: {0!s}'.format(e), "RED")
  68. sys.exit(99)
  69. logger.log('[I] Login to "' + username + '" OK!', "GREEN")
  70. if show_cookie_expiry == 'True':
  71. cookie_expiry = api.cookie_jar.expires_earliest
  72. logger.log('[I] Login cookie expiry date: {0!s}'.format(datetime.datetime.fromtimestamp(cookie_expiry).strftime('%Y-%m-%d at %H:%M:%S')), "GREEN")
  73. return api