chore(openapi): add new objects endpoint

Author: nkoester

api/model-server.yaml

@@ -54,6 +54,24 @@ paths:
       responses:
         "200":
           $ref: '#/components/responses/200'
+  /v2/repositories/{repository}/objects:
+    put:
+      operationId: putRepositoryObjects
+      parameters:
+        - name: repository
+          in: "path"
+          required: true
+          schema:
+            type: string
+      responses:
+        "403":
+          $ref: '#/components/responses/403'
+        "401":
+          $ref: '#/components/responses/401'
+        "500":
+          $ref: '#/components/responses/500'
+        "200":
+          $ref: '#/components/responses/200json'
   /v2/repositories/{repository}/branches:
     get:
       operationId: getRepositoryBranches

model-server/src/main/kotlin/org/modelix/model/server/handlers/ModelReplicationServer.kt

@@ -275,32 +275,30 @@ class ModelReplicationServer(val repositoriesManager: RepositoriesManager) {
             ModelQLServer.handleCall(call, branch.getRootNode(), branch.getArea())
         }
 
-//        route("objects") {
-//            put {
-//                val writtenEntries = withContext(Dispatchers.IO) {
-//                    val entries = call.receiveStream().bufferedReader().use { reader ->
-//                        reader.lineSequence().windowed(2, 2).map {
-//                            val key = it[0]
-//                            val value = it[1]
-//
-//                            require(HashUtil.isSha256(key)) {
-//                                "This API cannot be used to store other entries than serialized objects." +
-//                                    " The key is expected to be a SHA256 hash over the value: $key -> $value"
-//                            }
-//                            val expectedKey = HashUtil.sha256(value)
-//                            require(expectedKey == key) { "Hash mismatch. Expected $expectedKey, but $key was provided. Value: $value" }
-//
-//                            key to value
-//                        }.toMap()
-//                    }
-//
-//                    storeClient.putAll(entries, true)
-//
-//                    entries.size
-//                }
-//                call.respondText("$writtenEntries objects received")
-//            }
-//        }
+        put<Paths.putRepositoryObjects> {
+            val writtenEntries = withContext(Dispatchers.IO) {
+                val entries = call.receiveStream().bufferedReader().use { reader ->
+                    reader.lineSequence().windowed(2, 2).map {
+                        val key = it[0]
+                        val value = it[1]
+
+                        require(HashUtil.isSha256(key)) {
+                            "This API cannot be used to store other entries than serialized objects." +
+                                " The key is expected to be a SHA256 hash over the value: $key -> $value"
+                        }
+                        val expectedKey = HashUtil.sha256(value)
+                        require(expectedKey == key) { "Hash mismatch. Expected $expectedKey, but $key was provided. Value: $value" }
+
+                        key to value
+                    }.toMap()
+                }
+
+                storeClient.putAll(entries, true)
+
+                entries.size
+            }
+            call.respondText("$writtenEntries objects received")
+        }
 
         get<Paths.getVersionHash> {
             // TODO versions should be stored inside a repository with permission checks.