#!/usr/bin/python3
import sys
import os
import o11
import json
import datetime
import pytz
import base64
import time
from pywidevine.cdm import Cdm
from pywidevine.device import Device
from pywidevine.pssh import PSSH
from bs4 import BeautifulSoup

WVD_PATH = './WVD.wvd'

user = o11.parse_params(sys.argv, 'user')
password = o11.parse_params(sys.argv, 'password')

id = o11.parse_params(sys.argv, 'id')
action = o11.parse_params(sys.argv, 'action')

bind = o11.parse_params(sys.argv, 'bind')
proxy = o11.parse_params(sys.argv, 'proxy')
doh = o11.parse_params(sys.argv, 'doh')
worker = o11.parse_params(sys.argv, 'worker')

cdm_param = o11.parse_params(sys.argv, 'cdm')
challenge = o11.parse_params(sys.argv, 'challenge')

o11Session = o11.session(bind=bind, proxy=proxy, worker=worker)
req = o11Session.get_session()
if doh != "":
    o11.dns(doh)

if challenge == "cert":
    challenge = "CAQ="

authFile = '/VooTV_' + user + '.tokens'
user_agent = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36'

def do_cdm_external(pssh_data, jsession):
    pssh_obj = PSSH(pssh_data)
    device_obj = Device.load(WVD_PATH)
    cdm_obj = Cdm.from_device(device_obj)
    session_id = cdm_obj.open()
    challenge_data = cdm_obj.get_license_challenge(session_id, pssh_obj)
    lic_headers = {'Accept': '*/*', 'Origin': 'https://tvplus.voo.be', 'Referer': 'https://tvplus.voo.be/', 'User-Agent': user_agent, 'dt-custom-data': base64.b64encode(('{"sessionId":"' + jsession + '","merchant":"voo"}').encode()).decode(), 'Content-Type': 'application/octet-stream'}
    licence = req.post('https://lic.drmtoday.com/license-proxy-widevine/cenc/', headers=lic_headers, data=challenge_data)
    data = licence.json()
    cdm_obj.parse_license(session_id, base64.b64decode(data['license']))
    keys = [f"{key.kid.hex}:{key.key.hex()}" for key in cdm_obj.get_keys(session_id) if key.type != 'SIGNING']
    cdm_obj.close(session_id)
    return keys

def get_pssh_from_mpd(url):
    headers = {'Accept': '*/*', 'User-Agent': user_agent}
    response = req.get(url, headers=headers)
    for cp in BeautifulSoup(response.content, features="xml").findAll('ContentProtection'):
        if cp.get('schemeIdUri', '').lower() == 'urn:uuid:edef8ba9-79d6-4ace-a3c8-27dcd51d21ed':
            pssh_tag = cp.find('cenc:pssh')
            if pssh_tag:
                return pssh_tag.text, response.url
    return None, response.url

def get_channels(jsession):
    cookies = {'JSESSIONID': jsession}
    headers = {'Accept': 'application/json, text/plain, */*', 'Content-Type': 'application/xml', 'Origin': 'https://tvplus.voo.be', 'Referer': 'https://tvplus.voo.be/', 'User-Agent': user_agent}
    params = {'output': 'json'}
    data = '\n      <Request xmlns="urn:eventis:traxisweb:1.0">\n        <RootRelationQuery relationName="Channels">\n          <Options>\n            <Option type="sort">LogicalChannelNumber</Option>\n            <Option type="Props">OnFavorites,IsAdult,Pictures,IsViewableOnCpe,LogicalChannelNumber,PersonalChannelNumber,Name,LongName,Blocked,CustomProperties</Option>\n          </Options>\n        </RootRelationQuery>\n      </Request>\n    '
    response = req.post('https://publisher.voo.be/traxis/web/', params=params, cookies=cookies, headers=headers, data=data)
    return response.json().get('Channels', {}).get('Channel', [])

def get_single(jsession, channel_id):
    cookies = {'JSESSIONID': jsession}
    headers = {'Accept': 'application/json, text/plain, */*', 'Content-Type': 'application/xml', 'Origin': 'https://tvplus.voo.be', 'Referer': 'https://tvplus.voo.be/', 'User-Agent': user_agent}
    params = {'output': 'json', 'Language': 'FR'}
    data = f'<CreateSession><ChannelId>{channel_id}</ChannelId></CreateSession>'
    response = req.post('https://publisher.voo.be/traxis/web/Session/Props/Playlist', params=params, cookies=cookies, headers=headers, data=data)
    resp_data = response.json()
    return resp_data.get('Session', {}).get('Playlist', {}).get('Channel', {}).get('Value', ''), resp_data.get('Session', {}).get('id', '')

def delete_session(jsession, session_id):
    cookies = {'JSESSIONID': jsession}
    headers = {'Accept': 'application/json, text/plain, */*', 'Content-Type': 'application/xml', 'Origin': 'https://tvplus.voo.be', 'Referer': 'https://tvplus.voo.be/', 'User-Agent': user_agent}
    params = {'Method': 'DELETE'}
    data = f'<DeleteSession><TrackId>0</TrackId><TimeOffset>{int(time.time())}</TimeOffset><SessionEndCode>2</SessionEndCode></DeleteSession>'
    req.post(f'https://publisher.voo.be/traxis/web/Session/{session_id}', params=params, cookies=cookies, headers=headers, data=data)

def do_login_request(username, pwd):
    headers = {'Accept': 'application/json, text/plain, */*', 'Content-Type': 'application/xml', 'Origin': 'https://tvplus.voo.be', 'Referer': 'https://tvplus.voo.be/', 'User-Agent': user_agent}
    params = {'op': 'AuthenticateUserDeviceRequest', 'env_route': 'prod'}
    data = f'<AuthenticateUserDeviceRequest version="5.1.0">\n      <request>\n        <user>\n          <u>{username}</u>\n          <p>{pwd}</p>\n        </user>\n        <cred_type>1</cred_type>\n        <smart_security_token>null</smart_security_token>\n      </request>\n    </AuthenticateUserDeviceRequest>'
    response = req.post('https://ssologin.voo.be/mobicents', params=params, headers=headers, data=data)
    return response.cookies.get('JSESSIONID', '')

def login():
    print("logging in...", file=sys.stderr)
    jsession = do_login_request(user, password)
    auth_data = {'jsession': jsession}
    json.dump(auth_data, open(os.path.abspath(os.path.dirname(__file__)) + authFile, 'w'))
    print("logged in successfully", file=sys.stderr)

def do_action():
    if action == "login":
        login()
        sys.exit()
    try:
        auth = json.load(open(os.path.abspath(os.path.dirname(__file__)) + authFile))
        jsession = auth['jsession']
    except:
        return "error"

    if action == "channels":
        output = {'Channels': []}
        for c in get_channels(jsession):
            output['Channels'].append({'Name': c['Name'], 'Mode': "live", 'SessionManifest': True, 'ManifestScript': 'id=' + c['id'], 'CdmType': "widevine", 'UseCdm': True, 'Cdm': 'id=' + c['id'], 'Video': 'best'})
        print(json.dumps(output, indent=2))
    elif action == "events":
        output = {'Events': []}
        for c in get_channels(jsession):
            output['Events'].append({'Name': c['Name'], 'Mode': "live", 'SessionManifest': True, 'ManifestScript': 'id=' + c['id'], 'CdmType': "widevine", 'UseCdm': True, 'Cdm': 'id=' + c['id'], 'Video': 'best', 'Autostart': True, 'Start': int(datetime.datetime.now(pytz.UTC).timestamp()), 'End': int((datetime.datetime.now(pytz.UTC) + datetime.timedelta(hours=4)).timestamp())})
        print(json.dumps(output, indent=2))
    elif action == "manifest":
        channel_id = id.replace('id=', '') if id.startswith('id=') else id
        url, session_id = get_single(jsession, channel_id)
        if session_id:
            delete_session(jsession, session_id)
        pssh_data, loc_url = get_pssh_from_mpd(url)
        output = {"Cdn": [], "ManifestUrl": loc_url, "Headers": {"Manifest": {'User-Agent': user_agent}, "Media": {'User-Agent': user_agent}}, "JSession": jsession}
        if pssh_data:
            output['Pssh'] = pssh_data
        print(json.dumps(output))
    elif action == "cdm" and cdm_param == "external":
        channel_id = id.replace('id=', '') if id.startswith('id=') else id
        url, session_id = get_single(jsession, channel_id)
        if session_id:
            delete_session(jsession, session_id)
        pssh_data, loc_url = get_pssh_from_mpd(url)
        if pssh_data:
            for key in do_cdm_external(pssh_data, jsession):
                print(key)

if do_action() == "error":
    login()
    do_action()