Refactor RegistryClient to use npr-api model classes

- Replace manual JSON handling with npr-api models and Jackson ObjectMapper
- Use CreatePluginReleaseRequest with fluent API for building requests
- Use CreatePluginReleaseResponse for parsing responses
- Add Jackson dependencies (jackson-databind and jackson-datatype-jsr310)
- Register JavaTimeModule to handle OffsetDateTime fields
- Fix test mocks to use proper PluginRelease fields instead of non-existent status field

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <[email protected]>
Signed-off-by: Paolo Di Tommaso <[email protected]>

Author: pditommaso

build.gradle

@@ -10,12 +10,16 @@ version = file('VERSION').text.trim()
 
 repositories {
     mavenCentral()
+    maven { url = 'https://s3-eu-west-1.amazonaws.com/maven.seqera.io/releases' }
+    maven { url = 'https://s3-eu-west-1.amazonaws.com/maven.seqera.io/snapshots' }
 }
-
 dependencies {
     implementation 'commons-io:commons-io:2.18.0'
     implementation 'com.github.zafarkhaja:java-semver:0.10.2'
     implementation 'com.google.code.gson:gson:2.10.1'
+    implementation 'io.seqera:npr-api:0.15.0'
+    implementation 'com.fasterxml.jackson.core:jackson-databind:2.18.2'
+    implementation 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.18.2'
 
     testImplementation('org.spockframework:spock-core:2.3-groovy-3.0')
     testImplementation 'org.wiremock:wiremock:3.5.4'

src/main/groovy/io/nextflow/gradle/registry/RegistryClient.groovy

@@ -1,9 +1,12 @@
 package io.nextflow.gradle.registry
 
-import groovy.json.JsonOutput
-import groovy.json.JsonSlurper
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule
 import groovy.transform.CompileStatic
 import groovy.util.logging.Slf4j
+import io.seqera.npr.api.schema.v1.CreatePluginReleaseRequest
+import io.seqera.npr.api.schema.v1.CreatePluginReleaseResponse
+import io.seqera.npr.api.schema.v1.UploadPluginReleaseResponse
 
 import java.net.http.HttpClient
 import java.net.http.HttpRequest
@@ -27,6 +30,8 @@ import java.time.Duration
 class RegistryClient {
     private final URI url
     private final String authToken
+    private final ObjectMapper objectMapper = new ObjectMapper()
+        .registerModule(new JavaTimeModule())
 
     /**
      * Creates a new registry client.
@@ -131,17 +136,17 @@ class RegistryClient {
         def fileBytes = Files.readAllBytes(file.toPath())
         def checksum = computeSha512(fileBytes)
 
-        // Build JSON request body
-        def requestBody = [
-            id: id,
-            version: version,
-            checksum: "sha512:${checksum}",
-            provider: provider
-        ]
-        def jsonBody = JsonOutput.toJson(requestBody)
+        // Build request using API model with fluent API
+        def request = new CreatePluginReleaseRequest()
+            .id(id)
+            .version(version)
+            .checksum("sha512:${checksum}".toString())
+            .provider(provider)
+
+        def jsonBody = objectMapper.writeValueAsString(request)
 
         def requestUri = URI.create(url.toString() + "v1/plugins/release")
-        def request = HttpRequest.newBuilder()
+        def httpRequest = HttpRequest.newBuilder()
             .uri(requestUri)
             .header("Authorization", "Bearer ${authToken}")
             .header("Content-Type", "application/json")
@@ -150,21 +155,21 @@ class RegistryClient {
             .build()
 
         try {
-            def response = client.send(request, HttpResponse.BodyHandlers.ofString())
+            def response = client.send(httpRequest, HttpResponse.BodyHandlers.ofString())
 
             if (response.statusCode() != 200) {
                 throw new RegistryReleaseException(getErrorMessage(response, requestUri))
             }
 
-            // Parse JSON response to extract releaseId
-            def json = new JsonSlurper().parseText(response.body()) as Map
-            return json.releaseId as Long
+            // Parse JSON response using API model
+            def responseObj = objectMapper.readValue(response.body(), CreatePluginReleaseResponse)
+            return responseObj.getReleaseId()
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt()
             throw new RegistryReleaseException("Plugin draft creation to ${requestUri} was interrupted: ${e.message}", e)
         } catch (ConnectException e) {
             throw new RegistryReleaseException("Unable to connect to plugin repository at ${requestUri}: Connection refused", e)
-        } catch (UnknownHostException | IOException e) {
+        } catch (IOException e) {
             throw new RegistryReleaseException("Unable to connect to plugin repository at ${requestUri}: ${e.message}", e)
         }
     }

src/test/groovy/io/nextflow/gradle/registry/RegistryClientTest.groovy

@@ -59,15 +59,15 @@ class RegistryClientTest extends Specification {
             .withRequestBody(containing("\"checksum\""))
             .willReturn(aResponse()
                 .withStatus(200)
-                .withBody('{"releaseId": 123, "pluginRelease": {"status": "DRAFT"}}')))
+                .withBody('{"releaseId": 123, "pluginRelease": {"version": "1.0.0", "url": "https://example.com/plugin.zip", "date": "2024-01-01T00:00:00Z", "sha512sum": "abc123", "requires": ">=21.0.0", "dependsOn": [], "downloadCount": 0, "downloadGhCount": 0}}')))
 
         // Step 2: Upload artifact (multipart)
         wireMockServer.stubFor(post(urlMatching("/api/v1/plugins/release/.*/upload"))
             .withHeader("Authorization", equalTo("Bearer test-token"))
             .withRequestBody(containing("payload"))
             .willReturn(aResponse()
                 .withStatus(200)
-                .withBody('{"pluginRelease": {"status": "PUBLISHED"}}')))
+                .withBody('{"pluginRelease": {"version": "1.0.0", "url": "https://example.com/plugin.zip", "date": "2024-01-01T00:00:00Z", "sha512sum": "abc123", "requires": ">=21.0.0", "dependsOn": [], "downloadCount": 0, "downloadGhCount": 0}}')))
 
         when:
         client.release("test-plugin", "1.0.0", pluginFile, "seqera.io")
@@ -162,7 +162,7 @@ class RegistryClientTest extends Specification {
         wireMockServer.stubFor(post(urlEqualTo("/api/v1/plugins/release"))
             .willReturn(aResponse()
                 .withStatus(200)
-                .withBody('{"releaseId": 456}')))
+                .withBody('{"releaseId": 456, "pluginRelease": {"version": "2.1.0", "url": "https://example.com/plugin.zip", "date": "2024-01-01T00:00:00Z", "sha512sum": "abc123", "requires": ">=21.0.0", "dependsOn": [], "downloadCount": 0, "downloadGhCount": 0}}')))
 
         // Step 2: Upload artifact (multipart)
         wireMockServer.stubFor(post(urlMatching("/api/v1/plugins/release/.*/upload"))