promote to master

.drone.yml

@@ -5,12 +5,23 @@ platform:
   os: linux
   arch: amd64
 
+services:
+  - name: nats-streaming
+    image: nats-streaming
+    command: [-mc, 0]
+    ports:
+      - 4222
+
 steps:
-  - name: branch-push
+  - name: tests
     image: golang
+    environment:
+      CODECOV_TOKEN:
+        from_secret: CODECOV_TOKEN
+      COVERALLS_TOKEN:
+        from_secret: COVERALLS_TOKEN
     commands:
-      - apt-get update
-      - apt-get install unzip
+      - export STAN_HOST="nats-streaming"
       - go get -v golang.org/x/lint/golint
       - go get -v golang.org/x/tools/cmd/cover
       - go get -v github.com/mattn/goveralls
@@ -19,16 +30,12 @@ steps:
       - go get -v github.com/onsi/ginkgo/ginkgo
       - go get -v github.com/onsi/gomega
       - go get -v github.com/moleculer-go/cupaloy
-      - curl -fSsL https://github.com/nats-io/nats-streaming-server/releases/download/v0.11.2/nats-streaming-server-v0.11.2-linux-amd64.zip -o nats.zip
-      - unzip nats.zip && ls
-      - nohup nats-*/nats-streaming-server -mc 0 -l /dev/null &
       - mkdir /usr/local/go/src/github.com/
       - mkdir /usr/local/go/src/github.com/moleculer-go
       - ln -s /drone/src/ /usr/local/go/src/github.com/moleculer-go/moleculer
       - cd /usr/local/go/src/github.com/moleculer-go/moleculer
       - go get -d ./...
       - ginkgo -r --randomizeAllSpecs --failFast --cover --trace
-      - export CODECOV_TOKEN="e1ecc5e9-6a8a-47cf-b3bb-c046d2fd9f1c"
       - gover ./ coverage.txt
       - curl -s https://codecov.io/bash | bash
-      - goveralls -coverprofile=coverage.txt -service=drone.io -repotoken cXy9o2ocOliHLtJ4HMMQQ8MAFHWV7Io1q
+      - goveralls -coverprofile=coverage.txt -service=drone.io

.gitignore

@@ -15,4 +15,4 @@
 
 .idea
 .DS_Store
-broker/broker.coverprofile
+

.travis.yml

@@ -15,6 +15,7 @@ matrix:
     - os: windows
 
 before_install:
+  - export STAN_HOST="localhost"
   - go get -v golang.org/x/lint/golint
   - go get -v golang.org/x/tools/cmd/cover
   - go get -v github.com/mattn/goveralls

README.md

@@ -5,17 +5,11 @@
 Lightning fast, lightweight, simple and fun to develop with. Also easy, very easy to test ;)
 
 [![Gitter](https://badges.gitter.im/moleculer-go/community.svg)](https://gitter.im/moleculer-go/community?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge)
-
 [![Travis Build Status](https://travis-ci.org/moleculer-go/moleculer.svg?branch=master)](https://travis-ci.org/moleculer-go/moleculer)
-
 [![Drone.io Build Status](https://cloud.drone.io/api/badges/moleculer-go/moleculer/status.svg)](https://cloud.drone.io/moleculer-go/moleculer)
-
 [![Go Report Card](https://goreportcard.com/badge/github.com/moleculer-go/moleculer)](https://goreportcard.com/report/github.com/moleculer-go/moleculer)
-
 [![Coverage -> Coveralls](https://coveralls.io/repos/github/moleculer-go/moleculer/badge.svg?branch=master)](https://coveralls.io/github/moleculer-go/moleculer?branch=master)
-
 [![Coverage -> Codecov](https://codecov.io/gh/moleculer-go/moleculer/branch/develop/graph/badge.svg)](https://codecov.io/gh/moleculer-go/moleculer)
-
 [![FOSSA Status](https://app.fossa.io/api/projects/git%2Bgithub.com%2Fmoleculer-go%2Fmoleculer.svg?type=shield)](https://app.fossa.io/projects/git%2Bgithub.com%2Fmoleculer-go%2Fmoleculer?ref=badge_shield)
 
 <!--
@@ -25,9 +19,9 @@ Lightning fast, lightweight, simple and fun to develop with. Also easy, very eas
 ![](https://img.shields.io/badge/performance---42%25-red.svg)
 -->
 
-**Website**: [tbd](https://moleculer.services)
+**Website**: [tbd](https://gomicro.services)
 
-**Documentation**: [tbd](https://moleculer.services/docs)
+**Documentation**: [tbd](https://gomicro.services/docs)
 
 Status: In development !
 

transit/nats/stan.go

@@ -55,7 +55,7 @@ func (transporter *StanTransporter) Connect() chan bool {
 		connection, error := stan.Connect(transporter.clusterID, transporter.clientID, stan.NatsURL(transporter.url))
 		if error != nil {
 			transporter.logger.Error("\nConnect() - Error: ", error, " clusterID: ", transporter.clusterID, " clientID: ", transporter.clientID)
-			panic(error)
+			panic("Error trying to connect to stan server. url: " + transporter.url + " clusterID: " + transporter.clusterID + " clientID: " + transporter.clientID + " -> Stan error: " + error.Error())
 		}
 		transporter.logger.Info("Connect() - connection success!")
 

transit/nats/stan_test.go

@@ -2,6 +2,7 @@ package nats_test
 
 import (
 	"fmt"
+	"os"
 
 	"github.com/moleculer-go/moleculer/payload"
 	"github.com/moleculer-go/moleculer/util"
@@ -83,7 +84,7 @@ var _ = Describe("NATS Streaming Transit", func() {
 	contextA := context.BrokerContext(brokerDelegates)
 	logger := contextA.Logger()
 	var serializer serializer.Serializer = serializer.CreateJSONSerializer(logger)
-	url := "stan://localhost:4222"
+	url := "stan://" + os.Getenv("STAN_HOST") + ":4222"
 	options := nats.StanOptions{
 		"MOL",
 		url,

transit/pubsub/pubsub.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"fmt"
 	"math"
+	"os"
 	"sync"
 	"time"
 
@@ -126,7 +127,7 @@ func (pubsub *PubSub) createStanTransporter() transit.Transport {
 	//TODO: move this to config and params
 	broker := pubsub.broker
 	prefix := "MOL"
-	url := "stan://localhost:4222"
+	url := "stan://" + os.Getenv("STAN_HOST") + ":4222"
 	clusterID := "test-cluster"
 
 	localNodeID := broker.LocalNode().GetID()