from models import sqs_message
import config


transcoding_jobs = [
    {
      'transcoding_job_id': 993798,
      'status': 'requested',
      'output_bucket': 'qa-orcd-mezzanine-assets',
      'output_key': '06240296_286c_44e7_984b_b35638c5fe50.mp3',
      'container': 'mpeg audio',
      'channels': 2,
      'codec': 'mpa1l3',
      'sample_rate': 44100,
      'bit_rate': 192000,
      'bit_depth': 16,
    },
    {
      'transcoding_job_id': 993797,
      'output_bucket': 'qa-orcd-mezzanine-assets',
      'output_key': 'a825c8ae_cf90_424c_a77c_2d1e90665629.wav',
      'container': 'wave',
      'channels': 2,
      'codec': 'pcm',
      'sample_rate': 44100,
      'bit_rate': 1411200,
      'bit_depth': 16
    },
    {
      'transcoding_job_id': 993796,
      'status': 'requested',
      'output_bucket': 'qa-orcd-mezzanine-assets',
      'output_key': '1918e028_2a69_4160_b8ee_fa3d0bd4ef99.flac',
      'container': 'flac',
      'channels': 2,
      'codec': 'flac',
      'sample_rate': 44100,
      'bit_rate': 1411200,
      'bit_depth': 16,
    }
]

transcoding_order = {
    'input_bucket': 'qa-orcd-raw-assets',
    'input_key': '028aac7d_b491_4e05_a88c_60e2cb782c9e.wav'
}


def main():
    for transcoding_job in transcoding_jobs:
        send_message_response = sqs_message.send_sqs_message(
            queue_url=config.SQS_TRANSCODING_URL,
            message={
                'transcoding_job_id': transcoding_job['transcoding_job_id'],
                'input_bucket': transcoding_order['input_bucket'],
                'input_key': transcoding_order['input_key'],
                'output_bucket': transcoding_job['output_bucket'],
                'output_key': transcoding_job['output_key'],
                'container': transcoding_job['container'],
                'channels': transcoding_job['channels'],
                'codec': transcoding_job['codec'],
                'sample_rate': transcoding_job['sample_rate'],
                'bit_rate': transcoding_job['bit_rate'],
                'bit_depth': transcoding_job['bit_depth']})

        print(send_message_response)


if __name__ == "__main__":
    main()