Move VM status method to Nova extractor

Author: alvarolopez

caso/extract/base.py

@@ -115,30 +115,6 @@
 
 LOG = log.getLogger(__name__)
 
-openstack_vm_statuses = {
-    "active": "started",
-    "build": "started",
-    "confirming_resize": "started",
-    "deleted": "completed",
-    "error": "error",
-    "hard_reboot": "started",
-    "migrating": "started",
-    "password": "started",
-    "paused": "paused",
-    "reboot": "started",
-    "rebuild": "started",
-    "rescue": "started",
-    "resize": "started",
-    "revert_resize": "started",
-    "verify_resize": "started",
-    "shutoff": "completed",
-    "suspended": "suspended",
-    "terminated": "completed",
-    "stopped": "stopped",
-    "saving": "started",
-    "unknown": "unknown",
-}
-
 
 @six.add_metaclass(abc.ABCMeta)
 class BaseProjectExtractor(object):
@@ -182,13 +158,6 @@ def voms_map(self):
                     voms_map[project] = vo
             return voms_map
 
-    def vm_status(self, status):
-        """Return the status corresponding to the OpenStack status.
-
-        :param status: OpenStack status.
-        """
-        return openstack_vm_statuses.get(status.lower(), "unknown")
-
     @abc.abstractmethod
     def extract(self, extract_from):
         """Extract records for a project from given date.

caso/extract/openstack/nova.py

@@ -131,6 +131,36 @@ def _count_ips_on_server(self, server):
                     count += 1
         return count
 
+    def vm_status(self, status):
+        """Return the status corresponding to the OpenStack status.
+
+        :param status: OpenStack status.
+        """
+        openstack_vm_statuses = {
+            "active": "started",
+            "build": "started",
+            "confirming_resize": "started",
+            "deleted": "completed",
+            "error": "error",
+            "hard_reboot": "started",
+            "migrating": "started",
+            "password": "started",
+            "paused": "paused",
+            "reboot": "started",
+            "rebuild": "started",
+            "rescue": "started",
+            "resize": "started",
+            "revert_resize": "started",
+            "verify_resize": "started",
+            "shutoff": "completed",
+            "suspended": "suspended",
+            "terminated": "completed",
+            "stopped": "stopped",
+            "saving": "started",
+            "unknown": "unknown",
+        }
+        return openstack_vm_statuses.get(status.lower(), "unknown")
+
     def _build_record(self, server):
         user = self.users[server.user_id]