#!/usr/bin/env python

# -*- coding: utf-8 -*-

import requests

import random

import json

import hashlib

import hmac

import urllib

import uuid

import time

import copy

import math

import sys

from datetime import datetime

import calendar

import os

from requests_toolbelt import MultipartEncoder

# Turn off InsecureRequestWarning

from requests.packages.urllib3.exceptions import InsecureRequestWarning

requests.packages.urllib3.disable_warnings(InsecureRequestWarning)

try:

from moviepy.editor import VideoFileClip

except ImportError:

print("Fail to import moviepy. Need only for Video upload.")

# The urllib library was split into other modules from Python 2 to Python 3

if sys.version_info.major == 3:

import urllib.parse

try:

from ImageUtils import getImageSize

except:

# Issue 159, python3 import fix

from .ImageUtils import getImageSize

from .exceptions import SentryBlockException

class InstagramAPI:

API_URL = 'https://i.instagram.com/api/v1/'

DEVICE_SETTINTS = {'manufacturer': 'Xiaomi',

'model': 'HM 1SW',

'android_version': 18,

'android_release': '4.3'}

USER_AGENT = 'Instagram 10.26.0 Android ({android_version}/{android_release}; 320dpi; 720x1280; {manufacturer}; {model}; armani; qcom; en_US)'.format(**DEVICE_SETTINTS)

IG_SIG_KEY = '4f8732eb9ba7d1c8e8897a75d6474d4eb3f5279137431b2aafb71fafe2abe178'

EXPERIMENTS = 'ig_promote_reach_objective_fix_universe,ig_android_universe_video_production,ig_search_client_h1_2017_holdout,ig_android_live_follow_from_comments_universe,ig_android_carousel_non_square_creation,ig_android_live_analytics,ig_android_follow_all_dialog_confirmation_copy,ig_android_stories_server_coverframe,ig_android_video_captions_universe,ig_android_offline_location_feed,ig_android_direct_inbox_retry_seen_state,ig_android_ontact_invite_universe,ig_android_live_broadcast_blacklist,ig_android_insta_video_reconnect_viewers,ig_android_ad_async_ads_universe,ig_android_search_clear_layout_universe,ig_android_shopping_reporting,ig_android_stories_surface_universe,ig_android_verified_comments_universe,ig_android_preload_media_ahead_in_current_reel,android_instagram_prefetch_suggestions_universe,ig_android_reel_viewer_fetch_missing_reels_universe,ig_android_direct_search_share_sheet_universe,ig_android_business_promote_tooltip,ig_android_direct_blue_tab,ig_android_async_network_tweak_universe,ig_android_elevate_main_thread_priority_universe,ig_android_stories_gallery_nux,ig_android_instavideo_remove_nux_comments,ig_video_copyright_whitelist,ig_react_native_inline_insights_with_relay,ig_android_direct_thread_message_animation,ig_android_draw_rainbow_client_universe,ig_android_direct_link_style,ig_android_live_heart_enhancements_universe,ig_android_rtc_reshare,ig_android_preload_item_count_in_reel_viewer_buffer,ig_android_users_bootstrap_service,ig_android_auto_retry_post_mode,ig_android_shopping,ig_android_main_feed_seen_state_dont_send_info_on_tail_load,ig_fbns_preload_default,ig_android_gesture_dismiss_reel_viewer,ig_android_tool_tip,ig_android_ad_logger_funnel_logging_universe,ig_android_gallery_grid_column_count_universe,ig_android_business_new_ads_payment_universe,ig_android_direct_links,ig_android_audience_control,ig_android_live_encore_consumption_settings_universe,ig_perf_android_holdout,ig_android_cache_contact_import_list,ig_android_links_receivers,ig_android_ad_impression_backtest,ig_android_list_redesign,ig_android_stories_separate_overlay_creation,ig_android_stop_video_recording_fix_universe,ig_android_render_video_segmentation,ig_android_live_encore_reel_chaining_universe,ig_android_sync_on_background_enhanced_10_25,ig_android_immersive_viewer,ig_android_mqtt_skywalker,ig_fbns_push,ig_android_ad_watchmore_overlay_universe,ig_android_react_native_universe,ig_android_profile_tabs_redesign_universe,ig_android_live_consumption_abr,ig_android_story_viewer_social_context,ig_android_hide_post_in_feed,ig_android_video_loopcount_int,ig_android_enable_main_feed_reel_tray_preloading,ig_android_camera_upsell_dialog,ig_android_ad_watchbrowse_universe,ig_android_internal_research_settings,ig_android_search_people_tag_universe,ig_android_react_native_ota,ig_android_enable_concurrent_request,ig_android_react_native_stories_grid_view,ig_android_business_stories_inline_insights,ig_android_log_mediacodec_info,ig_android_direct_expiring_media_loading_errors,ig_video_use_sve_universe,ig_android_cold_start_feed_request,ig_android_enable_zero_rating,ig_android_reverse_audio,ig_android_branded_content_three_line_ui_universe,ig_android_live_encore_production_universe,ig_stories_music_sticker,ig_android_stories_teach_gallery_location,ig_android_http_stack_experiment_2017,ig_android_stories_device_tilt,ig_android_pending_request_search_bar,ig_android_fb_topsearch_sgp_fork_request,ig_android_seen_state_with_view_info,ig_android_animation_perf_reporter_timeout,ig_android_new_block_flow,ig_android_story_tray_title_play_all_v2,ig_android_direct_address_links,ig_android_stories_archive_universe,ig_android_save_collections_cover_photo,ig_android_live_webrtc_livewith_production,ig_android_sign_video_url,ig_android_stories_video_prefetch_kb,ig_android_stories_create_flow_favorites_tooltip,ig_android_live_stop_broadcast_on_404,ig_android_live_viewer_invite_universe,ig_android_promotion_feedback_channel,ig_android_render_iframe_interval,ig_android_accessibility_logging_universe,ig_android_camera_shortcut_universe,ig_android_use_one_cookie_store_per_user_override,ig_profile_holdout_2017_universe,ig_android_stories_server_brushes,ig_android_ad_media_url_logging_universe,ig_android_shopping_tag_nux_text_universe,ig_android_comments_single_reply_universe,ig_android_stories_video_loading_spinner_improvements,ig_android_collections_cache,ig_android_comment_api_spam_universe,ig_android_facebook_twitter_profile_photos,ig_android_shopping_tag_creation_universe,ig_story_camera_reverse_video_experiment,ig_android_direct_bump_selected_recipients,ig_android_ad_cta_haptic_feedback_universe,ig_android_vertical_share_sheet_experiment,ig_android_family_bridge_share,ig_android_search,ig_android_insta_video_consumption_titles,ig_android_stories_gallery_preview_button,ig_android_fb_auth_education,ig_android_camera_universe,ig_android_me_only_universe,ig_android_instavideo_audio_only_mode,ig_android_user_profile_chaining_icon,ig_android_live_video_reactions_consumption_universe,ig_android_stories_hashtag_text,ig_android_post_live_badge_universe,ig_android_swipe_fragment_container,ig_android_search_users_universe,ig_android_live_save_to_camera_roll_universe,ig_creation_growth_holdout,ig_android_sticker_region_tracking,ig_android_unified_inbox,ig_android_live_new_watch_time,ig_android_offline_main_feed_10_11,ig_import_biz_contact_to_page,ig_android_live_encore_consumption_universe,ig_android_experimental_filters,ig_android_search_client_matching_2,ig_android_react_native_inline_insights_v2,ig_android_business_conversion_value_prop_v2,ig_android_redirect_to_low_latency_universe,ig_android_ad_show_new_awr_universe,ig_family_bridges_holdout_universe,ig_android_background_explore_fetch,ig_android_following_follower_social_context,ig_android_video_keep_screen_on,ig_android_ad_leadgen_relay_modern,ig_android_profile_photo_as_media,ig_android_insta_video_consumption_infra,ig_android_ad_watchlead_universe,ig_android_direct_prefetch_direct_story_json,ig_android_shopping_react_native,ig_android_top_live_profile_pics_universe,ig_android_direct_phone_number_links,ig_android_stories_weblink_creation,ig_android_direct_search_new_thread_universe,ig_android_histogram_reporter,ig_android_direct_on_profile_universe,ig_android_network_cancellation,ig_android_background_reel_fetch,ig_android_react_native_insights,ig_android_insta_video_audio_encoder,ig_android_family_bridge_bookmarks,ig_android_data_usage_network_layer,ig_android_universal_instagram_deep_links,ig_android_dash_for_vod_universe,ig_android_modular_tab_discover_people_redesign,ig_android_mas_sticker_upsell_dialog_universe,ig_android_ad_add_per_event_counter_to_logging_event,ig_android_sticky_header_top_chrome_optimization,ig_android_rtl,ig_android_biz_conversion_page_pre_select,ig_android_promote_from_profile_button,ig_android_live_broadcaster_invite_universe,ig_android_share_spinner,ig_android_text_action,ig_android_own_reel_title_universe,ig_promotions_unit_in_insights_landing_page,ig_android_business_settings_header_univ,ig_android_save_longpress_tooltip,ig_android_constrain_image_size_universe,ig_android_business_new_graphql_endpoint_universe,ig_ranking_following,ig_android_stories_profile_camera_entry_point,ig_android_universe_reel_video_production,ig_android_power_metrics,ig_android_sfplt,ig_android_offline_hashtag_feed,ig_android_live_skin_smooth,ig_android_direct_inbox_search,ig_android_stories_posting_offline_ui,ig_android_sidecar_video_upload_universe,ig_android_promotion_manager_entry_point_universe,ig_android_direct_reply_audience_upgrade,ig_android_swipe_navigation_x_angle_universe,ig_android_offline_mode_holdout,ig_android_live_send_user_location,ig_android_direct_fetch_before_push_notif,ig_android_non_square_first,ig_android_insta_video_drawing,ig_android_swipeablefilters_universe,ig_android_live_notification_control_universe,ig_android_analytics_logger_running_background_universe,ig_android_save_all,ig_android_reel_viewer_data_buffer_size,ig_direct_quality_holdout_universe,ig_android_family_bridge_discover,ig_android_react_native_restart_after_error_universe,ig_android_startup_manager,ig_story_tray_peek_content_universe,ig_android_profile,ig_android_high_res_upload_2,ig_android_http_service_same_thread,ig_android_scroll_to_dismiss_keyboard,ig_android_remove_followers_universe,ig_android_skip_video_render,ig_android_story_timestamps,ig_android_live_viewer_comment_prompt_universe,ig_profile_holdout_universe,ig_android_react_native_insights_grid_view,ig_stories_selfie_sticker,ig_android_stories_reply_composer_redesign,ig_android_streamline_page_creation,ig_explore_netego,ig_android_ig4b_connect_fb_button_universe,ig_android_feed_util_rect_optimization,ig_android_rendering_controls,ig_android_os_version_blocking,ig_android_encoder_width_safe_multiple_16,ig_search_new_bootstrap_holdout_universe,ig_android_snippets_profile_nux,ig_android_e2e_optimization_universe,ig_android_comments_logging_universe,ig_shopping_insights,ig_android_save_collections,ig_android_live_see_fewer_videos_like_this_universe,ig_android_show_new_contact_import_dialog,ig_android_live_view_profile_from_comments_universe,ig_fbns_blocked,ig_formats_and_feedbacks_holdout_universe,ig_android_reduce_view_pager_buffer,ig_android_instavideo_periodic_notif,ig_search_user_auto_complete_cache_sync_ttl,ig_android_marauder_update_frequency,ig_android_suggest_password_reset_on_oneclick_login,ig_android_promotion_entry_from_ads_manager_universe,ig_android_live_special_codec_size_list,ig_android_enable_share_to_messenger,ig_android_background_main_feed_fetch,ig_android_live_video_reactions_creation_universe,ig_android_channels_home,ig_android_sidecar_gallery_universe,ig_android_upload_reliability_universe,ig_migrate_mediav2_universe,ig_android_insta_video_broadcaster_infra_perf,ig_android_business_conversion_social_context,android_ig_fbns_kill_switch,ig_android_live_webrtc_livewith_consumption,ig_android_destroy_swipe_fragment,ig_android_react_native_universe_kill_switch,ig_android_stories_book_universe,ig_android_all_videoplayback_persisting_sound,ig_android_draw_eraser_universe,ig_direct_search_new_bootstrap_holdout_universe,ig_android_cache_layer_bytes_threshold,ig_android_search_hash_tag_and_username_universe,ig_android_business_promotion,ig_android_direct_search_recipients_controller_universe,ig_android_ad_show_full_name_universe,ig_android_anrwatchdog,ig_android_qp_kill_switch,ig_android_2fac,ig_direct_bypass_group_size_limit_universe,ig_android_promote_simplified_flow,ig_android_share_to_whatsapp,ig_android_hide_bottom_nav_bar_on_discover_people,ig_fbns_dump_ids,ig_android_hands_free_before_reverse,ig_android_skywalker_live_event_start_end,ig_android_live_join_comment_ui_change,ig_android_direct_search_story_recipients_universe,ig_android_direct_full_size_gallery_upload,ig_android_ad_browser_gesture_control,ig_channel_server_experiments,ig_android_video_cover_frame_from_original_as_fallback,ig_android_ad_watchinstall_universe,ig_android_ad_viewability_logging_universe,ig_android_new_optic,ig_android_direct_visual_replies,ig_android_stories_search_reel_mentions_universe,ig_android_threaded_comments_universe,ig_android_mark_reel_seen_on_Swipe_forward,ig_internal_ui_for_lazy_loaded_modules_experiment,ig_fbns_shared,ig_android_capture_slowmo_mode,ig_android_live_viewers_list_search_bar,ig_android_video_single_surface,ig_android_offline_reel_feed,ig_android_video_download_logging,ig_android_last_edits,ig_android_exoplayer_4142,ig_android_post_live_viewer_count_privacy_universe,ig_android_activity_feed_click_state,ig_android_snippets_haptic_feedback,ig_android_gl_drawing_marks_after_undo_backing,ig_android_mark_seen_state_on_viewed_impression,ig_android_live_backgrounded_reminder_universe,ig_android_live_hide_viewer_nux_universe,ig_android_live_monotonic_pts,ig_android_search_top_search_surface_universe,ig_android_user_detail_endpoint,ig_android_location_media_count_exp_ig,ig_android_comment_tweaks_universe,ig_android_ad_watchmore_entry_point_universe,ig_android_top_live_notification_universe,ig_android_add_to_last_post,ig_save_insights,ig_android_live_enhanced_end_screen_universe,ig_android_ad_add_counter_to_logging_event,ig_android_blue_token_conversion_universe,ig_android_exoplayer_settings,ig_android_progressive_jpeg,ig_android_offline_story_stickers,ig_android_gqls_typing_indicator,ig_android_chaining_button_tooltip,ig_android_video_prefetch_for_connectivity_type,ig_android_use_exo_cache_for_progressive,ig_android_samsung_app_badging,ig_android_ad_holdout_watchandmore_universe,ig_android_offline_commenting,ig_direct_stories_recipient_picker_button,ig_insights_feedback_channel_universe,ig_android_insta_video_abr_resize,ig_android_insta_video_sound_always_on'''

SIG_KEY_VERSION = '4'

# username # Instagram username

# password # Instagram password

# debug # Debug

# uuid # UUID

# device_id # Device ID

# username_id # Username ID

# token # _csrftoken

# isLoggedIn # Session status

# rank_token # Rank token

# IGDataPath # Data storage path

def __init__(self, username, password, debug=False, IGDataPath=None):

m = hashlib.md5()

m.update(username.encode('utf-8') + password.encode('utf-8'))

self.device_id = self.generateDeviceId(m.hexdigest())

self.setUser(username, password)

self.isLoggedIn = False

self.LastResponse = None

self.s = requests.Session()

def setUser(self, username, password):

self.username = username

self.password = password

self.uuid = self.generateUUID(True)

def setProxy(self, proxy=None):

"""

Set proxy for all requests::

Proxy format - user:password@ip:port

"""

if proxy is not None:

print('Set proxy!')

proxies = {'http': proxy, 'https': proxy}

self.s.proxies.update(proxies)

def login(self, force=False):

if (not self.isLoggedIn or force):

if (self.SendRequest('si/fetch_headers/?challenge_type=signup&guid=' + self.generateUUID(False), None, True)):

data = {'phone_id': self.generateUUID(True),

'_csrftoken': self.LastResponse.cookies['csrftoken'],

'username': self.username,

'guid': self.uuid,

'device_id': self.device_id,

'password': self.password,

'login_attempt_count': '0'}

if (self.SendRequest('accounts/login/', self.generateSignature(json.dumps(data)), True)):

self.isLoggedIn = True

self.username_id = self.LastJson["logged_in_user"]["pk"]

self.rank_token = "%s_%s" % (self.username_id, self.uuid)

self.token = self.LastResponse.cookies["csrftoken"]

self.syncFeatures()

self.autoCompleteUserList()

self.timelineFeed()

self.getv2Inbox()

self.getRecentActivity()

print("Login success!\n")

return True

def syncFeatures(self):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'id': self.username_id,

'_csrftoken': self.token,

'experiments': self.EXPERIMENTS})

return self.SendRequest('qe/sync/', self.generateSignature(data))

def autoCompleteUserList(self):

return self.SendRequest('friendships/autocomplete_user_list/')

def timelineFeed(self):

return self.SendRequest('feed/timeline/')

def megaphoneLog(self):

return self.SendRequest('megaphone/log/')

def expose(self):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'id': self.username_id,

'_csrftoken': self.token,

'experiment': 'ig_android_profile_contextual_feed'})

return self.SendRequest('qe/expose/', self.generateSignature(data))

def logout(self):

logout = self.SendRequest('accounts/logout/')

def uploadPhoto(self, photo, caption=None, upload_id=None, is_sidecar=None):

if upload_id is None:

upload_id = str(int(time.time() * 1000))

data = {'upload_id': upload_id,

'_uuid': self.uuid,

'_csrftoken': self.token,

'image_compression': '{"lib_name":"jt","lib_version":"1.3.0","quality":"87"}',

'photo': ('pending_media_%s.jpg' % upload_id, open(photo, 'rb'), 'application/octet-stream', {'Content-Transfer-Encoding': 'binary'})}

if is_sidecar:

data['is_sidecar'] = '1'

m = MultipartEncoder(data, boundary=self.uuid)

self.s.headers.update({'X-IG-Capabilities': '3Q4=',

'X-IG-Connection-Type': 'WIFI',

'Cookie2': '$Version=1',

'Accept-Language': 'en-US',

'Accept-Encoding': 'gzip, deflate',

'Content-type': m.content_type,

'Connection': 'close',

'User-Agent': self.USER_AGENT})

response = self.s.post(self.API_URL + "upload/photo/", data=m.to_string())

if response != 200:

if self.configure(upload_id, photo, caption):

self.expose()

return True

else:

return False

else:

return True

def uploadVideo(self, video, thumbnail, caption=None, upload_id=None, is_sidecar=None):

if upload_id is None:

upload_id = str(int(time.time() * 1000))

data = {'upload_id': upload_id,

'_csrftoken': self.token,

'media_type': '2',

'_uuid': self.uuid}

if is_sidecar:

data['is_sidecar'] = '1'

m = MultipartEncoder(data, boundary=self.uuid)

self.s.headers.update({'X-IG-Capabilities': '3Q4=',

'X-IG-Connection-Type': 'WIFI',

'Host': 'i.instagram.com',

'Cookie2': '$Version=1',

'Accept-Language': 'en-US',

'Accept-Encoding': 'gzip, deflate',

'Content-type': m.content_type,

'Connection': 'keep-alive',

'User-Agent': self.USER_AGENT})

response = self.s.post(self.API_URL + "upload/video/", data=m.to_string())

if response.status_code == 200:

body = json.loads(response.text)

upload_url = body['video_upload_urls'][3]['url']

upload_job = body['video_upload_urls'][3]['job']

videoData = open(video, 'rb').read()

# solve issue #85 TypeError: slice indices must be integers or None or have an __index__ method

request_size = int(math.floor(len(videoData) / 4))

lastRequestExtra = (len(videoData) - (request_size * 3))

headers = copy.deepcopy(self.s.headers)

self.s.headers.update({'X-IG-Capabilities': '3Q4=',

'X-IG-Connection-Type': 'WIFI',

'Cookie2': '$Version=1',

'Accept-Language': 'en-US',

'Accept-Encoding': 'gzip, deflate',

'Content-type': 'application/octet-stream',

'Session-ID': upload_id,

'Connection': 'keep-alive',

'Content-Disposition': 'attachment; filename="video.mov"',

'job': upload_job,

'Host': 'upload.instagram.com',

'User-Agent': self.USER_AGENT})

for i in range(0, 4):

start = i * request_size

if i == 3:

end = i * request_size + lastRequestExtra

else:

end = (i + 1) * request_size

length = lastRequestExtra if i == 3 else request_size

content_range = "bytes {start}-{end}/{lenVideo}".format(start=start, end=(end - 1),

lenVideo=len(videoData)).encode('utf-8')

self.s.headers.update({'Content-Length': str(end - start), 'Content-Range': content_range, })

response = self.s.post(upload_url, data=videoData[start:start + length])

self.s.headers = headers

if response.status_code == 200:

if self.configureVideo(upload_id, video, thumbnail, caption):

self.expose()

return False

def uploadAlbum(self, media, caption=None, upload_id=None):

if not media:

raise Exception("List of media to upload can't be empty.")

if len(media) < 2 or len(media) > 10:

raise Exception('Instagram requires that albums contain 2-10 items. You tried to submit {}.'.format(len(media)))

# Figure out the media file details for ALL media in the album.

# NOTE: We do this first, since it validates whether the media files are

# valid and lets us avoid wasting time uploading totally invalid albums!

for idx, item in enumerate(media):

if not item.get('file', '') or item.get('tipe', ''):

raise Exception('Media at index "{}" does not have the required "file" and "type" keys.'.format(idx))

# $itemInternalMetadata = new InternalMetadata();

# If usertags are provided, verify that the entries are valid.

if item.get('usertags', []):

self.throwIfInvalidUsertags(item['usertags'])

# Pre-process media details and throw if not allowed on Instagram.

if item.get('type', '') == 'photo':

# Determine the photo details.

# $itemInternalMetadata->setPhotoDetails(Constants::FEED_TIMELINE_ALBUM, $item['file']);

pass

elif item.get('type', '') == 'video':

# Determine the video details.

# $itemInternalMetadata->setVideoDetails(Constants::FEED_TIMELINE_ALBUM, $item['file']);

pass

else:

raise Exception('Unsupported album media type "{}".'.format(item['type']))

itemInternalMetadata = {}

item['internalMetadata'] = itemInternalMetadata

# Perform all media file uploads.

for idx, item in enumerate(media):

itemInternalMetadata = item['internalMetadata']

item_upload_id = self.generateUploadId()

if item.get('type', '') == 'photo':

self.uploadPhoto(item['file'], caption=caption, is_sidecar=True, upload_id=item_upload_id)

# $itemInternalMetadata->setPhotoUploadResponse($this->ig->internal->uploadPhotoData(Constants::FEED_TIMELINE_ALBUM, $itemInternalMetadata));

elif item.get('type', '') == 'video':

# Attempt to upload the video data.

self.uploadVideo(item['file'], item['thumbnail'], caption=caption, is_sidecar=True, upload_id=item_upload_id)

# $itemInternalMetadata = $this->ig->internal->uploadVideo(Constants::FEED_TIMELINE_ALBUM, $item['file'], $itemInternalMetadata);

# Attempt to upload the thumbnail, associated with our video's ID.

# $itemInternalMetadata->setPhotoUploadResponse($this->ig->internal->uploadPhotoData(Constants::FEED_TIMELINE_ALBUM, $itemInternalMetadata));

pass

item['internalMetadata']['upload_id'] = item_upload_id

albumInternalMetadata = {}

return self.configureTimelineAlbum(media, albumInternalMetadata, captionText=caption)

def throwIfInvalidUsertags(self, usertags):

for user_position in usertags:

# Verify this usertag entry, ensuring that the entry is format

# ['position'=>[0.0,1.0],'user_id'=>'123'] and nothing else.

correct = True

if isinstance(user_position, dict):

position = user_position.get('position', None)

user_id = user_position.get('user_id', None)

if isinstance(position, list) and len(position) == 2:

try:

x = float(position[0])

y = float(position[1])

if x < 0.0 or x > 1.0:

correct = False

if y < 0.0 or y > 1.0:

correct = False

except:

correct = False

try:

user_id = long(user_id)

if user_id < 0:

correct = False

except:

correct = False

if not correct:

raise Exception('Invalid user entry in usertags array.')

def configureTimelineAlbum(self, media, albumInternalMetadata, captionText='', location=None):

endpoint = 'media/configure_sidecar/'

albumUploadId = self.generateUploadId()

date = datetime.utcnow().isoformat()

childrenMetadata = []

for item in media:

itemInternalMetadata = item['internalMetadata']

uploadId = itemInternalMetadata.get('upload_id', self.generateUploadId())

if item.get('type', '') == 'photo':

# Build this item's configuration.

photoConfig = {'date_time_original': date,

'scene_type': 1,

'disable_comments': False,

'upload_id': uploadId,

'source_type': 0,

'scene_capture_type': 'standard',

'date_time_digitized': date,

'geotag_enabled': False,

'camera_position': 'back',

'edits': {'filter_strength': 1,

'filter_name': 'IGNormalFilter'}

}

# This usertag per-file EXTERNAL metadata is only supported for PHOTOS!

if item.get('usertags', []):

# NOTE: These usertags were validated in Timeline::uploadAlbum.

photoConfig['usertags'] = json.dumps({'in': item['usertags']})

childrenMetadata.append(photoConfig)

if item.get('type', '') == 'video':

# Get all of the INTERNAL per-VIDEO metadata.

videoDetails = itemInternalMetadata.get('video_details', {})

# Build this item's configuration.

videoConfig = {'length': videoDetails.get('duration', 1.0),

'date_time_original': date,

'scene_type': 1,

'poster_frame_index': 0,

'trim_type': 0,

'disable_comments': False,

'upload_id': uploadId,

'source_type': 'library',

'geotag_enabled': False,

'edits': {

'length': videoDetails.get('duration', 1.0),

'cinema': 'unsupported',

'original_length': videoDetails.get('duration', 1.0),

'source_type': 'library',

'start_time': 0,

'camera_position': 'unknown',

'trim_type': 0}

}

childrenMetadata.append(videoConfig)

# Build the request...

data = {'_csrftoken': self.token,

'_uid': self.username_id,

'_uuid': self.uuid,

'client_sidecar_id': albumUploadId,

'caption': captionText,

'children_metadata': childrenMetadata}

self.SendRequest(endpoint, self.generateSignature(json.dumps(data)))

response = self.LastResponse

if response.status_code == 200:

self.LastResponse = response

self.LastJson = json.loads(response.text)

return True

else:

print("Request return " + str(response.status_code) + " error!")

# for debugging

try:

self.LastResponse = response

self.LastJson = json.loads(response.text)

except:

pass

return False

def direct_message(self, text, recipients):

if type(recipients) != type([]):

recipients = [str(recipients)]

recipient_users = '"",""'.join(str(r) for r in recipients)

endpoint = 'direct_v2/threads/broadcast/text/'

boundary = self.uuid

bodies = [

{

'type' : 'form-data',

'name' : 'recipient_users',

'data' : '[["{}"]]'.format(recipient_users),

},

{

'type' : 'form-data',

'name' : 'client_context',

'data' : self.uuid,

},

{

'type' : 'form-data',

'name' : 'thread',

'data' : '["0"]',

},

{

'type' : 'form-data',

'name' : 'text',

'data' : text or '',

},

]

data = self.buildBody(bodies,boundary)

self.s.headers.update (

{

'User-Agent' : self.USER_AGENT,

'Proxy-Connection' : 'keep-alive',

'Connection': 'keep-alive',

'Accept': '*/*',

'Content-Type': 'multipart/form-data; boundary={}'.format(boundary),

'Accept-Language': 'en-en',

}

)

#self.SendRequest(endpoint,post=data) #overwrites 'Content-type' header and boundary is missed

response = self.s.post(self.API_URL + endpoint, data=data)

if response.status_code == 200:

self.LastResponse = response

self.LastJson = json.loads(response.text)

return True

else:

print ("Request return " + str(response.status_code) + " error!")

# for debugging

try:

self.LastResponse = response

self.LastJson = json.loads(response.text)

except:

pass

return False

def direct_share(self, media_id, recipients, text=None):

if not isinstance(position, list):

recipients = [str(recipients)]

recipient_users = '"",""'.join(str(r) for r in recipients)

endpoint = 'direct_v2/threads/broadcast/media_share/?media_type=photo'

boundary = self.uuid

bodies = [

{

'type': 'form-data',

'name': 'media_id',

'data': media_id,

},

{

'type': 'form-data',

'name': 'recipient_users',

'data': '[["{}"]]'.format(recipient_users),

},

{

'type': 'form-data',

'name': 'client_context',

'data': self.uuid,

},

{

'type': 'form-data',

'name': 'thread',

'data': '["0"]',

},

{

'type': 'form-data',

'name': 'text',

'data': text or '',

},

]

data = self.buildBody(bodies, boundary)

self.s.headers.update({'User-Agent': self.USER_AGENT,

'Proxy-Connection': 'keep-alive',

'Connection': 'keep-alive',

'Accept': '*/*',

'Content-Type': 'multipart/form-data; boundary={}'.format(boundary),

'Accept-Language': 'en-en'})

# self.SendRequest(endpoint,post=data) #overwrites 'Content-type' header and boundary is missed

response = self.s.post(self.API_URL + endpoint, data=data)

if response.status_code == 200:

self.LastResponse = response

self.LastJson = json.loads(response.text)

return True

else:

print("Request return " + str(response.status_code) + " error!")

# for debugging

try:

self.LastResponse = response

self.LastJson = json.loads(response.text)

except:

pass

return False

def configureVideo(self, upload_id, video, thumbnail, caption=''):

clip = VideoFileClip(video)

self.uploadPhoto(photo=thumbnail, caption=caption, upload_id=upload_id)

data = json.dumps({

'upload_id': upload_id,

'source_type': 3,

'poster_frame_index': 0,

'length': 0.00,

'audio_muted': False,

'filter_type': 0,

'video_result': 'deprecated',

'clips': {

'length': clip.duration,

'source_type': '3',

'camera_position': 'back',

},

'extra': {

'source_width': clip.size[0],

'source_height': clip.size[1],

},

'device': self.DEVICE_SETTINTS,

'_csrftoken': self.token,

'_uuid': self.uuid,

'_uid': self.username_id,

'caption': caption,

})

return self.SendRequest('media/configure/?video=1', self.generateSignature(data))

def configure(self, upload_id, photo, caption=''):

(w, h) = getImageSize(photo)

data = json.dumps({'_csrftoken': self.token,

'media_folder': 'Instagram',

'source_type': 4,

'_uid': self.username_id,

'_uuid': self.uuid,

'caption': caption,

'upload_id': upload_id,

'device': self.DEVICE_SETTINTS,

'edits': {

'crop_original_size': [w * 1.0, h * 1.0],

'crop_center': [0.0, 0.0],

'crop_zoom': 1.0

},

'extra': {

'source_width': w,

'source_height': h

}})

return self.SendRequest('media/configure/?', self.generateSignature(data))

def editMedia(self, mediaId, captionText=''):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'caption_text': captionText})

return self.SendRequest('media/' + str(mediaId) + '/edit_media/', self.generateSignature(data))

def removeSelftag(self, mediaId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token})

return self.SendRequest('media/' + str(mediaId) + '/remove/', self.generateSignature(data))

def mediaInfo(self, mediaId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'media_id': mediaId})

return self.SendRequest('media/' + str(mediaId) + '/info/', self.generateSignature(data))

def deleteMedia(self, mediaId, media_type=1):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'media_type': media_type,

'media_id': mediaId})

return self.SendRequest('media/' + str(mediaId) + '/delete/', self.generateSignature(data))

def changePassword(self, newPassword):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'old_password': self.password,

'new_password1': newPassword,

'new_password2': newPassword})

return self.SendRequest('accounts/change_password/', self.generateSignature(data))

def explore(self):

return self.SendRequest('discover/explore/')

def comment(self, mediaId, commentText):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'comment_text': commentText})

return self.SendRequest('media/' + str(mediaId) + '/comment/', self.generateSignature(data))

def deleteComment(self, mediaId, commentId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token})

return self.SendRequest('media/' + str(mediaId) + '/comment/' + str(commentId) + '/delete/', self.generateSignature(data))

def changeProfilePicture(self, photo):

# TODO Instagram.php 705-775

return False

def removeProfilePicture(self):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token})

return self.SendRequest('accounts/remove_profile_picture/', self.generateSignature(data))

def setPrivateAccount(self):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token})

return self.SendRequest('accounts/set_private/', self.generateSignature(data))

def setPublicAccount(self):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token})

return self.SendRequest('accounts/set_public/', self.generateSignature(data))

def getProfileData(self):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token})

return self.SendRequest('accounts/current_user/?edit=true', self.generateSignature(data))

def editProfile(self, url, phone, first_name, biography, email, gender):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'external_url': url,

'phone_number': phone,

'username': self.username,

'full_name': first_name,

'biography': biography,

'email': email,

'gender': gender})

return self.SendRequest('accounts/edit_profile/', self.generateSignature(data))

def getStory(self, usernameId):

return self.SendRequest('feed/user/' + str(usernameId) + '/reel_media/')

def getUsernameInfo(self, usernameId):

return self.SendRequest('users/' + str(usernameId) + '/info/')

def getSelfUsernameInfo(self):

return self.getUsernameInfo(self.username_id)

def getSelfSavedMedia(self):

return self.SendRequest('feed/saved')

def getRecentActivity(self):

activity = self.SendRequest('news/inbox/?')

return activity

def getFollowingRecentActivity(self):

activity = self.SendRequest('news/?')

return activity

def getv2Inbox(self):

inbox = self.SendRequest('direct_v2/inbox/?')

return inbox

def getv2Threads(self, thread, cursor=None):

endpoint = 'direct_v2/threads/{0}'.format(thread)

if cursor is not None:

endpoint += '?cursor={0}'.format(cursor)

inbox = self.SendRequest(endpoint)

return inbox

def getUserTags(self, usernameId):

tags = self.SendRequest('usertags/' + str(usernameId) + '/feed/?rank_token=' + str(self.rank_token) + '&ranked_content=true&')

return tags

def getSelfUserTags(self):

return self.getUserTags(self.username_id)

def tagFeed(self, tag):

userFeed = self.SendRequest('feed/tag/' + str(tag) + '/?rank_token=' + str(self.rank_token) + '&ranked_content=true&')

return userFeed

def getMediaLikers(self, mediaId):

likers = self.SendRequest('media/' + str(mediaId) + '/likers/?')

return likers

def getGeoMedia(self, usernameId):

locations = self.SendRequest('maps/user/' + str(usernameId) + '/')

return locations

def getSelfGeoMedia(self):

return self.getGeoMedia(self.username_id)

def fbUserSearch(self, query):

query = self.SendRequest('fbsearch/topsearch/?context=blended&query=' + str(query) + '&rank_token=' + str(self.rank_token))

return query

def searchUsers(self, query):

query = self.SendRequest('users/search/?ig_sig_key_version=' + str(self.SIG_KEY_VERSION) + '&is_typeahead=true&query=' + str(query) + '&rank_token=' + str(self.rank_token))

return query

def searchUsername(self, usernameName):

query = self.SendRequest('users/' + str(usernameName) + '/usernameinfo/')

return query

def syncFromAdressBook(self, contacts):

return self.SendRequest('address_book/link/?include=extra_display_name,thumbnails', "contacts=" + json.dumps(contacts))

def searchTags(self, query):

query = self.SendRequest('tags/search/?is_typeahead=true&q=' + str(query) + '&rank_token=' + str(self.rank_token))

return query

def getTimeline(self):

query = self.SendRequest('feed/timeline/?rank_token=' + str(self.rank_token) + '&ranked_content=true&')

return query

def getUserFeed(self, usernameId, maxid='', minTimestamp=None):

query = self.SendRequest('feed/user/%s/?max_id=%s&min_timestamp=%s&rank_token=%s&ranked_content=true'

% (usernameId, maxid, minTimestamp, self.rank_token))

return query

def getSelfUserFeed(self, maxid='', minTimestamp=None):

return self.getUserFeed(self.username_id, maxid, minTimestamp)

def getHashtagFeed(self, hashtagString, maxid=''):

return self.SendRequest('feed/tag/' + hashtagString + '/?max_id=' + str(maxid) + '&rank_token=' + self.rank_token + '&ranked_content=true&')

def searchLocation(self, query):

locationFeed = self.SendRequest('fbsearch/places/?rank_token=' + str(self.rank_token) + '&query=' + str(query))

return locationFeed

def getLocationFeed(self, locationId, maxid=''):

return self.SendRequest('feed/location/' + str(locationId) + '/?max_id=' + maxid + '&rank_token=' + self.rank_token + '&ranked_content=true&')

def getPopularFeed(self):

popularFeed = self.SendRequest('feed/popular/?people_teaser_supported=1&rank_token=' + str(self.rank_token) + '&ranked_content=true&')

return popularFeed

def getUserFollowings(self, usernameId, maxid=''):

url = 'friendships/' + str(usernameId) + '/following/?'

query_string = {'ig_sig_key_version': self.SIG_KEY_VERSION,

'rank_token': self.rank_token}

if maxid:

query_string['max_id'] = maxid

if sys.version_info.major == 3:

url += urllib.parse.urlencode(query_string)

else:

url += urllib.urlencode(query_string)

return self.SendRequest(url)

def getSelfUsersFollowing(self):

return self.getUserFollowings(self.username_id)

def getUserFollowers(self, usernameId, maxid=''):

if maxid == '':

return self.SendRequest('friendships/' + str(usernameId) + '/followers/?rank_token=' + self.rank_token)

else:

return self.SendRequest('friendships/' + str(usernameId) + '/followers/?rank_token=' + self.rank_token + '&max_id=' + str(maxid))

def getSelfUserFollowers(self):

return self.getUserFollowers(self.username_id)

def getPendingFollowRequests(self):

return self.SendRequest('friendships/pending?')

def like(self, mediaId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'media_id': mediaId})

return self.SendRequest('media/' + str(mediaId) + '/like/', self.generateSignature(data))

def unlike(self, mediaId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'media_id': mediaId})

return self.SendRequest('media/' + str(mediaId) + '/unlike/', self.generateSignature(data))

def save(self, mediaId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'media_id': mediaId})

return self.SendRequest('media/' + str(mediaId) + '/save/', self.generateSignature(data))

def unsave(self, mediaId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token,

'media_id': mediaId})

return self.SendRequest('media/' + str(mediaId) + '/unsave/', self.generateSignature(data))

def getMediaComments(self, mediaId, max_id=''):

return self.SendRequest('media/' + mediaId + '/comments/?max_id=' + max_id)

def setNameAndPhone(self, name='', phone=''):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'first_name': name,

'phone_number': phone,

'_csrftoken': self.token})

return self.SendRequest('accounts/set_phone_and_name/', self.generateSignature(data))

def getDirectShare(self):

return self.SendRequest('direct_share/inbox/?')

def backup(self):

# TODO Instagram.php 1470-1485

return False

def approve(self, userId):

data = json.dumps({

'_uuid' : self.uuid,

'_uid' : self.username_id,

'user_id' : userId,

'_csrftoken' : self.token

})

return self.SendRequest('friendships/approve/'+ str(userId) + '/', self.generateSignature(data))

def ignore(self, userId):

data = json.dumps({

'_uuid' : self.uuid,

'_uid' : self.username_id,

'user_id' : userId,

'_csrftoken' : self.token

})

return self.SendRequest('friendships/ignore/'+ str(userId) + '/', self.generateSignature(data))

def follow(self, userId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'user_id': userId,

'_csrftoken': self.token})

return self.SendRequest('friendships/create/' + str(userId) + '/', self.generateSignature(data))

def unfollow(self, userId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'user_id': userId,

'_csrftoken': self.token})

return self.SendRequest('friendships/destroy/' + str(userId) + '/', self.generateSignature(data))

def block(self, userId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'user_id': userId,

'_csrftoken': self.token})

return self.SendRequest('friendships/block/' + str(userId) + '/', self.generateSignature(data))

def unblock(self, userId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'user_id': userId,

'_csrftoken': self.token})

return self.SendRequest('friendships/unblock/' + str(userId) + '/', self.generateSignature(data))

def userFriendship(self, userId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'user_id': userId,

'_csrftoken': self.token})

return self.SendRequest('friendships/show/' + str(userId) + '/', self.generateSignature(data))

def getLikedMedia(self, maxid=''):

return self.SendRequest('feed/liked/?max_id=' + str(maxid))

def generateSignature(self, data, skip_quote=False):

if not skip_quote:

try:

parsedData = urllib.parse.quote(data)

except AttributeError:

parsedData = urllib.quote(data)

else:

parsedData = data

return 'ig_sig_key_version=' + self.SIG_KEY_VERSION + '&signed_body=' + hmac.new(self.IG_SIG_KEY.encode('utf-8'), data.encode('utf-8'), hashlib.sha256).hexdigest() + '.' + parsedData

def generateDeviceId(self, seed):

volatile_seed = "12345"

m = hashlib.md5()

m.update(seed.encode('utf-8') + volatile_seed.encode('utf-8'))

return 'android-' + m.hexdigest()[:16]

def generateUUID(self, type):

generated_uuid = str(uuid.uuid4())

if (type):

return generated_uuid

else:

return generated_uuid.replace('-', '')

def generateUploadId(self):

return str(calendar.timegm(datetime.utcnow().utctimetuple()))

def createBroadcast(self, previewWidth=1080, previewHeight=1920, broadcastMessage=''):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'preview_height': previewHeight,

'preview_width': previewWidth,

'broadcast_message': broadcastMessage,

'broadcast_type': 'RTMP',

'internal_only': 0,

'_csrftoken': self.token})

return self.SendRequest('live/create/', self.generateSignature(data))

def startBroadcast(self, broadcastId, sendNotification=False):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'should_send_notifications': int(sendNotification),

'_csrftoken': self.token})

return self.SendRequest('live/' + str(broadcastId) + '/start', self.generateSignature(data))

def stopBroadcast(self, broadcastId):

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token})

return self.SendRequest('live/' + str(broadcastId) + '/end_broadcast/', self.generateSignature(data))

def addBroadcastToLive(self, broadcastId):

# broadcast has to be ended first!

data = json.dumps({'_uuid': self.uuid,

'_uid': self.username_id,

'_csrftoken': self.token})

return self.SendRequest('live/' + str(broadcastId) + '/add_to_post_live/', self.generateSignature(data))

def buildBody(self, bodies, boundary):

body = u''

for b in bodies:

body += u'--{boundary}\r\n'.format(boundary=boundary)

body += u'Content-Disposition: {b_type}; name="{b_name}"'.format(b_type=b['type'], b_name=b['name'])

_filename = b.get('filename', None)

_headers = b.get('headers', None)

if _filename:

_filename, ext = os.path.splitext(_filename)

_body += u'; filename="pending_media_{uid}.{ext}"'.format(uid=self.generateUploadId(), ext=ext)

if _headers and isinstance(_headers, list):

for h in _headers:

_body += u'\r\n{header}'.format(header=h)

body += u'\r\n\r\n{data}\r\n'.format(data=b['data'])

body += u'--{boundary}--'.format(boundary=boundary)

return body

def SendRequest(self, endpoint, post=None, login=False):

verify = False # don't show request warning

if (not self.isLoggedIn and not login):

raise Exception("Not logged in!\n")

self.s.headers.update({'Connection': 'close',

'Accept': '*/*',

'Content-type': 'application/x-www-form-urlencoded; charset=UTF-8',

'Cookie2': '$Version=1',

'Accept-Language': 'en-US',

'User-Agent': self.USER_AGENT})

while True:

try:

if (post is not None):

response = self.s.post(self.API_URL + endpoint, data=post, verify=verify)

else:

response = self.s.get(self.API_URL + endpoint, verify=verify)

break

except Exception as e:

print('Except on SendRequest (wait 60 sec and resend): ' + str(e))

time.sleep(60)

if response.status_code == 200:

self.LastResponse = response

self.LastJson = json.loads(response.text)

return True

else:

print("Request return " + str(response.status_code) + " error!")

# for debugging

try:

self.LastResponse = response

self.LastJson = json.loads(response.text)

print(self.LastJson)

if 'error_type' in self.LastJson and self.LastJson['error_type'] == 'sentry_block':

raise SentryBlockException(self.LastJson['message'])

except SentryBlockException:

raise

except:

pass

return False

def getTotalFollowers(self, usernameId):

followers = []

next_max_id = ''

while 1:

self.getUserFollowers(usernameId, next_max_id)

temp = self.LastJson