#!/usr/bin/env python2

import json
import os
import requests
import sys
import datetime


def ppjson(val):
    if (isinstance(val, dict)):
        print json.dumps(val, indent=4)
    else:
        print json.dumps(json.loads(val), indent=4)
    return 0


DEF_ACCESS_TOK = ''
GRAPH_URL = 'https://graph.facebook.com/v2.11/'
RULE_ID = 1146337825502790


def main():
    try:
        ACCESS_TOKEN = os.environ['ACCESS_TOKEN']
    except KeyError:
        ACCESS_TOKEN = DEF_ACCESS_TOK

    payload = {'access_token': ACCESS_TOKEN}
    print('-->')
    ppjson(payload)

    r = requests.get(GRAPH_URL + 'me', params=payload)
    print('<--')
    ppjson(r.text)

    # Get page id from Page access token
    try:
        page_id = json.loads(r.text)['id']
    except KeyError:
        print('Error: Invalid access token. Please verify that this is a '
              'valid Page access token.')
        return -1

    # Create Live Video and store the id
    payload['title'] = 'Live: ' + datetime.datetime.now().isoformat()
    payload['description'] = datetime.datetime.now().isoformat()
    payload['stop_on_delete_stream'] = True
    payload['status'] = 'UNPUBLISHED'
    payload['ownership_countries'] = ['BR']

    print('-->')
    ppjson(payload)

    live_videos = requests.post(GRAPH_URL + page_id +
            '/live_videos', params=payload)

    live_videos = json.loads(live_videos.text)
    print('<--')
    ppjson(live_videos)

    # Get video id and stream url
    try:
        video_id = live_videos['id']
        stream_url = live_videos['stream_url']
    except KeyError:
        print('Error: Bad live_videos response')
        return -1

    payload = {'access_token': ACCESS_TOKEN}
    payload['copyright_content_id'] = video_id
    payload['rule_id'] = RULE_ID
    payload['monitoring_type'] = 'VIDEO_AND_AUDIO'
    payload['is_reference_video'] = True

    print('-->')
    ppjson(payload)

    r = requests.post(GRAPH_URL + page_id + '/video_copyrights',
        params=payload)
    ppjson(r.text)

    print('Stream URL: ' + stream_url)

sys.exit(main())