1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
# -*- coding: utf-8 -*-
# Copyright 2017 Leo Moll and Dominik Schlösser
#
# -- Imports ------------------------------------------------
import os
import sys
import urllib
import xbmc
import xbmcgui
import xbmcaddon
import xbmcplugin
from resources.lib.kodi.KodiLogger import KodiLogger
# -- Classes ------------------------------------------------
class KodiAddon( KodiLogger ):
def __init__( self ):
self.addon = xbmcaddon.Addon()
self.addon_id = self.addon.getAddonInfo( 'id' )
self.icon = self.addon.getAddonInfo( 'icon' )
self.fanart = self.addon.getAddonInfo( 'fanart' )
self.version = self.addon.getAddonInfo( 'version' )
self.path = self.addon.getAddonInfo( 'path' )
self.datapath = xbmc.translatePath( self.addon.getAddonInfo('profile').decode('utf-8') )
self.language = self.addon.getLocalizedString
KodiLogger.__init__( self, self.addon_id, self.version )
def getSetting( self, setting_id ):
return self.addon.getSetting( setting_id )
def setSetting( self, setting_id, value ):
return self.addon.setSetting( setting_id, value )
def doAction( self, action ):
self.debug( 'Triggered action {}', action )
xbmc.executebuiltin( 'Action({})'.format( action ) )
class KodiService( KodiAddon ):
def __init__( self ):
KodiAddon.__init__( self )
class KodiPlugin( KodiAddon ):
def __init__( self ):
KodiAddon.__init__( self )
self.base_url = sys.argv[0]
self.addon_handle = int( sys.argv[1] )
def build_url( self, query ):
return self.base_url + '?' + urllib.urlencode( query )
def runPlugin( self, params ):
xbmc.executebuiltin( 'RunPlugin({})'.format( self.build_url( params ) ) )
def addActionItem( self, name, params ):
self.addDirectoryItem( name, params, False )
def addFolderItem( self, name, params ):
self.addDirectoryItem( name, params, True )
def addDirectoryItem( self, name, params, isFolder ):
if isinstance( name, int ):
name = self.language( name )
li = xbmcgui.ListItem( name )
xbmcplugin.addDirectoryItem(
handle = self.addon_handle,
url = self.build_url( params ),
listitem = li,
isFolder = isFolder
)
def endOfDirectory( self, succeeded = True, updateListing = False, cacheToDisc = True ):
xbmcplugin.endOfDirectory( self.addon_handle, succeeded, updateListing, cacheToDisc )
class KodiInterlockedMonitor( xbmc.Monitor ):
def __init__( self, service, setting_id ):
super( KodiInterlockedMonitor, self ).__init__()
self.instance_id = ''.join( format( x, '02x' ) for x in bytearray( os.urandom( 16 ) ) )
self.setting_id = setting_id
self.service = service
def RegisterInstance( self, waittime = 1 ):
if self.BadInstance():
self.service.info( 'Found other instance with id {}', self.instance_id )
self.service.info( 'Startup delayed by {} second(s) waiting the other instance to shut down', waittime )
self.service.setSetting( self.setting_id, self.instance_id )
xbmc.Monitor.waitForAbort( self, waittime )
else:
self.service.setSetting( self.setting_id, self.instance_id )
def UnregisterInstance( self ):
self.service.setSetting( self.setting_id, '' )
def BadInstance( self ):
instance_id = self.service.getSetting( self.setting_id )
return len( instance_id ) > 0 and self.instance_id != instance_id
def abortRequested( self ):
return self.BadInstance() or xbmc.Monitor.abortRequested( self )
def waitForAbort( self, timeout = None ):
if timeout is None:
# infinite wait
while not self.abortRequested():
if xbmc.Monitor.waitForAbort( self, 1 ):
return True
return True
else:
for _ in range( timeout ):
if self.BadInstance() or xbmc.Monitor.waitForAbort( self, 1 ):
return True
return self.BadInstance()
|
