Skip to content

Commit

Permalink
Update mongo_scaler_test.go
Browse files Browse the repository at this point in the history
Signed-off-by: rickbrouwer <[email protected]>
  • Loading branch information
rickbrouwer committed Oct 23, 2024
1 parent 58365d8 commit a15836d
Showing 1 changed file with 2 additions and 41 deletions.
43 changes: 2 additions & 41 deletions pkg/scalers/mongo_scaler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,6 @@ package scalers

import (
"context"
"net"
"net/url"
"testing"

"github.com/go-logr/logr"
Expand Down Expand Up @@ -102,62 +100,25 @@ var mongoDBMetricIdentifiers = []mongoDBMetricIdentifier{

func TestParseMongoDBMetadata(t *testing.T) {
for _, testData := range testMONGODBMetadata {
meta, err := parseMongoDBMetadata(&scalersconfig.ScalerConfig{ResolvedEnv: testData.resolvedEnv, TriggerMetadata: testData.metadata, AuthParams: testData.authParams})
_, err := parseMongoDBMetadata(&scalersconfig.ScalerConfig{ResolvedEnv: testData.resolvedEnv, TriggerMetadata: testData.metadata, AuthParams: testData.authParams})
if err != nil && !testData.raisesError {
t.Error("Expected success but got error:", err)
}
if err == nil && testData.raisesError {
t.Error("Expected error but got success")
}
if err == nil {
err = meta.Validate()
if err != nil && !testData.raisesError {
t.Error("Expected success but got error:", err)
}
if err == nil && testData.raisesError {
t.Error("Expected error but got success")
}
}
}
}

func TestParseMongoDBConnectionString(t *testing.T) {
for _, testData := range mongoDBConnectionStringTestDatas {
meta, err := parseMongoDBMetadata(&scalersconfig.ScalerConfig{
_, err := parseMongoDBMetadata(&scalersconfig.ScalerConfig{
ResolvedEnv: testData.metadataTestData.resolvedEnv,
TriggerMetadata: testData.metadataTestData.metadata,
AuthParams: testData.metadataTestData.authParams,
})
if err != nil {
t.Error("Expected success but got error:", err)
continue
}

var connString string
if meta.ConnectionString != "" {
connString = meta.ConnectionString
} else {
if meta.Scheme == "mongodb+srv" {
u := &url.URL{
Scheme: meta.Scheme,
User: url.UserPassword(meta.Username, meta.Password),
Host: meta.Host,
Path: meta.DBName,
}
connString = u.String()
} else {
u := &url.URL{
Scheme: meta.Scheme,
User: url.UserPassword(meta.Username, meta.Password),
Host: net.JoinHostPort(meta.Host, meta.Port),
Path: meta.DBName,
}
connString = u.String()
}
}

if connString != testData.connectionString {
t.Errorf("Expected connection string %s but got %s", testData.connectionString, connString)
}
}
}
Expand Down

0 comments on commit a15836d

Please sign in to comment.