Fix duration deserialisation

Signed-off-by: Paolo Di Tommaso <[email protected]>

Author: pditommaso

src/main/groovy/io/seqera/wave/encoder/DateTimeAdapter.groovy

@@ -32,7 +32,12 @@ class DateTimeAdapter {
     }
 
     @FromJson
-    Duration deserializeDuration(Long value) {
-        return value != null ? Duration.ofNanos(value) : null
+    Duration deserializeDuration(String value) {
+        if( value==null )
+            return null
+        // for backward compatibility duration may be encoded as float value
+        // instead of long (number of nanoseconds) as expected
+        final val0 = value.contains('.') ? Math.round(value.toDouble() * 1_000_000_000) : value.toLong()
+        return value != null ? Duration.ofNanos(val0) : null
     }
 }

src/test/groovy/io/seqera/wave/encoder/MoshiEncodingStrategyTest.groovy

@@ -2,6 +2,7 @@ package io.seqera.wave.encoder
 
 import spock.lang.Specification
 
+import java.time.Duration
 import java.time.Instant
 
 import io.seqera.wave.api.ContainerConfig
@@ -36,6 +37,22 @@ class MoshiEncodingStrategyTest extends Specification {
         copy == build
     }
 
+    def 'should decode old format build result' () {
+        given:
+        def encoder = new MoshiEncodeStrategy<BuildResult>() { }
+        and:
+        def json = '{"id":"100","exitStatus":1,"logs":"logs","startTime":"2022-12-03T22:27:04.079724Z","duration":60.000000000}'
+
+        when:
+        def build = encoder.decode(json)
+        then:
+        build.id == '100'
+        build.exitStatus == 1
+        build.logs == 'logs'
+        build.startTime == Instant.parse('2022-12-03T22:27:04.079724Z')
+        build.duration == Duration.ofSeconds(60)
+    }
+
     def 'should encode and decode ContainerRequestData' () {
         given:
         def encoder = new MoshiEncodeStrategy<ContainerRequestData>() { }