Testing

Author: sofyan48

go.mod

@@ -4,7 +4,6 @@ go 1.18
 
 require (
 	cloud.google.com/go/pubsub v1.24.0
-	github.com/joho/godotenv v1.4.0
 	google.golang.org/api v0.92.0
 )
 

go.sum

@@ -184,8 +184,6 @@ github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ
 github.com/hashicorp/golang-lru v0.5.1/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8=
 github.com/ianlancetaylor/demangle v0.0.0-20181102032728-5e5cf60278f6/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
 github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
-github.com/joho/godotenv v1.4.0 h1:3l4+N6zfMWnkbPEXKng2o2/MR5mSwTrBih4ZEkkz1lg=
-github.com/joho/godotenv v1.4.0/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU=
 github.com/jstemmer/go-junit-report v0.9.1/go.mod h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=

server.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"log"
 	"sync/atomic"
 	"time"
 
@@ -22,6 +23,7 @@ type Server struct {
 func NewSession(ctx context.Context, sess session.Contract) *Server {
 	cl, err := client.NewClient(sess)
 	if err != nil {
+		log.Fatal("Pubsubrouter client not connected")
 		defer cl.Client().Close()
 	}
 	return &Server{
@@ -33,6 +35,7 @@ func NewSession(ctx context.Context, sess session.Contract) *Server {
 func NewSessionAutoConfig(ctx context.Context, projectID string) *Server {
 	cl, err := client.NewClientAutoConfig(ctx, projectID)
 	if err != nil {
+		log.Fatal("Pubsubrouter client not connected")
 		defer cl.Client().Close()
 	}
 	return &Server{