diff --git a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/services/PackageSearchFUSService.kt b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/services/PackageSearchFUSService.kt index 2ab63037..58c64be7 100644 --- a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/services/PackageSearchFUSService.kt +++ b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/services/PackageSearchFUSService.kt @@ -23,7 +23,7 @@ class PackageSearchFUSService(coroutineScope: CoroutineScope) { init { fusEventsFlow .onEach { it.log() } - .retry { + .retry(5) { logWarn("${this::class.qualifiedName}#eventReportingJob", it) { "Failed to log FUS" } true } diff --git a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/services/PackageSearchProjectService.kt b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/services/PackageSearchProjectService.kt index a853b63a..f8d074f8 100644 --- a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/services/PackageSearchProjectService.kt +++ b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/services/PackageSearchProjectService.kt @@ -12,7 +12,6 @@ import com.intellij.psi.PsiManager import com.jetbrains.packagesearch.plugin.PackageSearchModuleBaseTransformerUtils import com.jetbrains.packagesearch.plugin.core.extensions.PackageSearchKnownRepositoriesContext import com.jetbrains.packagesearch.plugin.core.utils.IntelliJApplication -import com.jetbrains.packagesearch.plugin.core.utils.PackageSearchProjectCachesService import com.jetbrains.packagesearch.plugin.core.utils.fileOpenedFlow import com.jetbrains.packagesearch.plugin.core.utils.replayOn import com.jetbrains.packagesearch.plugin.core.utils.toolWindowOpenedFlow @@ -79,7 +78,7 @@ class PackageSearchProjectService( .getKnownRepositories() .associateBy { it.id } } - .retry { + .retry(5) { logWarn("${this::class.simpleName}#knownRepositoriesStateFlow", throwable = it) true } @@ -169,7 +168,7 @@ class PackageSearchProjectService( .filter { it } .throttle(30.minutes) .onEach { restart() } - .retry { + .retry(5) { logWarn("${this::class.simpleName}#isOnlineFlow", throwable = it) true } @@ -188,7 +187,7 @@ class PackageSearchProjectService( ?.let { DaemonCodeAnalyzer.getInstance(project).restart(it) } } } - .retry { + .retry(5) { logWarn("${this::class.simpleName}#fileOpenedFlow", throwable = it) true } diff --git a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/ToolWindowViewModel.kt b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/ToolWindowViewModel.kt index aac7fe25..02fad081 100644 --- a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/ToolWindowViewModel.kt +++ b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/ToolWindowViewModel.kt @@ -82,7 +82,7 @@ class ToolWindowViewModel(project: Project, private val viewModelScope: Coroutin else -> PackageSearchToolWindowState.NoModules } } - .retry() + .retry(5) .stateIn( scope = viewModelScope, started = SharingStarted.Lazily, diff --git a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/infopanel/InfoPanelViewModel.kt b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/infopanel/InfoPanelViewModel.kt index 3782b9f0..67d6eeaa 100644 --- a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/infopanel/InfoPanelViewModel.kt +++ b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/infopanel/InfoPanelViewModel.kt @@ -74,7 +74,7 @@ class InfoPanelViewModel( } } } - .retry() + .retry(5) .stateIn(viewModelScope, SharingStarted.Eagerly, emptyList()) private val activeTabTitleMutableStateFlow: MutableStateFlow = MutableStateFlow(null) diff --git a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/packageslist/PackageListViewModel.kt b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/packageslist/PackageListViewModel.kt index 02556253..76b11f12 100644 --- a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/packageslist/PackageListViewModel.kt +++ b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/packageslist/PackageListViewModel.kt @@ -170,7 +170,7 @@ class PackageListViewModel( current } } - .retry() + .retry(5) .stateIn(viewModelScope, SharingStarted.Eagerly, emptyMap()) val selectableLazyListState = SelectableLazyListState(LazyListState()) @@ -202,7 +202,7 @@ class PackageListViewModel( } } } - .retry() + .retry(5) .stateIn(viewModelScope, SharingStarted.WhileSubscribed(), emptyList()) private suspend fun PackageSearchModule.Base.getSearchQuery( diff --git a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/tree/TreeViewModel.kt b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/tree/TreeViewModel.kt index 9ab9bd0b..2c15073c 100644 --- a/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/tree/TreeViewModel.kt +++ b/plugin/src/main/kotlin/com/jetbrains/packagesearch/plugin/ui/model/tree/TreeViewModel.kt @@ -33,7 +33,7 @@ internal class TreeViewModel( ) { modules, stableOnly -> modules.asTree(stableOnly) } - .retry() + .retry(5) .onEach { logDebug("${this::class.qualifiedName}#treeStateFlow") { it.print() } } .stateIn(viewModelScope, SharingStarted.Lazily, emptyTree())