Initial version_checker refactor

medusa/__main__.py

@@ -67,7 +67,7 @@
 from medusa import (
     app, auto_post_processor, cache, db, event_queue, exception_handler,
     helpers, logger as app_logger, metadata, name_cache, naming, network_timezones, providers,
-    scheduler, show_queue, show_updater, subtitles, torrent_checker, trakt_checker, version_checker
+    scheduler, show_queue, show_updater, subtitles, torrent_checker, trakt_checker
 )
 from medusa.common import SD, SKIPPED, WANTED
 from medusa.config import (
@@ -90,6 +90,7 @@
 from medusa.system.shutdown import Shutdown
 from medusa.themes import read_themes
 from medusa.tv import Series
+from medusa.updater.version_checker import CheckVersion
 
 
 logger = logging.getLogger(__name__)
@@ -987,9 +988,9 @@ def initialize(self, console_logging=True):
                 pass
 
             if app.VERSION_NOTIFY:
-                updater = version_checker.CheckVersion().updater
+                updater = CheckVersion().updater
                 if updater:
-                    app.APP_VERSION = updater.get_cur_version()
+                    app.APP_VERSION = updater.current_version
 
             app.MAJOR_DB_VERSION, app.MINOR_DB_VERSION = db.DBConnection().checkDBVersion()
 
@@ -1128,7 +1129,7 @@ def initialize(self, console_logging=True):
 
             # initialize schedulers
             # updaters
-            app.version_check_scheduler = scheduler.Scheduler(version_checker.CheckVersion(),
+            app.version_check_scheduler = scheduler.Scheduler(CheckVersion(),
                                                               cycleTime=datetime.timedelta(hours=app.UPDATE_FREQUENCY),
                                                               threadName='CHECKVERSION', silent=False)
 

medusa/config.py

@@ -32,7 +32,7 @@
 from medusa.helper.common import try_int
 from medusa.helpers.utils import split_and_strip
 from medusa.logger.adapters.style import BraceAdapter
-from medusa.version_checker import CheckVersion
+from medusa.updater.version_checker import CheckVersion
 
 from requests.compat import urlsplit
 

medusa/github_client.py

@@ -102,3 +102,21 @@ def get_github_repo(organization, repo, gh=None):
     except github.GithubException as e:
         logger.debug('Unable to contact Github: {ex!r}', ex=e)
         raise
+
+
+def get_latest_release(organization, repo, gh=None):
+    """Return the latest release of a repository.
+
+    :param repo:
+    :type repo: string
+    :param gh:
+    :type gh: Github
+    :return:
+    :rtype github.GitRelease.GitRelease
+    """
+    try:
+        gh = gh or github.MainClass.Github(**OPTIONS)
+        return gh.get_organization(organization).get_repo(repo).get_latest_release()
+    except github.GithubException as e:
+        logger.debug('Unable to contact Github: {ex!r}', ex=e)
+        raise

medusa/server/api/v1/core.py

@@ -59,7 +59,7 @@
 from medusa.show.show import Show
 from medusa.system.restart import Restart
 from medusa.system.shutdown import Shutdown
-from medusa.version_checker import CheckVersion
+from medusa.updater.version_checker import CheckVersion
 
 from requests.compat import unquote_plus
 
@@ -1421,7 +1421,7 @@ def run(self):
                 'commit': check_version.updater.get_newest_commit_hash(),
                 'version': check_version.updater.get_newest_version(),
             },
-            'commits_offset': check_version.updater.get_num_commits_behind(),
+            'commits_offset': check_version.updater.commits_behind,
             'needs_update': needs_update,
         }
 

medusa/server/web/core/error_logs.py

@@ -13,7 +13,7 @@
 from medusa.issue_submitter import IssueSubmitter
 from medusa.logger import filter_logline, read_loglines
 from medusa.server.web.core.base import PageTemplate, WebRoot
-from medusa.version_checker import CheckVersion
+from medusa.updater.version_checker import CheckVersion
 
 from six import text_type
 

medusa/server/web/home/handler.py

@@ -105,7 +105,7 @@
 from medusa.system.restart import Restart
 from medusa.system.shutdown import Shutdown
 from medusa.tv.series import Series, SeriesIdentifier
-from medusa.version_checker import CheckVersion
+from medusa.updater.version_checker import CheckVersion
 
 from requests.compat import (
     quote_plus,

medusa/updater/__init__.py

@@ -0,0 +1 @@
+# coding=utf-8

medusa/updater/docker_updater.py

@@ -0,0 +1,54 @@
+# coding=utf-8
+
+from __future__ import unicode_literals
+
+import logging
+
+from medusa import app
+from medusa.logger.adapters.style import BraceAdapter
+from medusa.updater.source_updater import SourceUpdateManager
+
+
+log = BraceAdapter(logging.getLogger(__name__))
+log.logger.addHandler(logging.NullHandler())
+
+
+class DockerUpdateManager(SourceUpdateManager):
+    def __init__(self):
+        super(DockerUpdateManager, self).__init__()
+
+    def __str__(self):
+        return 'Docker Updater'
+
+    def need_update(self):
+        if self.branch != self._find_installed_branch():
+            log.debug(u'Branch checkout: {0}->{1}', self._find_installed_branch(), self.branch)
+            return True
+
+        if self.branch == 'master' and not self.is_latest_version():
+            self._set_update_text()
+            return True
+
+        return False
+
+    def can_update(self):
+        """Whether or not the update can be performed.
+
+        :return:
+        :rtype: bool
+        """
+        return False
+
+    def _set_update_text(self):
+        """Set an update text, when running in a Docker container."""
+        log.debug('There is an update available, Medusa is running in a Docker container,'
+                  ' so auto updating is disabled.')
+
+        url = 'http://github.com/' + self.github_org + '/' + self.github_repo + '/releases'
+        newest_text = 'There is a <a href="' + url + '" onclick="window.open(this.href); return false;">newer version available</a>'
+        newest_text += ' (' + self.newest_version + ') &mdash; Pull the latest Docker image and rebuild your container to update'
+        app.NEWEST_VERSION_STRING = newest_text
+
+    def update(self):
+        """Download the latest version."""
+        return False