feat: added support for BungeeCord

api/src/main/kotlin/dev/cubxity/plugins/metrics/api/platform/PlatformType.kt

@@ -21,4 +21,5 @@ package dev.cubxity.plugins.metrics.api.platform
 sealed class PlatformType(val name: String) {
     object Bukkit : PlatformType("Bukkit")
     object Velocity : PlatformType("Velocity")
+    object BungeeCord : PlatformType("BungeeCord")
 }

bungee/build.gradle.kts

@@ -0,0 +1,45 @@
+/*
+ *     UnifiedMetrics is a fully-featured metrics collection plugin for Minecraft servers.
+ *     Copyright (C) 2021  Cubxity
+ *
+ *     This program is free software: you can redistribute it and/or modify
+ *     it under the terms of the GNU Affero General Public License as published
+ *     by the Free Software Foundation, either version 3 of the License, or
+ *     (at your option) any later version.
+ *
+ *     This program is distributed in the hope that it will be useful,
+ *     but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *     GNU Affero General Public License for more details.
+ *
+ *     You should have received a copy of the GNU Affero General Public License
+ *     along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+plugins {
+    id("com.github.johnrengelman.shadow")
+}
+
+repositories {
+    maven("https://oss.sonatype.org/content/repositories/snapshots/")
+}
+
+dependencies {
+    api(project(":unifiedmetrics-core"))
+
+    compileOnly("net.md-5", "bungeecord-api", "1.17-R0.1-SNAPSHOT")
+}
+
+tasks {
+    shadowJar {
+        archiveClassifier.set("")
+    }
+    processResources {
+        duplicatesStrategy = DuplicatesStrategy.INCLUDE
+
+        from("src/main/resources") {
+            expand("version" to version)
+            include("plugin.yml")
+        }
+    }
+}

bungee/src/main/kotlin/dev/cubxity/plugins/metrics/bungee/UnifiedMetricsBungeePlugin.kt

@@ -0,0 +1,44 @@
+/*
+ *     UnifiedMetrics is a fully-featured metrics collection plugin for Minecraft servers.
+ *     Copyright (C) 2021  Cubxity
+ *
+ *     This program is free software: you can redistribute it and/or modify
+ *     it under the terms of the GNU Affero General Public License as published
+ *     by the Free Software Foundation, either version 3 of the License, or
+ *     (at your option) any later version.
+ *
+ *     This program is distributed in the hope that it will be useful,
+ *     but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *     GNU Affero General Public License for more details.
+ *
+ *     You should have received a copy of the GNU Affero General Public License
+ *     along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package dev.cubxity.plugins.metrics.bungee
+
+import dev.cubxity.plugins.metrics.api.UnifiedMetrics
+import dev.cubxity.plugins.metrics.bungee.bootstrap.UnifiedMetricsBungeeBootstrap
+import dev.cubxity.plugins.metrics.bungee.metric.EventsMetric
+import dev.cubxity.plugins.metrics.bungee.metric.server.ServerMetric
+import dev.cubxity.plugins.metrics.core.plugin.CoreUnifiedMetricsPlugin
+
+class UnifiedMetricsBungeePlugin(
+    override val bootstrap: UnifiedMetricsBungeeBootstrap
+) : CoreUnifiedMetricsPlugin() {
+    override fun registerPlatformService(api: UnifiedMetrics) {
+        // Bungee doesn't have a service manager
+    }
+
+    override fun registerPlatformMetrics() {
+        super.registerPlatformMetrics()
+
+        apiProvider.metricsManager.apply {
+            with(config.metrics.collectors) {
+                if (server) registerMetric(ServerMetric(bootstrap))
+                if (events) registerMetric(EventsMetric(bootstrap))
+            }
+        }
+    }
+}

bungee/src/main/kotlin/dev/cubxity/plugins/metrics/bungee/bootstrap/UnifiedMetricsBungeeBootstrap.kt

@@ -0,0 +1,59 @@
+/*
+ *     UnifiedMetrics is a fully-featured metrics collection plugin for Minecraft servers.
+ *     Copyright (C) 2021  Cubxity
+ *
+ *     This program is free software: you can redistribute it and/or modify
+ *     it under the terms of the GNU Affero General Public License as published
+ *     by the Free Software Foundation, either version 3 of the License, or
+ *     (at your option) any later version.
+ *
+ *     This program is distributed in the hope that it will be useful,
+ *     but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *     GNU Affero General Public License for more details.
+ *
+ *     You should have received a copy of the GNU Affero General Public License
+ *     along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package dev.cubxity.plugins.metrics.bungee.bootstrap
+
+import dev.cubxity.plugins.metrics.api.platform.PlatformType
+import dev.cubxity.plugins.metrics.bungee.UnifiedMetricsBungeePlugin
+import dev.cubxity.plugins.metrics.common.UnifiedMetricsBootstrap
+import dev.cubxity.plugins.metrics.common.plugin.dispatcher.CurrentThreadDispatcher
+import dev.cubxity.plugins.metrics.common.plugin.logger.JavaLogger
+import kotlinx.coroutines.CoroutineDispatcher
+import net.md_5.bungee.api.plugin.Plugin
+import java.nio.file.Path
+
+class UnifiedMetricsBungeeBootstrap : Plugin(), UnifiedMetricsBootstrap {
+    private val plugin = UnifiedMetricsBungeePlugin(this)
+
+    override val type: PlatformType
+        get() = PlatformType.BungeeCord
+
+    override val version: String
+        get() = description.version
+
+    override val serverBrand: String
+        get() = proxy.name
+
+    override val dataDirectory: Path
+        get() = dataFolder.toPath()
+
+    override val configDirectory: Path
+        get() = dataFolder.toPath()
+
+    override val logger = JavaLogger(getLogger())
+
+    override val dispatcher: CoroutineDispatcher = CurrentThreadDispatcher
+
+    override fun onEnable() {
+        plugin.enable()
+    }
+
+    override fun onDisable() {
+        plugin.disable()
+    }
+}

bungee/src/main/kotlin/dev/cubxity/plugins/metrics/bungee/metric/EventsMetric.kt

@@ -0,0 +1,69 @@
+/*
+ *     UnifiedMetrics is a fully-featured metrics collection plugin for Minecraft servers.
+ *     Copyright (C) 2021  Cubxity
+ *
+ *     This program is free software: you can redistribute it and/or modify
+ *     it under the terms of the GNU Affero General Public License as published
+ *     by the Free Software Foundation, either version 3 of the License, or
+ *     (at your option) any later version.
+ *
+ *     This program is distributed in the hope that it will be useful,
+ *     but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *     GNU Affero General Public License for more details.
+ *
+ *     You should have received a copy of the GNU Affero General Public License
+ *     along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package dev.cubxity.plugins.metrics.bungee.metric
+
+import dev.cubxity.plugins.metrics.api.metric.Metric
+import dev.cubxity.plugins.metrics.api.metric.collector.Counter
+import dev.cubxity.plugins.metrics.api.metric.collector.MetricCollector
+import dev.cubxity.plugins.metrics.bungee.bootstrap.UnifiedMetricsBungeeBootstrap
+import net.md_5.bungee.api.event.ChatEvent
+import net.md_5.bungee.api.event.PlayerDisconnectEvent
+import net.md_5.bungee.api.event.PostLoginEvent
+import net.md_5.bungee.api.event.ProxyPingEvent
+import net.md_5.bungee.api.plugin.Listener
+import net.md_5.bungee.event.EventHandler
+
+@Suppress("UNUSED_PARAMETER")
+class EventsMetric(private val bootstrap: UnifiedMetricsBungeeBootstrap) : Metric, Listener {
+    private val joinCounter = Counter("minecraft_events_join_total")
+    private val quitCounter = Counter("minecraft_events_quit_total")
+    private val chatCounter = Counter("minecraft_events_chat_total")
+    private val pingCounter = Counter("minecraft_events_ping_total")
+
+    override val collectors: List<MetricCollector> =
+        listOf(joinCounter, quitCounter, chatCounter, pingCounter)
+
+    override fun initialize() {
+        bootstrap.proxy.pluginManager.registerListener(bootstrap, this)
+    }
+
+    override fun dispose() {
+        bootstrap.proxy.pluginManager.unregisterListener(this)
+    }
+
+    @EventHandler
+    fun onJoin(event: PostLoginEvent) {
+        joinCounter.inc()
+    }
+
+    @EventHandler
+    fun onQuit(event: PlayerDisconnectEvent) {
+        quitCounter.inc()
+    }
+
+    @EventHandler
+    fun onChat(event: ChatEvent) {
+        chatCounter.inc()
+    }
+
+    @EventHandler
+    fun onPing(event: ProxyPingEvent) {
+        pingCounter.inc()
+    }
+}

bungee/src/main/kotlin/dev/cubxity/plugins/metrics/bungee/metric/server/ServerCollector.kt

@@ -0,0 +1,35 @@
+/*
+ *     UnifiedMetrics is a fully-featured metrics collection plugin for Minecraft servers.
+ *     Copyright (C) 2021  Cubxity
+ *
+ *     This program is free software: you can redistribute it and/or modify
+ *     it under the terms of the GNU Affero General Public License as published
+ *     by the Free Software Foundation, either version 3 of the License, or
+ *     (at your option) any later version.
+ *
+ *     This program is distributed in the hope that it will be useful,
+ *     but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *     GNU Affero General Public License for more details.
+ *
+ *     You should have received a copy of the GNU Affero General Public License
+ *     along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package dev.cubxity.plugins.metrics.bungee.metric.server
+
+import dev.cubxity.plugins.metrics.api.metric.collector.MetricCollector
+import dev.cubxity.plugins.metrics.api.metric.data.GaugeSample
+import dev.cubxity.plugins.metrics.api.metric.data.MetricSample
+import dev.cubxity.plugins.metrics.bungee.bootstrap.UnifiedMetricsBungeeBootstrap
+
+class ServerCollector(private val bootstrap: UnifiedMetricsBungeeBootstrap) : MetricCollector {
+    override fun collect(): List<MetricSample> {
+        val proxy = bootstrap.proxy
+        return listOf(
+            GaugeSample("minecraft_plugins", proxy.pluginManager.plugins.size),
+            GaugeSample("minecraft_players_count", proxy.onlineCount),
+            GaugeSample("minecraft_players_max", proxy.config.playerLimit)
+        )
+    }
+}

bungee/src/main/kotlin/dev/cubxity/plugins/metrics/bungee/metric/server/ServerMetric.kt

@@ -0,0 +1,27 @@
+/*
+ *     UnifiedMetrics is a fully-featured metrics collection plugin for Minecraft servers.
+ *     Copyright (C) 2021  Cubxity
+ *
+ *     This program is free software: you can redistribute it and/or modify
+ *     it under the terms of the GNU Affero General Public License as published
+ *     by the Free Software Foundation, either version 3 of the License, or
+ *     (at your option) any later version.
+ *
+ *     This program is distributed in the hope that it will be useful,
+ *     but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *     GNU Affero General Public License for more details.
+ *
+ *     You should have received a copy of the GNU Affero General Public License
+ *     along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package dev.cubxity.plugins.metrics.bungee.metric.server
+
+import dev.cubxity.plugins.metrics.api.metric.Metric
+import dev.cubxity.plugins.metrics.api.metric.collector.MetricCollector
+import dev.cubxity.plugins.metrics.bungee.bootstrap.UnifiedMetricsBungeeBootstrap
+
+class ServerMetric(bootstrap: UnifiedMetricsBungeeBootstrap) : Metric {
+    override val collectors: List<MetricCollector> = listOf(ServerCollector(bootstrap))
+}

bungee/src/main/resources/plugin.yml

@@ -0,0 +1,5 @@
+name: UnifiedMetrics
+main: dev.cubxity.plugins.metrics.bungee.bootstrap.UnifiedMetricsBungeeBootstrap
+description: "Fully-featured metrics plugin for Minecraft servers"
+author: Cubxity
+version: ${version}

settings.gradle.kts

@@ -25,6 +25,7 @@ include(modulePrefix + "common")
 include(modulePrefix + "core")
 include(modulePrefix + "bukkit")
 include(modulePrefix + "velocity")
+include(modulePrefix + "bungee")
 
 include(modulePrefix + "influx-driver")
 include(modulePrefix + "prometheus-driver")
@@ -34,6 +35,7 @@ project(modulePrefix + "common").projectDir = File(rootDir, "common")
 project(modulePrefix + "core").projectDir = File(rootDir, "core")
 project(modulePrefix + "bukkit").projectDir = File(rootDir, "bukkit")
 project(modulePrefix + "velocity").projectDir = File(rootDir, "velocity")
+project(modulePrefix + "bungee").projectDir = File(rootDir, "bungee")
 
 val driversDir = File(rootDir, "drivers")
 project(modulePrefix + "influx-driver").projectDir = File(driversDir, "influx")