
from tasks import app

import subprocess
import logging
import os
import shutil

import boto3

# can't get this to work...
# from django.conf import settings
# if not settings.configured: settings.configure()

def get_video_filepath(video_dir, extension, filename="video"):
    full_filename = '{:}.{:}'.format(filename, extension)
    return os.path.join(video_dir, full_filename)

def transcode_to_hls(src, out):
    logger = logging.getLogger(__name__)
    result = subprocess.check_call(["ffmpeg", "-i", src, '-start_number', '0', '-hls_list_size', '0', '-f', 'hls', out])

    if result == 0:
        logger.info('Successfully transcoded {:} to {:}'.format(src, out))
    else:
        # this will retry the job
        raise RuntimeError('Error transcoding {:} to {:}. Error code: {:}'.format(src, out, result))


def upload_to_s3(src_dir):
    s3 = boto3.resource('s3')

    base_dir = os.path.basename(src_dir)
    # TODO : make this use the actual environment 
    s3_dir = os.path.join('prod', base_dir)
    for filename in os.listdir(src_dir):
        disk_path = os.path.join(src_dir, filename)
        s3_path = os.path.join(s3_dir, filename)

        s3.Object('jamjar-videos', s3_path).put(Body=open(disk_path, 'rb'), ACL='public-read')

def delete_source(src_dir):
    # can't load settings from job queue task. Why!?
    #if settings.VIDEOS_PATH in src_dir:
    #    shutil.rmtree(src_dir)
    #else:
    #    raise RuntimeError("trying to delete dir that shouldn't be deleted!: {:}".format(src_dir))

    shutil.rmtree(src_dir)

@app.task(name='tasks.transcode_video')
def transcode_video(src_filepath, out_dir):

    hls_filepath = get_video_filepath(out_dir, 'm3u8')

    transcode_to_hls(src_filepath, hls_filepath)
    upload_to_s3(out_dir)
    # TODO : fingerprint here
    delete_source(out_dir)



from tasks import app

import subprocess
import logging
import os
import shutil

import boto3

# from django.conf import settings

def get_video_filepath(video_dir, extension, filename="video"):
    full_filename = '{:}.{:}'.format(filename, extension)
    return os.path.join(video_dir, full_filename)

def transcode_to_hls(src, out):
    logger = logging.getLogger(__name__)
    result = subprocess.check_call(["ffmpeg", "-i", src, '-start_number', '0', '-hls_list_size', '0', '-f', 'hls', out])

    if result == 0:
        logger.info('Successfully transcoded {:} to {:}'.format(src, out))
    else:
        # this will retry the job
        raise RuntimeError('Error transcoding {:} to {:}. Error code: {:}'.format(src, out, result))


def upload_to_s3(src_dir):
    s3 = boto3.resource('s3')

    base_dir = os.path.basename(src_dir)
    # TODO : make this use the actual environment 
    s3_dir = os.path.join('prod', base_dir)
    for filename in os.listdir(src_dir):
        disk_path = os.path.join(src_dir, filename)
        s3_path = os.path.join(s3_dir, filename)

        s3.Object('jamjar-videos', s3_path).put(Body=open(disk_path, 'rb'), ACL='public-read')

def delete_source(src_dir):
    # can't load settings from job queue task. Why!?
    #if settings.VIDEOS_PATH in src_dir:
    #    shutil.rmtree(src_dir)
    #else:
    #    raise RuntimeError("trying to delete dir that shouldn't be deleted!: {:}".format(src_dir))

    shutil.rmtree(src_dir)

@app.task(name='tasks.transcode_video')
def transcode_video(src_filepath, out_dir):

    hls_filepath = get_video_filepath(out_dir, 'm3u8')

    transcode_to_hls(src_filepath, hls_filepath)
    upload_to_s3(out_dir)
    # TODO : fingerprint here
    delete_source(out_dir)


remove junk