service.py

   1 #!/usr/bin/env python
   2 # -*- coding: utf-8 -*-
   3 # Module: service
   4 # Created on: 26.01.2017
   5
   6 import threading
   7 import SocketServer
   8 import xbmc
   9 import socket
  10 from xbmcaddon import Addon
  11 from resources.lib.KodiHelper import KodiHelper
  12 from resources.lib.MSLHttpRequestHandler import MSLHttpRequestHandler
  13 from resources.lib.NetflixHttpRequestHandler import NetflixHttpRequestHandler
  14
  15 def select_unused_port():
  16     sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  17     sock.bind(('localhost', 0))
  18     addr, port = sock.getsockname()
  19     sock.close()
  20     return port
  21
  22 addon = Addon()
  23 kodi_helper = KodiHelper()
  24
  25 msl_port = select_unused_port()
  26 addon.setSetting('msl_service_port', str(msl_port))
  27 kodi_helper.log(msg='[MSL] Picked Port: ' + str(msl_port))
  28
  29 ns_port = select_unused_port()
  30 addon.setSetting('netflix_service_port', str(ns_port))
  31 kodi_helper.log(msg='[NS] Picked Port: ' + str(ns_port))
  32
  33 # server defaults
  34 SocketServer.TCPServer.allow_reuse_address = True
  35
  36 # configure the MSL Server
  37 msl_server = SocketServer.TCPServer(('127.0.0.1', msl_port), MSLHttpRequestHandler)
  38 msl_server.server_activate()
  39 msl_server.timeout = 1
  40
  41 # configure the Netflix Data Server
  42 nd_server = SocketServer.TCPServer(('127.0.0.1', ns_port), NetflixHttpRequestHandler)
  43 nd_server.server_activate()
  44 nd_server.timeout = 1
  45
  46 if __name__ == '__main__':
  47     monitor = xbmc.Monitor()
  48
  49     msl_thread = threading.Thread(target=msl_server.serve_forever)
  50     msl_thread.daemon = True
  51     msl_thread.start()
  52
  53     nd_thread = threading.Thread(target=nd_server.serve_forever)
  54     nd_thread.daemon = True
  55     nd_thread.start()
  56
  57     while not monitor.abortRequested():
  58         if monitor.waitForAbort(5):
  59             msl_server.shutdown()
  60             nd_server.shutdown()
  61             break
  62
  63     msl_server.server_close()
  64     msl_server.socket.close()
  65     msl_server.shutdown()
  66     kodi_helper.log(msg='Stopped MSL Service')
  67
  68     nd_server.server_close()
  69     nd_server.socket.close()
  70     nd_server.shutdown()
  71     kodi_helper.log(msg='Stopped HTTP Service')