def handle(self, connection):
+ logger = logging.getLogger('plugin_m3u')
hostport = connection.headers['Host']
self.splitted_path=connection.path.split('/')
None
else:
connection.dieWithError(404)
+ return
if len(self.splitted_path)>3 and self.splitted_path[1]!="play":
connection.dieWithError()
connection.end_headers()
elif self.splitted_path[1]=="play":
channel=self.splitted_path[len(self.splitted_path)-1]
+ logger.debug('channel requestes= "%s"' % channel)
+ if not channel:
+ connection.dieWithError(404)
+ return
channel=urllib.unquote(channel).decode('utf-8')
if len(self.splitted_path)<=4:
prefix="get"
prefix=self.splitted_path[len(self.splitted_path)-2]
if prefix not in ('get','mp4','webm'):
connection.dieWithError()
+ return
else:
connection.dieWithError()
+ return
url=None
for record in playlist:
+ if record.title:
if record.title.decode('utf-8').replace('/','')==channel:
url=record.path.decode('utf-8')
if url:
connection.send_header('Location', redirect)
connection.end_headers()
else:
+ logger.debug('Nothing found!')
connection.dieWithError(404)
+ return
else:
connection.send_response(200)
connection.dieWithError()
return
+ exported = ""
+
if self.splitted_path[1]=="list":
- exported = ""
-
for record in playlist:
if record.title:
exported = exported + "" + record.title.decode('utf-8').replace('/','') + "\n"
exported = playlistgen.exportm3u(hostport,prefix)
- exported = exported.encode('utf-8')
-
- connection.wfile.write(exported)
+ if exported:
+ exported = exported.encode('utf-8')
+ connection.wfile.write(exported)
def getparam(self, key):
if key in self.params: