Move all integ tests into a same Spec and mark the ones failing previ…

…ously as Pending

There were an "Integration" and an "Integration2" test Spec. Only
Integration2 was being ran by our targets, I put all tests under the
same Spec and marked the ones in "Integration" that were failing as
pending. Also modified the `make integration` target to skip unit tests
and focus only in Integration ones

.travis.yml

@@ -17,7 +17,7 @@ cache:
   directories:
   - "$HOME/.cache/librdkafka"
 before_install:
-- sudo /bin/bash ./travis_install_kafka.sh
+- sudo /bin/bash ./travis-install-librkafka.sh
 install:
 - make setup-ci
 script:

Makefile

@@ -133,7 +133,7 @@ test-integration integration func: deps test-db-drop test-db-create
 	@echo "=               Running integration tests...             ="
 	@echo "-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-="
 	@echo
-	@env MY_IP=${MY_IP} ginkgo -r -tags=integration --randomizeAllSpecs --randomizeSuites --skip="\[Integration\].*" .
+	@env MY_IP=${MY_IP} ginkgo -r -tags=integration --randomizeAllSpecs --randomizeSuites --focus="\[Integration\].*" .
 	@echo
 	@echo "-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-="
 	@echo "=               Integration tests finished.              ="

extensions/gcm_message_handler_test.go

@@ -702,7 +702,7 @@ var _ = Describe("GCM Message Handler", func() {
 			hook.Reset()
 		})
 
-		Describe("Creating new handler", func() {
+		PDescribe("Creating new handler", func() {
 			It("should fail when real client", func() {
 				var err error
 				handler, err = NewGCMMessageHandler(

extensions/kafka_consumer_test.go

@@ -319,7 +319,7 @@ var _ = Describe("Kafka Extension", func() {
 			})
 		})
 
-		Describe("ConsumeLoop", func() {
+		PDescribe("ConsumeLoop", func() {
 			It("should consume message and add it to msgChan", func() {
 				stopChannel := make(chan struct{})
 				client, err := NewKafkaConsumer(config, logger, &stopChannel)

extensions/pg_test.go

@@ -159,7 +159,7 @@ var _ = Describe("PG Extension", func() {
 	})
 
 	Describe("[Integration]", func() {
-		Describe("Creating new client", func() {
+		PDescribe("Creating new client", func() {
 			It("should return connected client", func() {
 				client, err := NewPGClient("push.db", config)
 				Expect(err).NotTo(HaveOccurred())

feedback/kafka_consumer_test.go

@@ -297,7 +297,7 @@ var _ = Describe("Kafka Consumer", func() {
 		})
 	})
 
-	Describe("[Integration2]", func() {
+	Describe("[Integration]", func() {
 		var config *viper.Viper
 		var err error
 

feedback/listener_test.go

@@ -114,7 +114,7 @@ var _ = Describe("Feedback Listener", func() {
 		}
 	})
 
-	Describe("[Integration2]", func() {
+	Describe("[Integration]", func() {
 		Describe("Create a new instance of listener", func() {
 			var logger *logrus.Logger