andrewinci/Insulator

package insulator.viewmodel.configurations

import insulator.configuration.ConfigurationRepo
import insulator.helper.dispatch
import insulator.kafka.local.LocalKafka
import insulator.kafka.model.Cluster
import insulator.viewmodel.common.InsulatorViewModel
import javafx.collections.FXCollections
import javafx.collections.ObservableList
import javax.inject.Inject

class ListClusterViewModel @Inject constructor(
    configurationRepo: ConfigurationRepo,
    private val localKafka: LocalKafka
) : InsulatorViewModel() {

    val clustersProperty: ObservableList<Cluster> = FXCollections.observableArrayList()

    init {
        configurationRepo.addNewClusterCallback { new -> with(clustersProperty) { clear(); addAll(new.clusters) } }
        configurationRepo.dispatch {
            val configurations = getConfiguration()
                .fold({ error.set(it); emptyList() }, { it.clusters })
            clustersProperty.addAll(configurations)
        }
    }

    private var cache: Cluster? = null
    suspend fun startLocalKafka(): Cluster? {
        if (cache == null) {
            localKafka.start().fold({ this.error.set(it) }, { cache = it })
        }
        return cache
    }
}