Revert (part of) #6646

2 files changed, 2 insertions, 4 deletions

diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/DB.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/DB.kt
index 94d3263a..c164aee8 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/DB.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/DB.kt
@@ -302,7 +302,7 @@ class NexusUserEntity(id: EntityID<String>) : Entity<String>(id) {
 }
 
 object NexusBankConnectionsTable : IdTable<String>() {
-    override val id = NexusBankConnectionsTable.text("id").entityId()
+    override val id = NexusBankConnectionsTable.text("id").entityId().uniqueIndex()
     val type = text("type")
     val owner = reference("user", NexusUsersTable)
 }
diff --git a/nexus/src/main/kotlin/tech/libeufin/nexus/server/NexusServer.kt b/nexus/src/main/kotlin/tech/libeufin/nexus/server/NexusServer.kt
index 6f03ab01..3c8d06bc 100644
--- a/nexus/src/main/kotlin/tech/libeufin/nexus/server/NexusServer.kt
+++ b/nexus/src/main/kotlin/tech/libeufin/nexus/server/NexusServer.kt
@@ -718,9 +718,7 @@ fun serverMain(dbName: String, host: String, port: Int) {
                 val body = call.receive<CreateBankConnectionRequestJson>()
                 transaction {
                     val user = authenticateRequest(call.request)
-                    if (NexusBankConnectionEntity.find {
-                            NexusBankConnectionsTable.id eq body.name and (NexusBankConnectionsTable.owner eq user.id)
-                        }.firstOrNull() != null) {
+                    if (NexusBankConnectionEntity.findById(body.name) != null) {
                         throw NexusError(HttpStatusCode.NotAcceptable, "connection '${body.name}' exists already")
                     }
                     when (body) {