import httplib2
from apiclient.discovery import build
from oauth2client.client import flow_from_clientsecrets
from oauth2client.file import Storage
from oauth2client.tools import run_flow

DATA_SCOPE = "https://www.googleapis.com/auth/youtube"
DATA_SERVICE = "youtube"
DATA_VERSION = "v3"

# Client Secrets File
#  -- I am using the same file I created for the Reporting API
CLIENT_SECRETS = 'client_secrets.json'

# Credentials File
CREDENTIALS_FILE = 'data-api-oauth2.json'

# OAuth2 Authentication: First Time
#  -- this will open up your browser and have you choose your Google Account
#  -- it will also have you select a channel or content owner
#  -- when completed, you will be authenticated in current session and have a JSON
#     file to use for authentication for all subsequent sessions
data_storage = Storage(CREDENTIALS_FILE)
data_flow = flow_from_clientsecrets(CLIENT_SECRETS, scope=DATA_SCOPE,  message=' Derr! ')
credentials = run_flow(data_flow, data_storage)

# OAuth2: All Subsequent Sessions
credentials = storage.get()

# OAuth2 Code (Any Session)
#  -- this code combines the above and can be used for any session
CREDENTIALS_FILE = 'data-api-oauth2.json'
data_storage = Storage(CREDENTIALS_FILE)
credentials = data_storage.get()
if credentials is None or credentials.invalid:
  data_flow = flow_from_clientsecrets(CLIENT_SECRETS, scope=DATA_SCOPE,  message=' Derr! ')
  credentials = run_flow(data_flow, data_storage)
  
# Create DATA API Connection
data_api = build(DATA_SERVICE, DATA_VERSION, http=credentials.authorize(httplib2.Http()))

info = data_api.activities().list(part='snippet,contentDetails', mine=True, maxResults=50).execute()

import pandas as pd
def get_channel_playlists_and_videos(channelId, publishedAfter=None, publishedBefore=None, regionCode=None):
  """
  channelId:  YouTube Channel ID
  publishedAfter, publishedBefore: YYYY-MM-DDThh:mm:ss.sZ (default: None)
  regionCode:  ISO 3166-1 alpha-2 country code
  """
  rows = pd.DataFrame(columns=['channel_id', 'channel_title', 'playlist_id', 
    'video_id', 'video_title', 'time_published'])
  temp = data_api.activities().list(
    part       = 'snippet,contentDetails', 
    maxResults = 50, 
    channelId  = channel_id,
    publishedAfter = publishedAfter,
    publishedBefore = publishedBefore
  ).execute()
  there_is_more_data = True
  offset = 0
  while there_is_more_data:
    for idx,item in enumerate(temp['items']):
      content = item['contentDetails']
      snippet = item['snippet']
      if 'upload' in content.keys():
        row = [
          snippet['channelId'], snippet['channelTitle'], None,
          content['upload']['videoId'], snippet['title'], snippet['publishedAt']
        ] #endInfo
      elif 'playlistItem' in content.keys():
        row = [
          snippet['channelId'], snippet['channelTitle'], content['playlistItem']['playlistId'],
          content['playlistItem']['resourceId']['videoId'], snippet['title'], snippet['publishedAt']
        ] #endInfo
      rows.loc[idx+offset] = row   
    try:
      temp = data_api.activities().list(
        part       ='snippet,contentDetails', 
        maxResults = 50, 
        channelId  = channel_id,
        publishedAfter = publishedAfter,
        publishedBefore = publishedBefore,
        pageToken  = temp['nextPageToken']
      ).execute()
      offset += 50
    except:
      there_is_more_data = False
  return rows

# Get Channel Info
bella_twins = 'UCIJnHb6meZoOjKF68h35QgQ' 
df = get_channel_playlists_and_videos(bella_twins)
wwe = 'UCJ5v_MCY6GNUBTO8-D3XoAg'

data_api.search().list(part='snippet',channelId=wwe, type='video').execute()

data_api.channels().list(part='snippet', mine=True).execute()

data_api.channels().list(part='statistics', mine=True).execute()

maxResults = 50
temp = data_api.channels().list(part='status', mySubscribers=True, maxResults=maxResults).execute()
user_channel_id = [item['id'] for item in temp['items']]
nextPageToken = temp['nextPageToken']
totalSubs = temp['pageInfo']['totalResults']
numPages = totalSubs // maxResults +1
for i in range(1,numPages):
  temp = data_api.channels().list(part='status', mySubscribers=True, maxResults=maxResults, pageToken=nextPageToken).execute()
  user_channel_id += [item['id'] for item in temp['items']]
  nextPageToken = temp['nextPageToken']

data_api.i18nRegions().list(part='snippet').execute()

us_cat_info = data_api.videoCategories().list(regionCode='US', part='snippet').execute()
[(item['id'], item['snippet']['title']) for item in us_cat_info['items']]