#!/usr/bin/eny python3
import yaml
import requests
from pprint import pprint
from requests.auth import HTTPBasicAuth

AUTH = HTTPBasicAuth('admin', 'opencast')
INGEST_URL = 'https://develop.opencast.org/ingest/addMediaPackage/fast'


with open('media.yml', 'r') as f:
    config = yaml.safe_load(f)

for series in config['series']:
    metadata = ''
    for key, value in series.items():
        metadata += f'<dcterms:{key}>{value}</dcterms:{key}>'
    series_xml = \
    f'''<?xml version="1.0"?>
    <dublincore
        xmlns="http://www.opencastproject.org/xsd/1.0/dublincore/"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://www.opencastproject.org http://www.opencastproject.org/schema.xsd"
        xmlns:dc="http://purl.org/dc/elements/1.1/"
        xmlns:dcterms="http://purl.org/dc/terms/"
        xmlns:oc="http://www.opencastproject.org/matterhorn/">
      {metadata}
    </dublincore>'''
    acl = '<?xml version="1.0" encoding="UTF-8" standalone="yes"?>' \
            '<acl xmlns="http://org.opencastproject.security"></acl>'
    print(series_xml)
    r = requests.post('https://develop.opencast.org/series/', auth=AUTH,
                      data={'series': series_xml, 'acl': acl})
    print(r.ok)

for media in config['media']:
    fields = [('acl', (None, '{"acl": {"ace": [{"allow": true,"role": "ROLE_ANONYMOUS","action": "read"}]}}'))]
    for field in media:
        for key, value in field.items():
            fields.append((key, (None, value)))
    print(fields)
    r = requests.post(INGEST_URL, auth=AUTH, files=fields)
    #print(r)
    print(r.ok)
    #print(r.content)
    #print(r.text)