override fun registerDirectoryCleaners()

in plugin-rust-agent/src/main/kotlin/jetbrains/buildServer/rust/RustupCacheCleaner.kt [35:77]
38 lines of code
6 McCabe index (conditional complexity)

    override fun registerDirectoryCleaners(context: DirectoryCleanersProviderContext,
                                           registry: DirectoryCleanersRegistry) {
        rustupPath?.let {
            LOG.info("Registering rust toolchains directory $rustupCache for cleaning")

            registry.addCleaner(rustupCache, Date()) {
                try {
                    commandExecutor.executeWithReadLock(rustupPath, listOf("toolchain", "list"))
                            .lineSequence()
                            .filter { it.isNotBlank() && !it.endsWith("(default)") }
                            .forEach {
                                LOG.info("Removing rust toolchain $it")
                                try {
                                    commandExecutor.executeWithWriteLock(rustupPath, listOf("toolchain", "uninstall", it))
                                } catch (e: Throwable) {
                                    LOG.warnAndDebugDetails("Failed to uninstall rust toolchain $it: ${e.message}", e)
                                    LOG.info("Will try to remove toolchain $it automatically")

                                    val toolchainDirectory = File(rustupCache, "${CargoConstants.RUSTUP_TOOLCHAINS_DIR}/$it")
                                    if (!FileUtil.delete(toolchainDirectory)) {
                                        LOG.warn("Failed to delete directory: $toolchainDirectory")
                                    }

                                    val toolchainFile = File(rustupCache, "${CargoConstants.RUSTUP_HASHES_DIR}/$it")
                                    if (!FileUtil.delete(toolchainFile)) {
                                        LOG.warn("Failed to delete file: $toolchainFile")
                                    }
                                }
                            }
                } catch (e: Throwable) {
                    LOG.warnAndDebugDetails("Failed to get list of rust toolchains: ${e.message}", e)
                }
            }

            val downloads = File(rustupCache, CargoConstants.RUSTUP_DOWNLOADS_DIR)
            LOG.info("Registering directory $downloads for cleaning")
            registry.addCleaner(downloads, Date())

            val tmp = File(rustupCache, CargoConstants.RUSTUP_TMP_DIR)
            LOG.info("Registering directory $tmp for cleaning")
            registry.addCleaner(tmp, Date())
        }
    }