Add: Support authorization config without service token

Author: sofyan48

client.go

@@ -34,3 +34,7 @@ func NewServer(ctx context.Context, cfg *Config) *Server {
 	})
 	return NewSession(ctx, sess)
 }
+
+func NewServerAutoConfig(ctx context.Context, projectID string) *Server {
+	return NewSessionAutoConfig(ctx, projectID)
+}

example/main.go

@@ -3,42 +3,41 @@ package main
 import (
 	"context"
 	"fmt"
-	"os"
 
-	"github.com/joho/godotenv"
 	pubsubrouter "github.com/sofyan48/pubsub-router"
 	"github.com/sofyan48/pubsub-router/example/router"
 )
 
 func main() {
-	err := godotenv.Load()
-	if err != nil {
-		fmt.Println("error: ", err)
-	}
-	cfg := &pubsubrouter.Config{
-		Type:                    "service_account",
-		ProjectID:               os.Getenv("GOOGLE_PROJECT_ID"),
-		PrivateKeyID:            os.Getenv("GOOGLE_PRIVATE_KEY_ID"),
-		PrivateKey:              os.Getenv("GOOGLE_PRIVATE_KEY"),
-		ClientEmail:             os.Getenv("GOOGLE_CLIENT_EMAIL"),
-		ClientID:                os.Getenv("GOOGLE_CLIENT_ID"),
-		AuthURI:                 os.Getenv("GOOGLE_AUTH_URI"),
-		TokenURI:                os.Getenv("GOOGLE_TOKEN_URI"),
-		AuthProviderX509CertURL: os.Getenv("GOOGLE_AUTH_PROVIDER"),
-		ClientX509CertURL:       os.Getenv("GOOGLE_CLIENT_CERT_URL"),
-	}
-	sv := pubsubrouter.NewServer(context.Background(), cfg)
-
-	// // publish data
-	// result, err := sv.Publish(os.Getenv("EVENT_BROKER_SERIAL"), "/test", "Message send test")
+	// err := godotenv.Load()
 	// if err != nil {
 	// 	fmt.Println("error: ", err)
-	// 	panic(err)
 	// }
-	// fmt.Println("result Publish:> ", result)
+	// cfg := &pubsubrouter.Config{
+	// 	Type:                    "service_account",
+	// 	ProjectID:               os.Getenv("GOOGLE_PROJECT_ID"),
+	// 	PrivateKeyID:            os.Getenv("GOOGLE_PRIVATE_KEY_ID"),
+	// 	PrivateKey:              os.Getenv("GOOGLE_PRIVATE_KEY"),
+	// 	ClientEmail:             os.Getenv("GOOGLE_CLIENT_EMAIL"),
+	// 	ClientID:                os.Getenv("GOOGLE_CLIENT_ID"),
+	// 	AuthURI:                 os.Getenv("GOOGLE_AUTH_URI"),
+	// 	TokenURI:                os.Getenv("GOOGLE_TOKEN_URI"),
+	// 	AuthProviderX509CertURL: os.Getenv("GOOGLE_AUTH_PROVIDER"),
+	// 	ClientX509CertURL:       os.Getenv("GOOGLE_CLIENT_CERT_URL"),
+	// }
+	// sv := pubsubrouter.NewServer(context.Background(), cfg)
+	sv := pubsubrouter.NewServerAutoConfig(context.Background(), "kirimin-aja")
+
+	// publish data
+	result, err := sv.Publish("cekaja", "/test", "Message send test")
+	if err != nil {
+		fmt.Println("error: ", err)
+		panic(err)
+	}
+	fmt.Println("result Publish:> ", result)
 	// // subscribe data
 	rtr := router.NewRouter()
 
-	sv.Subscribe(os.Getenv("EVENT_BROKER_SERIAL"), rtr.Route()).Start()
+	sv.Subscribe("cekaja", rtr.Route()).Start()
 
 }

example/router/router.go

@@ -21,7 +21,6 @@ func (r *Router) handle(svc controller.UseCase) pubsubrouter.HandlerFunc {
 
 func (r *Router) Route() *pubsubrouter.Router {
 
-	r.rtr.Handle("/event", r.handle(controller.NewEvent()))
 	r.rtr.Handle("/test", r.handle(controller.Newtest()))
 
 	return r.rtr

pkg/client/pubsub.go

@@ -27,6 +27,17 @@ func NewClient(credential session.Contract) (*clientPubsub, error) {
 	}, nil
 }
 
+func NewClientAutoConfig(ctx context.Context, projectID string) (*clientPubsub, error) {
+	sess, err := pubsub.NewClient(ctx, projectID)
+	if err != nil {
+		return nil, err
+	}
+	return &clientPubsub{
+		ctx:        ctx,
+		sessPubsub: sess,
+	}, nil
+}
+
 func (c *clientPubsub) Client() *pubsub.Client {
 	return c.sessPubsub
 }

server.go

@@ -30,6 +30,17 @@ 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 {
+		defer cl.Client().Close()
+	}
+	return &Server{
+		clients: cl.Client(),
+		ctx:     ctx,
+	}
+}
+
 func (s *Server) Subscribe(topic string, r *Router) *Server {
 	s.subClient = s.clients.Subscription(topic)
 	s.router = r