Introduce gopush

modules/gopush/Puppetfile

@@ -0,0 +1,7 @@
+mod 'cargomedia/helper',
+  :git => 'git@github.com:cargomedia/puppet-packages.git',
+  :path => 'modules/helper'
+
+mod 'cargomedia/monit',
+  :git => 'git@github.com:cargomedia/puppet-packages.git',
+  :path => 'modules/monit'

modules/gopush/manifests/core/cometd.pp

@@ -0,0 +1,29 @@
+define gopush::core::cometd (
+  $port_ws = 6968,
+  $port_tcp = 6969,
+  $port_rpc = 6970,
+  $bind_ip = undef,
+  $zoo_comet_path = '/gopush-cluster-comet',
+  $zoo_msg_path = '/gopush-cluster-message',
+  $zoo_host = 'localhost:2181'
+) {
+
+  require 'gopush'
+
+  $daemon = 'gpcomet'
+  $instance_name = "${daemon}_${name}"
+
+  file {
+    "/etc/gopush/${instance_name}.conf":
+      ensure  => file,
+      content => template('gopush/cometd/conf'),
+      mode    => '0644',
+      owner   => 'gopush',
+      group   => 'gopush',
+      notify  => Service[$instance_name];
+  }
+  ->
+
+  gopush::core::service {$instance_name: }
+
+}

modules/gopush/manifests/core/msgd.pp

@@ -0,0 +1,24 @@
+define gopush::core::msgd (
+  $port = 8170,
+  $bind_ip = undef
+) {
+
+  require 'gopush'
+
+  $daemon = 'gpmsg'
+  $instance_name = "${daemon}_${name}"
+
+  file {
+    "/etc/gopush/${instance_name}.conf":
+      ensure  => file,
+      content => template('gopush/msgd/conf'),
+      mode    => '0644',
+      owner   => 'gopush',
+      group   => 'gopush',
+      notify  => Service[$instance_name];
+  }
+  ->
+
+  gopush::core::service {$instance_name: }
+
+}

modules/gopush/manifests/core/service.pp

@@ -0,0 +1,21 @@
+define gopush::core::service {
+
+  file {
+    "/etc/init.d/${name}":
+    ensure  => file,
+    content => template('gopush/init'),
+    mode    => '0755',
+    owner   => 'gopush',
+    group   => 'gopush',
+    notify  => Service[$name];
+  }
+  ->
+
+  helper::service {$name: }
+
+  @monit::entry {$name:
+    content => template('gopush/monit'),
+    require => Service[$name],
+  }
+
+}

modules/gopush/manifests/core/webd.pp

@@ -0,0 +1,24 @@
+define gopush::core::webd (
+  $port = 8080,
+  $bind_ip = undef
+) {
+
+  require 'gopush'
+
+  $daemon = 'gpweb'
+  $instance_name = "${daemon}_${name}"
+
+  file {
+    "/etc/gopush/${instance_name}.conf":
+      ensure  => file,
+      content => template('gopush/webd/conf'),
+      mode    => '0644',
+      owner   => 'gopush',
+      group   => 'gopush',
+      notify  => Service[$instance_name];
+  }
+  ->
+
+  gopush::core::service {$instance_name: }
+
+}

modules/gopush/manifests/init.pp

@@ -0,0 +1,30 @@
+class gopush (
+  $version = '1.0-commit'
+) {
+
+  user {'gopush':
+    ensure => present,
+    system => true,
+  }
+
+  file {
+    '/etc/gopush':
+      ensure  => directory,
+      mode    => '0644',
+      owner   => 'gopush',
+      group   => 'gopush';
+
+    '/var/run/gopush':
+      ensure  => directory,
+      mode    => '0644',
+      owner   => 'gopush',
+      group   => 'gopush';
+  }
+  ->
+
+  helper::script {'install gopush-cluster':
+    content => template('gopush/install.sh'),
+    unless => "test -x /usr/bin/gpcomet && /usr/bin/gpcomet -v | grep 'go${version}'",
+  }
+
+}

modules/gopush/manifests/role/comet.pp

@@ -0,0 +1,13 @@
+class gopush::role::comet (
+  $port_ws = 6968,
+  $port_tcp = 6969,
+  $port_rpc = 6970
+) {
+
+  gopush::core::cometd {'comet':
+    port_ws => $port_ws,
+    port_tcp => $port_tcp,
+    port_rpc => $port_rpc,
+  }
+
+}

modules/gopush/manifests/role/message.pp

@@ -0,0 +1,9 @@
+class gopush::role::message (
+  $port = 8170
+) {
+
+  gopush::core::msgd {'message':
+    port => $port,
+  }
+
+}

modules/gopush/manifests/role/web.pp

@@ -0,0 +1,9 @@
+class gopush::role::web (
+  $port = 8080
+) {
+
+  gopush::core::webd {'web':
+    port => $port,
+  }
+
+}

modules/gopush/spec/role-web/manifest.pp

@@ -0,0 +1,5 @@
+node default {
+
+  class {'gopush::role::web': }
+
+}

modules/gopush/spec/role-web/spec.rb

@@ -0,0 +1,5 @@
+require 'spec_helper'
+
+describe command('sleep 15') do
+  it { should return_exit_status 0 }
+end

modules/gopush/spec/webd/manifest.pp

@@ -0,0 +1,7 @@
+node default {
+
+  gopush::core::webd {'web':
+    port => 8081
+  }
+
+}

modules/gopush/spec/webd/spec.rb

@@ -0,0 +1,5 @@
+require 'spec_helper'
+
+describe command('sleep 15') do
+  it { should return_exit_status 0 }
+end