refactor: remove unnecessary code

Author: siyul-park

cmd/pkg/driver/mongo.go

@@ -27,7 +27,7 @@ type MongoDriver struct {
 var _ Driver = (*MongoDriver)(nil)
 
 // NewMongoDriver initializes a new MongoDB connection and returns a Driver instance.
-func NewMongoDriver(ctx context.Context, uri, name string) (Driver, error) {
+func NewMongoDriver(uri, name string) (Driver, error) {
 	var server *memongo.Server
 	if strings.HasPrefix(uri, "memongodb://") {
 		server = mongoserver.New()

cmd/pkg/driver/mongo_test.go

@@ -11,7 +11,7 @@ func TestNewMongoDriver(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.TODO())
 	defer cancel()
 
-	driver, err := NewMongoDriver(ctx, "memongodb://", "")
+	driver, err := NewMongoDriver("memongodb://", "")
 	assert.NoError(t, err)
 	assert.NotNil(t, driver)
 	assert.NoError(t, driver.Close(ctx))
@@ -21,7 +21,7 @@ func TestMongoDriver_SpecStore(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.TODO())
 	defer cancel()
 
-	driver, _ := NewMongoDriver(ctx, "memongodb://", "")
+	driver, _ := NewMongoDriver("memongodb://", "")
 	defer driver.Close(ctx)
 
 	store, err := driver.SpecStore(ctx, "")
@@ -33,7 +33,7 @@ func TestMongoDriver_SecretStore(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.TODO())
 	defer cancel()
 
-	driver, _ := NewMongoDriver(ctx, "memongodb://", "")
+	driver, _ := NewMongoDriver("memongodb://", "")
 	defer driver.Close(ctx)
 
 	store, err := driver.SecretStore(ctx, "")
@@ -45,7 +45,7 @@ func TestMongoDriver_ChartStore(t *testing.T) {
 	ctx, cancel := context.WithCancel(context.TODO())
 	defer cancel()
 
-	driver, _ := NewMongoDriver(ctx, "memongodb://", "")
+	driver, _ := NewMongoDriver("memongodb://", "")
 	defer driver.Close(ctx)
 
 	store, err := driver.ChartStore(ctx, "")

cmd/pkg/uniflow/main.go

@@ -88,7 +88,7 @@ func main() {
 
 	if strings.HasPrefix(databaseURL, "memongodb://") || strings.HasPrefix(databaseURL, "mongodb://") {
 		var err error
-		if drv, err = driver.NewMongoDriver(ctx, databaseURL, databaseName); err != nil {
+		if drv, err = driver.NewMongoDriver(databaseURL, databaseName); err != nil {
 			log.Fatal(err)
 		}
 	}

cmd/pkg/uniflowctl/main.go

@@ -54,7 +54,7 @@ func main() {
 
 	if strings.HasPrefix(databaseURL, "memongodb://") || strings.HasPrefix(databaseURL, "mongodb://") {
 		var err error
-		if drv, err = driver.NewMongoDriver(ctx, databaseURL, databaseName); err != nil {
+		if drv, err = driver.NewMongoDriver(databaseURL, databaseName); err != nil {
 			log.Fatal(err)
 		}
 	}

driver/mongo/pkg/chart/store.go

@@ -56,9 +56,8 @@ func (s *Store) Index(ctx context.Context) error {
 				{Key: chart.KeyNamespace, Value: 1},
 				{Key: chart.KeyName, Value: 1},
 			},
-			Options: options.Index().SetUnique(true).SetPartialFilterExpression(bson.M{
-				chart.KeyName: bson.M{"$exists": true},
-			}),
+			Options: options.Index().SetUnique(true).
+				SetPartialFilterExpression(bson.M{chart.KeyName: bson.M{"$exists": true}}),
 		},
 	}
 

driver/mongo/pkg/secret/store.go

@@ -55,9 +55,8 @@ func (s *Store) Index(ctx context.Context) error {
 				{Key: secret.KeyNamespace, Value: 1},
 				{Key: secret.KeyName, Value: 1},
 			},
-			Options: options.Index().SetUnique(true).SetPartialFilterExpression(bson.M{
-				secret.KeyName: bson.M{"$exists": true},
-			}),
+			Options: options.Index().SetUnique(true).
+				SetPartialFilterExpression(bson.M{secret.KeyName: bson.M{"$exists": true}}),
 		},
 	}
 

driver/mongo/pkg/spec/store.go

@@ -56,9 +56,8 @@ func (s *Store) Index(ctx context.Context) error {
 				{Key: spec.KeyNamespace, Value: 1},
 				{Key: spec.KeyName, Value: 1},
 			},
-			Options: options.Index().SetUnique(true).SetPartialFilterExpression(bson.M{
-				spec.KeyName: bson.M{"$exists": true},
-			}),
+			Options: options.Index().SetUnique(true).
+				SetPartialFilterExpression(bson.M{spec.KeyName: bson.M{"$exists": true}}),
 		},
 		{
 			Keys: bson.M{spec.KeyKind: 1},

ext/pkg/network/listener.go

@@ -27,7 +27,7 @@ import (
 type ListenNodeSpec struct {
 	spec.Meta `map:",inline"`
 	Protocol  string `map:"protocol" validate:"required"`
-	Host      string `map:"host,omitempty"`
+	Host      string `map:"host,omitempty" validate:"omitempty,hostname|ip"`
 	Port      int    `map:"port" validate:"required"`
 	Cert      string `map:"cert,omitempty"`
 	Key       string `map:"key,omitempty"`

pkg/resource/store.go

@@ -102,6 +102,7 @@ func (s *store[T]) Watch(ctx context.Context, resources ...T) (Stream, error) {
 
 	go func() {
 		<-stream.Done()
+
 		s.mu.Lock()
 		defer s.mu.Unlock()