Add several helpers for cleanup and fixes

solar/solar/cli/system_log.py

@@ -31,7 +31,7 @@ def stage():
 
 
 @changes.command()
-def send():
+def process():
     click.echo(change.send_to_orchestration())
 
 
@@ -50,3 +50,9 @@ def history(n):
 @changes.command()
 def test():
     testing.test_all()
+
+
+@changes.command(name='clean-history')
+def clean_history():
+    data.CL().clean()
+    data.CD().clean()

solar/solar/system_log/change.py

@@ -55,7 +55,9 @@ def create_diff(staged, commited):
     if 'tags' in commited:
         commited['tags'].sort()
         staged['tags'].sort()
-
+    if 'tags' in commited.get('metadata', {}):
+        commited['metadata']['tags'].sort()
+        staged['metadata']['tags'].sort()
     return list(diff(commited, staged))
 
 

solar/solar/system_log/data.py

@@ -70,6 +70,8 @@ class Log(object):
 
     def pop(self, uid):
         item = self.get(uid)
+        if not item:
+            return None
         self.ordered_log.rem([uid])
         return item
 
@@ -118,3 +120,6 @@ class Data(collections.MutableMapping):
 
     def __len__(self):
         return len(self.store)
+
+    def clean(self):
+        db.save(self.path, {}, collection=db.COLLECTIONS.state_data)

solar/solar/system_log/operations.py

@@ -1,6 +1,7 @@
 
 
 from solar.system_log import data
+from dictdiffer import patch
 
 
 def set_error(task_uuid, *args, **kwargs):
@@ -13,9 +14,11 @@ def set_error(task_uuid, *args, **kwargs):
 
 def move_to_commited(task_uuid, *args, **kwargs):
     sl = data.SL()
-    item = sl.get(task_uuid)
+    item = sl.pop(task_uuid)
     if item:
-        sl.rem(task_uuid)
+        commited = data.CD()
+        staged_data = patch(item.diff, commited.get(item.res, {}))
         cl = data.CL()
         item.state = data.STATES.success
         cl.append(item)
+        commited[item.res] = staged_data