11package nmcp
22
3+ import java.time.Duration
4+ import kotlin.time.Duration.Companion.minutes
5+ import kotlin.time.TimeSource.Monotonic.markNow
6+ import kotlin.time.toJavaDuration
7+ import kotlin.time.toKotlinDuration
38import kotlinx.serialization.json.Json
49import kotlinx.serialization.json.JsonObject
510import kotlinx.serialization.json.JsonPrimitive
@@ -14,15 +19,13 @@ import okio.ByteString
1419import org.gradle.api.DefaultTask
1520import org.gradle.api.file.RegularFileProperty
1621import org.gradle.api.provider.Property
17- import org.gradle.api.tasks.*
22+ import org.gradle.api.tasks.Input
23+ import org.gradle.api.tasks.InputFile
24+ import org.gradle.api.tasks.Optional
25+ import org.gradle.api.tasks.PathSensitive
26+ import org.gradle.api.tasks.PathSensitivity
27+ import org.gradle.api.tasks.TaskAction
1828import org.gradle.work.DisableCachingByDefault
19- import java.time.Duration
20- import kotlin.time.Duration.Companion.minutes
21- import kotlin.time.Duration.Companion.seconds
22- import kotlin.time.TimeSource.Monotonic.markNow
23- import kotlin.time.toJavaDuration
24- import kotlin.time.toKotlinDuration
25-
2629
2730@DisableCachingByDefault
2831abstract class NmcpPublishTask : DefaultTask () {
@@ -75,7 +78,7 @@ abstract class NmcpPublishTask : DefaultTask() {
7578 .addFormDataPart(
7679 " bundle" ,
7780 publicationName.get(),
78- inputFile.get().asFile.asRequestBody(" application/zip" .toMediaType())
81+ inputFile.get().asFile.asRequestBody(" application/zip" .toMediaType()),
7982 )
8083 .build()
8184
@@ -105,17 +108,20 @@ abstract class NmcpPublishTask : DefaultTask() {
105108 val timeout = verificationTimeout.orElse(10 .minutes.toJavaDuration()).get()
106109 val mark = markNow()
107110 while (true ) {
108- check (mark.elapsedNow() < timeout.toKotlinDuration()) {
111+ check(mark.elapsedNow() < timeout.toKotlinDuration()) {
109112 " Nmcp: timeout while verifying deployment status."
110113 }
111- when (val status = verifyStatus(
112- deploymentId = deploymentId,
113- endpoint = endpoint,
114- token = token,
115- )) {
114+ when (
115+ val status = verifyStatus(
116+ deploymentId = deploymentId,
117+ endpoint = endpoint,
118+ token = token,
119+ )
120+ ) {
116121 PENDING ,
117122 VALIDATING ,
118- PUBLISHING -> {
123+ PUBLISHING ,
124+ -> {
119125 // Come back later
120126 Thread .sleep(2000 )
121127 }
@@ -201,4 +207,4 @@ private fun verifyStatus(
201207 else -> error(" Nmcp: unexpected status: $state " )
202208 }
203209 }
204- }
210+ }
0 commit comments