Rename observer to openstack_observer, making room for more convenient

[plstackapi.git] / planetstack / observer / steps / sync_nodes.py

diff --git a/planetstack/observer/steps/sync_nodes.py b/planetstack/observer/steps/sync_nodes.py
deleted file mode 100644 (file)
index 030d57c..0000000
--- a/planetstack/observer/steps/sync_nodes.py
+++ /dev/null
@@ -1,41 +0,0 @@
-import os
-import base64
-import random
-from datetime import datetime 
-from django.db.models import F, Q
-from planetstack.config import Config
-from observer.openstacksyncstep import OpenStackSyncStep
-from core.models.node import Node
-from core.models.site import Site, Deployment
-
-class SyncNodes(OpenStackSyncStep):
-    provides=[Node]
-    requested_interval=0
-
-    def fetch_pending(self):
-        # collect local nodes
-        sites = Site.objects.all()
-        nodes = Node.objects.all()
-        node_hostnames  = [node.name for node in nodes]
-
-        # fetch all nodes from each deployment 
-        deployments = Deployment.objects.all()
-        new_nodes = []
-        for deployment in deployments:
-            driver = self.driver.admin_driver(deployment=deployment.name)
-            compute_nodes = driver.shell.nova.hypervisors.list()
-            for compute_node in compute_nodes:
-                if compute_node.hypervisor_hostname not in node_hostnames:
-                    # XX TODO:figure out how to correctly identify a node's site.
-                    # XX pick a random site to add the node to for now
-                    site_index = random.randint(0, len(sites))
-                    node = Node(name=compute_node.hypervisor_hostname,
-                                site=sites[site_index], deployment=deployment)
-                    new_nodes.append(node)
-
-        return new_nodes    
-                 
-
-    def sync_record(self, node):
-        node.save()
-