fix: validate cluster id

KM8S · Aug 14, 2023 · 02777ec · 02777ec
1 parent e1c6948
commit 02777ec
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/service/src/main/scala/io/kafkamate/grpc/ClustersService.scala b/service/src/main/scala/io/kafkamate/grpc/ClustersService.scala
@@ -20,7 +20,8 @@ object ClustersService {
 
     def addCluster(request: ClusterDetails): ZIO[Env, Status, ClusterDetails] =
       for {
-        clusterId     <- genRandStr(6).map(str => s"${request.name.trim}-$str")
+        clusterId <- genRandStr(6)
+                       .map(str => s"${request.name.trim.replaceAll(" ", "-")}-$str")
         hosts          = request.kafkaHosts.split(",").toList
         schemaRegistry = Option.unless(request.schemaRegistryUrl.isEmpty)(request.schemaRegistryUrl)
         c <- ClustersConfig