1 files changed, 175 insertions, 0 deletions
diff --git a/plugin.video.eurosportplayer/resources/lib/client.py b/plugin.video.eurosportplayer/resources/lib/client.py
new file mode 100644
index 0000000..ff534d5
--- /dev/null
+++ b/plugin.video.eurosportplayer/resources/lib/client.py
@@ -0,0 +1,175 @@
+# -*- coding: utf-8 -*-
+
+import simple_requests as requests
+
+class Client:
+
+    def __init__(self, plugin):
+        self.plugin = plugin
+
+        self.API_KEY = '2I84ZDjA2raVJ3hyTdADwdwxgDz7r62J8J0W8bE8N8VVILY446gDlrEB33fqLaXD'
+
+        self.IDENTITY_URL = self.plugin.global_base + 'v2/user/identity'
+        self.USER_URL = self.plugin.global_base + 'v2/user/profile'
+        self.TOKEN_URL = self.plugin.global_base + 'token'
+        self.GRAPHQL_URL = self.plugin.search_base + 'svc/search/v2/graphql'
+
+        self.DEVICE_ID = self.plugin.get_setting('device_id')
+        self.ACCESS_TOKEN = self.plugin.get_setting('access_token')
+        self.REFRESH_TOKEN = self.plugin.get_setting('refresh_token')
+        self.LANGUAGE = self.plugin.get_language()
+
+        if not plugin.startup:
+            self.refresh_token()
+
+    def graphql_request(self, url, query='', variables=None):
+        if variables is None:
+            variables = {}
+        headers = {
+            'accept': 'application/json',
+            'content-type': 'application/json',
+            'authorization': self.ACCESS_TOKEN
+        }
+        variables.update(
+            {
+                'language': self.LANGUAGE,
+                'mediaRights': ['GeoMediaRight'],
+                'preferredLanguages': [self.LANGUAGE, 'en']
+            }
+        )
+        post_data = {
+            'query': query,
+            'operationName': '',
+            'variables': variables
+        }
+        return requests.post(url, headers=headers, json=post_data).json()
+
+    def channels(self):
+        return self.graphql_request(self.GRAPHQL_URL + '/persisted/query/eurosport/web/Airings/onAir')
+
+    def categories(self):
+        return self.graphql_request(self.GRAPHQL_URL + '/persisted/query/eurosport/ListByTitle/sports_filter')
+
+    def category_all(self):
+        return self.graphql_request(self.GRAPHQL_URL + '/persisted/query/eurosport/CategoryAll')
+
+    def events(self):
+        return self.graphql_request(self.GRAPHQL_URL + '/persisted/query/eurosport/EventPageByLanguage')
+
+    def event(self, id_):
+        return self.graphql_request(
+            url = self.GRAPHQL_URL + '/persisted/query/eurosport/web/EventPageByContentId',
+            variables = {
+                'contentId': id_,
+                'include_media': True,
+                'include_images': True
+            }
+        )
+
+    def videos(self, id_):
+        return self.graphql_request(
+            url = self.GRAPHQL_URL,
+            query = '{ sport_%s:query (index: "eurosport_global",sort: new,page: 1,page_size: 1000,type: ["Video","Airing"],must: {termsFilters: [{attributeName: "category", values: ["%s"]}]},must_not: {termsFilters: [{attributeName: "mediaConfigState", values: ["OFF"]}]},should: {termsFilters: [{attributeName: "mediaConfigProductType", values: ["VOD"]},{attributeName: "type", values: ["Video"]}]}) @context(uiLang: "%s") { ... on QueryResponse { ...queryResponse }} }fragment queryResponse on QueryResponse {meta { hits }hits {hit { ... on Airing { ... airingData } ... on Video { ... videoData } }}}fragment airingData on Airing {type contentId mediaId liveBroadcast linear partnerProgramId programId runTime startDate endDate expires genres playbackUrls { href rel templated } channel { id parent callsign partnerId } photos { id uri width height } mediaConfig { state productType type } titles { language title descriptionLong descriptionShort episodeName } }fragment videoData on Video {type contentId epgPartnerProgramId programId appears releaseDate expires runTime genres media { playbackUrls { href rel templated } } titles { title titleBrief episodeName summaryLong summaryShort tags { type value displayName } } photos { rawImage width height photos { imageLocation width height } } }' % (id_, id_, self.LANGUAGE)
+        )
+
+    def epg(self, prev_date, date):
+        return self.graphql_request(
+            url = self.GRAPHQL_URL + '/persisted/query/eurosport/web/Airings/DateRange',
+            variables = {
+                'startDate': prev_date+'T23:59:59.000Z',
+                'endDate': date+'T23:59:59.999Z'
+            }
+        )
+
+    def license_key(self):
+        return '|authorization='+self.ACCESS_TOKEN+'|||plugin://'+self.plugin.addon_id+'/?mode=license_renewal'
+
+    def streams(self, url):
+        headers = {
+            'accept': 'application/vnd.media-service+json; version=1',
+            'authorization': self.ACCESS_TOKEN
+        }
+        data = requests.get(url.format(scenario='browser'), headers=headers).json()
+        if data.get('errors', ''):
+            self.plugin.log('[{0}] {1}'.format(self.plugin.addon_id, self.plugin.utfenc(data['errors'][0][:100])))
+        data['license_key'] = self.license_key()
+        return data
+    
+    def authorization(self, grant_type='refresh_token', token=''):
+        if token == '':
+            token = self.DEVICE_ID
+        headers = {
+            'accept': 'application/json',
+            'content-type': 'application/x-www-form-urlencoded',
+            'authorization': 'Bearer ' + self.API_KEY
+        }
+        post_data = {
+            'grant_type': grant_type,
+            'platform': 'browser',
+            'token': token
+        }
+        return requests.post(self.TOKEN_URL, headers=headers, data=post_data).json()
+        
+    def authentication(self, credentials):
+        headers = {
+            'accept': 'application/vnd.identity-service+json; version=1.0',
+            'content-type': 'application/json',
+            'authorization': self.authorization(grant_type='client_credentials')['access_token']
+        }
+        post_data = {
+            "type": "email-password",
+            "email": {
+                "address": credentials['email']
+            },
+            "password": {
+                "value": credentials['password']
+            }
+        }
+        return requests.post(self.IDENTITY_URL, headers=headers, json=post_data).json()
+
+    def user(self):
+        headers = {
+            'accept': 'application/vnd.identity-service+json; version=1.0',
+            'content-type': 'application/json',
+            'authorization': self.ACCESS_TOKEN
+        }
+        return requests.get(self.USER_URL, headers=headers).json()
+
+    def user_settings(self, data):
+        self.ACCESS_TOKEN = data.get('access_token', '')
+        self.REFRESH_TOKEN = data.get('refresh_token', '')
+        self.plugin.set_setting('access_token', self.ACCESS_TOKEN)
+        self.plugin.set_setting('refresh_token', self.REFRESH_TOKEN)
+
+    def refresh_token(self):
+        if self.REFRESH_TOKEN:
+            self.user_settings(self.authorization(token=self.REFRESH_TOKEN))
+        elif self.DEVICE_ID:
+            self.login()
+
+    def profile(self):
+        data = self.user()
+        properties = data['profile']['profileProperty']
+        for i in properties:
+            name = i['name']
+            if name == 'country':
+                self.plugin.set_setting('country', i['value'])
+            if name == 'language':
+                self.plugin.set_setting('language', i['value'])
+
+    def login(self):
+        code = None
+        credentials = self.plugin.get_credentials()
+        if credentials:
+            data = self.authentication(credentials)
+            if data.get('message'):
+                msg = self.plugin.utfenc(data['message'][:100])
+            else:
+                msg = 'logged in'
+                code = data['code']
+            self.plugin.log('[{0}] {1}'.format(self.plugin.addon_id, msg))
+        if code:
+            self.user_settings(self.authorization(grant_type='urn:mlbam:params:oauth:grant_type:token', token=code))
+            self.profile()
+        else:
+            self.plugin.dialog_ok(30004)