From fb66baae9a620bad979700db9dadbec2fd09dc2c Mon Sep 17 00:00:00 2001
From: Fabio Erculiani <lxnay@sabayon.org>
Date: Sun, 16 Oct 2011 13:17:21 +0200
Subject: [PATCH] [activator] goodbye, RIP

---
 server/activator.py        | 187 -----------
 server/server_activator.py | 631 -------------------------------------
 2 files changed, 818 deletions(-)
 delete mode 100644 server/activator.py
 delete mode 100644 server/server_activator.py

diff --git a/server/activator.py b/server/activator.py
deleted file mode 100644
index fddb83080..000000000
--- a/server/activator.py
+++ /dev/null
@@ -1,187 +0,0 @@
-#!/usr/bin/python2 -O
-# -*- coding: utf-8 -*-
-"""
-
-    @author: Fabio Erculiani <lxnay@sabayon.org>
-    @contact: lxnay@sabayon.org
-    @copyright: Fabio Erculiani
-    @license: GPL-2
-
-    B{Entropy Package Manager Server}.
-
-"""
-
-import os, sys
-sys.path.insert(0, '../libraries')
-sys.path.insert(1, '../client')
-sys.path.insert(2, '../server')
-sys.path.insert(3, '/usr/lib/entropy/client')
-sys.path.insert(4, '/usr/lib/entropy/libraries')
-sys.path.insert(5, '/usr/lib/entropy/server')
-from entropy.i18n import _
-import entropy.tools
-from entropy.output import red, is_stdout_a_tty, nocolor, print_generic, \
-    etpUi, print_error, darkgreen
-from entropy.const import etpConst, const_kill_threads
-from entropy.server.interfaces import Server
-from text_tools import print_menu
-
-def get_entropy_server():
-    return Server(community_repo = etpConst['community']['mode'])
-
-help_opts = [
-    None,
-    (0, " ~ activator ~ ", 1,
-        'Entropy Package Manager - (C) %s' % (entropy.tools.get_year(),) ),
-    None,
-    (0, _('Basic Options'), 0, None),
-    None,
-    (1, '--help', 2, _('this output')),
-    (1, '--version', 1, _('print version')),
-    (1, '--nocolor', 1, _('disable colorized output')),
-    (1, '--color', 2, _('force colorized output')),
-    None,
-    (0, _('Application Options'), 0, None),
-    None,
-    (1, 'sync', 3, _('sync packages, database and also do some tidy')),
-        (2, '--branch=<branch>', 1, _('choose on what branch operating')),
-        (2, '--noask', 3, _('do not ask anything except critical things')),
-        (2, '--syncall', 2, _('sync all the configured repositories')),
-    (1, 'syncas <repository>', 1, _('same as sync, but put repository database ONLY into a dummy repository')),
-    None,
-    (1, 'tidy', 3, _('remove binary packages not in repositories and expired')),
-    None,
-    (1, 'packages', 2, _('package repositories handling functions')),
-        (2, 'sync', 3, _('sync package repositories across primary mirrors')),
-            (3, '--ask', 3, _('ask before making any changes')),
-            (3, '--pretend', 2, _('only show what would be done')),
-            (3, '--syncall', 2, _('sync all the configured repositories')),
-            (3, '--do-packages-check', 1, _('also verify packages integrity')),
-    None,
-    (1, 'repo', 3, _('repository handling functions')),
-        (2, 'sync', 3, _('sync the current repository database across primary mirrors')),
-            (3, '--syncall', 1, _('sync all the configured repositories')),
-        (2, 'syncas <repository>', 1, _('same as sync, but put repository database ONLY into a dummy repository')),
-        (2, 'vacuum', 3, _('clean unavailable packages from mirrors (similar to tidy, but more nazi)')),
-            (3, '--days=<days>', 1, _('expiration days [default is: 0, dangerous!]')),
-        (2, 'lock', 3, _('lock the current repository database (server-side)')),
-        (2, 'unlock', 3, _('unlock the current repository database (server-side)')),
-        (2, 'download-lock', 2, _('lock the current repository database (client-side)')),
-        (2, 'download-unlock', 2, _('unlock the current repository database (client-side)')),
-        (2, 'lock-status', 2, _('show current lock status')),
-
-    None,
-    (1, 'notice', 3, _('notice board handling functions')),
-        (2, 'add', 2, _('add a news item to the notice board')),
-        (2, 'remove', 2, _('remove a news item from the notice board')),
-        (2, 'read', 2, _('read the current notice board')),
-    None,
-]
-
-options = sys.argv[1:]
-
-def handle_exception(exc_class, exc_instance, exc_tb):
-
-    # restore original exception handler, to avoid loops
-    uninstall_exception_handler()
-    entropy.tools.kill_threads()
-
-    if exc_class is KeyboardInterrupt:
-        raise SystemExit(1)
-
-    # always slap exception data (including stack content)
-    entropy.tools.print_exception(tb_data = exc_tb)
-
-    raise exc_instance
-
-def install_exception_handler():
-    sys.excepthook = handle_exception
-
-def uninstall_exception_handler():
-    sys.excepthook = sys.__excepthook__
-
-# print version
-if ("--version" in options) or ("-V" in options):
-    print_generic("activator: "+etpConst['entropyversion'])
-    raise SystemExit(0)
-
-import re
-opt_r = re.compile("^(\\-)([a-z]+)$")
-for n in range(len(options)):
-    if opt_r.match(options[n]):
-        x = options[n]
-        del options[n]
-        options.extend(["-%s" % (d,) for d in x[1:]])
-
-# preliminary options parsing
-_options = []
-force_color = False
-for opt in options:
-    if opt in ["--nocolor", "-N"]:
-        nocolor()
-    elif opt in ["--color", "-C"]:
-        force_color = True
-    elif opt in ["--quiet", "-q"]:
-        etpUi['quiet'] = True
-    elif opt in ["--verbose", "-v"]:
-        etpUi['verbose'] = True
-    elif opt in ["--ask", "-a"]:
-        etpUi['ask'] = True
-    elif opt in ["--pretend", "-p"]:
-        etpUi['pretend'] = True
-    else:
-        _options.append(opt)
-options = _options
-
-# Check if we need to disable colors
-if (not force_color) and (not is_stdout_a_tty()):
-    nocolor()
-
-# print help
-if not options or ("--help" in options) or ("-h" in options):
-    print_menu(help_opts)
-    if len(options) < 1:
-        print_error("not enough parameters")
-    raise SystemExit(1)
-
-rc = -10
-if not entropy.tools.is_root():
-    print_error("you must be root in order to run activator")
-    rc = 2
-
-main_cmd = options.pop(0)
-install_exception_handler()
-
-if main_cmd == "sync":
-    import server_activator
-    rc = server_activator.sync(options)
-
-if main_cmd == "syncas":
-    import server_activator
-    rc = server_activator.syncas(options)
-
-elif main_cmd == "tidy":
-    import server_activator
-    rc = server_activator.sync(options, just_tidy = True)
-
-elif main_cmd == "repo":
-    import server_activator
-    rc = server_activator.repo(options)
-
-elif main_cmd == "packages":
-    import server_activator
-    rc = server_activator.packages(options)
-
-# database tool
-elif main_cmd == "notice":
-    import server_activator
-    rc = server_activator.notice(options)
-
-if rc == -10:
-    print_menu(help_opts)
-    print_error(red(" %s." % (_("Wrong parameters"),) ))
-    rc = 10
-
-uninstall_exception_handler()
-const_kill_threads()
-raise SystemExit(rc)
diff --git a/server/server_activator.py b/server/server_activator.py
deleted file mode 100644
index 7645cdd39..000000000
--- a/server/server_activator.py
+++ /dev/null
@@ -1,631 +0,0 @@
-# -*- coding: utf-8 -*-
-"""
-
-    @author: Fabio Erculiani <lxnay@sabayon.org>
-    @contact: lxnay@sabayon.org
-    @copyright: Fabio Erculiani
-    @license: GPL-2
-
-    B{Entropy Package Manager Server}.
-
-"""
-import os
-import tempfile
-import subprocess
-from entropy.const import etpConst, etpUi
-from entropy.output import red, green, print_info, bold, darkgreen, blue, \
-    darkred, brown, purple, teal, print_error, print_warning, readtext, \
-        print_generic
-from entropy.server.interfaces import Server, ServerSystemSettingsPlugin
-from entropy.server.interfaces.rss import ServerRssMetadata
-from entropy.transceivers import EntropyTransceiver
-from entropy.i18n import _
-
-import entropy.tools
-
-def get_entropy_server():
-    """
-    Return Entropy Server interface object.
-    """
-    return Server(community_repo = etpConst['community']['mode'])
-
-DEFAULT_REPO_COMMIT_MSG = """
-# This is Entropy Server repository commit message handler.
-# Please friggin' enter the commit message for your changes. Lines starting
-# with '#' will be ignored. To avoid encoding issue, write stuff in plain ASCII.
-"""
-
-def sync(options, just_tidy = False):
-    acquired = False
-    server = None
-    try:
-        server = get_entropy_server()
-        acquired = entropy.tools.acquire_entropy_locks(server)
-        if not acquired:
-            print_error(darkgreen(_("Another Entropy is currently running.")))
-            return 1
-        return _sync(server, options, just_tidy, None)
-    finally:
-        if server is not None:
-            if acquired:
-                entropy.tools.release_entropy_locks(server)
-            server.shutdown()
-
-def syncas(options, just_tidy = False):
-    if not options:
-        return -10
-    # syncas, validate args
-    as_repository_id = options[0]
-    if not entropy.tools.validate_repository_id(as_repository_id):
-        return -10
-
-    acquired = False
-    server = None
-    try:
-        server = get_entropy_server()
-        acquired = entropy.tools.acquire_entropy_locks(server)
-        if not acquired:
-            print_error(darkgreen(_("Another Entropy is currently running.")))
-            return 1
-        return _sync(server, [], just_tidy, as_repository_id)
-    finally:
-        if server is not None:
-            if acquired:
-                entropy.tools.release_entropy_locks(server)
-            server.shutdown()
-
-def _sync(entropy_server, options, just_tidy, as_repository_id):
-
-    do_noask = False
-    sync_all = False
-    myopts = []
-    for opt in options:
-        if opt == "--noask":
-            do_noask = True
-        elif opt == "--syncall":
-            sync_all = True
-        elif opt.startswith("--"):
-            return -10
-        else:
-            myopts.append(opt)
-    options = myopts
-
-    print_info(green(" * ")+red("%s ..." % (
-        _("Starting to sync data across mirrors (packages/database)"),) ))
-
-    repository_id = entropy_server.repository()
-    sys_settings_plugin_id = \
-        etpConst['system_settings_plugins_ids']['server_plugin']
-    srv_data = entropy_server.Settings()[sys_settings_plugin_id]['server']
-    rss_enabled = srv_data['rss']['enabled']
-    repos = [repository_id]
-    if sync_all:
-        repos = entropy_server.repositories()
-
-    rc = 0
-    for repo in repos:
-
-        # avoid __default__
-        if repo == etpConst['clientserverrepoid']:
-            continue
-
-        errors = False
-        if not just_tidy:
-
-            mirrors_tainted, mirrors_errors, successfull_mirrors, \
-                broken_mirrors, check_data = \
-                    entropy_server.Mirrors.sync_packages(
-                        repo, ask = not do_noask, pretend = etpUi['pretend'])
-
-            if mirrors_errors and not successfull_mirrors:
-                errors = True
-                print_error(darkred(" !!! ")+red(_("Aborting !")))
-                continue
-
-            if not successfull_mirrors:
-                continue
-
-            if mirrors_tainted and (as_repository_id is None):
-
-                if (not do_noask) and rss_enabled:
-                    tmp_fd, tmp_commit_path = tempfile.mkstemp(
-                        prefix="activator._sync", suffix=".COMMIT_MSG")
-                    with os.fdopen(tmp_fd, "w") as tmp_f:
-                        tmp_f.write(DEFAULT_REPO_COMMIT_MSG)
-                        if successfull_mirrors:
-                            tmp_f.write("# Changes to be committed:\n")
-                        for sf_mirror in sorted(successfull_mirrors):
-                            tmp_f.write("#\t updated:   %s\n" % (sf_mirror,))
-
-                    # spawn editor
-                    cm_msg_rc = entropy_server.edit_file(tmp_commit_path)
-                    if not cm_msg_rc:
-                        # wtf?, fallback to old way
-                        ServerRssMetadata()['commitmessage'] = \
-                            readtext(">> %s: " % (
-                                _("Please insert a commit message"),) )
-                    else:
-                        commit_msg = ''
-                        with open(tmp_commit_path, "r") as tmp_f:
-                            for line in tmp_f.readlines():
-                                if line.strip().startswith("#"):
-                                    continue
-                                commit_msg += line
-                        print_generic(commit_msg)
-                        ServerRssMetadata()['commitmessage'] = commit_msg
-
-                    os.remove(tmp_commit_path)
-
-                elif rss_enabled:
-                    ServerRssMetadata()['commitmessage'] = "Automatic update"
-
-            if as_repository_id is not None:
-                # change repository push location
-                ServerSystemSettingsPlugin.set_override_remote_repository(
-                    entropy_server.Settings(), repo, as_repository_id)
-
-            sts = _sync_remote_databases(entropy_server, repo)
-            if sts == 0:
-                # do not touch locking
-                entropy_server.Mirrors.lock_mirrors(repo, False,
-                    unlock_locally = (as_repository_id is None))
-            if (sts == 0) and not do_noask:
-                q_rc = entropy_server.ask_question(
-                    _("Should I continue with the tidy procedure ?"))
-                if q_rc == _("No"):
-                    continue
-            elif sts != 0:
-                errors = True
-                print_error(darkred(" !!! ")+red(_("Aborting !")))
-                continue
-
-        if not errors:
-            entropy_server.Mirrors.tidy_mirrors(repo, ask = not do_noask,
-                pretend = etpUi['pretend'])
-        else:
-            rc = 1
-
-    return rc
-
-def packages(options):
-    acquired = False
-    server = None
-    try:
-        server = get_entropy_server()
-        acquired = entropy.tools.acquire_entropy_locks(server)
-        if not acquired:
-            print_error(darkgreen(_("Another Entropy is currently running.")))
-            return 1
-        return _packages(server, options)
-    finally:
-        if server is not None:
-            if acquired:
-                entropy.tools.release_entropy_locks(server)
-            server.shutdown()
-
-def _packages(entropy_server, options):
-
-    sync_all = False
-    do_pkg_check = False
-    for opt in options:
-        if opt == "--do-packages-check":
-            do_pkg_check = True
-        elif opt == "--syncall":
-            sync_all = True
-        elif opt.startswith("--"):
-            return -10
-
-    if not options:
-        return -10
-
-    repository_id = entropy_server.repository()
-
-    if options[0] == "sync":
-
-        repos = [repository_id]
-        if sync_all:
-            repos = entropy_server.repositories()
-
-        rc = 0
-        for repo in repos:
-
-            # avoid __default__
-            if repo == etpConst['clientserverrepoid']:
-                continue
-
-            mirrors_tainted, mirrors_errors, successfull_mirrors, \
-            broken_mirrors, check_data = entropy_server.Mirrors.sync_packages(
-                repo, ask = etpUi['ask'],
-                pretend = etpUi['pretend'],
-                packages_check = do_pkg_check)
-
-            if mirrors_errors:
-                rc = 1
-
-        return rc
-
-    return -10
-
-def notice(options):
-    acquired = False
-    server = None
-    try:
-        server = get_entropy_server()
-        acquired = entropy.tools.acquire_entropy_locks(server)
-        if not acquired:
-            print_error(darkgreen(_("Another Entropy is currently running.")))
-            return 1
-        return _notice(server, options)
-    finally:
-        if server is not None:
-            if acquired:
-                entropy.tools.release_entropy_locks(server)
-            server.shutdown()
-
-def _notice(entropy_server, options):
-
-    if not options:
-        return -10
-
-    def show_notice(key, mydict):
-
-        mytxt = "[%s] [%s] %s: %s" % (
-            blue(str(key)),
-            brown(mydict['pubDate']),
-            _("Title"),
-            darkred(mydict['title']),
-        )
-        print_info(mytxt)
-
-        mytxt = "\t%s: %s" % (
-            darkgreen(_("Content")),
-            blue(mydict['description']),
-        )
-        print_info(mytxt)
-        mytxt = "\t%s: %s" % (
-            darkgreen(_("Link")),
-            blue(mydict['link']),
-        )
-        print_info(mytxt)
-
-        def fake_callback(s):
-            return True
-
-        input_params = [('idx', _('Press Enter to continue'), fake_callback, False)]
-        data = entropy_server.input_box('', input_params, cancel_button = True)
-
-
-    def show_notice_selector(title, mydict):
-        print_info('')
-        mykeys = sorted(mydict.keys())
-
-        for key in mykeys:
-            mydata = mydict.get(key)
-            mytxt = "[%s] [%s] %s: %s" % (
-                blue(str(key)),
-                brown(mydata['pubDate']),
-                _("Title"),
-                darkred(mydata['title']),
-            )
-            print_info(mytxt)
-
-        print_info('')
-        mytxt = "[%s] %s" % (
-            blue("-1"),
-            darkred(_("Exit/Commit")),
-        )
-        print_info(mytxt)
-
-        def fake_callback(s):
-            return s
-        input_params = [('id', blue(_('Choose one by typing its identifier')),
-            fake_callback, False)]
-        data = entropy_server.input_box(title, input_params,
-            cancel_button = True)
-        if not isinstance(data, dict):
-            return -1
-        try:
-            return int(data['id'])
-        except ValueError:
-            return -2
-
-    repository_id = entropy_server.repository()
-
-    if options[0] == "add":
-
-        def fake_callback(s):
-            return s
-
-        def fake_callback_tr(s):
-            return True
-
-        input_params = [
-            ('title', _('Title'), fake_callback, False),
-            ('text', _('Notice text'), fake_callback, False),
-            ('url', _('Relevant URL (optional)'), fake_callback_tr, False),
-        ]
-
-        data = entropy_server.input_box(blue("%s") % (
-            _("Repository notice board, new item insertion"),),
-                input_params, cancel_button = True)
-        if data is None:
-            return 0
-        status = entropy_server.Mirrors.update_notice_board(
-            repository_id, data['title'], data['text'],
-            link = data['url'])
-        if status:
-            return 0
-        return 1
-
-    elif options[0] == "read":
-
-        data = entropy_server.Mirrors.read_notice_board(repository_id)
-        if data is None:
-            print_error(darkred(" * ")+blue("%s" % (
-                _("Notice board not available"),) ))
-            return 1
-        items, counter = data
-        while True:
-            try:
-                sel = show_notice_selector('', items)
-            except KeyboardInterrupt:
-                return 0
-            if (sel >= 0) and (sel <= counter):
-                show_notice(sel, items.get(sel))
-            elif sel == -1:
-                return 0
-
-        return 0
-
-    elif options[0] == "remove":
-
-        data = entropy_server.Mirrors.read_notice_board(repository_id)
-        if data is None:
-            print_error(darkred(" * ")+blue("%s" % (
-                _("Notice board not available"),) ))
-            return 1
-        items, counter = data
-        changed = False
-        while True:
-            try:
-                sel = show_notice_selector(
-                    darkgreen(_("Choose the one you want to remove")), items)
-            except KeyboardInterrupt:
-                break
-            if (sel >= 0) and (sel <= counter):
-                show_notice(sel, items.get(sel))
-                q_rc = entropy_server.ask_question(
-                    _("Are you sure you want to remove this?"))
-                if q_rc == _("Yes"):
-                    changed = True
-                    entropy_server.Mirrors.remove_from_notice_board(
-                        repository_id, sel)
-                    data = entropy_server.Mirrors.read_notice_board(
-                        repository_id, do_download = False)
-                    items, counter = data
-            elif sel == -1:
-                break
-
-        if changed or (counter == 0):
-            if counter == 0:
-                status = entropy_server.Mirrors.remove_notice_board(
-                    repository_id)
-            else:
-                status = entropy_server.Mirrors.upload_notice_board(
-                    repository_id)
-            if not status:
-                return 1
-        return 0
-
-    return -10
-
-def repo(options):
-    acquired = False
-    server = None
-    try:
-        server = get_entropy_server()
-        acquired = entropy.tools.acquire_entropy_locks(server)
-        if not acquired:
-            print_error(darkgreen(_("Another Entropy is currently running.")))
-            return 1
-        return _repo(server, options)
-    finally:
-        if server is not None:
-            if acquired:
-                entropy.tools.release_entropy_locks(server)
-            server.shutdown()
-
-def _repo(entropy_server, options):
-
-    if not options:
-        return -10
-
-    cmd, args = options[0], options[1:]
-
-    repository_id = entropy_server.repository()
-
-    if cmd == "lock":
-
-        print_info(green(" * ")+green("%s ..." % (
-            _("Starting to lock mirrors databases"),) ))
-        done = entropy_server.Mirrors.lock_mirrors(repository_id, True)
-        rc = 0
-        if not done:
-            rc = 1
-            print_info(green(" * ")+red("%s !" % (
-                _("A problem occured on at least one mirror"),) ))
-        else:
-            print_info(green(" * ")+green(_("Repositories lock complete")))
-        return rc
-
-    elif cmd == "unlock":
-
-        print_info(green(" * ")+green("%s ..." % (
-            _("Starting to unlock mirrors databases"),)))
-        done = entropy_server.Mirrors.lock_mirrors(repository_id, False)
-        rc = 0
-        if not done:
-            rc = 1
-            print_info(green(" * ")+green("%s !" % (
-                _("A problem occured on at least one mirror"),) ))
-        else:
-            print_info(green(" * ")+green(
-                _("Repositories unlock complete")))
-        return rc
-
-    elif cmd == "download-lock":
-
-        print_info(green(" * ")+green("%s ..." % (
-            _("Starting to lock download mirrors databases"),) ))
-        done = entropy_server.Mirrors.lock_mirrors_for_download(
-            repository_id, True)
-        rc = 0
-        if not done:
-            rc = 1
-            print_info(green(" * ")+green("%s !" % (
-                _("A problem occured on at least one mirror"),) ))
-        else:
-            print_info(green(" * ")+green(_("Download mirrors lock complete")))
-        return rc
-
-    elif cmd == "download-unlock":
-
-        print_info(green(" * ")+green("%s ..." % (
-            _("Starting to unlock download mirrors databases"),) ))
-        done = entropy_server.Mirrors.lock_mirrors_for_download(repository_id,
-            False)
-        rc = 0
-        if not done:
-            rc = 1
-            print_info(green(" * ")+green("%s ..." % (
-                _("A problem occured on at least one mirror"),) ))
-        else:
-            print_info(green(" * ")+green(_("Download mirrors unlock complete")))
-        return rc
-
-    elif cmd == "lock-status":
-
-        print_info(brown(" * ")+green("%s:" % (_("Mirrors status table"),) ))
-        dbstatus = entropy_server.Mirrors.mirrors_status(repository_id)
-        for db in dbstatus:
-            if (db[1]):
-                db[1] = red(_("Locked"))
-            else:
-                db[1] = green(_("Unlocked"))
-            if (db[2]):
-                db[2] = red(_("Locked"))
-            else:
-                db[2] = green(_("Unlocked"))
-            host = EntropyTransceiver.get_uri_name(db[0])
-            print_info(bold("\t"+host+": ") + red("[") + \
-                brown("%s: " % (_("DATABASE"),) ) + db[1] + red("] [") + \
-                brown("%s: " % (_("DOWNLOAD"),) ) + db[2] + red("]"))
-        return 0
-
-    elif cmd in ("sync", "syncas"):
-
-        repos = [repository_id]
-        as_repository_id = None
-        if cmd == "sync":
-            if "--syncall" in args:
-                repos = entropy_server.repositories()
-        elif not args:
-            # syncas without repo
-            return -10
-        elif len(args) > 1:
-            # syncas, too many args
-            return -10
-        else:
-            # syncas, validate args
-            as_repository_id = args[0]
-            if not entropy.tools.validate_repository_id(as_repository_id):
-                return -10
-
-            # change repository push location
-            ServerSystemSettingsPlugin.set_override_remote_repository(
-                entropy_server.Settings(), repository_id, as_repository_id)
-
-        rc = 0
-        for repo in repos:
-
-            # avoid __default__
-            if repo == etpConst['clientserverrepoid']:
-                continue
-
-            if as_repository_id is not None:
-                print_info("%s %s %s => %s" % (
-                    green(" *"), teal(_("Syncing repository")),
-                    purple(repo), bold(as_repository_id),))
-            else:
-                print_info("%s %s %s" % (
-                    green(" *"), teal(_("Syncing repository")),
-                    purple(repo),))
-            sts = _sync_remote_databases(entropy_server, repo)
-            if sts != 0:
-                print_error(darkred(" !!! ") + \
-                    green(_("Repositories sync error, cannot continue.")))
-                rc = 1
-
-        return rc
-
-    elif cmd == "vacuum":
-
-        days = 0
-        for arg in args:
-            if arg.startswith("--days="):
-                s_days = arg[len("--days="):]
-                try:
-                    days = int(s_days)
-                    if days < 0:
-                        raise ValueError()
-                except ValueError:
-                    return -10
-                break
-            else:
-                return -10
-
-        print_info(green(" * ")+darkgreen("%s ..." % (
-            _("Cleaning unavailable packages from repository"),) ))
-        print_warning(teal(" * ") + \
-            purple(_("Removing unavailable packages, overriding Entropy defaults is generally bad.")))
-        print_warning(teal(" * ") + \
-            purple(_("Users with outdated repositories, won't be able to find package files remotely.")))
-        sts = entropy_server.Mirrors.tidy_mirrors(repository_id, ask = True,
-            pretend = etpUi['pretend'], expiration_days = days)
-        if sts:
-            return 0
-        return 1
-
-    return -10
-
-def _sync_remote_databases(entropy_server, repository_id):
-
-    print_info(green(" * ")+red("%s:" % (
-        _("Remote Entropy Repository Status"),) ))
-    remote_db_status = entropy_server.Mirrors.remote_repository_status(
-        repository_id)
-    for url, revision in remote_db_status.items():
-        host = EntropyTransceiver.get_uri_name(url)
-        print_info(green("    %s: " % (_("Host"),) )+bold(host))
-        print_info(red("     * %s: " % (_("Revision"),) ) + \
-            blue(str(revision)))
-
-    local_revision = entropy_server.local_repository_revision(repository_id)
-    print_info(red("    * %s: " % (
-        _("Local revision currently at"),) ) + \
-            blue(str(local_revision)))
-
-    # do the rest
-    sts = entropy_server.Mirrors.sync_repository(repository_id)
-
-    print_info(darkgreen(" * ")+red("%s:" % (
-        _("Remote Entropy Repository Status"),) ))
-    remote_status = entropy_server.Mirrors.remote_repository_status(
-        repository_id)
-    for url, revision in remote_status.items():
-        host = EntropyTransceiver.get_uri_name(url)
-        print_info(darkgreen("    %s: " % (_("Host"),) )+bold(host))
-        print_info(red("      * %s: " % (_("Revision"),) ) + \
-            blue(str(revision)))
-
-    return sts