fix: Fix some issues caused by merge

snapp-incubator · May 20, 2024 · ad77fbd · ad77fbd
1 parent 044abe4
commit ad77fbd
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 18 deletions.
diff --git a/internal/config/config.go b/internal/config/config.go
@@ -24,9 +24,9 @@ const (
 type (
 	// Config holds all configurations.
 	Config struct {
-		Logger logger.Config `json:"logger,omitempty" koanf:"logger"`
-		NATS   client.Config `json:"nats,omitempty" koanf:"nats"`
-		Metric metric.Config `json:"metric,omitempty" koanf:"metric"`
+		Logger logger.Config     `json:"logger,omitempty" koanf:"logger"`
+		NATS   natsclient.Config `json:"nats,omitempty" koanf:"nats"`
+		Metric metric.Config     `json:"metric,omitempty" koanf:"metric"`
 	}
 )
 

diff --git a/internal/natsclient/client.go b/internal/natsclient/client.go
@@ -14,12 +14,12 @@ type NatsClient struct {
 	Metrics Metrics
 }
 
-func New(logger *zap.Logger, cfg Config) *Client {
+func New(logger *zap.Logger, cfg Config) *NatsClient {
 	nc := connect(logger, cfg)
 
 	metrics := NewMetrics()
 
-	client := &Client{
+	client := &NatsClient{
 		Conn:    nc,
 		Logger:  logger,
 		Config:  cfg,
@@ -56,18 +56,13 @@ func (c *NatsClient) StartMessaging() {
 	go c.Publish("")
 }
 
-func New(nc *nats.Conn, logger *zap.Logger, cfg Config) *NatsClient {
-	return &NatsClient{
-		Conn:   nc,
-		Logger: logger,
-		Config: cfg,
-	}
-}
-
-func (c *NatsClient) StartMessaging() {
-	go c.Subscribe("")
-	go c.Publish("")
-}
+// func New(nc *nats.Conn, logger *zap.Logger, cfg Config) *NatsClient {
+// 	return &NatsClient{
+// 		Conn:   nc,
+// 		Logger: logger,
+// 		Config: cfg,
+// 	}
+// }
 
 func (c *NatsClient) Publish(subject string) {
 	if subject == "" {

diff --git a/internal/natsclient/metric.go b/internal/natsclient/metric.go
@@ -1,4 +1,4 @@
-package client
+package natsclient
 
 import (
 	"errors"