working clone/copy

Author: adrw

service/src/main/kotlin/app/cash/backfila/ui/actions/BackfillCreateHandlerAction.kt

@@ -5,7 +5,9 @@ import app.cash.backfila.dashboard.StartBackfillAction
 import app.cash.backfila.dashboard.StopBackfillAction
 import app.cash.backfila.dashboard.UpdateBackfillAction
 import app.cash.backfila.protos.service.CreateBackfillRequest
-import com.squareup.wire.internal.immutableCopyOf
+import app.cash.backfila.ui.pages.BackfillCreateAction.BackfillCreateField
+import javax.inject.Inject
+import javax.inject.Singleton
 import misk.scope.ActionScoped
 import misk.security.authz.Authenticated
 import misk.web.Get
@@ -15,9 +17,9 @@ import misk.web.ResponseBody
 import misk.web.ResponseContentType
 import misk.web.actions.WebAction
 import misk.web.mediatype.MediaTypes
-import okio.ByteString
-import javax.inject.Inject
-import javax.inject.Singleton
+import misk.web.toResponseBody
+import okhttp3.Headers
+import okio.ByteString.Companion.encodeUtf8
 
 @Singleton
 class BackfillCreateHandlerAction @Inject constructor(
@@ -48,36 +50,37 @@ class BackfillCreateHandlerAction @Inject constructor(
     val formFieldNames = this.httpCall.get().asOkHttpRequest().url.queryParameterNames
     val formFields = formFieldNames.associateWith { this.httpCall.get().asOkHttpRequest().url.queryParameter(it) }
 
-
     // Submit create call
-    createBackfillAction.create(
-      service = TODO(),
-      variant = TODO(),
-      request = CreateBackfillRequest.Builder()
-        .backfill_name(TODO())
-        .dry_run(TODO())
-        .range_start(TODO())
-        .range_end(TODO())
-        .batch_size(TODO())
-        .scan_size(TODO())
-        .extra_sleep_ms(TODO())
-        .backoff_schedule(TODO())
-        .custom_parameters(
-          mapOf(
-            "mealDelayMs" to ByteString.encodeUtf8(TODO())
-          )
-        )
-        .build()
-
-
+    val createRequestBuilder = CreateBackfillRequest.Builder()
+    formFields[BackfillCreateField.BACKFILL_NAME.fieldId]?.ifNotBlank { createRequestBuilder.backfill_name(it) }
+    createRequestBuilder.dry_run(
+      when (formFields[BackfillCreateField.DRY_RUN.fieldId]) {
+        // Unchecked box in UI will not send a value
+        "off", null -> false
+        else -> true
+      },
     )
+    formFields[BackfillCreateField.RANGE_START.fieldId]?.ifNotBlank { createRequestBuilder.pkey_range_start(it.encodeUtf8()) }
+    formFields[BackfillCreateField.RANGE_END.fieldId]?.ifNotBlank { createRequestBuilder.pkey_range_end(it.encodeUtf8()) }
+    formFields[BackfillCreateField.BATCH_SIZE.fieldId]?.ifNotBlank { createRequestBuilder.batch_size(it.toLongOrNull()) }
+    formFields[BackfillCreateField.SCAN_SIZE.fieldId]?.ifNotBlank { createRequestBuilder.scan_size(it.toLongOrNull()) }
+    formFields[BackfillCreateField.THREADS_PER_PARTITION.fieldId]?.ifNotBlank { createRequestBuilder.num_threads(it.toIntOrNull()) }
+    formFields[BackfillCreateField.EXTRA_SLEEP_MS.fieldId]?.ifNotBlank { createRequestBuilder.extra_sleep_ms(it.toLongOrNull()) }
+    formFields[BackfillCreateField.BACKOFF_SCHEDULE.fieldId]?.ifNotBlank { createRequestBuilder.backoff_schedule(it) }
+    val customParameters = formFields.filter { it.key.startsWith(BackfillCreateField.CUSTOM_PARAMETER_PREFIX.fieldId) }
+      .mapValues { it.value?.encodeUtf8() }
+    if (customParameters.isNotEmpty()) {
+      createRequestBuilder.parameter_map(customParameters)
+    }
 
+    val response = createBackfillAction.create(
+      service = formFields[BackfillCreateField.SERVICE.fieldId]!!,
+      variant = formFields[BackfillCreateField.VARIANT.fieldId]!!,
+      request = createRequestBuilder.build(),
+    )
 
     // TODO get created backfill id and redirect to that page on create/clone
-    val id = 2
-
-
-
+    val id = response.backfill_run_id
 
     return Response(
       body = "go to /backfills/$id".toResponseBody(),
@@ -88,5 +91,7 @@ class BackfillCreateHandlerAction @Inject constructor(
 
   companion object {
     const val PATH = "/api/backfill/create"
+
+    private fun <T>String?.ifNotBlank(block: (String) -> T) = if (this.isNullOrBlank()) null else block(this)
   }
 }

service/src/main/kotlin/app/cash/backfila/ui/components/AutoReload.kt

@@ -9,7 +9,7 @@ import kotlinx.html.div
 //     (ie. update form for backfill show page)
 fun TagConsumer<*>.AutoReload(block: TagConsumer<*>.() -> Unit) {
   div {
-//    attributes["data-controller"] = "auto-reload"
+    attributes["data-controller"] = "auto-reload"
     attributes["data-auto-reload-target"] = "frame"
 
     block()