fullchain test in nomad

CMakeModules/prepare_asapo.cmake

@@ -2,10 +2,13 @@ function(prepare_asapo)
     get_target_property(RECEIVER_DIR receiver-bin BINARY_DIR)
     get_target_property(RECEIVER_NAME receiver-bin OUTPUT_NAME)
     get_target_property(DISCOVERY_FULLPATH asapo-discovery EXENAME)
+    get_target_property(BROKER_FULLPATH asapo-broker EXENAME)
     set(WORK_DIR ${CMAKE_CURRENT_BINARY_DIR})
     configure_file(${CMAKE_SOURCE_DIR}/config/nomad/receiver.nmd.in  receiver.nmd @ONLY)
     configure_file(${CMAKE_SOURCE_DIR}/config/nomad/discovery.nmd.in  discovery.nmd @ONLY)
+    configure_file(${CMAKE_SOURCE_DIR}/config/nomad/broker.nmd.in  broker.nmd @ONLY)
     configure_file(${CMAKE_SOURCE_DIR}/tests/automatic/settings/receiver.json.tpl receiver.json.tpl COPYONLY)
     configure_file(${CMAKE_SOURCE_DIR}/tests/automatic/settings/discovery_settings.json.tpl discovery.json.tpl COPYONLY)
+    configure_file(${CMAKE_SOURCE_DIR}/tests/automatic/settings/broker_settings.json.tpl broker.json.tpl COPYONLY)
 endfunction()
 

broker/src/asapo_broker/server/get_health.go

+package server
+
+import (
+	"net/http"
+)
+
+
+func routeGetHealth(w http.ResponseWriter, r *http.Request) {
+	r.Header.Set("Content-type", "application/json")
+	w.WriteHeader(http.StatusNoContent)
+}

broker/src/asapo_broker/server/get_health_test.go

+package server
+
+import (
+	"github.com/stretchr/testify/assert"
+	"net/http"
+	"testing"
+)
+
+
+func TestGetNext(t *testing.T) {
+	w := doRequest("/health")
+	assert.Equal(t, http.StatusNoContent, w.Code)
+}

broker/src/asapo_broker/server/listroutes.go

@@ -11,4 +11,11 @@ var listRoutes = utils.Routes{
 		"/database/{dbname}/next",
 		routeGetNext,
 	},
+		utils.Route{
+    		"Health",
+    		"Get",
+    		"/health",
+    		routeGetHealth,
+    	},
+
 }

config/nomad/broker.nmd.in

+job "broker" {
+  datacenters = ["dc1"]
+
+  type = "service"
+
+  group "group" {
+    count = 1
+
+    task "service" {
+      driver = "raw_exec"
+
+      config {
+        command = "@BROKER_FULLPATH@",
+        args =  ["-config","${NOMAD_TASK_DIR}/broker.json"]
+      }
+
+      resources {
+        cpu    = 500 # 500 MHz
+        memory = 256 # 256MB
+        network {
+          port "broker" {
+            static = "5005"
+          }
+        }
+      }
+
+      service {
+        name = "broker"
+        port = "broker"
+        check {
+          name     = "alive"
+          type     = "http"
+          path     = "/health"
+          interval = "10s"
+          timeout  = "2s"
+          initial_status =   "passing"
+        }
+      }
+
+      template {
+         source        = "@WORK_DIR@/broker.json.tpl"
+         destination   = "local/broker.json"
+         change_mode   = "signal"
+         change_signal = "SIGHUP"
+      }
+
+    }
+  }
+}

tests/automatic/full_chain/simple_chain/CMakeLists.txt

@@ -3,7 +3,5 @@ set(TARGET_NAME full_chain_simple_chain)
 ################################
 # Testing
 ################################
-configure_file(${CMAKE_SOURCE_DIR}/tests/automatic/settings/receiver.json receiver.json COPYONLY)
-configure_file(${CMAKE_SOURCE_DIR}/tests/automatic/settings/broker_settings.json broker.json COPYONLY)
-
+prepare_asapo()
 add_script_test("${TARGET_NAME}" "$<TARGET_FILE:dummy-data-producer> $<TARGET_FILE:receiver-bin> $<TARGET_PROPERTY:asapo-broker,EXENAME> $<TARGET_FILE:getnext_broker>" nomem)

tests/automatic/full_chain/simple_chain/check_linux.sh

@@ -11,30 +11,26 @@ broker_address=127.0.0.1:5005
 Cleanup() {
 	echo cleanup
 	rm -rf files
-    kill -9 $receiverid
-    kill -9 $brokerid
-    #kill -9 $producerrid
+    nomad stop receiver
+    nomad stop discovery
+    nomad stop broker
     echo "db.dropDatabase()" | mongo ${broker_database_name}
     influx -execute "drop database ${monitor_database_name}"
 }
 
 influx -execute "create database ${monitor_database_name}"
 
+nomad run receiver.nmd
+nomad run discovery.nmd
+nomad run broker.nmd
 
-#receiver
-$2 receiver.json &
-sleep 0.3
-receiverid=`echo $!`
-
-#broker
-$3 -config broker.json &
-sleep 0.3
-brokerid=`echo $!`
+sleep 1
 
 
 #producer
 mkdir files
-$1 localhost:4200 100 100 &
+$1 localhost:5006 100 100 4 0 &
+
 #producerrid=`echo $!`
 sleep 0.1
 

tests/automatic/settings/broker_settings.json.tpl

+{
+  "BrokerDbAddress":"127.0.0.1:27017",
+  "MonitorDbAddress": "localhost:8086",
+  "MonitorDbName": "db_test",
+  "port":{{ env "NOMAD_PORT_broker" }},
+  "LogLevel":"info"
+}
\ No newline at end of file