104 lines
3.7 KiB
Python
104 lines
3.7 KiB
Python
#! /usr/bin/env python
|
|
# -*- coding: utf-8 -*-
|
|
# ------------------------------------------------------------
|
|
# Launcher
|
|
# ------------------------------------------------------------
|
|
import os
|
|
import sys
|
|
import threading
|
|
import time
|
|
from functools import wraps
|
|
|
|
sys.dont_write_bytecode = True
|
|
from platformcode import config
|
|
|
|
sys.path.append(os.path.join(config.get_runtime_path(), 'lib'))
|
|
from platformcode import platformtools, logger
|
|
import HTTPServer
|
|
import WebSocket
|
|
|
|
http_port = config.get_setting("server.port")
|
|
websocket_port = config.get_setting("websocket.port")
|
|
myip = config.get_local_ip()
|
|
version = config.get_addon_version()
|
|
|
|
|
|
def thread_name_wrap(func):
|
|
@wraps(func)
|
|
def bar(*args, **kw):
|
|
if "name" not in kw:
|
|
kw['name'] = threading.current_thread().name
|
|
return func(*args, **kw)
|
|
|
|
return bar
|
|
|
|
|
|
threading.Thread.__init__ = thread_name_wrap(threading.Thread.__init__)
|
|
|
|
if sys.version_info < (2, 7, 11):
|
|
import ssl
|
|
|
|
ssl._create_default_https_context = ssl._create_unverified_context
|
|
|
|
|
|
def show_info():
|
|
os.system('cls' if os.name == 'nt' else 'clear')
|
|
print ("--------------------------------------------------------------------")
|
|
print ("Alfa %s Iniciado" %version)
|
|
print ("La URL para acceder es http://%s:%s" % (myip, http_port))
|
|
print ("WebSocket Server iniciado en ws://%s:%s" % (myip, websocket_port))
|
|
print ("--------------------------------------------------------------------")
|
|
print ("Runtime Path : " + config.get_runtime_path())
|
|
print ("Data Path : " + config.get_data_path())
|
|
print ("Download Path : " + config.get_setting("downloadpath"))
|
|
print ("DownloadList Path : " + config.get_setting("downloadlistpath"))
|
|
print ("Bookmark Path : " + config.get_setting("bookmarkpath"))
|
|
print ("Videolibrary Path : " + config.get_setting("videolibrarypath"))
|
|
print ("--------------------------------------------------------------------")
|
|
controllers = platformtools.controllers
|
|
for a in controllers:
|
|
try:
|
|
print platformtools.controllers[a].controller.client_ip + " - (" + platformtools.controllers[
|
|
a].controller.name + ")"
|
|
except:
|
|
pass
|
|
|
|
|
|
def start():
|
|
logger.info("server init...")
|
|
config.verify_directories_created()
|
|
try:
|
|
HTTPServer.start(show_info)
|
|
WebSocket.start(show_info)
|
|
|
|
# Da por levantado el servicio
|
|
logger.info("--------------------------------------------------------------------")
|
|
logger.info("Alfa %s Iniciado" %version)
|
|
logger.info("La URL para acceder es http://%s:%s" % (myip, http_port))
|
|
logger.info("WebSocket Server iniciado en ws://%s:%s" % (myip, websocket_port))
|
|
logger.info("--------------------------------------------------------------------")
|
|
logger.info("Runtime Path : " + config.get_runtime_path())
|
|
logger.info("Data Path : " + config.get_data_path())
|
|
logger.info("Download Path : " + config.get_setting("downloadpath"))
|
|
logger.info("DownloadList Path : " + config.get_setting("downloadlistpath"))
|
|
logger.info("Bookmark Path : " + config.get_setting("bookmarkpath"))
|
|
logger.info("VideoLibrary Path : " + config.get_setting("videolibrarypath"))
|
|
logger.info("--------------------------------------------------------------------")
|
|
show_info()
|
|
|
|
flag = True
|
|
while flag:
|
|
time.sleep(1)
|
|
|
|
except KeyboardInterrupt:
|
|
print 'Deteniendo el servidor HTTP...'
|
|
HTTPServer.stop()
|
|
print 'Deteniendo el servidor WebSocket...'
|
|
WebSocket.stop()
|
|
print 'Alfa Detenido'
|
|
flag = False
|
|
|
|
|
|
# Inicia el programa
|
|
start()
|