@@ -6,9 +6,6 @@ import failchat.gui.ChatFrameLauncher
66import failchat.gui.GuiLauncher
77import failchat.gui.GuiMode
88import failchat.gui.PortBindAlert
9- import failchat.reporter.EventAction
10- import failchat.reporter.EventCategory
11- import failchat.reporter.EventReporter
129import failchat.skin.Skins
1310import failchat.util.CoroutineExceptionLogger
1411import failchat.util.bytesToMegabytes
@@ -29,7 +26,6 @@ import io.ktor.websocket.WebSockets
2926import io.ktor.websocket.webSocket
3027import kotlinx.coroutines.CoroutineName
3128import kotlinx.coroutines.CoroutineScope
32- import kotlinx.coroutines.Dispatchers
3329import kotlinx.coroutines.asCoroutineDispatcher
3430import kotlinx.coroutines.launch
3531import mu.KotlinLogging
@@ -42,8 +38,6 @@ import java.net.ServerSocket
4238import java.nio.file.Files
4339import java.time.Instant
4440import java.time.ZoneOffset
45- import java.util.concurrent.ScheduledExecutorService
46- import java.util.concurrent.TimeUnit
4741import kotlin.concurrent.thread
4842import kotlin.reflect.KClass
4943import io.ktor.application.Application as KtorApplication
@@ -93,11 +87,6 @@ fun main0(args: Array<String>) {
9387 httpServer.start()
9488 logger.info(" Http/websocket server started at {}:{}" , FailchatServerInfo .host.hostAddress, FailchatServerInfo .port)
9589
96-
97- // Reporter
98- val backgroundExecutor = deps.backgroundExecutorService
99- runReporterIfEnabled(backgroundExecutor, config, deps.eventReporter)
100-
10190 // If emoticon db file not exists, reset 'last-updated' config values
10291 val dbFileExists = Files .exists(emoticonDbFile)
10392 if (! dbFileExists) {
@@ -121,8 +110,11 @@ fun main0(args: Array<String>) {
121110
122111 // Load global badges in background thread
123112 val badgeManager: BadgeManager = deps.badgeManager
124- val badgeLoaderCtx = backgroundExecutor.asCoroutineDispatcher() + CoroutineName (" GlobalBadgeLoader" ) + CoroutineExceptionLogger
125- CoroutineScope (badgeLoaderCtx).launch {
113+ CoroutineScope (
114+ deps.backgroundExecutorService.asCoroutineDispatcher() +
115+ CoroutineName (" GlobalBadgeLoader" ) +
116+ CoroutineExceptionLogger
117+ ).launch {
126118 badgeManager.loadGlobalBadges()
127119 }
128120
@@ -206,7 +198,6 @@ private fun runGui(guiMode: GuiMode, deps: Dependencies) {
206198private fun parseArguments (args : Array <String >): CommandLine {
207199 val options = Options ().apply {
208200 addOption(Option (" c" , " skip-release-check" , false , " Skip the check for a new release" ))
209- addOption(Option (" r" , " disable-reporter" , false , " Disable reporter" ))
210201 addOption(Option (" l" , " logger-root-level" , true , " Logging level for root logger" ))
211202 addOption(Option (" f" , " logger-failchat-level" , true , " Logging level for failchat package" ))
212203 addOption(Option (" o" , " enable-console-logging" , false , " Enable logging into the console" ))
@@ -242,9 +233,6 @@ private fun handleProgramArguments(cmd: CommandLine, config: Configuration) {
242233 if (cmd.hasOption(" skip-release-check" )) {
243234 config.setProperty(" release-checker.enabled" , false )
244235 }
245- if (cmd.hasOption(" disable-reporter" )) {
246- config.setProperty(" reporter.enabled" , false )
247- }
248236 if (cmd.hasOption(" gui-mode" )) {
249237 config.setProperty(" gui-mode" , cmd.getOptionValue(" gui-mode" ))
250238 } else {
@@ -284,37 +272,3 @@ fun KtorApplication.failchat(wsMessageDispatcher: WsMessageDispatcher, wsFrameSe
284272 }
285273 }
286274}
287-
288- /* *
289- * Send General.AppLaunch event and schedule General.Heartbeat events.
290- * */
291- private fun runReporterIfEnabled (
292- executor : ScheduledExecutorService ,
293- config : Configuration ,
294- eventReporter : EventReporter
295- ) {
296- if (! config.getBoolean(" reporter.enabled" )) {
297- logger.info(" Event reporter is disabled and won't be running" )
298- return
299- }
300-
301- val dispatcher = executor.asCoroutineDispatcher()
302-
303- CoroutineScope (dispatcher).launch {
304- try {
305- eventReporter.report(EventCategory .GENERAL , EventAction .APP_LAUNCH )
306- } catch (t: Throwable ) {
307- logger.warn(" Failed to report event {}.{}" , EventCategory .GENERAL , EventAction .APP_LAUNCH , t)
308- }
309- }
310-
311- executor.scheduleAtFixedRate({
312- CoroutineScope (Dispatchers .Default ).launch {
313- try {
314- eventReporter.report(EventCategory .GENERAL , EventAction .HEARTBEAT )
315- } catch (t: Throwable ) {
316- logger.warn(" Failed to report event {}.{}" , EventCategory .GENERAL , EventAction .HEARTBEAT , t)
317- }
318- }
319- }, 2 , 2 , TimeUnit .MINUTES )
320- }
0 commit comments