Rabbitmq resources

example.py

@@ -26,6 +26,10 @@ def deploy():
     node1 = resource.create('node1', 'resources/ro_node/', {'ip': '10.0.0.3', 'ssh_key': '/vagrant/.vagrant/machines/solar-dev1/virtualbox/private_key', 'ssh_user': 'vagrant'})
     node2 = resource.create('node2', 'resources/ro_node/', {'ip': '10.0.0.4', 'ssh_key': '/vagrant/.vagrant/machines/solar-dev2/virtualbox/private_key', 'ssh_user': 'vagrant'})
 
+    rabbitmq_service1 = resource.create('rabbitmq_service1', 'resources/rabbitmq_service/', {'ssh_user':'', 'ip':'','management_port':'15672', 'port':'5672', 'ssh_key':'', 'container_name': 'rabbitmq_service1', 'image': 'rabbitmq:3-management'})
+    openstack_vhost = resource.create('openstack_vhost', 'resources/rabbitmq_vhost/', {'ssh_user':'', 'ip':'', 'ssh_key':'', 'vhost_name' : 'openstack', 'container_name':''})
+    openstack_rabbitmq_user = resource.create('openstack_rabbitmq_user', 'resources/rabbitmq_user/', {'ssh_user':'', 'ip':'', 'ssh_key':'', 'vhost_name' : '', 'user_name':'openstack', 'password':'openstack_password', 'container_name':''})
+
     mariadb_service1 = resource.create('mariadb_service1', 'resources/mariadb_service', {'image': 'mariadb', 'root_password': 'mariadb', 'port': 3306, 'ip': '', 'ssh_user': '', 'ssh_key': ''})
     keystone_db = resource.create('keystone_db', 'resources/mariadb_db/', {'db_name': 'keystone_db', 'login_password': '', 'login_user': 'root', 'login_port': '', 'ip': '', 'ssh_user': '', 'ssh_key': ''})
     keystone_db_user = resource.create('keystone_db_user', 'resources/mariadb_user/', {'new_user_name': 'keystone', 'new_user_password': 'keystone', 'db_name': '', 'login_password': '', 'login_user': 'root', 'login_port': '', 'ip': '', 'ssh_user': '', 'ssh_key': ''})
@@ -34,8 +38,7 @@ def deploy():
     keystone_service1 = resource.create('keystone_service1', 'resources/keystone_service/', {'port': 5001, 'admin_port': 35357, 'image': '', 'ip': '', 'ssh_key': '', 'ssh_user': '', 'config_dir': ''})
 
     keystone_config2 = resource.create('keystone_config2', 'resources/keystone_config/', {'config_dir': '/etc/solar/keystone', 'ip': '', 'ssh_user': '', 'ssh_key': '', 'admin_token': 'admin', 'db_password': '', 'db_name': '', 'db_user': '', 'db_host': '', 'db_port': ''})
-    keystone_service2 = resource.create('keystone_service2', 'resources/keystone_service/', {'port': 5002, 'admin_port': 35357, 'image': '', 'ip': '', 'ssh_key': '', 'ssh_user': '', 'config_dir': ''})
+    keystone_service2 = resource.create('keystone_service2', 'resources/keystone_service/', {'port': 5002, 'admin_port': 35358, 'image': '', 'ip': '', 'ssh_key': '', 'ssh_user': '', 'config_dir': ''})
-
 
     haproxy_keystone_config = resource.create('haproxy_keystone1_config', 'resources/haproxy_keystone_config/', {'name': 'keystone_config', 'listen_port':5000, 'servers':[], 'ports':[]})
     haproxy_config = resource.create('haproxy_config', 'resources/haproxy', {'ip': '', 'ssh_key': '', 'ssh_user': '', 'configs_names':[], 'configs_ports':[], 'listen_ports':[], 'configs':[], 'config_dir': ''})
@@ -54,6 +57,12 @@ def deploy():
     # mariadb
     signals.connect(node1, mariadb_service1)
 
+    #rabbitmq
+    signals.connect(node1, rabbitmq_service1)
+    signals.connect(rabbitmq_service1, openstack_vhost)
+    signals.connect(rabbitmq_service1, openstack_rabbitmq_user)
+    signals.connect(openstack_vhost, openstack_rabbitmq_user, {'vhost_name': 'vhost_name'})
+
     # keystone db
     signals.connect(node1, keystone_db)
     signals.connect(mariadb_service1, keystone_db, {'root_password': 'login_password', 'port': 'login_port'})
@@ -101,6 +110,9 @@ def deploy():
               node2,
               mariadb_service1,
               keystone_db,
+              rabbitmq_service1,
+              openstack_vhost,
+              openstack_rabbitmq_user,
               keystone_db_user,
               keystone_config1,
               keystone_service1,
@@ -124,11 +136,14 @@ def deploy():
 
     # run
     actions.resource_action(mariadb_service1, 'run')
-    time.sleep(10)
+    actions.resource_action(rabbitmq_service1, 'run')
+    actions.resource_action(openstack_vhost, 'run')
+    actions.resource_action(openstack_rabbitmq_user, 'run')
     actions.resource_action(keystone_db, 'run')
     actions.resource_action(keystone_db_user, 'run')
     actions.resource_action(keystone_config1, 'run')
     actions.resource_action(keystone_service1, 'run')
+    time.sleep(10) #TODO fix keystone services to check if tables are created
     actions.resource_action(keystone_config2, 'run')
     actions.resource_action(keystone_service2, 'run')
     actions.resource_action(haproxy_config, 'run')
@@ -144,8 +159,7 @@ def deploy():
     requests.get('http://%s:%s' % (keystone_service1.args['ip'].value, keystone_service1.args['port'].value))
     requests.get('http://%s:%s' % (keystone_service2.args['ip'].value, keystone_service2.args['port'].value))
     requests.get('http://%s:%s' % (haproxy_service.args['ip'].value, haproxy_service.args['ports'].value[0]['value'][0]['value']))
-
+    requests.get('http://%s:%s' % (rabbitmq_service1.args['ip'].value, rabbitmq_service1.args['management_port'].value))
-
 
 
 @click.command()
@@ -168,6 +182,9 @@ def undeploy():
     actions.resource_action(resources['keystone_db_user'], 'remove')
     actions.resource_action(resources['keystone_db'], 'remove')
     actions.resource_action(resources['mariadb_service1'], 'remove')
+    actions.resource_action(resources['openstack_rabbitmq_user'], 'remove')
+    actions.resource_action(resources['openstack_vhost'], 'remove')
+    actions.resource_action(resources['rabbitmq_service1'], 'remove')
 
     db.clear()
 

resources/keystone_config/meta.yaml

@@ -5,10 +5,10 @@ version: 1.0.0
 input:
     config_dir:
       schema: str!
-      value:
+      value: /etc/solar/keystone
     admin_token:
       schema: str!
-      value: /etc/solar/keystone
+      value: 
     db_password:
       schema: str!
       value: password

resources/rabbitmq_config/actions/remove.yml

@@ -0,0 +1,4 @@
+- hosts: [{{ ip }}]
+  sudo: yes
+  tasks:
+    - file: path={{config_dir}} state=absent

resources/rabbitmq_config/actions/run.yml

@@ -0,0 +1,8 @@
+- hosts: [{{ ip }}]
+  sudo: yes
+  vars:
+    admin_user: {{admin_user}}
+    admin_password: {{admin_password}}
+  tasks:
+    - file: path={{config_dir}} state=directory
+    - template: src={{resource_dir}}/templates/rabbitmq.conf dest={{config_dir}}/rabbitmq.conf

resources/rabbitmq_config/meta.yaml

@@ -0,0 +1,22 @@
+id: rabbitmq_config
+handler: ansible
+version: 1.0.0
+input:
+    config_dir:
+      schema: str!
+      value:
+    admin_name:
+      schema: str!
+      value:
+    admin_password:
+      schema: str!
+      value:
+    ip:
+      schema: str!
+      value:
+    ssh_key:
+      schema: str!
+      value:
+    ssh_user:
+      schema: str!
+      value:

resources/rabbitmq_config/templates/rabbitmq.conf

@@ -0,0 +1,30 @@
+[
+  {rabbit, [
+    {cluster_partition_handling, autoheal},
+    {default_permissions, [<<".*">>, <<".*">>, <<".*">>]},
+    {default_vhost, <<"/">>},
+    {log_levels, [connection,info,error]},
+    {tcp_listen_options, [
+      binary,
+      {packet, raw},
+      {reuseaddr, true},
+      {backlog, 128},
+      {nodelay, true},
+      {exit_on_close, false},
+      {keepalive, true}
+    ]},
+    {default_user, <<"{{default_user}}">>},
+    {default_pass, <<"{{default_password}}">>}
+  ]},
+  {kernel, [
+    {inet_default_connect_options, [{nodelay,true}]},
+    {inet_dist_listen_max, 41055},
+    {inet_dist_listen_min, 41055}
+  ]}
+,
+  {rabbitmq_management, [
+    {listener, [
+      {port, 15672}
+    ]}
+  ]}
+].

resources/rabbitmq_service/actions/remove.yml

@@ -0,0 +1,9 @@
+# TODO
+- hosts: [{{ ip }}]
+  sudo: yes
+  tasks:
+    - name: rabbitmq container
+      docker:
+        name: {{ container_name }}
+        image: {{ image }}
+        state: absent

resources/rabbitmq_service/actions/run.yml

@@ -0,0 +1,17 @@
+- hosts: [{{ ip }}]
+  sudo: yes
+  tasks:
+    - name: rabbitmq container
+      docker:
+        command: /bin/bash -c rabbitmq-server
+        name: {{ container_name }}
+        image: {{ image }}
+        state: running
+        expose:
+        - 5672
+        - 15672
+        ports:
+        - {{ port }}:5672
+        - {{ management_port }}:15672
+        env:
+            RABBITMQ_NODENAME: {{container_name}}

resources/rabbitmq_service/meta.yaml

@@ -0,0 +1,25 @@
+id: rabbitmq_service
+handler: ansible
+version: 1.0.0
+input:
+    image: 
+      schema: str!
+      value: rabbitmq:3-management
+    container_name:
+      schema: str!
+      value:
+    management_port:
+      schema: str!
+      value:
+    port:
+      schema: str!
+      value:
+    ip:
+      schema: str!
+      value:
+    ssh_key:
+      schema: str!
+      value:
+    ssh_user:
+      schema: str!
+      value:

resources/rabbitmq_service/templates/erlang.cookie

@@ -0,0 +1 @@
+{{erlang_cookie}}

resources/rabbitmq_user/actions/remove.yml

@@ -0,0 +1,8 @@
+- hosts: [{{ ip }}]
+  sudo: yes
+  tasks:
+    - new_rabbitmq_user: user={{user_name}}
+                         vhost={{vhost_name}}
+                         state=absent
+                         node={{container_name}}
+                         rabbitmqctl="docker exec -it {{container_name}} rabbitmqctl"

resources/rabbitmq_user/actions/run.yml

@@ -0,0 +1,12 @@
+- hosts: [{{ ip }}]
+  sudo: yes
+  tasks:
+    - new_rabbitmq_user: user={{user_name}}
+                         password={{password}}
+                         vhost={{vhost_name}}
+                         configure_priv=.*
+                         read_priv=.*
+                         write_priv=.*
+                         state=present
+                         node={{container_name}}
+                         rabbitmqctl="docker exec -it {{container_name}} rabbitmqctl"

resources/rabbitmq_user/meta.yaml

@@ -0,0 +1,25 @@
+id: keystone_user
+handler: ansible
+version: 1.0.0
+input:
+    container_name:
+      schema: str!
+      value:
+    user_name:
+      schema: str!
+      value:
+    password:
+      schema: str!
+      value:
+    vhost_name:
+      schema: str!
+      value:
+    ip:
+      schema: str!
+      value:
+    ssh_key:
+      schema: str!
+      value:
+    ssh_user:
+      schema: str!
+      value:

resources/rabbitmq_vhost/actions/remove.yml

@@ -0,0 +1,7 @@
+- hosts: [{{ ip }}]
+  sudo: yes
+  tasks:
+    - new_rabbitmq_vhost: name={{vhost_name}}
+                          state=absent
+                          rabbitmqctl="docker exec -it {{container_name}} rabbitmqctl"
+                          node={{container_name}}

resources/rabbitmq_vhost/actions/run.yml

@@ -0,0 +1,7 @@
+- hosts: [{{ ip }}]
+  sudo: yes
+  tasks:
+      - new_rabbitmq_vhost: name={{vhost_name}}
+                            node={{container_name}}
+                            state=present
+                            rabbitmqctl="docker exec -it {{container_name}} rabbitmqctl"

resources/rabbitmq_vhost/meta.yaml

@@ -0,0 +1,21 @@
+id: rabbitmq_vhost
+handler: ansible
+version: 1.0.0
+input:
+    container_name:
+      schema: str!
+      value:
+    vhost_name:
+      schema: str!
+      value:
+    ip:
+      schema: str!
+      value:
+    ssh_key:
+      schema: str!
+      value:
+    ssh_user:
+      schema: str!
+      value:
+
+tags: [resource/rabbitmq]