forked from vially/googlemusic-xbmc
-
Notifications
You must be signed in to change notification settings - Fork 1
/
GoogleMusicPlaySong.py
119 lines (93 loc) · 4.85 KB
/
GoogleMusicPlaySong.py
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
115
116
117
118
119
import GoogleMusicApi, utils, xbmc
from GoogleMusicStorage import storage
class GoogleMusicPlaySong():
def __init__(self):
self.api = GoogleMusicApi.GoogleMusicApi()
def play(self, params):
song_id = params.pop('song_id')
if song_id[0] == 't': song_id = song_id.capitalize()
params = self.__getSongStreamUrl(song_id, params)
url = params.pop('url')
title = params.get('title')
utils.log("Song: %s - %r " % (title, url))
li = utils.createItem(title, params.pop('albumart'), params.pop('artistart'))
li.setInfo(type='music', infoLabels=params)
li.setPath(url)
utils.setResolvedUrl(li)
self.__incrementSongPlayCount(song_id)
if utils.addon.getSetting( "prefetch" ) == "true":
try:
self.__prefetchUrl()
except Exception as ex:
utils.log("ERROR trying to fetch url: "+repr(ex))
#raise
def __incrementSongPlayCount(self, song_id):
xbmc.sleep(5000)
self.api.incrementSongPlayCount(song_id)
def __getSongStreamUrl(self, song_id, params):
# try to fetch from library first
song = storage.getSong(song_id)
params['url'] = song['url'] if song else ''
# if no metadata
if not 'title' in params:
if not song:
# fecth from web
song = self.api.getTrack(song_id)
params['title'] = song['title']
params['artist'] = song['artist']
params['albumart'] = song['albumart']
params['artistart'] = song['artistart']
params['tracknumber'] = song['tracknumber']
params['album'] = song['album']
params['year'] = song['year']
params['rating'] = song['rating']
# if url in library check if local library or if not expired before returning
if params['url'] and not song_id[0:4] == 'kodi':
import time
utils.log("TIME:"+str(time.time()))
if int(utils.paramsToDict(params['url']).get('expire',0)) < time.time():
params['url'] = ''
if not params['url']:
# try to fetch from web
params['url'] = self.api.getSongStreamUrl(song_id, session_token=params.pop('sessiontoken',None), wentry_id=params.pop('wentryid',None))
return params
def __prefetchUrl(self):
import gmusicapi.compat as compat
loadJson = compat.json.loads
jsonGetPlaylistPos = '{"jsonrpc":"2.0", "method":"Player.GetProperties", "params":{"playerid":0,"properties":["playlistid","position","percentage"]},"id":1}'
jsonGetPlaylistItems = '{"jsonrpc":"2.0", "method":"Playlist.GetItems", "params":{"playlistid":0,"properties":["file","duration"]}, "id":1}'
# get song position in playlist
playerProperties = loadJson(xbmc.executeJSONRPC(jsonGetPlaylistPos))
while not 'result' in playerProperties or playerProperties['result']['percentage'] > 5:
#wait for song playing and playlist ready
xbmc.sleep(1000)
playerProperties = loadJson(xbmc.executeJSONRPC(jsonGetPlaylistPos))
position = playerProperties['result']['position']
utils.log("position:"+str(position)+" percentage:"+str(playerProperties['result']['percentage']))
# get next song id and fetch url
playlistItems = loadJson(xbmc.executeJSONRPC(jsonGetPlaylistItems))
#utils.log("playlistItems:: "+repr(playlistItems))
if not 'items' in playlistItems['result']:
utils.log("empty playlist")
return
if position+1 >= len(playlistItems['result']['items']):
utils.log("playlist end:: position "+repr(position)+" size "+repr(len(playlistItems['result']['items'])))
return
song_id_next = utils.paramsToDict(playlistItems['result']['items'][position+1]['file']).get("song_id")
#if local file skip prefetch
if song_id_next[0:4] == 'kodi':
return
stream_url = self.api.getSongStreamUrl(song_id_next)
storage.updateSongStreamUrl(song_id_next, stream_url)
# stream url expires in 1 minute, refetch to always have a valid one
while True:
xbmc.sleep(50000)
# test if music changed
playerProperties = loadJson(xbmc.executeJSONRPC(jsonGetPlaylistPos))
utils.log("playerProperties:: "+repr(playerProperties))
if not 'result' in playerProperties or position != playerProperties['result']['position']:
utils.log("ending:: position "+repr(position)+" "+repr(playerProperties))
break
# before the stream url expires we fetch it again
stream_url = self.api.getSongStreamUrl(song_id_next)
storage.updateSongStreamUrl(song_id_next, stream_url)