diff --git a/mopidy_iris/pusher.py b/mopidy_iris/pusher.py index 0ba3cd8a..8adb767f 100755 --- a/mopidy_iris/pusher.py +++ b/mopidy_iris/pusher.py @@ -267,18 +267,15 @@ class PusherWebsocketHandler(tornado.websocket.WebSocketHandler): ) # get system version and check for upgrade - elif messageJson['action'] == 'perform_upgrade': + elif messageJson['action'] == 'upgrade': version = self.frontend.get_version() - version['upgrade_successful'] = self.frontend.perform_upgrade() + upgrade_successful = self.frontend.perform_upgrade() send_message( self.connectionid, 'response', messageJson['request_id'], - { 'version': version } + { 'upgrade_successful': upgrade_successful, 'version': version } ) - - # notify all clients of this change - broadcast( 'upgraded', { 'version': version }) # restart mopidy elif messageJson['action'] == 'restart': diff --git a/src/js/services/pusher/middleware.js b/src/js/services/pusher/middleware.js index 3c9df1fd..588f2372 100755 --- a/src/js/services/pusher/middleware.js +++ b/src/js/services/pusher/middleware.js @@ -22,6 +22,8 @@ const PusherMiddleware = (function(){ // handle all manner of socket messages const handleMessage = (ws, store, message) => { + //console.log('handleMessage', message) + switch (message.action){ case 'response': if (typeof( deferredRequests[ message.request_id ]) !== 'undefined' ){ @@ -127,13 +129,13 @@ const PusherMiddleware = (function(){ break; case 'START_UPGRADE': - request({ action: 'perform_upgrade' }) + request({ action: 'upgrade' }) .then( response => { - if (response.data.version.upgrade_successful){ - uiActions.createNotification('Upgrade complete') + if (response.data.upgrade_successful){ + store.dispatch( uiActions.createNotification('Upgrade complete') ) }else{ - uiActions.createNotification('Upgrade failed, manual upgrade required') + store.dispatch( uiActions.createNotification('Upgrade failed, please upgrade manually','bad') ) } store.dispatch({ type: 'VERSION', data: response.data }) } @@ -180,7 +182,7 @@ const PusherMiddleware = (function(){ }) .then( response => { - uiActions.createNotification('Authorization sent') + store.dispatch( uiActions.createNotification('Authorization sent') ) } ) break;