checking user is a string

exoscale · Nov 21, 2024 · c44e254 · c44e254
1 parent b63fc93
commit c44e254
Showing 1 changed file with 43 additions and 0 deletions.
diff --git a/pkg/resources/database/datasource_uri.go b/pkg/resources/database/datasource_uri.go
@@ -283,6 +283,13 @@ func (d *DataSourceURI) Read(ctx context.Context, req datasource.ReadRequest, re
 			)
 			return
 		}
+		if user == "" {
+			resp.Diagnostics.AddError(
+				"Client Error",
+				"Database Service Kafka user is empty",
+			)
+			return
+		}
 
 		creds, err := client.RevealDBAASMysqlUserPassword(ctx, data.Name.ValueString(), user)
 		if err != nil {
@@ -320,6 +327,13 @@ func (d *DataSourceURI) Read(ctx context.Context, req datasource.ReadRequest, re
 			)
 			return
 		}
+		if user == "" {
+			resp.Diagnostics.AddError(
+				"Client Error",
+				"Database Service MySQL user is empty",
+			)
+			return
+		}
 		data.Schema = types.StringValue("mysql")
 
 		creds, err := client.RevealDBAASMysqlUserPassword(ctx, data.Name.ValueString(), user)
@@ -367,6 +381,13 @@ func (d *DataSourceURI) Read(ctx context.Context, req datasource.ReadRequest, re
 			)
 			return
 		}
+		if user == "" {
+			resp.Diagnostics.AddError(
+				"Client Error",
+				"Database Service Postgres user is empty",
+			)
+			return
+		}
 		data.Schema = types.StringValue("postgres")
 
 		creds, err := client.RevealDBAASPostgresUserPassword(ctx, data.Name.ValueString(), user)
@@ -385,6 +406,7 @@ func (d *DataSourceURI) Read(ctx context.Context, req datasource.ReadRequest, re
 			)
 			return
 		}
+
 		params["password"] = creds.Password
 	case "redis":
 		res, err := waitForDBAASService(
@@ -413,6 +435,13 @@ func (d *DataSourceURI) Read(ctx context.Context, req datasource.ReadRequest, re
 			)
 			return
 		}
+		if user == "" {
+			resp.Diagnostics.AddError(
+				"Client Error",
+				"Database Service Redis user is empty",
+			)
+			return
+		}
 		data.Schema = types.StringValue("rediss")
 
 		creds, err := client.RevealDBAASRedisUserPassword(ctx, data.Name.ValueString(), user)
@@ -459,6 +488,13 @@ func (d *DataSourceURI) Read(ctx context.Context, req datasource.ReadRequest, re
 			)
 			return
 		}
+		if user == "" {
+			resp.Diagnostics.AddError(
+				"Client Error",
+				"Database Service Opensearch user is empty",
+			)
+			return
+		}
 		data.Schema = types.StringValue("https")
 
 		creds, err := client.RevealDBAASOpensearchUserPassword(ctx, data.Name.ValueString(), user)
@@ -507,6 +543,13 @@ func (d *DataSourceURI) Read(ctx context.Context, req datasource.ReadRequest, re
 			)
 			return
 		}
+		if user == "" {
+			resp.Diagnostics.AddError(
+				"Client Error",
+				"Database Service Grafana user is empty",
+			)
+			return
+		}
 		data.Schema = types.StringValue("https")
 
 		creds, err := client.RevealDBAASGrafanaUserPassword(ctx, data.Name.ValueString(), user)