Redis: fix get_obj_resource undefined method

cli.py

@@ -113,8 +113,8 @@ def init_cli_connect():
     @click.option('--mapping', default=None)
     def connect(mapping, receiver, emitter):
         print 'Connect', emitter, receiver
-        emitter = db.get_obj_resource(emitter)
-        receiver = db.get_obj_resource(receiver)
+        emitter = xr.load(emitter)
+        receiver = xr.load(receiver)
         print emitter
         print receiver
         if mapping is not None:
@@ -128,8 +128,8 @@ def init_cli_connect():
     @click.argument('receiver')
     def disconnect(receiver, emitter):
         print 'Disconnect', emitter, receiver
-        emitter = db.get_obj_resource(emitter)
-        receiver = db.get_obj_resource(receiver)
+        emitter = xr.load(emitter)
+        receiver = xr.load(receiver)
         print emitter
         print receiver
         xs.disconnect(emitter, receiver)

solar/solar/cli.py

@@ -88,14 +88,14 @@ class Cmd(object):
 
     def run(self, args):
         from solar.core import actions
-        from solar.core import signals
+        from solar.core import resource
 
         resources = filter(
             lambda r: Expression(args.tags, r.get('tags', [])).evaluate(),
             self.db.get_list('resource'))
 
         for resource in resources:
-            resource_obj = self.db.get_obj_resource(resource['id'])
+            resource_obj = resource.load(resource['id'])
             actions.resource_action(resource_obj, args.action)
 
     def profile(self, args):

solar/solar/operations.py

@@ -167,7 +167,7 @@ def rollback(log_item):
         log_item.res, df, guess_action(commited, staged))
     log.add(log_item)
 
-    res = db.get_obj_resource(log_item.res)
+    res = resource.load(log_item.res)
     res.update(staged.get('args', {}))
     res.save()
 

solar/solar/state.py

@@ -23,12 +23,10 @@ from enum import Enum
 
 from solar.interfaces.db import get_db
 
-import yaml
-
 db = get_db()
 
 
-STATES = Enum('States', 'pending inprogress error success')
+STATES = Enum('States', 'error inprogress pending success')
 
 
 def state_file(name):
@@ -107,7 +105,7 @@ class Log(object):
         return item
 
     def show(self, verbose=False):
-        return ['L(uuid={0}, res={1}, aciton={2})'.format(
+        return ['L(uuid={0}, res={1}, action={2})'.format(
             l.uid, l.res, l.action) for l in self.items]
 
     def __repr__(self):