1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
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)
|
