#!/usr/bin/env python
"""Cloudflare API code - example"""

import os
import sys
import json
import datetime
import requests

sys.path.insert(0, os.path.abspath('.'))
sys.path.insert(0, os.path.abspath('..'))
import CloudFlare

#
# Warning: You need to enable image storage on your account for this code to work.
# You'll get 403 errors if you don't have it enabled (go pay for it)
#
# If you need to delete images after running this code you can do this:
#
# cli4 --delete /accounts/:"${ACCOUNT}"/images/v1/::${image_id}
#
# Or if you want to live dangerously - do this and delete every image you have
# You should not run this unless you really really really know what you're doing! (like rm -rf /)
#
# cli4 /accounts/:"${ACCOUNT}"/images/v1 | jq -r '.images[]|.id' | while read image_id ; do cli4 --delete /accounts/:"${ACCOUNT}"/images/v1/::$image_id ; done
#

#
# A note about version numbers.
# this code works with 2.14.2 in a simple way
# this code works with 2.18.0 is a simple way
# released between then require at-least one paramater send via files= in order to not trigger a backend API bug
#

def rfc3339_iso8601_time(hour_delta=0, with_hms=False):
    """ rfc3339_iso8601_time """
    # format time (with an hour offset in RFC3339 ISO8601 format (and do it UTC time)
    dt = (datetime.datetime.now(datetime.UTC).replace(microsecond=0) + datetime.timedelta(hours=hour_delta))
    if with_hms:
        return dt.isoformat().replace('+00:00', 'Z')
    return dt.strftime('%Y-%m-%d')

def method_from_library_version():
    """ method_from_library_version """
    if CloudFlare.__version__ <= '2.14.2':
        print('Using %s version of Cloudflare python library - hence do not need data= or files=; but use files= if passing anything' % (CloudFlare.__version__))
        return ''
    if CloudFlare.__version__ <= '2.17.0':
        print('Using %s version of Cloudflare python library - hence must use files=' % (CloudFlare.__version__))
        return 'USE-FILES'
    # with newer library than 2.17.0 (i.e 2.18.0 and above) you should be able to pass just the data version
    print('Using %s version of Cloudflare python library - hence use data= as it is simpler' % (CloudFlare.__version__))
    return 'USE-DATA'

def doit(account_name, image_filename):
    """ doit """

    # https://developers.cloudflare.com/stream/uploading-videos/direct-creator-uploads/
    # https://developers.cloudflare.com/api/operations/cloudflare-images-create-authenticated-direct-upload-url-v-2

    with CloudFlare.CloudFlare(debug=False) as cf:
        try:
            params = {'name': account_name, 'per_page': 1}
            accounts = cf.accounts.get(params=params)
        except CloudFlare.exceptions.CloudFlareAPIError as e:
            sys.exit('%s: %d %s - api call failed' % ('/accounts', int(e), str(e)))
        try:
            account_id = accounts[0]['id']
        except IndexError:
            sys.exit('%s: account name not found' % (account_name))

        try:
           image_fp = open(image_filename, 'rb')
        except Exception as e:
            sys.exit('%s: %s - file read failed' % (image_filename, e))

        image_filesize = os.fstat(image_fp.fileno()).st_size
        if image_filesize > 1024*1024*1024:
                print('%s: filesize = %0.1f GBytes' % (image_filename, float(image_filesize)/1024*1024*1024))
        elif image_filesize > 1024*1024:
                print('%s: filesize = %0.1f MBytes' % (image_filename, float(image_filesize)/1024*1024))
        elif image_filesize > 1024:
                print('%s: filesize = %0.1f KBytes' % (image_filename, float(image_filesize)/1024))
        else:
                print('%s: filesize = %d Bytes' % (image_filename, image_filesize))

        # format future time in RFC3339 format (and do it UTC time)
        time_plus_one_hour_in_iso = rfc3339_iso8601_time(1, True)

        # direct_upload uses multipart/form-data and hence this info is passed as files (but None for filename)
        # these are the four form values
        # presently you need to upload at-least one of these until the library version is greater than 2.17.0
        # --form expiry= \
        # --form id= \
        # --form metadata= \
        # --form requireSignedURLs=

        # here's examples using metadata and expiry.

        # this is just simple metadata created to show it working - your code will be different
        metadata_values = {
            'source': image_filename,
            'size': image_filesize,
        }

        data = None
        files = None

        lib_method = method_from_library_version()

        if lib_method == 'USE-FILES':
            files = {
                ('metadata', (None, json.dumps(metadata_values))),
                ('expiry', (None, time_plus_one_hour_in_iso))
            }
        elif lib_method == 'USE-DATA':
            data = {
                'metadata': json.dumps(metadata_values),
                'expiry': time_plus_one_hour_in_iso,
            }
        elif lib_method == '':
            # optionally do nothing or send via files=
            pass

        try:
            r = cf.accounts.images.v2.direct_upload.post(account_id, data=data, files=files)
        except CloudFlare.exceptions.CloudFlareAPIError as e:
            sys.exit('%s: %d %s - api call failed' % ('/accounts/images/v2/direct_upload', int(e), str(e)))
        print('v2 new image post results')
        print(json.dumps(r, indent=4))

        image_id = r['id']
        image_url = r['uploadURL']

        # https://developers.cloudflare.com/stream/uploading-videos/direct-creator-uploads/
        # curl -X POST \
        #      -F file=@/Users/mickie/Downloads/example_video.mp4 \
        #      https://upload.videodelivery.net/f65014bc6ff5419ea86e7972a047ba22

        try:
            r = requests.post(image_url, files={('file', image_fp)}, timeout=5)
        except Exception as e:
            sys.exit('%s: %s - api call failed' % (image_url, e))

        image_fp.close()

        if r.status_code != 200:
           if r.status_code == 403:
               print('403 means you need to enable images in your account')
           if r.status_code == 403:
               print('415 means the file is a bad image format')
           sys.exit('%s: HTTP Error %s' % (image_url, r.status_code))

        j = r.json()
        if j['success'] is True:
            print('Image upload results')
            print(json.dumps(j['result'], indent=4))
        else:
            sys.exit('Error:\n    errors: %s\n    messages: %s' % (j['errors'], j['messages']))

        # list all images
        try:
            r = cf.accounts.images.v2(account_id)
        except CloudFlare.exceptions.CloudFlareAPIError as e:
            sys.exit('%s: %d %s - api call failed' % ('/accounts/images/v1', int(e), str(e)))

        print('All account images:')
        for img in r['images']:
            print('%s   %s: %s %s %s' % ('>' if img['id'] == image_id else ' ', img['id'], img['uploaded'], img['filename'], img['variants'][0]))
            if 'meta' in img:
                for k,v in img['meta'].items():
                    print('        %s = %s' % (k, v))
            else:
                print('        - no meta data')

        # delete the image - this was just a test (comment this out if you end up using this code for uploads)
        try:
            r = cf.accounts.images.v1.delete(account_id, image_id)
        except CloudFlare.exceptions.CloudFlareAPIError as e:
            sys.exit('%s: %d %s - api call failed' % ('/accounts/images/v1', int(e), str(e)))
        print('Image delete')
        print(json.dumps(r, indent=4))

def main():
    """ main """
    try:
        account_name = sys.argv[1]
    except IndexError:
        sys.exit('usage: example_images_v2_direct_upload.py account_name image_filename')
    try:
        image_filename = sys.argv[2]
    except IndexError:
        sys.exit('usage: example_images_v2_direct_upload.py account_name image_filename')
    doit(account_name, image_filename)
    sys.exit(0)

if __name__ == '__main__':
    main()