stakkr.services

Complexity

Total Complexity

10

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

3 Functions

Rating	Name	Duplication	Size	Complexity
B	install()	0	23	5
A	update_package()	0	9	3
A	update_all()	0	6	2

# coding: utf-8
"""
Manage Stakkr Packages (extra packages)
"""

__github_url__ = 'https://github.com/stakkr-org'


def install(services_dir: str, package: str):
    from os.path import isdir
    from urllib.parse import urlparse

    url = '{}/services-{}.git'.format(__github_url__, package)
    if urlparse(package).scheme != '':
        url = package

    path = '{}/{}'.format(services_dir, package)
    if isdir(path):
        msg = 'Package "{}" is already installed, updating'.format(package)
        update_package(path)
        return True, msg

    try:
        from git import Repo, exc
        Repo.clone_from(url, path)

        return True, None
    except ImportError as error:
        return False, 'Make sure git is installed'
    except exc.GitCommandError as error:
        return False, "Couldn't clone {} ({})".format(url, error)


def update_all(services_dir: str):
    from os import listdir

    for folder in listdir(services_dir):
        path = services_dir + '/' + folder
        update_package(path)


def update_package(path: str):
    from git import Repo, exc

    try:
        repo = Repo(path)
        if repo.remotes.origin.url.startswith(__github_url__):
            repo.remotes.origin.pull()
    except exc.InvalidGitRepositoryError:
        pass