✨ Integration tests sources updates to be optional

Author: Bigomby

tests/0014-http-posts.c

@@ -1,17 +1,4 @@
-#include <curl/curl.h>
-#include <fcntl.h>
-#include <signal.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-#include <zlib.h>
-
-#include <setjmp.h>
-#include <stdarg.h>
-#include <stddef.h>
-
-#include <cmocka.h>
+#include "integration_tests.h"
 
 #define VALID_MESSAGE "{\"message\": \"Hello world\"}"
 #define VALID_TOPIC "/rb_flow"
@@ -23,6 +10,8 @@
 
 // It should returns 200 when UUID, TOPIC and MESSAGE are valids
 static void Test_Valid_POST() {
+  SKIP_IF_NOT_INTEGRATION;
+
   CURL *curl;
   CURLcode res;
   long http_code = 0;
@@ -53,6 +42,8 @@ static void Test_Valid_POST() {
 
 // It should returns 401 when UUID is not valid
 static void Test_Invalid_UUID() {
+  SKIP_IF_NOT_INTEGRATION;
+
   CURL *curl;
   CURLcode res;
   long http_code = 0;
@@ -83,6 +74,8 @@ static void Test_Invalid_UUID() {
 
 // It should returns 403 when Topic is not valid
 static void Test_Invalid_Topic() {
+  SKIP_IF_NOT_INTEGRATION;
+
   CURL *curl;
   CURLcode res;
   long http_code = 0;
@@ -112,6 +105,8 @@ static void Test_Invalid_Topic() {
 }
 
 static void Test_No_Topic() {
+  SKIP_IF_NOT_INTEGRATION;
+
   CURL *curl;
   CURLcode res;
   long http_code = 0;
@@ -140,6 +135,8 @@ static void Test_No_Topic() {
 }
 
 static void Test_Empty_Body() {
+  SKIP_IF_NOT_INTEGRATION;
+
   CURL *curl;
   CURLcode res;
   long http_code = 0;
@@ -170,6 +167,8 @@ static void Test_Empty_Body() {
 
 // It should returns 403 when Topic is not valid
 static void Test_Invalid_URL() {
+  SKIP_IF_NOT_INTEGRATION;
+
   CURL *curl;
   CURLcode res;
   long http_code = 0;
@@ -200,6 +199,8 @@ static void Test_Invalid_URL() {
 
 // It should returns 403 when Topic is not valid
 static void Test_Deflate() {
+  SKIP_IF_NOT_INTEGRATION;
+
   z_stream defstream;
   defstream.zalloc = Z_NULL;
   defstream.zfree = Z_NULL;
@@ -251,6 +252,7 @@ static void Test_Deflate() {
 }
 
 int main() {
+#ifdef TESTS_KAFKA_HOST
   curl_global_init(CURL_GLOBAL_ALL);
 
   printf("Initializing n2kafka\n");
@@ -265,28 +267,29 @@ int main() {
     (void)(dup(0) + 1);
     (void)(dup(0) + 1);
 
-    execlp("./n2kafka", "n2kafka", "configs_example/n2kafka_config_rbhttp.json",
+    execlp("./n2kafka", "n2kafka", "configs_example/n2kafka_tests_http.json",
            (char *)0);
     printf("Error executing n2kafka\n");
     exit(1);
-
   } else if (pID < 0) {
     exit(1);
   }
+#endif
 
   // Wait for n2kafka to initialize
   sleep(1);
-
   const struct CMUnitTest tests[] = {
       cmocka_unit_test(Test_Valid_POST),    cmocka_unit_test(Test_Invalid_UUID),
       cmocka_unit_test(Test_Invalid_Topic), cmocka_unit_test(Test_No_Topic),
       cmocka_unit_test(Test_Invalid_URL),   cmocka_unit_test(Test_Deflate),
       cmocka_unit_test(Test_Empty_Body)};
   const int res = cmocka_run_group_tests(tests, NULL, NULL);
 
+#ifdef TESTS_KAFKA_HOST
   curl_global_cleanup();
   kill(pID, SIGINT);
   sleep(1);
+#endif
 
   return res;
 }

tests/0015-kafka-producer.c

@@ -1,21 +1,8 @@
-#include "assertion_handler.c"
+#include "integration_tests.h"
 
-#include <curl/curl.h>
-#include <fcntl.h>
-#include <signal.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
+#include "assertion_handler.c"
 
 #include <arpa/inet.h>
-
-#include <setjmp.h>
-#include <stdarg.h>
-#include <stddef.h>
-
-#include <cmocka.h>
-
 #include <librdkafka/rdkafka.h>
 
 #define SENT_MESSAGE_HTTP_1 "{\"message\": \"Hello world HTTP\"}"
@@ -30,12 +17,13 @@
 #define TCP_PORT 2056
 #define TCP_MESSAGES_DELAY 5
 
+#ifdef TESTS_KAFKA_HOST
 static rd_kafka_t *init_kafka() {
   rd_kafka_t *rk;
 
   // Kafka
   char errstr[512];
-  char *brokers = "kafka:9092";
+  char *brokers = TESTS_KAFKA_HOST;
   rd_kafka_topic_partition_list_t *topics;
   rd_kafka_resp_err_t err;
   rd_kafka_conf_t *conf = rd_kafka_conf_new();
@@ -93,12 +81,15 @@ static rd_kafka_t *init_kafka() {
 
   return rk;
 }
+#endif
 
 /**
  * Send a message using curl and expect to receive the enriched message via
  * kafka
  */
 static void test_send_message_http() {
+  SKIP_IF_NOT_INTEGRATION;
+
   CURL *curl;
   CURLcode res;
   long http_code = 0;
@@ -112,12 +103,12 @@ static void test_send_message_http() {
 
   if (pID == 0) {
     // Close stdin, stdout, stderr
-    // close(0);
-    // close(1);
-    // close(2);
-    // open("/dev/null", O_RDWR);
-    // (void)(dup(0) + 1);
-    // (void)(dup(0) + 1);
+    close(0);
+    close(1);
+    close(2);
+    open("/dev/null", O_RDWR);
+    (void)(dup(0) + 1);
+    (void)(dup(0) + 1);
 
     execlp("./n2kafka", "n2kafka", "configs_example/n2kafka_tests_http.json",
            (char *)0);
@@ -219,6 +210,8 @@ static void test_send_message_http() {
  * via kafka
  */
 static void test_send_message_tcp() {
+  SKIP_IF_NOT_INTEGRATION;
+
   int sock;
   struct sockaddr_in server;
   struct assertion_handler_s *assertion_handler = NULL;

tests/integration_tests.h

@@ -0,0 +1,25 @@
+#include "../config.h"
+
+#include <curl/curl.h>
+#include <fcntl.h>
+#include <signal.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <zlib.h>
+
+#include <setjmp.h>
+#include <stdarg.h>
+#include <stddef.h>
+
+#include <cmocka.h>
+#ifdef TESTS_KAFKA_HOST
+#define SKIP_IF_NOT_INTEGRATION
+#else
+#define SKIP_IF_NOT_INTEGRATION                                                \
+  do {                                                                         \
+    skip();                                                                    \
+    return;                                                                    \
+  } while (0)
+#endif