Finalize basic command manager's responsibilities

...pushing the generic processing to be implemented further to the
command itself.

Signed-off-by: Jan Pokorný <jpokorny@redhat.com>

2 files changed, 29 insertions, 1 deletions

diff --git a/command.py b/command.py
index 9742797..9c5e946 100644
--- a/command.py
+++ b/command.py
@@ -10,6 +10,7 @@ from optparse import make_option, SUPPRESS_HELP
 
 from .plugin_registry import PluginRegistry
 from .utils import ClufterError, \
+                   EC, \
                    func_defaults_varnames, \
                    head_tail, \
                    hybridproperty
@@ -98,6 +99,30 @@ class Command(object):
         """Chain of filter identifiers/classes for the command"""
         return this._filter_chain
 
+    def __call__(self, opts, args=None):
+        """Proceed the command"""
+        ec = EC.EXIT_SUCCESS
+        fnc_defaults, fnc_varnames = self._figure_func_defaults_varnames()
+        kwargs = {}
+        for v in fnc_varnames:
+            if hasattr(opts, v):
+                kwargs[v] = getattr(opts, v)
+        format_chain = self._fnc(**kwargs)
+        ##print format_chain
+        ##from .utils import apply_aggregation_preserving_passing_depth
+        ##print apply_aggregation_preserving_passing_depth(
+        ##    lambda x, d: ('\n' + d * ' ') + (' ').join(x)
+        ##)(format_chain)
+        # TODO
+        # - validate format_chain vs chain
+        #   1. "shapes" match
+        #   2. I/O formats path(s) through the graph exist(s)
+        #   3. some per-filter validations?
+        #   - could some initial steps be done earlier?
+        # - perform the chain
+        #   - [advanced] threading for parallel branches?
+        return ec
+
     @classmethod
     def deco(cls, *filter_chain):
         """Decorator as an easy factory of actual commands"""
diff --git a/command_manager.py b/command_manager.py
index dfd28f2..389c843 100644
--- a/command_manager.py
+++ b/command_manager.py
@@ -90,7 +90,10 @@ class CommandManager(PluginManager):
                 ))
                 print parser.format_customized_help(usage=usage)
                 return ec
-            print opts, args  # TODO
+            logging.getLogger().setLevel(opts.loglevel)
+            log.debug("Running command `{0}';  opts={1}, args={2}"
+                      .format(cmd, opts.__dict__, args))
+            ec = command(opts, args)
         except ClufterError as e:
             ec = EC.EXIT_FAILURE
             print e