Added dummy ClusterChangesHandler

nailgun/api/handlers.py

@@ -7,6 +7,7 @@ import netaddr
 
 from models import Release, Cluster, Node, Role, Network, Vlan
 from settings import settings
+import rpc
 
 
 def check_client_content_type(handler):
@@ -215,6 +216,28 @@ class ClusterCollectionHandler(JSONHandler):
         ))
 
 
+class ClusterChangesHandler(JSONHandler):
+    fields = (
+        "id",
+        "name",
+    )
+
+    def PUT(self, cluster_id):
+        web.header('Content-Type', 'application/json')
+        q = web.ctx.orm.query(Cluster).filter(Cluster.id == cluster_id)
+        cluster = q.first()
+        if not cluster:
+            return web.notfound()
+
+        message = {"method": "deploy", "args": {"var1": "Hello from nailgun"}}
+        rpc.cast('mcollective', message)
+
+        return json.dumps(
+            self.render(cluster),
+            indent=4
+        )
+
+
 class ReleaseHandler(JSONHandler):
     fields = (
         "id",

nailgun/api/urls.py

@@ -3,6 +3,7 @@
 import web
 
 from api.handlers import ClusterHandler, ClusterCollectionHandler
+from api.handlers import ClusterChangesHandler
 from api.handlers import ReleaseHandler, ReleaseCollectionHandler
 from api.handlers import NodeHandler, NodeCollectionHandler
 from api.handlers import RoleHandler, RoleCollectionHandler
@@ -13,6 +14,7 @@ urls = (
     r'/releases/(?P<release_id>\d+)/?$', 'ReleaseHandler',
     r'/clusters/?$', 'ClusterCollectionHandler',
     r'/clusters/(?P<cluster_id>\d+)/?$', 'ClusterHandler',
+    r'/clusters/(?P<cluster_id>\d+)/changes/?$', 'ClusterChangesHandler',
     r'/nodes/?$', 'NodeCollectionHandler',
     r'/nodes/(?P<node_id>\d+)/?$', 'NodeHandler',
     r'/roles/?$', 'RoleCollectionHandler',

nailgun/test/test_cluster_changes_handler.py

@@ -0,0 +1,16 @@
+import json
+
+from base import BaseHandlers
+from base import reverse
+
+
+class TestClusterChangesHandler(BaseHandlers):
+    def test_cluster_starts_deploy(self):
+        cluster = self.create_default_cluster()
+        resp = self.app.put(
+            reverse(
+                'ClusterChangesHandler',
+                kwargs={'cluster_id': cluster.id}),
+            headers=self.default_headers
+        )
+        self.assertEquals(200, resp.status)