override fun create()

in plugin-azure-server/src/main/kotlin/jetbrains/buildServer/clouds/azure/arm/connector/tasks/StartVirtualMachineTaskImpl.kt [17:55]

39 lines of code
2 McCabe index (conditional complexity)


    override fun create(api: AzureApi, taskContext: AzureTaskContext, parameter: StartVirtualMachineTaskParameter): Single<Unit> {
        LOG.debug("Starting virtual machine. Group: ${parameter.groupId}, Name: ${parameter.name}, corellationId: [${taskContext.corellationId}]")
        return api
            .virtualMachinesEx()
            .inner()
            .updateRawAsync(
                parameter.groupId,
                parameter.name,
                mapOf(
                    TEMPATE_PROPERTIES_FIELD to mapOf(
                        USERDATA_TEMPLATE_FIELD to parameter.userData
                    )
                )
            )
            .doOnNext {
                LOG.debug("Updated userData for virtual machine: ${it["id"]}. CorellationId: ${taskContext.corellationId}")
            }
            .flatMap {
                taskContext
                    .getDeferralSequence()
                    .flatMap {
                        api
                            .virtualMachines()
                            .getByResourceGroupAsync(parameter.groupId, parameter.name)
                            .flatMap { vm ->
                                if (vm != null) {
                                    vm.startAsync()
                                        .toObservable<Unit>()
                                        .concatMap { myNotifications.raise(AzureTaskVirtualMachineStatusChangedEventArgs(api, vm)) }
                                } else {
                                    LOG.warnAndDebugDetails("Could not find resource to start. GroupId: ${parameter.groupId}, Name: ${parameter.name}", null)
                                    Observable.just(Unit)
                                }
                            }
                    }
            }
            .defaultIfEmpty(Unit)
            .toSingle()
    }