add error message
This commit is contained in:
		
							
								
								
									
										11
									
								
								stream.py
									
									
									
									
									
								
							
							
						
						
									
										11
									
								
								stream.py
									
									
									
									
									
								
							@@ -27,6 +27,7 @@ for key in proxies:
 | 
				
			|||||||
playlist = None
 | 
					playlist = None
 | 
				
			||||||
icecast_server = os.environ.get("ICECAST_SERVER")
 | 
					icecast_server = os.environ.get("ICECAST_SERVER")
 | 
				
			||||||
stream_server = os.environ.get("STREAM_SERVER")
 | 
					stream_server = os.environ.get("STREAM_SERVER")
 | 
				
			||||||
 | 
					
 | 
				
			||||||
if icecast_server is not None and stream_server is not None:
 | 
					if icecast_server is not None and stream_server is not None:
 | 
				
			||||||
    with open("/app/sources.json", "r") as f:
 | 
					    with open("/app/sources.json", "r") as f:
 | 
				
			||||||
        data = json.loads(f.read())
 | 
					        data = json.loads(f.read())
 | 
				
			||||||
@@ -43,7 +44,7 @@ if icecast_server is not None and stream_server is not None:
 | 
				
			|||||||
                playlist += stream_server + key + "\n"
 | 
					                playlist += stream_server + key + "\n"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
class MainHandler(tornado.web.RequestHandler):
 | 
					class MainHandler(tornado.web.RequestHandler):
 | 
				
			||||||
    def handle_any(self):
 | 
					    def handle_any(self, write):
 | 
				
			||||||
        provider = self.get_query_argument("provider", None)
 | 
					        provider = self.get_query_argument("provider", None)
 | 
				
			||||||
        endpoint = None
 | 
					        endpoint = None
 | 
				
			||||||
        if provider is not None and provider in providers.keys():
 | 
					        if provider is not None and provider in providers.keys():
 | 
				
			||||||
@@ -67,13 +68,15 @@ class MainHandler(tornado.web.RequestHandler):
 | 
				
			|||||||
                    print(str(e))
 | 
					                    print(str(e))
 | 
				
			||||||
                    endpoint = None
 | 
					                    endpoint = None
 | 
				
			||||||
        if endpoint is None:
 | 
					        if endpoint is None:
 | 
				
			||||||
            self.set_status(404, reason="stream not found")
 | 
					            self.set_status(404)
 | 
				
			||||||
 | 
					            if write:
 | 
				
			||||||
 | 
					                self.write("stream not found")
 | 
				
			||||||
        else:
 | 
					        else:
 | 
				
			||||||
            self.redirect(endpoint, status=303)
 | 
					            self.redirect(endpoint, status=303)
 | 
				
			||||||
    def get(self):
 | 
					    def get(self):
 | 
				
			||||||
        self.handle_any()
 | 
					        self.handle_any(True)
 | 
				
			||||||
    def head(self):
 | 
					    def head(self):
 | 
				
			||||||
        self.handle_any()
 | 
					        self.handle_any(False)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
class FileHandler(tornado.web.RequestHandler):
 | 
					class FileHandler(tornado.web.RequestHandler):
 | 
				
			||||||
    def get(self):
 | 
					    def get(self):
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user