Archives
/
plugin.video.TVOnline.ro
mirror of https://github.com/cralin/plugin.video.TVOnline.ro
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
release/Kodi_21_Omega
release/Kodi_20_Nexus
release/Kodi_19_Matrix
master
21.0.1
20.0.15
21.0.0
21.0.0-RC04
20.0.14
21.0.0-RC03
20.0.13
21.0.0-RC02
21.0.0-RC01
19.3.13
20.0.12
19.3.12
20.0.11
19.3.11
20.0.10
19.3.10
20.0.9
20.0.8
19.3.9
19.3.8
20.0.7
20.0.6
19.3.7
20.0.5
19.3.6
20.0.4
20.0.3
19.3.5
20.0.2
19.3.4
20.0.1
19.3.3
20.0.0
19.3.2
19.3.1
19.3.0
19.2.9
19.2.8
19.2.7
19.2.6
19.2.5
19.2.4
19.2.3
19.2.2
19.2.1
19.2.0
19.1.7
19.1.6
19.1.5
19.1.4
19.1.3
19.1.2
19.1.1
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from '679b9b6952'
${ noResults }
plugin.video.TVOnline.ro/resources/lib/primaplay/functions.py

590 lines
23 KiB
Python
Raw Blame History

#
#
# Copyright (C) 2021 Alin Cretu
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <https://www.gnu.org/licenses/>.
#
#
import sys
import xbmcplugin
import xbmcgui
import xbmcaddon
import xbmcvfs
import os
import logging
import http.cookiejar
import re
import time
import json
import inputstreamhelper
import resources.lib.common.vars as common_vars
import resources.lib.common.functions as common_functions
def init_AddonCookieJar(NAME, DATA_DIR):
####
#
# Initialize the common_vars.__primaplay_CookieJar__ variable.
#
# Parameters:
# NAME: common_vars.__logger__ name to use for sending the log messages
# DATA_DIR: The addon's 'userdata' directory.
#
####
common_vars.__logger__ = logging.getLogger(NAME)
common_vars.__logger__.debug('Enter function')
# File containing the session cookies
cookies_file = os.path.join(DATA_DIR, common_vars.__primaplay_CookiesFilename__)
common_vars.__logger__.debug('[ Addon cookies file ] cookies_file = ' + str(cookies_file))
common_vars.__primaplay_CookieJar__ = http.cookiejar.MozillaCookieJar(cookies_file)
# If it doesn't exist already, create a new file where the cookies should be saved
if not os.path.exists(cookies_file):
common_vars.__primaplay_CookieJar__.save()
common_vars.__logger__.debug('[ Addon cookiefile ] Created cookiejar file: ' + str(cookies_file))
# Load any cookies saved from the last run
common_vars.__primaplay_CookieJar__.load()
common_vars.__logger__.debug('[ Addon cookiejar ] Loaded cookiejar from file: ' + str(cookies_file))
def do_login(NAME, COOKIEJAR, SESSION):
####
#
# Login to primaplay.ro for the given session.
#
# Parameters:
# NAME: Logger name to use for sending the log messages
# COOKIEJAR: The cookiejar to be used with the given session
# SESSION: The session to be used for login
#
# Return: dict variable with authentication details
#
####
common_vars.__logger__ = logging.getLogger(NAME)
common_vars.__logger__.debug('Enter function')
MyHeaders = {
'User-Agent': common_vars.__primaplay_userAgent__,
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
'Accept-Language': 'en-US',
'Accept-Encoding': 'identity',
'Content-Type': 'application/x-www-form-urlencoded',
'Connection': 'keep-alive',
'Upgrade-Insecure-Requests': '1',
'Cache-Control': 'max-age=0'
}
common_vars.__logger__.debug('Cookies: ' + str(list(COOKIEJAR)))
common_vars.__logger__.debug('Headers: ' + str(MyHeaders))
common_vars.__logger__.debug('URL: https://www.primaplay.ro/login')
common_vars.__logger__.debug('Method: GET')
# Send the GET request
_request_ = SESSION.get('https://www.primaplay.ro/login', headers=MyHeaders, allow_redirects=False)
# Save cookies for later use.
COOKIEJAR.save(ignore_discard=True)
common_vars.__logger__.debug('Received status code: ' + str(_request_.status_code))
common_vars.__logger__.debug('Received cookies: ' + str(list(COOKIEJAR)))
common_vars.__logger__.debug('Received headers: ' + str(_request_.headers))
common_vars.__logger__.debug('Received data: ' + _request_.content.decode())
_has_token_ = re.search('_token', _request_.content.decode(), re.IGNORECASE|re.DOTALL)
if _has_token_:
_token_ = re.findall('name="_token" value="(.+?)"', _request_.content.decode(), re.IGNORECASE|re.DOTALL)[0]
common_vars.__logger__.debug('Found _token_ = ' + str(_token_))
else:
_token_ = "NO_TOKEN"
common_vars.__logger__.debug('Set _token_ = ' + str(_token_))
MyHeaders = {
'User-Agent': common_vars.__primaplay_userAgent__,
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
'Accept-Language': 'en-US',
'Accept-Encoding': 'identity',
'Content-Type': 'application/x-www-form-urlencoded',
'Connection': 'keep-alive',
'Upgrade-Insecure-Requests': '1',
'Cache-Control': 'max-age=0'
}
# Setup form data to be sent
MyFormData = {
'email': common_vars.__config_primaplay_Username__,
'password': common_vars.__config_primaplay_Password__,
'_token': _token_,
}
MyFormData_logger = {
'email': common_vars.__config_primaplay_Username__,
'password': '****************',
'_token': _token_,
}
common_vars.__logger__.debug('Cookies: ' + str(list(COOKIEJAR)))
common_vars.__logger__.debug('Headers: ' + str(MyHeaders))
common_vars.__logger__.debug('MyFormData: ' + str(MyFormData_logger))
common_vars.__logger__.debug('URL: https://www.primaplay.ro/login')
common_vars.__logger__.debug('Method: POST')
# Send the POST request
_request_ = SESSION.post('https://www.primaplay.ro/login', headers=MyHeaders, data=MyFormData, allow_redirects=True)
# Save cookies for later use.
COOKIEJAR.save(ignore_discard=True)
common_vars.__logger__.debug('Received status code: ' + str(_request_.status_code))
common_vars.__logger__.debug('Received cookies: ' + str(list(COOKIEJAR)))
common_vars.__logger__.debug('Received headers: ' + str(_request_.headers))
common_vars.__logger__.debug('Received data: ' + _request_.content.decode())
common_vars.__logger__.debug('Exit function')
def play_video(CHANNEL_ENDPOINT, NAME, COOKIEJAR, SESSION, DATA_DIR):
####
#
# Play a video by the provided path.
#
# Parameters:
# path: Fully-qualified video URL
#
####
common_vars.__logger__ = logging.getLogger(NAME)
common_vars.__logger__.debug('Enter function')
common_vars.__logger__.debug('Chanel endpoint = ' + CHANNEL_ENDPOINT)
_auth_ = do_login(NAME, COOKIEJAR, SESSION)
common_vars.__logger__.debug('_auth_ = ' + str(_auth_))
# Get the URL for the stream metadata
# Setup headers for the request
MyHeaders = {
'User-Agent': common_vars.__primaplay_userAgent__,
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
'Accept-Language': 'en-US',
'Accept-Encoding': 'identity',
'Connection': 'keep-alive',
'Upgrade-Insecure-Requests': '1',
'Cache-Control': 'max-age=0',
}
common_vars.__logger__.debug('Cookies: ' + str(list(COOKIEJAR)))
common_vars.__logger__.debug('Headers: ' + str(MyHeaders))
common_vars.__logger__.debug('URL: ' + CHANNEL_ENDPOINT)
common_vars.__logger__.debug('Method: GET')
# Send the GET request
_request_ = SESSION.get(CHANNEL_ENDPOINT, headers=MyHeaders)
# Save cookies for later use.
COOKIEJAR.save(ignore_discard=True)
common_vars.__logger__.debug('Received status code: ' + str(_request_.status_code))
common_vars.__logger__.debug('Received cookies: ' + str(list(COOKIEJAR)))
common_vars.__logger__.debug('Received headers: ' + str(_request_.headers))
common_vars.__logger__.debug('Received data: ' + _request_.content.decode())
_premium_content_ = re.search('class="premium-content"', _request_.content.decode(), re.IGNORECASE|re.DOTALL)
common_vars.__logger__.debug('Found _premium_content_ = ' + str(_premium_content_))
if _premium_content_:
_raw_message_ = re.findall('<div class="premium-content">(.+?)</div>', _request_.content.decode(), re.IGNORECASE|re.DOTALL)[0]
common_vars.__logger__.debug('Found _raw_message_ = ' + str(_raw_message_))
_title_ = ""
_title_ = re.findall('<h2>(.+?)</h2>', _raw_message_, re.IGNORECASE|re.DOTALL)[0]
common_vars.__logger__.debug('Found _title_ = ' + str(_title_))
_has_message_ = re.search('<p>', _raw_message_, re.IGNORECASE|re.DOTALL)
if _has_message_:
_message_ = re.findall('<p>(.+?)</br>', _raw_message_, re.IGNORECASE|re.DOTALL)[0]
common_vars.__logger__.debug('Found _message_ = ' + str(_message_))
common_vars.__logger__.info('[primaplus.ro] => ' + _title_ + ' => ' + _message_)
xbmcgui.Dialog().ok('[primaplus.ro] => ' + _title_.strip(), _message_.strip())
else:
common_vars.__logger__.info('[primaplus.ro] => Error => ' + _title_.strip())
xbmcgui.Dialog().ok('[primaplus.ro] => Error ', _title_.strip())
common_vars.__logger__.debug('Exit function')
else:
_raw_stream_manifest_url_ = re.search(r'(?<!=// )\w+',_request_.content.decode())
common_vars.__logger__.debug('Found _raw_stream_manifest_url_ = ' + str(_raw_stream_manifest_url_.groups))
_stream_manifest_url_ = re.findall('var videoSrc = \'(.+?)\';',_request_.content.decode(), re.IGNORECASE|re.DOTALL)[1]
common_vars.__logger__.debug('Found _stream_manifest_url_ = ' + str(_stream_manifest_url_))
# Set the headers to be used with imputstream.adaptive
_headers_ = ''
_headers_ = _headers_ + '&User-Agent=' + common_vars.__primaplay_userAgent__
_headers_ = _headers_ + '&Host=clever-live1ro.deja.media'
_headers_ = _headers_ + '&Origin=https://www.primaplay.ro'
_headers_ = _headers_ + '&Referer=https://www.primaplay.ro/'
_headers_ = _headers_ + '&Connection=keep-alive'
_headers_ = _headers_ + '&Accept-Language=en-US'
_headers_ = _headers_ + '&Accept=*/*'
_headers_ = _headers_ + '&Accept-Encoding=identity'
common_vars.__logger__.debug('Created: _headers_ = ' + _headers_)
# # Create a playable item with a path to play.
# # See: https://github.com/peak3d/inputstream.adaptive/issues/131#issuecomment-375059796
# is_helper = inputstreamhelper.Helper('hls')
# if is_helper.check_inputstream():
# play_item = xbmcgui.ListItem(path=_stream_manifest_url_ + '|' + _headers_)
# play_item.setProperty('inputstream', 'inputstream.adaptive')
# play_item.setProperty('inputstream.adaptive.stream_headers', _headers_)
# play_item.setMimeType('application/vnd.apple.mpegurl')
# play_item.setContentLookup(False)
#
# # Pass the item to the Kodi player.
# xbmcplugin.setResolvedUrl(int(common_vars.__handle__), True, listitem=play_item)
play_item = xbmcgui.ListItem(path=_stream_manifest_url_ + '|' + _headers_)
xbmcplugin.setResolvedUrl(int(common_vars.__handle__), True, listitem=play_item)
common_vars.__logger__.debug('Exit function')
def list_categories(NAME, COOKIEJAR, SESSION, DATA_DIR):
####
#
# Create the list of video categories in the Kodi interface.
#
####
common_vars.__logger__ = logging.getLogger(NAME)
common_vars.__logger__.debug('Enter function')
common_vars.__logger__.debug('Exit function')
def list_channels(NAME, COOKIEJAR, SESSION, DATA_DIR):
####
#
# Create the list of playable videos in the Kodi interface.
#
# Parameters:
# NAME: Logger name to use for sending the log messages.
# COOKIEJAR: The cookiejar to be used with the given session.
# SESSION: The session to be used for login this call
# DATA_DIR: The addon's 'userdata' directory.
#
# Return: The list of cached video categories
#
####
common_vars.__logger__ = logging.getLogger(NAME)
common_vars.__logger__.debug('Enter function')
# Get the list of videos in the category.
channels = get_channels(NAME, COOKIEJAR, SESSION)
common_vars.__logger__.debug('Received channels = ' + str(channels))
for channel in channels:
common_vars.__logger__.debug('Channel data => ' + str(channel))
common_vars.__logger__.debug('Channel name: ' + channel['name'])
common_vars.__logger__.debug('Channel url: ' + channel['url'])
common_vars.__logger__.debug('Channel logo: ' + channel['logo'])
common_vars.__logger__.debug('Channel ID: ' + channel['id'])
# Create a list item with a text label and a thumbnail image.
list_item = xbmcgui.ListItem(label=channel['name'])
# Set additional info for the list item.
# For available properties see https://codedocs.xyz/xbmc/xbmc/group__python__xbmcgui__listitem.html#ga0b71166869bda87ad744942888fb5f14
# 'mediatype' is needed for skin to display info for this ListItem correctly.
list_item.setInfo('video', {'title': channel['name'],
'genre': 'General',
'mediatype': 'video'})
# Set graphics (thumbnail, fanart, banner, poster, landscape etc.) for the list item.
list_item.setArt({'thumb': channel['logo']})
# Set 'IsPlayable' property to 'true'.
# This is mandatory for playable items!
list_item.setProperty('IsPlayable', 'true')
# Create a URL for a plugin recursive call.
# Example: plugin://plugin.video.example/?action=play&channel_endpoint=/filme/tnt&channel_metadata=...
url = common_functions.get_url(action='play', account='primaplay.ro', channel_endpoint=channel['url'])
common_vars.__logger__.debug('URL for plugin recursive call: ' + url)
# This means that this item won't open any sub-list.
is_folder = False
# Add our item to the Kodi virtual folder listing.
xbmcplugin.addDirectoryItem(int(common_vars.__handle__), url, list_item, is_folder)
# Add a sort method for the virtual folder items (alphabetically, ignore articles)
xbmcplugin.addSortMethod(int(common_vars.__handle__), xbmcplugin.SORT_METHOD_LABEL_IGNORE_THE)
# Finish creating a virtual folder.
xbmcplugin.endOfDirectory(int(common_vars.__handle__))
common_vars.__logger__.debug('Exit function')
def get_channels(NAME, COOKIEJAR, SESSION):
####
#
# Get from primaplay.ro the list of channels/streams.
#
# Parameters:
# NAME: Logger name to use for sending the log messages
# COOKIEJAR: The cookiejar to be used with the given session
# SESSION: The session to be used for this call
# DATA_DIR: The addon's 'userdata' directory.
#
# Return: The list of channels/streams in the given category
#
####
common_vars.__logger__ = logging.getLogger(NAME)
common_vars.__logger__.debug('Enter function')
# Setup headers for the request
MyHeaders = {
'User-Agent': common_vars.__primaplay_userAgent__,
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
'Accept-Language': 'en-US',
'Accept-Encoding': 'identity',
'Connection': 'keep-alive',
'Upgrade-Insecure-Requests': '1',
'Cache-Control': 'max-age=0'
}
common_vars.__logger__.debug('Cookies: ' + str(list(COOKIEJAR)))
common_vars.__logger__.debug('Headers: ' + str(MyHeaders))
common_vars.__logger__.debug('URL: https://www.primaplay.ro/live')
common_vars.__logger__.debug('Method: GET')
# Send the GET request
_request_ = SESSION.get('https://www.primaplay.ro/live', headers=MyHeaders)
# Save cookies for later use.
COOKIEJAR.save(ignore_discard=True)
common_vars.__logger__.debug('Received status code: ' + str(_request_.status_code))
common_vars.__logger__.debug('Received cookies: ' + str(list(COOKIEJAR)))
common_vars.__logger__.debug('Received headers: ' + str(_request_.headers))
common_vars.__logger__.debug('Received data: ' + _request_.content.decode())
_raw_channels_ = re.findall('<div class="card card-responsive card-bg chanel-live">(.+?)/span>', _request_.content.decode(), re.IGNORECASE|re.DOTALL)
common_vars.__logger__.debug('Found _raw_channels_ = ' + str(_raw_channels_))
# Initialize the list of channels
_channels_ = []
_channel_id_ = 0
for _raw_channel_ in _raw_channels_:
common_vars.__logger__.debug('_raw_channel_ = ' + str(_raw_channel_))
_channel_record_ = {}
_channel_name_ = re.findall('<span>(.+?)<', _raw_channel_, re.IGNORECASE)[0]
common_vars.__logger__.debug('_channel_name_ = ' + str(_channel_name_))
_channel_url_ = re.findall('<a class="card-content" href="(.+?)"', _raw_channel_, re.IGNORECASE)[0]
common_vars.__logger__.debug('_channel_url_ = ' + str(_channel_url_))
_channel_logo_ = re.findall('img src="(.+?)"', _raw_channel_, re.IGNORECASE)[0]
common_vars.__logger__.debug('_channel_logo_ = ' + str(_channel_logo_))
#_channel_id_ = re.findall('card-bg (.+?)"', _raw_channel_, re.IGNORECASE|re.DOTALL)[0]
_channel_id_ = _channel_id_ + 1
common_vars.__logger__.debug('_channel_id_ = ' + str(_channel_id_))
_channel_record_["name"] = _channel_name_
_channel_record_["url"] = _channel_url_
_channel_record_["logo"] = _channel_logo_
_channel_record_["id"] = _channel_id_
common_vars.__logger__.debug('Created: _channel_record_ = ' + str(_channel_record_))
_channels_.append(_channel_record_)
common_vars.__logger__.debug('_channels_ = ' + str(_channels_))
common_vars.__logger__.debug('Exit function')
return _channels_
def PVRIPTVSimpleClientIntegration_update_m3u_file(M3U_FILE, START_NUMBER, NAME, COOKIEJAR, SESSION):
common_vars.__logger__ = logging.getLogger(NAME)
common_vars.__logger__.debug('Enter function')
common_vars.__logger__.debug('M3U_FILE = ' + M3U_FILE)
common_vars.__logger__.debug('START_NUMBER = ' + str(START_NUMBER))
# Get the list of channels in the category.
channels = get_channels(NAME, COOKIEJAR, SESSION)
common_vars.__logger__.debug('Received channels = ' + str(channels))
_CHNO_ = START_NUMBER
_data_file_ = open(M3U_FILE, 'a', encoding='utf-8')
for channel in channels:
_line_ = "#EXTINF:0 tvg-id=\"primaplay__" + str(channel['id']) + "\" tvg-name=\"" + channel['name'] + "\" tvg-logo=\"" + channel['logo'] + "\" tvg-chno=\"" + str(_CHNO_) + "\" group-title=\"Prima Play\"," + channel['name']
_url_ = common_functions.get_url(action='play', account='primaplay.ro', channel_endpoint=channel['url'])
_play_url_ = "plugin://" + common_vars.__AddonID__ + "/" + _url_
_data_file_.write(_line_ + "\n")
_data_file_.write(_play_url_ + "\n")
_CHNO_ = _CHNO_ + 1
_data_file_.close()
common_vars.__logger__.debug('Exit function')
return _CHNO_
#def PVRIPTVSimpleClientIntegration_update_EPG_file(XML_FILE, NAME, COOKIEJAR, SESSION):
# common_vars.__logger__ = logging.getLogger(NAME)
# common_vars.__logger__.debug('Enter function')
#
# common_vars.__logger__.debug('XML_FILE = ' + XML_FILE)
#
# # Get the list of channels in the category.
# channels = voyo_functions.get_channels(NAME, COOKIEJAR, SESSION)
# common_vars.__logger__.debug('Received channels = ' + str(channels))
#
# epg = voyo_functions.get_epg_data(NAME, COOKIEJAR, SESSION)
# common_vars.__logger__.debug('Received epg = ' + str(epg))
#
# _data_file_ = open(XML_FILE, 'a', encoding='utf-8')
#
# for channel in channels:
# #common_vars.__logger__.debug('Channel name = ' + channel['name'])
# #common_vars.__logger__.debug('Channel url = ' + channel['url'])
# #common_vars.__logger__.debug('Channel logo = ' + channel['logo'])
# #common_vars.__logger__.debug('Channel id = ' + channel['id'])
# #common_vars.__logger__.debug('Channel data-url = ' + channel['data-url'])
#
# _line_ = " <channel id=\"voyo__" + channel['id'] + "\">"
# _data_file_.write(_line_ + "\n")
# _line_ = " <display-name>" + channel['name'] + "</display-name>"
# _data_file_.write(_line_ + "\n")
# _line_ = " </channel>"
# _data_file_.write(_line_ + "\n")
#
# for program in epg[channel['id']]:
#
# ###### Probably there is a better way to deal with this ######
# program['start_at'] = re.sub('-', '', program['start_at'], flags=re.IGNORECASE)
# program['start_at'] = re.sub('T', '', program['start_at'], flags=re.IGNORECASE)
# program['start_at'] = re.sub(':', '', program['start_at'], flags=re.IGNORECASE)
# program['start_at'] = re.sub('\+', ' +', program['start_at'], flags=re.IGNORECASE)
#
# program['end_at'] = re.sub('-', '', program['end_at'], flags=re.IGNORECASE)
# program['end_at'] = re.sub('T', '', program['end_at'], flags=re.IGNORECASE)
# program['end_at'] = re.sub(':', '', program['end_at'], flags=re.IGNORECASE)
# program['end_at'] = re.sub('\+', ' +', program['end_at'], flags=re.IGNORECASE)
# ###### Probably there is a better way to deal with this ######
#
# _line_ = " <programme start=\"" + program['start_at'] + "\" stop=\"" + program['end_at'] + "\" channel=\"voyo__" + channel['id'] + "\">"
# _data_file_.write(_line_ + "\n")
#
# # Replace unwanted characters in the program name
# program['title'] = re.sub('&nbsp;', ' ', program['title'], flags=re.IGNORECASE)
# program['title'] = re.sub('&apos;', '\'', program['title'], flags=re.IGNORECASE)
# _line_ = " <title>" + program['title'] + "</title>"
# _data_file_.write(_line_ + "\n")
#
# # Replace unwanted characters in the program description
# program['short_description'] = re.sub('&nbsp;', ' ', program['short_description'], flags=re.IGNORECASE)
# program['short_description'] = re.sub('&apos;', '\'', program['short_description'], flags=re.IGNORECASE)
# program['description'] = re.sub('&nbsp;', ' ', program['description'], flags=re.IGNORECASE)
# program['description'] = re.sub('&apos;', '\'', program['description'], flags=re.IGNORECASE)
#
# _line_ = " <desc>" + program['short_description'] + "\n\n " + program['description'] + "\n </desc>"
# _data_file_.write(_line_ + "\n")
#
# _line_ = " </programme>"
# _data_file_.write(_line_ + "\n")
#
# _data_file_.close
#
# common_vars.__logger__.debug('Exit function')
#
#
#
#def get_epg_data(NAME, COOKIEJAR, SESSION):
# ####
# #
# # Get from voyo.protv.ro the EPG data.
# #
# # Parameters:
# # NAME: Logger name to use for sending the log messages
# # COOKIEJAR: The cookiejar to be used with the given session
# # SESSION: The session to be used for this call
# #
# # Return: A dict object containing the EPG data
# #
# ####
# common_vars.__logger__ = logging.getLogger(NAME)
# common_vars.__logger__.debug('Enter function')
#
# # Setup headers for the request
# MyHeaders = {
# 'Host': 'protvplus.ro',
# 'User-Agent': common_vars.__protvplus_userAgent__,
# 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8',
# 'Accept-Language': 'en-US',
# 'Accept-Encoding': 'identity',
# 'Connection': 'keep-alive',
# 'Upgrade-Insecure-Requests': '1',
# 'Cache-Control': 'max-age=0'
# }
#
# common_vars.__logger__.debug('Cookies: ' + str(list(COOKIEJAR)))
# common_vars.__logger__.debug('Headers: ' + str(MyHeaders))
# common_vars.__logger__.debug('URL: https://protvplus.ro/tv-program')
# common_vars.__logger__.debug('Method: GET')
#
# # Send the GET request
# _request_ = SESSION.get('https://protvplus.ro/tv-program', headers=MyHeaders)
#
# # Save cookies for later use.
# COOKIEJAR.save(ignore_discard=True)
#
# common_vars.__logger__.debug('Received status code: ' + str(_request_.status_code))
# common_vars.__logger__.debug('Received cookies: ' + str(list(COOKIEJAR)))
# common_vars.__logger__.debug('Received headers: ' + str(_request_.headers))
# common_vars.__logger__.debug('Received data: ' + _request_.content.decode())
#
# _raw_epg_data_ = re.findall('EPG_program = (.+?);\n', _request_.content.decode(), re.IGNORECASE|re.DOTALL)[0]
# common_vars.__logger__.debug('Found _raw_epg_data_ = ' + str(_raw_epg_data_))
#
# _epg_data_ = json.loads(_raw_epg_data_)
#
# common_vars.__logger__.debug('Exit function')
#
# return _epg_data_
Reference in New Issue View Git Blame Copy Permalink