rework for 1.21, and it works!

This reduces memory usage by reusing block state objects.

.github/workflows-disabled/build.yml

@@ -0,0 +1,25 @@
+name: Build
+on: [push]
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Repository
+        uses: actions/checkout@v3
+      - name: Set up JDK 17
+        uses: actions/setup-java@v3
+        with:
+          java-version: '17'
+          distribution: 'temurin'
+      - name: Build with Gradle
+        uses: gradle/gradle-build-action@v2
+        with:
+          arguments: build check
+      - name: Organize Artifacts
+        run: ./tools/organize-artifacts.sh
+      - name: Upload Artifacts
+        uses: actions/upload-artifact@v3
+        with:
+          name: foundation-build
+          path: |
+            artifacts/*

.github/workflows-disabled/release.yml

@@ -0,0 +1,36 @@
+name: Release
+on:
+  push:
+    branches:
+      - main
+jobs:
+  upload:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Repository
+        uses: actions/checkout@v3
+      - name: Set up JDK 17
+        uses: actions/setup-java@v3
+        with:
+          java-version: '17'
+          distribution: 'temurin'
+      - name: Build with Gradle
+        uses: gradle/gradle-build-action@v2
+        with:
+          arguments: build
+        env:
+          CONCRETE_BUILD_NUMBER: "${{ github.run_number }}"
+      - name: Organize Artifacts
+        run: ./tools/organize-artifacts.sh
+      - name: Upload to Backblaze
+        run: ./tools/gh-upload-backblaze.sh
+        env:
+          ARTIFACTS_KEY_ID: "${{ secrets.ARTIFACTS_KEY_ID }}"
+          ARTIFACTS_APP_KEY: "${{ secrets.ARTIFACTS_APP_KEY }}"
+          ARTIFACTS_BUCKET: "${{ secrets.ARTIFACTS_BUCKET }}"
+      - name: Upload Artifacts
+        uses: actions/upload-artifact@v3
+        with:
+          name: foundation-build
+          path: |
+            artifacts/*

.gitignore

@@ -116,3 +116,10 @@ run/
 
 # Avoid ignoring Gradle wrapper jar file (.jar files are usually ignored)
 !gradle-wrapper.jar
+
+# Foundation Server
+/server
+
+# Foundation build
+/.concrete-local-path
+/artifacts

.gitlab-ci.yml

@@ -1,18 +0,0 @@
-image: gradle:7.3-jdk17
-
-variables:
-  GRADLE_OPTS: "-Dorg.gradle.daemon=false"
-
-build:
-  stage: build
-  script: gradle --build-cache assemble
-  cache:
-    key: "$CI_COMMIT_REF_NAME"
-    policy: push
-    paths:
-      - build
-      - .gradle
-  artifacts:
-    paths:
-      - "build/manifests/update.json"
-      - "**/build/libs/*-plugin.jar"

LICENSE

@@ -1,202 +1,21 @@
+MIT License
 
-                                 Apache License
-                           Version 2.0, January 2004
-                        http://www.apache.org/licenses/
+Copyright (c) 2023 Gay Pizza Specifications
 
-   TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
 
-   1. Definitions.
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
 
-      "License" shall mean the terms and conditions for use, reproduction,
-      and distribution as defined by Sections 1 through 9 of this document.
-
-      "Licensor" shall mean the copyright owner or entity authorized by
-      the copyright owner that is granting the License.
-
-      "Legal Entity" shall mean the union of the acting entity and all
-      other entities that control, are controlled by, or are under common
-      control with that entity. For the purposes of this definition,
-      "control" means (i) the power, direct or indirect, to cause the
-      direction or management of such entity, whether by contract or
-      otherwise, or (ii) ownership of fifty percent (50%) or more of the
-      outstanding shares, or (iii) beneficial ownership of such entity.
-
-      "You" (or "Your") shall mean an individual or Legal Entity
-      exercising permissions granted by this License.
-
-      "Source" form shall mean the preferred form for making modifications,
-      including but not limited to software source code, documentation
-      source, and configuration files.
-
-      "Object" form shall mean any form resulting from mechanical
-      transformation or translation of a Source form, including but
-      not limited to compiled object code, generated documentation,
-      and conversions to other media types.
-
-      "Work" shall mean the work of authorship, whether in Source or
-      Object form, made available under the License, as indicated by a
-      copyright notice that is included in or attached to the work
-      (an example is provided in the Appendix below).
-
-      "Derivative Works" shall mean any work, whether in Source or Object
-      form, that is based on (or derived from) the Work and for which the
-      editorial revisions, annotations, elaborations, or other modifications
-      represent, as a whole, an original work of authorship. For the purposes
-      of this License, Derivative Works shall not include works that remain
-      separable from, or merely link (or bind by name) to the interfaces of,
-      the Work and Derivative Works thereof.
-
-      "Contribution" shall mean any work of authorship, including
-      the original version of the Work and any modifications or additions
-      to that Work or Derivative Works thereof, that is intentionally
-      submitted to Licensor for inclusion in the Work by the copyright owner
-      or by an individual or Legal Entity authorized to submit on behalf of
-      the copyright owner. For the purposes of this definition, "submitted"
-      means any form of electronic, verbal, or written communication sent
-      to the Licensor or its representatives, including but not limited to
-      communication on electronic mailing lists, source code control systems,
-      and issue tracking systems that are managed by, or on behalf of, the
-      Licensor for the purpose of discussing and improving the Work, but
-      excluding communication that is conspicuously marked or otherwise
-      designated in writing by the copyright owner as "Not a Contribution."
-
-      "Contributor" shall mean Licensor and any individual or Legal Entity
-      on behalf of whom a Contribution has been received by Licensor and
-      subsequently incorporated within the Work.
-
-   2. Grant of Copyright License. Subject to the terms and conditions of
-      this License, each Contributor hereby grants to You a perpetual,
-      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
-      copyright license to reproduce, prepare Derivative Works of,
-      publicly display, publicly perform, sublicense, and distribute the
-      Work and such Derivative Works in Source or Object form.
-
-   3. Grant of Patent License. Subject to the terms and conditions of
-      this License, each Contributor hereby grants to You a perpetual,
-      worldwide, non-exclusive, no-charge, royalty-free, irrevocable
-      (except as stated in this section) patent license to make, have made,
-      use, offer to sell, sell, import, and otherwise transfer the Work,
-      where such license applies only to those patent claims licensable
-      by such Contributor that are necessarily infringed by their
-      Contribution(s) alone or by combination of their Contribution(s)
-      with the Work to which such Contribution(s) was submitted. If You
-      institute patent litigation against any entity (including a
-      cross-claim or counterclaim in a lawsuit) alleging that the Work
-      or a Contribution incorporated within the Work constitutes direct
-      or contributory patent infringement, then any patent licenses
-      granted to You under this License for that Work shall terminate
-      as of the date such litigation is filed.
-
-   4. Redistribution. You may reproduce and distribute copies of the
-      Work or Derivative Works thereof in any medium, with or without
-      modifications, and in Source or Object form, provided that You
-      meet the following conditions:
-
-      (a) You must give any other recipients of the Work or
-          Derivative Works a copy of this License; and
-
-      (b) You must cause any modified files to carry prominent notices
-          stating that You changed the files; and
-
-      (c) You must retain, in the Source form of any Derivative Works
-          that You distribute, all copyright, patent, trademark, and
-          attribution notices from the Source form of the Work,
-          excluding those notices that do not pertain to any part of
-          the Derivative Works; and
-
-      (d) If the Work includes a "NOTICE" text file as part of its
-          distribution, then any Derivative Works that You distribute must
-          include a readable copy of the attribution notices contained
-          within such NOTICE file, excluding those notices that do not
-          pertain to any part of the Derivative Works, in at least one
-          of the following places: within a NOTICE text file distributed
-          as part of the Derivative Works; within the Source form or
-          documentation, if provided along with the Derivative Works; or,
-          within a display generated by the Derivative Works, if and
-          wherever such third-party notices normally appear. The contents
-          of the NOTICE file are for informational purposes only and
-          do not modify the License. You may add Your own attribution
-          notices within Derivative Works that You distribute, alongside
-          or as an addendum to the NOTICE text from the Work, provided
-          that such additional attribution notices cannot be construed
-          as modifying the License.
-
-      You may add Your own copyright statement to Your modifications and
-      may provide additional or different license terms and conditions
-      for use, reproduction, or distribution of Your modifications, or
-      for any such Derivative Works as a whole, provided Your use,
-      reproduction, and distribution of the Work otherwise complies with
-      the conditions stated in this License.
-
-   5. Submission of Contributions. Unless You explicitly state otherwise,
-      any Contribution intentionally submitted for inclusion in the Work
-      by You to the Licensor shall be under the terms and conditions of
-      this License, without any additional terms or conditions.
-      Notwithstanding the above, nothing herein shall supersede or modify
-      the terms of any separate license agreement you may have executed
-      with Licensor regarding such Contributions.
-
-   6. Trademarks. This License does not grant permission to use the trade
-      names, trademarks, service marks, or product names of the Licensor,
-      except as required for reasonable and customary use in describing the
-      origin of the Work and reproducing the content of the NOTICE file.
-
-   7. Disclaimer of Warranty. Unless required by applicable law or
-      agreed to in writing, Licensor provides the Work (and each
-      Contributor provides its Contributions) on an "AS IS" BASIS,
-      WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-      implied, including, without limitation, any warranties or conditions
-      of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
-      PARTICULAR PURPOSE. You are solely responsible for determining the
-      appropriateness of using or redistributing the Work and assume any
-      risks associated with Your exercise of permissions under this License.
-
-   8. Limitation of Liability. In no event and under no legal theory,
-      whether in tort (including negligence), contract, or otherwise,
-      unless required by applicable law (such as deliberate and grossly
-      negligent acts) or agreed to in writing, shall any Contributor be
-      liable to You for damages, including any direct, indirect, special,
-      incidental, or consequential damages of any character arising as a
-      result of this License or out of the use or inability to use the
-      Work (including but not limited to damages for loss of goodwill,
-      work stoppage, computer failure or malfunction, or any and all
-      other commercial damages or losses), even if such Contributor
-      has been advised of the possibility of such damages.
-
-   9. Accepting Warranty or Additional Liability. While redistributing
-      the Work or Derivative Works thereof, You may choose to offer,
-      and charge a fee for, acceptance of support, warranty, indemnity,
-      or other liability obligations and/or rights consistent with this
-      License. However, in accepting such obligations, You may act only
-      on Your own behalf and on Your sole responsibility, not on behalf
-      of any other Contributor, and only if You agree to indemnify,
-      defend, and hold each Contributor harmless for any liability
-      incurred by, or claims asserted against, such Contributor by reason
-      of your accepting any such warranty or additional liability.
-
-   END OF TERMS AND CONDITIONS
-
-   APPENDIX: How to apply the Apache License to your work.
-
-      To apply the Apache License to your work, attach the following
-      boilerplate notice, with the fields enclosed by brackets "[]"
-      replaced with your own identifying information. (Don't include
-      the brackets!)  The text should be enclosed in the appropriate
-      comment syntax for the file format. We also recommend that a
-      file or class name and description of purpose be included on the
-      same "printed page" as the copyright notice for easier
-      identification within third-party archives.
-
-   Copyright [yyyy] [name of copyright owner]
-
-   Licensed under the Apache License, Version 2.0 (the "License");
-   you may not use this file except in compliance with the License.
-   You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-   Unless required by applicable law or agreed to in writing, software
-   distributed under the License is distributed on an "AS IS" BASIS,
-   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-   See the License for the specific language governing permissions and
-   limitations under the License.
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -1,7 +1,34 @@
 # Foundation
+
 Foundation is a set of plugins that implement the core functionality for a small community Minecraft
 server.
 
 ## Plugins
-* foundation-core - Core functionality
-* foundation-bifrost - Discord chat bridge
+
+* foundation-core: Core functionality
+* foundation-bifrost: Discord chat bridge
+* foundation-chaos: Simulate chaos inside a minecraft world
+* foundation-heimdall: Event tracking
+* foundation-tailscale: Connect the Minecraft Server to Tailscale
+
+## Tools
+
+* tool-gjallarhorn - Heimdall swiss army knife
+
+## Libraries
+
+* common-all: Common code for every Foundation module.
+* common-plugin: Common code for every Foundation plugin. Included directly in the plugin jar.
+* common-heimdall: Common code for Heimdall modules.
+* foundation-shared: Common code for every Foundation plugin. Linked dynamically from Foundation Core.
+
+## Installation
+
+The following command downloads and runs a script that will fetch the latest update manifest, and
+install all plugins available. It can also be used to update plugins to the latest version
+available.
+
+```bash
+# Always validate the contents of a script from the internet!
+bash -c "$(curl -sL https://github.com/GayPizzaSpecifications/foundation/raw/main/install.sh)"
+```

build.gradle.kts

@@ -1,24 +1,21 @@
-import com.github.jengelman.gradle.plugins.shadow.tasks.ShadowJar
-import org.jetbrains.kotlin.com.google.gson.Gson
-import java.io.FileWriter
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
 
+@Suppress("DSL_SCOPE_VIOLATION")
 plugins {
   java
-  id("org.jetbrains.kotlin.jvm") version "1.6.10" apply false
-  id("org.jetbrains.kotlin.plugin.serialization") version "1.6.10" apply false
-  id("com.github.johnrengelman.shadow") version "7.1.1" apply false
-}
 
-// Disable the JAR task for the root project.
-tasks["jar"].enabled = false
+  alias(libs.plugins.concrete.root)
+  alias(libs.plugins.concrete.base) apply false
+  alias(libs.plugins.concrete.library) apply false
+  alias(libs.plugins.concrete.plugin) apply false
+
+  alias(libs.plugins.versions)
+}
 
 allprojects {
   repositories {
     mavenCentral()
-    maven {
-      name = "papermc-repo"
-      url = uri("https://papermc.io/repo/repository/maven-public/")
-    }
+
     maven {
       name = "sonatype"
       url = uri("https://oss.sonatype.org/content/groups/public/")
@@ -26,93 +23,23 @@ allprojects {
   }
 }
 
-val manifestsDir = buildDir.resolve("manifests")
-manifestsDir.mkdirs()
-val gson = Gson()
-
-tasks.create("updateManifests") {
-  // TODO: not using task dependencies, outputs, blah blah blah.
-  doLast {
-    val updateFile = manifestsDir.resolve("update.json")
-    val writer = FileWriter(updateFile)
-    writer.use {
-      val rootPath = rootProject.rootDir.toPath()
-      val updateManifest = subprojects.mapNotNull { project ->
-        val files = project.tasks.getByName("shadowJar").outputs
-        val paths = files.files.map { rootPath.relativize(it.toPath()).toString() }
-
-        if (paths.isNotEmpty()) project.name to mapOf(
-          "version" to project.version,
-          "artifacts" to paths,
-        )
-        else null
-      }.toMap()
-
-      gson.toJson(
-        updateManifest,
-        writer
-      )
-    }
-  }
-}
-
-tasks.assemble {
-  dependsOn("updateManifests")
-}
+version = "0.2"
 
 subprojects {
-  plugins.apply("org.jetbrains.kotlin.jvm")
-  plugins.apply("org.jetbrains.kotlin.plugin.serialization")
-  plugins.apply("com.github.johnrengelman.shadow")
+  group = "gay.pizza.foundation"
 
-  version = "0.1"
-  group = "io.gorence"
-
-  // Add build number if running under CI.
-  val versionWithBuild = if (System.getenv("CI_PIPELINE_IID") != null) {
-    version as String + ".${System.getenv("CI_PIPELINE_IID")}"
-  } else {
-    "DEV"
-  }
-  version = versionWithBuild
-
-  dependencies {
-    // Kotlin dependencies
-    implementation(platform("org.jetbrains.kotlin:kotlin-bom"))
-    implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8")
-
-    // Serialization
-    implementation("com.charleskorn.kaml:kaml:0.38.0")
-    implementation("org.jetbrains.kotlinx:kotlinx-serialization-json:1.3.1")
-
-    // Persistence
-    implementation("org.jetbrains.xodus:xodus-openAPI:1.3.232")
-    implementation("org.jetbrains.xodus:xodus-entity-store:1.3.232")
-
-    // Paper API
-    compileOnly("io.papermc.paper:paper-api:1.18.1-R0.1-SNAPSHOT")
-  }
-
-  java {
-    val javaVersion = JavaVersion.toVersion(17)
-    sourceCompatibility = javaVersion
-    targetCompatibility = javaVersion
-  }
-
-  tasks.processResources {
-    val props = mapOf("version" to version)
-    inputs.properties(props)
-    filteringCharset = "UTF-8"
-    filesMatching("plugin.yml") {
-      expand(props)
+  tasks.withType<KotlinCompile> {
+    compilerOptions {
+      freeCompilerArgs.add("-opt-in=kotlinx.serialization.ExperimentalSerializationApi")
     }
   }
-
-  tasks.withType<ShadowJar> {
-    archiveClassifier.set("plugin")
-  }
-
-  tasks.assemble {
-    dependsOn("shadowJar")
-  }
+}
+
+val paperServerVersion: String = project.properties["paperServerVersion"]?.toString() ?: "1.21"
+
+concreteRoot {
+  minecraftServerPath.set("server")
+  paperServerVersionGroup.set(paperServerVersion)
+  paperApiVersion.set("1.21.4-R0.1-SNAPSHOT")
+  acceptServerEula.set(true)
 }

common-all/build.gradle.kts

@@ -0,0 +1,9 @@
+plugins {
+  id("gay.pizza.foundation.concrete-base")
+}
+
+dependencies {
+  // Serialization
+  api(libs.kotlin.serialization.json)
+  api(libs.kotlin.serialization.yaml)
+}

common-all/src/main/kotlin/gay/pizza/foundation/common/CommonExtensions.kt

@@ -0,0 +1,3 @@
+package gay.pizza.foundation.common
+
+fun <T> Array<T>.without(value: T): List<T> = filter { it != value }

common-heimdall/build.gradle.kts

@@ -0,0 +1,11 @@
+plugins {
+  id("gay.pizza.foundation.concrete-base")
+}
+
+dependencies {
+  api(project(":common-all"))
+  api(libs.postgresql)
+  api(libs.exposed.jdbc)
+  api(libs.exposed.java.time)
+  api(libs.hikaricp)
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/export/ExportedBlock.kt

@@ -0,0 +1,9 @@
+package gay.pizza.foundation.heimdall.export
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class ExportedBlock(
+  val type: String,
+  val data: String? = null
+)

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/export/ExportedChunk.kt

@@ -0,0 +1,11 @@
+package gay.pizza.foundation.heimdall.export
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class ExportedChunk(
+  val blocks: List<ExportedBlock>,
+  val x: Int,
+  val z: Int,
+  val sections: List<ExportedChunkSection>
+)

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/export/ExportedChunkSection.kt

@@ -0,0 +1,10 @@
+package gay.pizza.foundation.heimdall.export
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class ExportedChunkSection(
+  val x: Int,
+  val z: Int,
+  val blocks: List<Int>
+)

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/load/ExportedBlockTable.kt

@@ -0,0 +1,19 @@
+package gay.pizza.foundation.heimdall.load
+
+import gay.pizza.foundation.heimdall.export.ExportedBlock
+
+class ExportedBlockTable {
+  private val internalBlocks = mutableListOf<ExportedBlock>()
+
+  val blocks: List<ExportedBlock>
+    get() = internalBlocks
+
+  fun index(block: ExportedBlock): Int {
+    val existing = internalBlocks.indexOf(block)
+    if (existing >= 0) {
+      return existing
+    }
+    internalBlocks.add(block)
+    return internalBlocks.size - 1
+  }
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/load/WorldLoadCompactWorld.kt

@@ -0,0 +1,69 @@
+package gay.pizza.foundation.heimdall.load
+
+import kotlinx.serialization.Serializable
+import kotlin.math.absoluteValue
+
+@Serializable
+data class OffsetList<L: List<T>, T>(
+  val offset: Int,
+  val data: L
+) {
+  fun <K> toMap(toKey: (Int) -> K): Map<K, T> {
+    val map = mutableMapOf<K, T>()
+    for ((index, value) in data.withIndex()) {
+      val real = index + offset
+      val key = toKey(real)
+      map[key] = value
+    }
+    return map
+  }
+
+  fun <R> map(value: (T) -> R): ImmutableOffsetList<R> =
+    ImmutableOffsetList(offset, MutableList(data.size) { index -> value(data[index]) })
+
+  fun eachRealIndex(block: (Int, T) -> Unit) {
+    for ((fakeIndex, value) in data.withIndex()) {
+      val realIndex = fakeIndex + offset
+      block(realIndex, value)
+    }
+  }
+
+  companion object {
+    fun <K, T, V> transform(
+      map: Map<K, T>,
+      minAndTotal: (Map<K, T>) -> Pair<Int, Int>,
+      keyToInt: (K) -> Int,
+      valueTransform: (T) -> V
+    ): ImmutableOffsetList<V?> {
+      val (min, total) = minAndTotal(map)
+      val offset = if (min < 0) min.absoluteValue else 0
+      val list = MutableList<V?>(total) { null }
+      for ((key, value) in map) {
+        val pkey = keyToInt(key)
+        val rkey = pkey + offset
+          list[rkey] = valueTransform(value)
+      }
+      return OffsetList(if (min < 0) min else 0, list)
+    }
+  }
+}
+
+typealias ImmutableOffsetList<T> = OffsetList<List<T>, T>
+
+@Serializable
+class WorldLoadCompactWorld(
+  override val name: String,
+  val data: ImmutableOffsetList<ImmutableOffsetList<ImmutableOffsetList<Int?>?>?>
+) : WorldLoadWorld() {
+  override fun crawl(block: (Long, Long, Long, Int) -> Unit) {
+    data.eachRealIndex { x, zList ->
+      zList?.eachRealIndex { z, yList ->
+        yList?.eachRealIndex { y, index ->
+          if (index != null) {
+            block(x.toLong(), z.toLong(), y.toLong(), index)
+          }
+        }
+      }
+    }
+  }
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/load/WorldLoadFormat.kt

@@ -0,0 +1,10 @@
+package gay.pizza.foundation.heimdall.load
+
+import gay.pizza.foundation.heimdall.export.ExportedBlock
+import kotlinx.serialization.Serializable
+
+@Serializable
+class WorldLoadFormat(
+  val blockLookupTable: List<ExportedBlock>,
+  val worlds: Map<String, WorldLoadWorld>
+)

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/load/WorldLoadSimpleWorld.kt

@@ -0,0 +1,64 @@
+package gay.pizza.foundation.heimdall.load
+
+import kotlinx.serialization.Serializable
+import kotlin.math.absoluteValue
+
+@Serializable
+class WorldLoadSimpleWorld(
+  override val name: String,
+  val blocks: Map<Long, Map<Long, Map<Long, Int>>>
+) : WorldLoadWorld() {
+  fun compact(): WorldLoadCompactWorld {
+    val list = OffsetList.transform(
+      blocks,
+      minAndTotal = ::minAndTotal,
+      keyToInt = Long::toInt,
+      valueTransform = { zValue ->
+        OffsetList.transform(
+          zValue,
+          minAndTotal = ::minAndTotal,
+          keyToInt = Long::toInt,
+          valueTransform = { yValue ->
+            OffsetList.transform(
+              yValue,
+              minAndTotal = ::minAndTotal,
+              keyToInt = Long::toInt,
+              valueTransform = { it }
+            )
+          }
+        )
+      })
+    return WorldLoadCompactWorld(name, list)
+  }
+
+  private fun <T> minAndTotal(map: Map<Long, T>): Pair<Int, Int> {
+    val keys = map.keys
+
+    if (keys.isEmpty()) {
+      return 0 to 0
+    }
+
+    val min = keys.min()
+    val max = keys.max()
+    var total = 1L
+
+    if (max > 0) {
+      total += max
+    }
+
+    if (min < 0) {
+      total += min.absoluteValue
+    }
+    return min.toInt() to total.toInt()
+  }
+
+  override fun crawl(block: (Long, Long, Long, Int) -> Unit) {
+    for ((x, zBlocks) in blocks) {
+      for ((z, yBlocks) in zBlocks) {
+        for ((y, index) in yBlocks) {
+          block(x, z, y, index)
+        }
+      }
+    }
+  }
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/load/WorldLoadWorld.kt

@@ -0,0 +1,10 @@
+package gay.pizza.foundation.heimdall.load
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+sealed class WorldLoadWorld {
+  abstract val name: String
+
+  abstract fun crawl(block: (Long, Long, Long, Int) -> Unit)
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/BlockChangeTable.kt

@@ -0,0 +1,8 @@
+package gay.pizza.foundation.heimdall.table
+
+object BlockChangeTable : PlayerTimedLocalEventTable("block_changes") {
+  val block = text("block")
+  val data = text("data")
+  val cause = text("cause")
+  val inc = integer("inc")
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/EntityKillTable.kt

@@ -0,0 +1,6 @@
+package gay.pizza.foundation.heimdall.table
+
+object EntityKillTable : PlayerTimedLocalEventTable("entity_kills") {
+  val entity = uuid("entity")
+  val entityType = text("entity_type")
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/PlayerAdvancementTable.kt

@@ -0,0 +1,5 @@
+package gay.pizza.foundation.heimdall.table
+
+object PlayerAdvancementTable : PlayerTimedLocalEventTable("player_advancements") {
+  val advancement = text("advancement")
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/PlayerDeathTable.kt

@@ -0,0 +1,6 @@
+package gay.pizza.foundation.heimdall.table
+
+object PlayerDeathTable : PlayerTimedLocalEventTable("player_deaths") {
+  val experience = double("experience")
+  val message = text("message").nullable()
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/PlayerPositionTable.kt

@@ -0,0 +1,3 @@
+package gay.pizza.foundation.heimdall.table
+
+object PlayerPositionTable : PlayerTimedLocalEventTable("player_positions")

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/PlayerSessionTable.kt

@@ -0,0 +1,12 @@
+package gay.pizza.foundation.heimdall.table
+
+import org.jetbrains.exposed.sql.Table
+import org.jetbrains.exposed.sql.javatime.timestamp
+
+object PlayerSessionTable : Table("player_sessions") {
+  val id = uuid("id")
+  val player = uuid("player")
+  val name = text("name")
+  val startTime = timestamp("start")
+  val endTime = timestamp("end")
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/PlayerTimedLocalEventTable.kt

@@ -0,0 +1,7 @@
+package gay.pizza.foundation.heimdall.table
+
+abstract class PlayerTimedLocalEventTable(name: String) : TimedLocalEventTable(name) {
+  val player = uuid("player").nullable()
+  val pitch = double("pitch")
+  val yaw = double("yaw")
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/TimedEventTable.kt

@@ -0,0 +1,8 @@
+package gay.pizza.foundation.heimdall.table
+
+import org.jetbrains.exposed.sql.Table
+import org.jetbrains.exposed.sql.javatime.timestamp
+
+abstract class TimedEventTable(name: String) : Table(name) {
+  val time = timestamp("time")
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/TimedLocalEventTable.kt

@@ -0,0 +1,8 @@
+package gay.pizza.foundation.heimdall.table
+
+abstract class TimedLocalEventTable(name: String) : TimedEventTable(name) {
+  val world = uuid("world")
+  val x = double("x")
+  val y = double("y")
+  val z = double("z")
+}

common-heimdall/src/main/kotlin/gay/pizza/foundation/heimdall/table/WorldChangeTable.kt

@@ -0,0 +1,9 @@
+package gay.pizza.foundation.heimdall.table
+
+object WorldChangeTable : TimedEventTable("world_changes") {
+  val player = uuid("player")
+  val fromWorld = uuid("from_world")
+  val toWorld = uuid("to_world")
+  val fromWorldName = text("from_world_name")
+  val toWorldName = text("to_world_name")
+}

common-plugin/build.gradle.kts

@@ -0,0 +1,8 @@
+plugins {
+  id("gay.pizza.foundation.concrete-library")
+}
+
+dependencies {
+  api(project(":common-all"))
+  compileOnly(project(":foundation-shared"))
+}

common-plugin/src/main/kotlin/gay/pizza/foundation/common/BaseFoundationPlugin.kt

@@ -0,0 +1,34 @@
+package gay.pizza.foundation.common
+
+import gay.pizza.foundation.shared.IFoundationCore
+import gay.pizza.foundation.shared.loadConfigurationWithDefault
+import kotlinx.serialization.DeserializationStrategy
+import org.bukkit.command.CommandExecutor
+import org.bukkit.command.TabCompleter
+import org.bukkit.plugin.java.JavaPlugin
+
+abstract class BaseFoundationPlugin : JavaPlugin() {
+  fun registerCommandExecutor(name: String, executor: CommandExecutor) {
+    registerCommandExecutor(listOf(name), executor)
+  }
+
+  fun registerCommandExecutor(names: List<String>, executor: CommandExecutor) {
+    for (name in names) {
+      val command = getCommand(name) ?: throw Exception("Failed to get $name command")
+      command.setExecutor(executor)
+      if (executor is TabCompleter) {
+        command.tabCompleter = executor
+      }
+    }
+  }
+
+  inline fun <reified T> loadConfigurationWithDefault(
+    core: IFoundationCore,
+    deserializer: DeserializationStrategy<T>,
+    name: String
+  ): T {
+    return loadConfigurationWithDefault(
+      slF4JLogger, deserializer,
+      core.pluginDataPath, name)
+  }
+}

common-plugin/src/main/kotlin/gay/pizza/foundation/common/ChatExtensions.kt

@@ -0,0 +1,7 @@
+package gay.pizza.foundation.common
+
+import org.bukkit.entity.Player
+
+fun Player.chat(vararg messages: String): Unit = messages.forEach { message ->
+  chat(message)
+}

common-plugin/src/main/kotlin/gay/pizza/foundation/common/CollectionExtensions.kt

@@ -1,4 +1,4 @@
-package cloud.kubelet.foundation.core
+package gay.pizza.foundation.common
 
 fun <T, R : Comparable<R>> Collection<T>.sortedBy(order: SortOrder, selector: (T) -> R?): List<T> =
   if (order == SortOrder.Ascending) {

common-plugin/src/main/kotlin/gay/pizza/foundation/common/FoundationCoreLoader.kt

@@ -0,0 +1,11 @@
+package gay.pizza.foundation.common
+
+import gay.pizza.foundation.shared.IFoundationCore
+import org.bukkit.Server
+
+object FoundationCoreLoader {
+  fun get(server: Server): IFoundationCore {
+    return server.pluginManager.getPlugin("Foundation") as IFoundationCore?
+      ?: throw RuntimeException("Foundation Core is not loaded!")
+  }
+}

common-plugin/src/main/kotlin/gay/pizza/foundation/common/ServerExtensions.kt

@@ -1,4 +1,4 @@
-package cloud.kubelet.foundation.core
+package gay.pizza.foundation.common
 
 import org.bukkit.Material
 import org.bukkit.OfflinePlayer
@@ -9,7 +9,7 @@ import org.bukkit.entity.EntityType
 val Server.allPlayers: List<OfflinePlayer>
   get() = listOf(onlinePlayers, offlinePlayers.filter { !isPlayerOnline(it) }.toList()).flatten()
 
-fun Server.isPlayerOnline(player: OfflinePlayer) =
+fun Server.isPlayerOnline(player: OfflinePlayer): Boolean =
   onlinePlayers.any { onlinePlayer -> onlinePlayer.name == player.name }
 
 fun Server.allPlayerStatisticsOf(
@@ -17,7 +17,7 @@ fun Server.allPlayerStatisticsOf(
   material: Material? = null,
   entityType: EntityType? = null,
   order: SortOrder = SortOrder.Ascending
-) = allPlayers.map { player ->
+): List<Pair<OfflinePlayer, Int>> = allPlayers.map { player ->
   player to if (material != null) {
     player.getStatistic(statistic, material)
   } else if (entityType != null) {

common-plugin/src/main/kotlin/gay/pizza/foundation/common/SortOrder.kt

@@ -1,4 +1,4 @@
-package cloud.kubelet.foundation.core
+package gay.pizza.foundation.common
 
 enum class SortOrder {
   Ascending,

common-plugin/src/main/kotlin/gay/pizza/foundation/common/SpawnExtensions.kt

@@ -0,0 +1,12 @@
+package gay.pizza.foundation.common
+
+import org.bukkit.Location
+import org.bukkit.World
+import org.bukkit.entity.Entity
+import org.bukkit.entity.Player
+import kotlin.reflect.KClass
+
+fun <T: Entity> World.spawn(location: Location, clazz: KClass<T>): T = spawn(location, clazz.java)
+
+fun <T: Entity> Player.spawn(clazz: KClass<T>): T = spawn(clazz.java)
+fun <T: Entity> Player.spawn(clazz: Class<T>): T = world.spawn(location, clazz)

foundation-bifrost/build.gradle.kts

@@ -1,7 +1,16 @@
+plugins {
+  id("gay.pizza.foundation.concrete-plugin")
+}
+
 dependencies {
-  implementation("net.dv8tion:JDA:5.0.0-alpha.2") {
+  implementation(libs.discord.jda) {
     exclude(module = "opus-java")
   }
 
-  compileOnly(project(":foundation-core"))
+  implementation(project(":common-plugin"))
+  compileOnly(project(":foundation-shared"))
+}
+
+concreteItem {
+  dependency(project(":foundation-core"))
 }

foundation-bifrost/src/main/kotlin/cloud/kubelet/foundation/bifrost/FoundationBifrostPlugin.kt

@@ -1,139 +0,0 @@
-package cloud.kubelet.foundation.bifrost
-
-import cloud.kubelet.foundation.bifrost.model.BifrostConfig
-import cloud.kubelet.foundation.core.FoundationCorePlugin
-import cloud.kubelet.foundation.core.Util
-import com.charleskorn.kaml.Yaml
-import io.papermc.paper.event.player.AsyncChatEvent
-import net.dv8tion.jda.api.EmbedBuilder
-import net.dv8tion.jda.api.JDA
-import net.dv8tion.jda.api.JDABuilder
-import net.dv8tion.jda.api.MessageBuilder
-import net.dv8tion.jda.api.entities.TextChannel
-import net.dv8tion.jda.api.events.GenericEvent
-import net.dv8tion.jda.api.events.ReadyEvent
-import net.dv8tion.jda.api.events.message.MessageReceivedEvent
-import net.dv8tion.jda.api.hooks.EventListener
-import net.kyori.adventure.text.Component
-import net.kyori.adventure.text.TextComponent
-import org.bukkit.event.EventHandler
-import org.bukkit.event.Listener
-import org.bukkit.event.player.PlayerJoinEvent
-import org.bukkit.event.player.PlayerQuitEvent
-import org.bukkit.plugin.java.JavaPlugin
-import java.awt.Color
-import kotlin.io.path.inputStream
-
-class FoundationBifrostPlugin : JavaPlugin(), EventListener, Listener {
-  private lateinit var config: BifrostConfig
-  private lateinit var jda: JDA
-  private var isDev = false
-
-  override fun onEnable() {
-    isDev = description.version == "DEV"
-
-    val foundation = server.pluginManager.getPlugin("Foundation") as FoundationCorePlugin
-    slF4JLogger.info("Plugin data path: ${foundation.pluginDataPath}")
-
-    val configPath = Util.copyDefaultConfig<FoundationBifrostPlugin>(
-      slF4JLogger,
-      foundation.pluginDataPath,
-      "bifrost.yaml"
-    )
-    config = Yaml.default.decodeFromStream(BifrostConfig.serializer(), configPath.inputStream())
-
-    server.pluginManager.registerEvents(this, this)
-
-    jda = JDABuilder
-      .createDefault(config.authentication.token)
-      .addEventListeners(this)
-      .build()
-  }
-
-  override fun onDisable() {
-    onServerStop()
-
-    logger.info("Shutting down JDA")
-    jda.shutdown()
-    while (jda.status != JDA.Status.SHUTDOWN) {
-      Thread.sleep(100)
-    }
-  }
-
-  override fun onEvent(e: GenericEvent) {
-    when (e) {
-      is ReadyEvent -> {
-        val channel = getChannel() ?: return
-        if (isDev) return
-        channel.sendMessage(":white_check_mark: Server is ready!").queue()
-      }
-      is MessageReceivedEvent -> {
-        // Prevent this bot from receiving its own messages and creating a feedback loop.
-        if (e.author.id == jda.selfUser.id) return
-
-        // Only forward messages from the configured channel.
-        if (e.channel.id != config.channel.id) return
-
-        slF4JLogger.debug(
-          "${e.guild.name} - ${e.channel.name} - ${e.author.name}: ${e.message.contentDisplay}"
-        )
-        server.sendMessage(Component.text("${e.author.name} - ${e.message.contentDisplay}"))
-      }
-    }
-  }
-
-  private fun getChannel(): TextChannel? {
-    val channel = jda.getTextChannelById(config.channel.id)
-    if (channel == null) {
-      slF4JLogger.error("Failed to retrieve channel ${config.channel.id}")
-    }
-    return channel
-  }
-
-  private fun message(f: MessageBuilder.() -> Unit) = MessageBuilder().apply(f).build()
-  private fun MessageBuilder.embed(f: EmbedBuilder.() -> Unit) {
-    setEmbeds(EmbedBuilder().apply(f).build())
-  }
-
-  @EventHandler
-  private fun onPlayerJoin(e: PlayerJoinEvent) {
-    val channel = getChannel() ?: return
-
-    channel.sendMessage(message {
-      embed {
-        setAuthor("${e.player.name} joined the server")
-        setColor(Color.GREEN)
-      }
-    }).queue()
-  }
-
-  @EventHandler
-  private fun onPlayerQuit(e: PlayerQuitEvent) {
-    val channel = getChannel() ?: return
-
-    channel.sendMessage(message {
-      embed {
-        setAuthor("${e.player.name} left the server")
-        setColor(Color.RED)
-      }
-    }).queue()
-  }
-
-  @EventHandler
-  private fun onPlayerChat(e: AsyncChatEvent) {
-    val channel = getChannel() ?: return
-    val message = e.message()
-
-    if (message is TextComponent) {
-      channel.sendMessage("${e.player.name}: ${message.content()}").queue()
-    } else {
-      slF4JLogger.error("Not sure what to do here, message != TextComponent: ${message.javaClass}")
-    }
-  }
-
-  private fun onServerStop() {
-    val channel = getChannel() ?: return
-    if (isDev) return
-    channel.sendMessage(":octagonal_sign: Server is stopping!").queue()
-  }
-}

foundation-bifrost/src/main/kotlin/cloud/kubelet/foundation/bifrost/model/BifrostConfig.kt

@@ -1,19 +0,0 @@
-package cloud.kubelet.foundation.bifrost.model
-
-import kotlinx.serialization.Serializable
-
-@Serializable
-data class BifrostConfig(
-  val authentication: BifrostAuthentication,
-  val channel: BifrostChannel,
-)
-
-@Serializable
-data class BifrostAuthentication(
-  val token: String,
-)
-
-@Serializable
-data class BifrostChannel(
-  val id: String,
-)

foundation-bifrost/src/main/kotlin/gay/pizza/foundation/bifrost/FoundationBifrostPlugin.kt

@@ -0,0 +1,188 @@
+package gay.pizza.foundation.bifrost
+
+import gay.pizza.foundation.bifrost.model.BifrostConfig
+import gay.pizza.foundation.common.BaseFoundationPlugin
+import gay.pizza.foundation.common.FoundationCoreLoader
+import gay.pizza.foundation.shared.AdvancementTitleCache
+import gay.pizza.foundation.shared.PluginMainClass
+import io.papermc.paper.event.player.AsyncChatEvent
+import net.dv8tion.jda.api.EmbedBuilder
+import net.dv8tion.jda.api.JDA
+import net.dv8tion.jda.api.JDABuilder
+import net.dv8tion.jda.api.entities.channel.concrete.TextChannel
+import net.dv8tion.jda.api.events.GenericEvent
+import net.dv8tion.jda.api.events.message.MessageReceivedEvent
+import net.dv8tion.jda.api.events.session.ReadyEvent
+import net.dv8tion.jda.api.utils.messages.MessageCreateBuilder
+import net.dv8tion.jda.api.utils.messages.MessageCreateData
+import net.kyori.adventure.text.Component
+import net.kyori.adventure.text.serializer.legacy.LegacyComponentSerializer
+import org.bukkit.event.EventHandler
+import org.bukkit.event.EventPriority
+import org.bukkit.event.entity.PlayerDeathEvent
+import org.bukkit.event.player.PlayerAdvancementDoneEvent
+import org.bukkit.event.player.PlayerJoinEvent
+import org.bukkit.event.player.PlayerQuitEvent
+import java.awt.Color
+import net.dv8tion.jda.api.hooks.EventListener as DiscordEventListener
+import org.bukkit.event.Listener as BukkitEventListener
+
+@PluginMainClass
+class FoundationBifrostPlugin : BaseFoundationPlugin(), DiscordEventListener, BukkitEventListener {
+  private lateinit var config: BifrostConfig
+  private var jda: JDA? = null
+  private var isDev = false
+
+  override fun onEnable() {
+    isDev = description.version == "DEV"
+    val foundation = FoundationCoreLoader.get(server)
+    config = loadConfigurationWithDefault(
+      foundation,
+      BifrostConfig.serializer(),
+      "bifrost.yaml"
+    )
+    server.pluginManager.registerEvents(this, this)
+    if (config.authentication.token.isEmpty()) {
+      slF4JLogger.warn("Token empty, Bifrost will not connect to Discord.")
+      return
+    }
+
+    jda = JDABuilder
+      .createDefault(config.authentication.token)
+      .addEventListeners(this)
+      .build()
+  }
+
+  override fun onDisable() {
+    // Plugin was not initialized, don't do anything.
+    if (jda == null) return
+
+    onServerStop()
+
+    logger.info("Shutting down JDA")
+    jda?.shutdown()
+    while (jda != null && jda!!.status != JDA.Status.SHUTDOWN) {
+      Thread.sleep(100)
+    }
+  }
+
+  override fun onEvent(e: GenericEvent) {
+    when (e) {
+      is ReadyEvent -> {
+        onDiscordReady()
+      }
+      is MessageReceivedEvent -> {
+        if (!config.channel.bridge) return
+        // Prevent this bot from receiving its own messages and creating a feedback loop.
+        if (e.author.id == jda?.selfUser?.id) return
+
+        // Only forward messages from the configured channel.
+        if (e.channel.id != config.channel.id) return
+
+        slF4JLogger.debug(
+          "${e.guild.name} - ${e.channel.name} - ${e.author.name}: ${e.message.contentDisplay}"
+        )
+        server.sendMessage(Component.text("${e.author.name} - ${e.message.contentDisplay}"))
+      }
+    }
+  }
+
+  private fun getTextChannel(): TextChannel? {
+    if (jda == null) {
+      return null
+    }
+
+    val channel = jda?.getTextChannelById(config.channel.id)
+    if (channel == null) {
+      slF4JLogger.error("Failed to retrieve channel ${config.channel.id}")
+    }
+    return channel
+  }
+
+  private fun message(f: MessageCreateBuilder.() -> Unit) = MessageCreateBuilder().apply(f).build()
+  private fun MessageCreateBuilder.embed(f: EmbedBuilder.() -> Unit) {
+    setEmbeds(EmbedBuilder().apply(f).build())
+  }
+
+  private fun sendChannelMessage(message: MessageCreateData, debug: () -> String) {
+    val channel = getTextChannel()
+    channel?.sendMessage(message)?.queue()
+
+    if (config.enableDebugLog) {
+      slF4JLogger.info("Send '${debug()}' to Discord")
+    }
+  }
+
+  private fun sendChannelMessage(message: String): Unit = sendChannelMessage(message {
+    setContent(message)
+  }) { message }
+
+  private fun sendEmbedMessage(color: Color, message: String): Unit = sendChannelMessage(message {
+    embed {
+      setAuthor(message)
+      setColor(color)
+    }
+  }) { "[rgb:${color.rgb}] $message" }
+
+  @EventHandler(priority = EventPriority.MONITOR)
+  private fun onPlayerJoin(e: PlayerJoinEvent) {
+    if (!config.channel.sendPlayerJoin) return
+
+    sendEmbedMessage(Color.GREEN, "${e.player.name} joined the server")
+  }
+
+  @EventHandler(priority = EventPriority.MONITOR)
+  private fun onPlayerQuit(e: PlayerQuitEvent) {
+    if (!config.channel.sendPlayerQuit) return
+
+    sendEmbedMessage(Color.RED, "${e.player.name} left the server")
+  }
+
+  @EventHandler(priority = EventPriority.MONITOR)
+  private fun onPlayerChat(e: AsyncChatEvent) {
+    if (!config.channel.bridge) return
+    val message = e.message()
+
+    val messageAsText = LegacyComponentSerializer.legacySection().serialize(message)
+    sendChannelMessage("${e.player.name}: $messageAsText")
+  }
+
+  @EventHandler(priority = EventPriority.MONITOR)
+  private fun onPlayerDeath(e: PlayerDeathEvent) {
+    if (!config.channel.sendPlayerDeath) return
+    @Suppress("DEPRECATION")
+    var deathMessage = e.deathMessage
+    if (deathMessage.isNullOrBlank()) {
+      deathMessage = "${e.player.name} died"
+    }
+    sendEmbedMessage(Color.YELLOW, deathMessage)
+  }
+
+  @EventHandler(priority = EventPriority.MONITOR)
+  private fun onPlayerAdvancementDone(e: PlayerAdvancementDoneEvent) {
+    if (!config.channel.sendPlayerAdvancement) return
+    if (e.advancement.key.key.contains("recipe/")) {
+      return
+    }
+
+    val advancementDisplay = e.advancement.display ?: return
+    if (!advancementDisplay.doesAnnounceToChat()) {
+      return
+    }
+
+    val display = AdvancementTitleCache.of(e.advancement) ?: return
+    sendEmbedMessage(Color.CYAN, "${e.player.name} completed the advancement '${display}'")
+  }
+
+  private fun onDiscordReady() {
+    if (!config.channel.sendStart) return
+    if (isDev) return
+    sendChannelMessage(":white_check_mark: Server is ready!")
+  }
+
+  private fun onServerStop() {
+    if (!config.channel.sendShutdown) return
+    if (isDev) return
+    sendChannelMessage(":octagonal_sign: Server is stopping!")
+  }
+}

foundation-bifrost/src/main/kotlin/gay/pizza/foundation/bifrost/model/BifrostConfig.kt

@@ -0,0 +1,27 @@
+package gay.pizza.foundation.bifrost.model
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class BifrostConfig(
+  val authentication: BifrostAuthentication,
+  val channel: BifrostChannel,
+  val enableDebugLog: Boolean = false
+)
+
+@Serializable
+data class BifrostAuthentication(
+  val token: String,
+)
+
+@Serializable
+data class BifrostChannel(
+  val id: String,
+  val bridge: Boolean = true,
+  val sendStart: Boolean = true,
+  val sendShutdown: Boolean = true,
+  val sendPlayerJoin: Boolean = true,
+  val sendPlayerQuit: Boolean = true,
+  val sendPlayerDeath: Boolean = true,
+  val sendPlayerAdvancement: Boolean = true
+)

foundation-bifrost/src/main/resources/bifrost.yaml

@@ -1,10 +1,25 @@
 # Authentication configuration for the bridge.
 authentication:
-  # Token from the Discord Bot developer's page.
-  token: abc123
+  # Token from the Discord Bot developer's page. If this is empty, the Bifrost plugin will do
+  # nothing.
+  token: ""
 
 # Channel configuration for the bridge.
 channel:
   # Channel ID, can be copied by turning on Developer Mode in User Settings -> Advanced. The ID can
   # then be copied by right-clicking the channel and selecting "Copy ID".
   id: 123456789
+
+  # Toggles the chat message bridge.
+  bridge: true
+
+  # Toggles for common events that generate notifications that are sent to the channel.
+  sendStart: true
+  sendShutdown: true
+  sendPlayerJoin: true
+  sendPlayerQuit: true
+  sendPlayerDeath: true
+  sendPlayerAdvancement: true
+
+# Enables logging of what is sent to Discord.
+enableDebugLog: false

foundation-bifrost/src/main/resources/plugin.yml

@@ -1,10 +1,11 @@
 name: Foundation-Bifrost
 version: '${version}'
-main: cloud.kubelet.foundation.bifrost.FoundationBifrostPlugin
+main: gay.pizza.foundation.bifrost.FoundationBifrostPlugin
 api-version: 1.18
 prefix: Foundation-Bifrost
 load: STARTUP
 depend:
   - Foundation
 authors:
-  - kubelet
+  - kubeliv
+  - azenla

foundation-chaos/build.gradle.kts

@@ -0,0 +1,13 @@
+plugins {
+  id("gay.pizza.foundation.concrete-plugin")
+}
+
+dependencies {
+  implementation(project(":common-all"))
+  implementation(project(":common-plugin"))
+  compileOnly(project(":foundation-shared"))
+}
+
+concreteItem {
+  dependency(project(":foundation-core"))
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/ChaosController.kt

@@ -0,0 +1,94 @@
+package gay.pizza.foundation.chaos
+
+import gay.pizza.foundation.chaos.model.ChaosConfig
+import gay.pizza.foundation.chaos.modules.ChaosModule
+import gay.pizza.foundation.chaos.modules.ChaosModules
+import org.bukkit.boss.BarColor
+import org.bukkit.boss.BarStyle
+import org.bukkit.boss.BossBar
+import org.bukkit.event.EventHandler
+import org.bukkit.event.HandlerList
+import org.bukkit.event.Listener
+import org.bukkit.event.player.PlayerJoinEvent
+import org.bukkit.plugin.Plugin
+import java.util.concurrent.atomic.AtomicBoolean
+
+class ChaosController(val plugin: Plugin, val config: ChaosConfig) : Listener {
+  val state: AtomicBoolean = AtomicBoolean(false)
+  val selectorController = ChaosSelectorController(this, plugin)
+
+  val allModules = ChaosModules.all(plugin)
+  var allowedModules: List<ChaosModule> = emptyList()
+
+  private var activeModules = mutableSetOf<ChaosModule>()
+
+  var bossBar: BossBar? = null
+
+  fun load() {
+    if (state.get()) {
+      return
+    }
+    allowedModules = filterEnabledModules()
+    state.set(true)
+    selectorController.schedule()
+    bossBar = plugin.server.createBossBar("Chaos Mode", BarColor.RED, BarStyle.SOLID)
+    for (player in plugin.server.onlinePlayers) {
+      bossBar?.addPlayer(player)
+    }
+  }
+
+  private fun filterEnabledModules(): List<ChaosModule> = allModules.filter { module ->
+    val moduleConfig = config.modules[module.id()] ?: config.defaultModuleConfiguration
+    moduleConfig.enabled
+  }
+
+  fun activateAll() {
+    for (module in allowedModules) {
+      if (activeModules.contains(module)) {
+        continue
+      }
+      activate(module)
+    }
+  }
+
+  fun activate(module: ChaosModule) {
+    plugin.server.pluginManager.registerEvents(module, plugin)
+    module.activate()
+    activeModules.add(module)
+    updateBossBar()
+  }
+
+  fun deactivate(module: ChaosModule) {
+    HandlerList.unregisterAll(module)
+    module.deactivate()
+    activeModules.remove(module)
+    updateBossBar()
+  }
+
+  fun updateBossBar() {
+    val activeModuleText = activeModules.joinToString(", ") { it.name() }
+    bossBar?.setTitle("Chaos Mode: $activeModuleText")
+  }
+
+  fun deactivateAll() {
+    for (module in activeModules.toList()) {
+      deactivate(module)
+    }
+  }
+
+  @EventHandler
+  fun onPlayerJoin(event: PlayerJoinEvent) {
+    bossBar?.addPlayer(event.player)
+  }
+
+  fun unload() {
+    if (!state.get()) {
+      return
+    }
+    deactivateAll()
+    bossBar?.removeAll()
+    bossBar = null
+    state.set(false)
+    selectorController.cancel()
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/ChaosSelectorController.kt

@@ -0,0 +1,27 @@
+package gay.pizza.foundation.chaos
+
+import org.bukkit.plugin.Plugin
+import org.bukkit.scheduler.BukkitTask
+
+class ChaosSelectorController(val controller: ChaosController, val plugin: Plugin) {
+  var task: BukkitTask? = null
+
+  fun schedule() {
+    cancel()
+    task = plugin.server.scheduler.runTaskTimer(controller.plugin, { ->
+      select()
+    }, 20, controller.config.selection.timerTicks)
+  }
+
+  fun select() {
+    controller.deactivateAll()
+    val module = controller.allowedModules.randomOrNull()
+    if (module != null) {
+      controller.activate(module)
+    }
+  }
+
+  fun cancel() {
+    task?.cancel()
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/ChaosToggleCommand.kt

@@ -0,0 +1,30 @@
+package gay.pizza.foundation.chaos
+
+import net.kyori.adventure.text.Component
+import org.bukkit.command.Command
+import org.bukkit.command.CommandExecutor
+import org.bukkit.command.CommandSender
+
+class ChaosToggleCommand : CommandExecutor {
+  override fun onCommand(
+    sender: CommandSender,
+    command: Command,
+    label: String,
+    args: Array<out String>
+  ): Boolean {
+    val plugin = sender.server.pluginManager.getPlugin("Foundation-Chaos") as FoundationChaosPlugin
+    if (!plugin.config.allowed) {
+      sender.sendMessage("Chaos is not allowed.")
+      return true
+    }
+    val controller = plugin.controller
+    if (controller.state.get()) {
+      controller.unload()
+      sender.server.broadcast(Component.text("Chaos Mode Disabled"))
+    } else {
+      controller.load()
+      sender.server.broadcast(Component.text("Chaos Mode Enabled"))
+    }
+    return true
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/ChaosTools.kt

@@ -0,0 +1,11 @@
+package gay.pizza.foundation.chaos
+
+import org.bukkit.Location
+import org.bukkit.Server
+import org.bukkit.entity.Player
+
+fun Location.nearestPlayer(): Player? =
+  world?.players?.minByOrNull { it.location.distance(this) }
+
+fun Server.randomPlayer(): Player? =
+  onlinePlayers.randomOrNull()

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/FoundationChaosPlugin.kt

@@ -0,0 +1,25 @@
+package gay.pizza.foundation.chaos
+
+import gay.pizza.foundation.chaos.model.ChaosConfig
+import gay.pizza.foundation.common.BaseFoundationPlugin
+import gay.pizza.foundation.common.FoundationCoreLoader
+import gay.pizza.foundation.shared.PluginMainClass
+
+@PluginMainClass
+class FoundationChaosPlugin : BaseFoundationPlugin() {
+  lateinit var config: ChaosConfig
+
+  val controller by lazy {
+    ChaosController(this, config)
+  }
+
+  override fun onEnable() {
+    val foundation = FoundationCoreLoader.get(server)
+    config = loadConfigurationWithDefault(
+      foundation,
+      ChaosConfig.serializer(),
+      "chaos.yaml"
+    )
+    registerCommandExecutor("chaos", ChaosToggleCommand())
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/model/ChaosConfig.kt

@@ -0,0 +1,21 @@
+package gay.pizza.foundation.chaos.model
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+class ChaosConfig(
+  val allowed: Boolean = true,
+  val defaultModuleConfiguration: ChaosModuleConfig,
+  val modules: Map<String, ChaosModuleConfig> = emptyMap(),
+  val selection: ChaosSelectionConfig
+)
+
+@Serializable
+class ChaosModuleConfig(
+  val enabled: Boolean
+)
+
+@Serializable
+class ChaosSelectionConfig(
+  val timerTicks: Long
+)

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/ChaosHelpers.kt

@@ -0,0 +1,71 @@
+package gay.pizza.foundation.chaos.modules
+
+import org.bukkit.Chunk
+import org.bukkit.ChunkSnapshot
+import org.bukkit.World
+import org.bukkit.block.Block
+import org.bukkit.entity.Player
+import org.bukkit.plugin.Plugin
+import org.bukkit.scheduler.BukkitScheduler
+
+val World.heightRange
+  get() = minHeight until maxHeight
+
+inline fun forEachChunkPosition(crossinline each: (Int, Int) -> Unit) {
+  for (x in 0..15) {
+    for (z in 0..15) {
+      each(x, z)
+    }
+  }
+}
+
+inline fun Chunk.forEachPosition(crossinline each: (Int, Int, Int) -> Unit) {
+  for (x in 0..15) {
+    for (z in 0..15) {
+      for (y in world.heightRange) {
+        each(x, y, z)
+      }
+    }
+  }
+}
+
+inline fun Chunk.forEachBlock(crossinline each: (Int, Int, Int, Block) -> Unit) {
+  forEachPosition { x, y, z ->
+    each(x, y, z, getBlock(x, y, z))
+  }
+}
+
+fun Chunk.applyChunkSnapshot(snapshot: ChunkSnapshot) {
+  forEachPosition { x, y, z ->
+    val blockData = snapshot.getBlockData(x, y, z)
+    val block = getBlock(x, y, z)
+    block.blockData = blockData
+  }
+}
+
+fun Player.teleportHighestLocation() {
+  teleport(location.toHighestLocation().add(0.0, 1.0, 0.0))
+}
+
+fun <T> BukkitScheduler.scheduleUntilEmpty(
+  plugin: Plugin,
+  items: MutableList<T>,
+  ticksBetween: Long,
+  callback: (T) -> Unit
+) {
+  fun performOne() {
+    if (items.isEmpty()) {
+      return
+    }
+    val item = items.removeAt(0)
+    callback(item)
+
+    if (items.isNotEmpty()) {
+      runTaskLater(plugin, { ->
+        performOne()
+      }, ticksBetween)
+    }
+  }
+
+  performOne()
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/ChaosModule.kt

@@ -0,0 +1,11 @@
+package gay.pizza.foundation.chaos.modules
+
+import org.bukkit.event.Listener
+
+interface ChaosModule : Listener {
+  fun id(): String
+  fun name(): String
+  fun what(): String
+  fun activate() {}
+  fun deactivate() {}
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/ChaosModules.kt

@@ -0,0 +1,16 @@
+package gay.pizza.foundation.chaos.modules
+
+import org.bukkit.plugin.Plugin
+
+object ChaosModules {
+  fun all(plugin: Plugin) = listOf(
+    NearestPlayerEntitySpawn(plugin),
+    TeleportAllEntitiesNearestPlayer(plugin),
+    KillRandomPlayer(plugin),
+    TntAllPlayers(plugin),
+    MegaTnt(plugin),
+    PlayerSwap(plugin),
+    WorldSwapper(plugin),
+    ChunkEnterRotate()
+  ).shuffled()
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/ChunkEnterRotate.kt

@@ -0,0 +1,37 @@
+package gay.pizza.foundation.chaos.modules
+
+import org.bukkit.Chunk
+import org.bukkit.entity.Player
+import org.bukkit.event.EventHandler
+import org.bukkit.event.player.PlayerMoveEvent
+import java.util.WeakHashMap
+
+class ChunkEnterRotate : ChaosModule {
+  override fun id(): String = "chunk-enter-rotate"
+  override fun name(): String = "Chunk Enter Rotate"
+  override fun what(): String = "Rotates the chunk when the player enters a chunk."
+
+  private val playerChunkMap = WeakHashMap<Player, Chunk>()
+
+  @EventHandler
+  fun onPotentialChunkMove(event: PlayerMoveEvent) {
+    val player = event.player
+    val currentChunk = event.player.chunk
+    val previousChunk = playerChunkMap.put(player, currentChunk)
+    if (previousChunk == null || previousChunk == currentChunk) {
+      return
+    }
+    rotateChunk(currentChunk)
+    if (!player.isFlying) {
+      player.teleportHighestLocation()
+    }
+  }
+
+  private fun rotateChunk(chunk: Chunk) {
+    val snapshot = chunk.chunkSnapshot
+    chunk.forEachBlock { x, y, z, rotatedBlock ->
+      val originalBlockData = snapshot.getBlockData(z, y, x)
+      rotatedBlock.blockData = originalBlockData
+    }
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/KillRandomPlayer.kt

@@ -0,0 +1,14 @@
+package gay.pizza.foundation.chaos.modules
+
+import org.bukkit.plugin.Plugin
+
+class KillRandomPlayer(val plugin: Plugin) : ChaosModule {
+  override fun id(): String = "kill-random-player"
+  override fun name(): String = "Random Kill"
+  override fun what(): String = "Kill a random player."
+
+  override fun activate() {
+    val player = plugin.server.onlinePlayers.randomOrNull() ?: return
+    player.damage(1000000.0)
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/MegaTnt.kt

@@ -0,0 +1,19 @@
+package gay.pizza.foundation.chaos.modules
+
+import gay.pizza.foundation.common.spawn
+import org.bukkit.entity.TNTPrimed
+import org.bukkit.plugin.Plugin
+
+class MegaTnt(val plugin: Plugin) : ChaosModule {
+  override fun id(): String = "mega-tnt"
+  override fun name(): String = "Mega TNT"
+  override fun what(): String = "Spawn a massive TNT explosion"
+
+  override fun activate() {
+    for (player in plugin.server.onlinePlayers) {
+      val tnt = player.spawn(TNTPrimed::class)
+      tnt.fuseTicks = 1
+      tnt.yield = 10.0f
+    }
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/NearestPlayerEntitySpawn.kt

@@ -0,0 +1,22 @@
+package gay.pizza.foundation.chaos.modules
+
+import gay.pizza.foundation.chaos.nearestPlayer
+import org.bukkit.event.EventHandler
+import org.bukkit.event.entity.EntitySpawnEvent
+import org.bukkit.plugin.Plugin
+
+class NearestPlayerEntitySpawn(val plugin: Plugin) : ChaosModule {
+  override fun id(): String = "nearest-player-entity-spawn"
+  override fun name(): String = "Monster Me"
+  override fun what(): String = "Teleport all spawned entities to the nearest player"
+
+  @EventHandler
+  fun onMobSpawn(e: EntitySpawnEvent) {
+    val player = e.location.nearestPlayer()
+    if (player != null) {
+      e.entity.server.scheduler.runTask(plugin) { ->
+        e.entity.teleport(player)
+      }
+    }
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/PlayerSwap.kt

@@ -0,0 +1,30 @@
+package gay.pizza.foundation.chaos.modules
+
+import org.bukkit.Location
+import org.bukkit.entity.Player
+import org.bukkit.plugin.Plugin
+
+class PlayerSwap(val plugin: Plugin) : ChaosModule {
+  override fun id(): String = "player-swap"
+  override fun name(): String = "Player Swap"
+  override fun what(): String = "Randomly swaps player positions."
+
+  override fun activate() {
+    for (world in plugin.server.worlds) {
+      if (world.playerCount <= 0) {
+        continue
+      }
+
+      val players = world.players
+      val map = mutableMapOf<Player, Location>()
+      for (player in players) {
+        val next = players.filter { it != player }.randomOrNull() ?: continue
+        map[player] = next.location.clone()
+      }
+
+      for ((player, next) in map) {
+        player.teleport(next)
+      }
+    }
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/TeleportAllEntitiesNearestPlayer.kt

@@ -0,0 +1,21 @@
+package gay.pizza.foundation.chaos.modules
+
+import gay.pizza.foundation.chaos.nearestPlayer
+import org.bukkit.plugin.Plugin
+
+class TeleportAllEntitiesNearestPlayer(val plugin: Plugin) : ChaosModule {
+  override fun id(): String = "teleport-all-entities-nearest-player"
+  override fun name(): String = "Monster Me Once"
+  override fun what(): String = "Teleport all entities to the nearest player"
+
+  override fun activate() {
+    for (world in plugin.server.worlds) {
+      for (entity in world.entities) {
+        val player = entity.location.nearestPlayer()
+        if (player != null) {
+          entity.teleport(player)
+        }
+      }
+    }
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/TntAllPlayers.kt

@@ -0,0 +1,17 @@
+package gay.pizza.foundation.chaos.modules
+
+import gay.pizza.foundation.common.spawn
+import org.bukkit.entity.TNTPrimed
+import org.bukkit.plugin.Plugin
+
+class TntAllPlayers(val plugin: Plugin) : ChaosModule {
+  override fun id(): String = "tnt-all-players"
+  override fun name(): String = "TNT Us All"
+  override fun what(): String = "TNT All Players"
+
+  override fun activate() {
+    for (player in plugin.server.onlinePlayers) {
+      player.spawn(TNTPrimed::class)
+    }
+  }
+}

foundation-chaos/src/main/kotlin/gay/pizza/foundation/chaos/modules/WorldSwapper.kt

@@ -0,0 +1,81 @@
+package gay.pizza.foundation.chaos.modules
+
+import gay.pizza.foundation.chaos.randomPlayer
+import gay.pizza.foundation.common.without
+import org.bukkit.Chunk
+import org.bukkit.ChunkSnapshot
+import org.bukkit.block.Block
+import org.bukkit.block.data.BlockData
+import org.bukkit.plugin.Plugin
+
+class WorldSwapper(val plugin: Plugin) : ChaosModule {
+  override fun id(): String = "world-swapper"
+  override fun name(): String = "World Swapper"
+  override fun what(): String = "Swaps the world vertically on activation, and un-swaps it on deactivation."
+
+  var chunkInversions = mutableListOf<ChunkInversion>()
+
+  override fun activate() {
+    val player = plugin.server.randomPlayer() ?: return
+    val baseChunk = player.chunk
+    recordInvert(baseChunk)
+    player.teleport(player.location.toHighestLocation())
+    val chunksToInvert = player.world.loadedChunks.without(baseChunk).toMutableList()
+
+    println("Inverting ${chunksToInvert.size} chunks...")
+    plugin.server.scheduler.scheduleUntilEmpty(plugin, chunksToInvert, 5) { chunk ->
+      recordInvert(chunk)
+    }
+  }
+
+  fun recordInvert(chunk: Chunk) {
+    chunkInversions.add(invertChunk(chunk))
+  }
+
+  override fun deactivate() {
+    fun scheduleOne() {
+      if (chunkInversions.isEmpty()) {
+        return
+      }
+
+      val inversion = chunkInversions.removeAt(0)
+      plugin.server.scheduler.runTaskLater(plugin, { ->
+        inversion.revert()
+        scheduleOne()
+      }, 5)
+    }
+
+    scheduleOne()
+  }
+
+  fun invertChunk(chunk: Chunk): ChunkInversion {
+    val snapshot = chunk.chunkSnapshot
+    forEachChunkPosition { x, z ->
+      var sy = chunk.world.minHeight
+      var ey = chunk.world.maxHeight
+      while (sy != ey) {
+        sy++
+        ey--
+        val targetBlock = chunk.getBlock(x, sy, z)
+        val targetBlockData = targetBlock.blockData.clone()
+        val nextBlock = chunk.getBlock(x, ey, z)
+        val nextBlockData = nextBlock.blockData.clone()
+        invertSetBlockData(targetBlock, nextBlockData)
+        invertSetBlockData(nextBlock, targetBlockData)
+      }
+    }
+    return ChunkInversion(plugin, snapshot)
+  }
+
+  private fun invertSetBlockData(block: Block, data: BlockData) {
+    block.setBlockData(data, false)
+  }
+
+  class ChunkInversion(val plugin: Plugin, val snapshot: ChunkSnapshot) {
+    fun revert() {
+      val world = plugin.server.getWorld(snapshot.worldName) ?: return
+      val chunk = world.getChunkAt(snapshot.x, snapshot.z)
+      chunk.applyChunkSnapshot(snapshot)
+    }
+  }
+}

foundation-chaos/src/main/resources/chaos.yaml

@@ -0,0 +1,16 @@
+# Whether enabling the chaos mode is allowed.
+allowed: false
+# The default module configuration for modules with
+# no explicit configuration.
+defaultModuleConfiguration:
+  enabled: true
+# Module configuration.
+modules:
+  nearest-player-entity-spawn:
+    enabled: true
+  teleport-all-entities-nearest-player:
+    enabled: true
+# Chaos selection configuration.
+selection:
+  # The number of ticks before a new selection is made.
+  timerTicks: 6000

foundation-chaos/src/main/resources/plugin.yml

@@ -0,0 +1,16 @@
+name: Foundation-Chaos
+version: '${version}'
+main: gay.pizza.foundation.chaos.FoundationChaosPlugin
+api-version: 1.18
+prefix: Foundation-Chaos
+load: STARTUP
+depend:
+  - Foundation
+authors:
+  - kubeliv
+  - azenla
+commands:
+  chaos:
+    description: Chaos Toggle
+    usage: /chaos
+    permission: foundation.command.chaos

foundation-core/build.gradle.kts

@@ -1,3 +1,16 @@
-dependencies {
-  // TODO: might be able to ship all dependencies in core? are we duplicating classes in JARs?
+plugins {
+  id("gay.pizza.foundation.concrete-plugin")
+}
+
+dependencies {
+  api(project(":common-all"))
+  api(project(":common-plugin"))
+  implementation(project(":foundation-shared"))
+
+  implementation(libs.aws.sdk.s3)
+  implementation(libs.quartz.core)
+  implementation(libs.guava)
+
+  implementation(libs.koin.core)
+  testImplementation(libs.koin.test)
 }

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/FoundationCorePlugin.kt

@@ -1,131 +0,0 @@
-package cloud.kubelet.foundation.core
-
-import cloud.kubelet.foundation.core.command.*
-import cloud.kubelet.foundation.core.persist.PersistentStore
-import cloud.kubelet.foundation.core.persist.setAllProperties
-import io.papermc.paper.event.player.AsyncChatEvent
-import net.kyori.adventure.text.Component
-import net.kyori.adventure.text.TextComponent
-import org.bukkit.GameMode
-import org.bukkit.command.CommandExecutor
-import org.bukkit.event.EventHandler
-import org.bukkit.event.Listener
-import org.bukkit.plugin.java.JavaPlugin
-import java.nio.file.Path
-import java.time.Instant
-import java.util.concurrent.ConcurrentHashMap
-
-class FoundationCorePlugin : JavaPlugin(), Listener {
-  internal val persistentStores = ConcurrentHashMap<String, PersistentStore>()
-  private lateinit var _pluginDataPath: Path
-
-  var pluginDataPath: Path
-    /**
-     * Data path of the core plugin.
-     * Can be used as a sanity check of sorts for dependencies to be sure the plugin is loaded.
-     */
-    get() {
-      if (!::_pluginDataPath.isInitialized) {
-        throw Exception("FoundationCore is not loaded!")
-      }
-      return _pluginDataPath
-    }
-    private set(value) {
-      _pluginDataPath = value
-    }
-
-  /**
-   * Fetch a persistent store by name. Make sure the name is path-safe, descriptive and consistent across server runs.
-   */
-  fun getPersistentStore(name: String) = persistentStores.getOrPut(name) { PersistentStore(this, name) }
-
-  private lateinit var chatLogStore: PersistentStore
-
-  override fun onEnable() {
-    pluginDataPath = dataFolder.toPath()
-    val backupPath = pluginDataPath.resolve(BACKUPS_DIRECTORY)
-
-    // Create Foundation plugin directories.
-    pluginDataPath.toFile().mkdir()
-    backupPath.toFile().mkdir()
-
-    // Register this as an event listener.
-    server.pluginManager.registerEvents(this, this)
-
-    // Register commands.
-    registerCommandExecutor("fbackup", BackupCommand(this, backupPath))
-    registerCommandExecutor("fupdate", UpdateCommand())
-    registerCommandExecutor(listOf("survival", "s"), GamemodeCommand(GameMode.SURVIVAL))
-    registerCommandExecutor(listOf("creative", "c"), GamemodeCommand(GameMode.CREATIVE))
-    registerCommandExecutor(listOf("adventure", "a"), GamemodeCommand(GameMode.ADVENTURE))
-    registerCommandExecutor(listOf("spectator", "sp"), GamemodeCommand(GameMode.SPECTATOR))
-    registerCommandExecutor(listOf("leaderboard", "lb"), LeaderboardCommand())
-    registerCommandExecutor(listOf("pstorestats"), StoreStatsCommand(this))
-
-    val log = slF4JLogger
-    log.info("Features:")
-    Util.printFeatureStatus(log, "Backup", BACKUP_ENABLED)
-    chatLogStore = getPersistentStore("chat-logs")
-  }
-
-  override fun onDisable() {
-    persistentStores.values.forEach { store -> store.close() }
-    persistentStores.clear()
-  }
-
-  private fun registerCommandExecutor(name: String, executor: CommandExecutor) {
-    registerCommandExecutor(listOf(name), executor)
-  }
-
-  private fun registerCommandExecutor(names: List<String>, executor: CommandExecutor) {
-    for (name in names) {
-      val command = getCommand(name) ?: throw Exception("Failed to get $name command")
-      command.setExecutor(executor)
-    }
-  }
-
-  // TODO: Disabling chat reformatting until I do something with it and figure out how to make it
-  //  be less disruptive.
-  /*@EventHandler
-  private fun onChatMessage(e: ChatEvent) {
-    return
-    e.isCancelled = true
-    val name = e.player.displayName()
-    val component = Component.empty()
-      .append(leftBracket)
-      .append(name)
-      .append(rightBracket)
-      .append(Component.text(' '))
-      .append(e.message())
-    server.sendMessage(component)
-  }*/
-
-  @EventHandler
-  private fun logOnChatMessage(e: AsyncChatEvent) {
-    val player = e.player
-    val message = e.message()
-
-    if (message !is TextComponent) {
-      return
-    }
-
-    val content = message.content()
-    chatLogStore.create("ChatMessageEvent") {
-      setAllProperties(
-        "timestamp" to Instant.now().toEpochMilli(),
-        "player.id" to player.identity().uuid().toString(),
-        "player.name" to player.name,
-        "message.content" to content
-      )
-    }
-  }
-
-  companion object {
-    private const val BACKUPS_DIRECTORY = "backups"
-
-    private val leftBracket: Component = Component.text('[')
-    private val rightBracket: Component = Component.text(']')
-
-    const val BACKUP_ENABLED = true
-  }
-}

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/TextColors.kt

@@ -1,7 +0,0 @@
-package cloud.kubelet.foundation.core
-
-import net.kyori.adventure.text.format.TextColor
-
-object TextColors {
-  val AMARANTH_PINK = TextColor.fromHexString("#F7A8B8")!!
-}

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/Util.kt

@@ -1,64 +0,0 @@
-package cloud.kubelet.foundation.core
-
-import net.kyori.adventure.text.Component
-import net.kyori.adventure.text.format.TextColor
-import org.slf4j.Logger
-import java.nio.file.Path
-
-object Util {
-  private val leftBracket: Component = Component.text('[')
-  private val rightBracket: Component = Component.text(']')
-  private val whitespace: Component = Component.text(' ')
-  private val foundationName: Component = Component.text("Foundation")
-
-  fun printFeatureStatus(logger: Logger, feature: String?, state: Boolean) {
-    logger.info("{}: {}", feature, if (state) "Enabled" else "Disabled")
-  }
-
-  fun formatSystemMessage(message: String): Component {
-    return formatSystemMessage(TextColors.AMARANTH_PINK, message)
-  }
-
-  fun formatSystemMessage(prefixColor: TextColor, message: String): Component {
-    return leftBracket
-      .append(foundationName.color(prefixColor))
-      .append(rightBracket)
-      .append(whitespace)
-      .append(Component.text(message))
-  }
-
-  /**
-   * Copy the default configuration from the resource [resourceName] into the directory [targetPath].
-   * @param targetPath The output directory as a path, it must exist before calling this.
-   * @param resourceName Path to resource, it should be in the root of the `resources` directory,
-   *  without the leading slash.
-   */
-  inline fun <reified T> copyDefaultConfig(log: Logger, targetPath: Path, resourceName: String): Path {
-    if (resourceName.startsWith("/")) {
-      throw IllegalArgumentException("resourceName starts with slash")
-    }
-
-    if (!targetPath.toFile().exists()) {
-      throw Exception("Configuration output path does not exist!")
-    }
-    val outPath = targetPath.resolve(resourceName)
-    val outFile = outPath.toFile()
-    if (outFile.exists()) {
-      log.debug("Configuration file already exists.")
-      return outPath
-    }
-
-    val resourceStream = T::class.java.getResourceAsStream("/$resourceName")
-      ?: throw Exception("Configuration resource does not exist!")
-    val outputStream = outFile.outputStream()
-
-    resourceStream.use {
-      outputStream.use {
-        log.info("Copied default configuration to $outPath")
-        resourceStream.copyTo(outputStream)
-      }
-    }
-
-    return outPath
-  }
-}

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/command/BackupCommand.kt

@@ -1,143 +0,0 @@
-package cloud.kubelet.foundation.core.command
-
-import cloud.kubelet.foundation.core.FoundationCorePlugin
-import cloud.kubelet.foundation.core.Util
-import net.kyori.adventure.text.Component
-import net.kyori.adventure.text.format.TextColor
-import org.bukkit.Server
-import org.bukkit.command.Command
-import org.bukkit.command.CommandExecutor
-import org.bukkit.command.CommandSender
-import java.io.BufferedOutputStream
-import java.io.FileInputStream
-import java.io.FileOutputStream
-import java.io.IOException
-import java.nio.file.Files
-import java.nio.file.Path
-import java.time.Instant
-import java.util.concurrent.atomic.AtomicBoolean
-import java.util.zip.ZipEntry
-import java.util.zip.ZipOutputStream
-
-class BackupCommand(
-  private val plugin: FoundationCorePlugin,
-  private val backupPath: Path
-) : CommandExecutor {
-  override fun onCommand(
-    sender: CommandSender, command: Command, label: String, args: Array<String>
-  ): Boolean {
-    if (!FoundationCorePlugin.BACKUP_ENABLED) {
-      sender.sendMessage(
-        Component
-          .text("Backup is not enabled.")
-          .color(TextColor.fromHexString("#FF0000"))
-      )
-      return true
-    }
-
-    if (RUNNING.get()) {
-      sender.sendMessage(
-        Component
-          .text("Backup is already running.")
-          .color(TextColor.fromHexString("#FF0000"))
-      )
-      return true
-    }
-
-    try {
-      val server = sender.server
-      server.scheduler.runTaskAsynchronously(plugin, Runnable {
-        runBackup(server)
-      })
-    } catch (e: Exception) {
-      sender.sendMessage(String.format("Failed to backup: %s", e.message))
-    }
-
-    return true
-  }
-
-  private fun runBackup(server: Server) {
-    RUNNING.set(true)
-
-    server.sendMessage(Util.formatSystemMessage("Backup started."))
-
-    val backupFile =
-      backupPath.resolve(String.format("backup-%s.zip", Instant.now().toString())).toFile()
-
-    try {
-      FileOutputStream(backupFile).use { zipFileStream ->
-        ZipOutputStream(BufferedOutputStream(zipFileStream)).use { zipStream ->
-          backupPlugins(server, zipStream)
-          backupWorlds(server, zipStream)
-        }
-      }
-    } finally {
-      RUNNING.set(false)
-      server.sendMessage(Util.formatSystemMessage("Backup finished."))
-    }
-  }
-
-  private fun backupPlugins(server: Server, zipStream: ZipOutputStream) {
-    try {
-      addDirectoryToZip(zipStream, server.pluginsFolder.toPath())
-    } catch (e: IOException) {
-      // TODO: Add error handling.
-      e.printStackTrace()
-    }
-  }
-
-  private fun backupWorlds(server: Server, zipStream: ZipOutputStream) {
-    val worlds = server.worlds
-    for (world in worlds) {
-      val worldPath = world.worldFolder.toPath()
-
-      // Save the world, must be run on the main thread.
-      server.scheduler.runTask(plugin, Runnable {
-        world.save()
-      })
-
-      // Disable auto saving to prevent any world corruption while creating a ZIP.
-      world.isAutoSave = false
-      try {
-        addDirectoryToZip(zipStream, worldPath)
-      } catch (e: IOException) {
-        // TODO: Add error handling.
-        e.printStackTrace()
-      }
-
-      // Re-enable auto saving for this world.
-      world.isAutoSave = true
-    }
-  }
-
-  private fun addDirectoryToZip(zipStream: ZipOutputStream, directoryPath: Path) {
-    val paths = Files.walk(directoryPath)
-      .filter { path: Path? -> Files.isRegularFile(path) }
-      .toList()
-    val buffer = ByteArray(1024)
-    val backupsPath = backupPath.toRealPath()
-
-    for (path in paths) {
-      val realPath = path.toRealPath()
-
-      if (realPath.startsWith(backupsPath)) {
-        plugin.slF4JLogger.info("Skipping file for backup: {}", realPath)
-        continue
-      }
-
-      FileInputStream(path.toFile()).use { fileStream ->
-        val entry = ZipEntry(path.toString())
-        zipStream.putNextEntry(entry)
-
-        var n: Int
-        while (fileStream.read(buffer).also { n = it } > -1) {
-          zipStream.write(buffer, 0, n)
-        }
-      }
-    }
-  }
-
-  companion object {
-    private val RUNNING = AtomicBoolean()
-  }
-}

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/command/StoreStatsCommand.kt

@@ -1,22 +0,0 @@
-package cloud.kubelet.foundation.core.command
-
-import cloud.kubelet.foundation.core.FoundationCorePlugin
-import org.bukkit.command.Command
-import org.bukkit.command.CommandExecutor
-import org.bukkit.command.CommandSender
-
-class StoreStatsCommand(private val plugin: FoundationCorePlugin) : CommandExecutor {
-  override fun onCommand(sender: CommandSender, command: Command, label: String, args: Array<out String>): Boolean {
-    plugin.persistentStores.forEach { (name, store) ->
-      val counts = store.transact { tx ->
-        tx.entityTypes.associateWith { type -> tx.getAll(type).size() }.toSortedMap()
-      }
-
-      sender.sendMessage(
-        "Store $name ->",
-        *counts.map { "  ${it.key} -> ${it.value} entries" }.toTypedArray()
-      )
-    }
-    return true
-  }
-}

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/command/UpdateCommand.kt

@@ -1,51 +0,0 @@
-package cloud.kubelet.foundation.core.command
-
-import cloud.kubelet.foundation.core.update.UpdateUtil
-import org.bukkit.command.Command
-import org.bukkit.command.CommandExecutor
-import org.bukkit.command.CommandSender
-import kotlin.io.path.name
-import kotlin.io.path.toPath
-
-class UpdateCommand : CommandExecutor {
-  override fun onCommand(
-    sender: CommandSender,
-    command: Command,
-    label: String,
-    args: Array<out String>
-  ): Boolean {
-    val updateDir = sender.server.pluginsFolder.resolve("update")
-    if (!updateDir.exists()) {
-      sender.sendMessage("Error: Failed to create plugin update directory.")
-      return true
-    }
-    val updatePath = updateDir.toPath()
-
-    // TODO: Move to separate thread?
-    val modules = UpdateUtil.fetchManifest()
-    val plugins = sender.server.pluginManager.plugins.associateBy { it.name.lowercase() }
-
-    sender.sendMessage("Updates:")
-    modules.forEach { (name, manifest) ->
-      // Dumb naming problem. Don't want to fix it right now.
-      val plugin = if (name == "foundation-core") {
-        plugins["foundation"]
-      } else {
-        plugins[name.lowercase()]
-      }
-
-      if (plugin == null) {
-        sender.sendMessage("Plugin in manifest, but not installed: $name (${manifest.version})")
-      } else {
-        val fileName = plugin.javaClass.protectionDomain.codeSource.location.toURI().toPath().name
-        val artifactPath = manifest.artifacts.getOrNull(0) ?: return@forEach
-
-        sender.sendMessage("${plugin.name}: Updating ${plugin.description.version} to ${manifest.version}")
-        UpdateUtil.downloadArtifact(artifactPath, updatePath.resolve(fileName))
-      }
-    }
-    sender.sendMessage("Restart to take effect")
-
-    return true
-  }
-}

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/persist/PersistentStore.kt

@@ -1,35 +0,0 @@
-package cloud.kubelet.foundation.core.persist
-
-import cloud.kubelet.foundation.core.FoundationCorePlugin
-import jetbrains.exodus.entitystore.Entity
-import jetbrains.exodus.entitystore.EntityIterable
-import jetbrains.exodus.entitystore.PersistentEntityStores
-import jetbrains.exodus.entitystore.StoreTransaction
-
-class PersistentStore(corePlugin: FoundationCorePlugin, fileStoreName: String) : AutoCloseable {
-  private val fileStorePath = corePlugin.pluginDataPath.resolve("persistence/${fileStoreName}")
-  private val entityStore = PersistentEntityStores.newInstance(fileStorePath.toFile())
-
-  fun <R> transact(block: (StoreTransaction) -> R): R {
-    var result: R? = null
-    entityStore.executeInTransaction { tx ->
-      result = block(tx)
-    }
-    return result!!
-  }
-
-  fun create(entityTypeName: String, populate: Entity.() -> Unit) = transact { tx ->
-    val entity = tx.newEntity(entityTypeName)
-    populate(entity)
-  }
-
-  fun getAll(entityTypeName: String) =
-    transact { tx -> tx.getAll(entityTypeName) }
-
-  fun <T> find(entityTypeName: String, propertyName: String, value: Comparable<T>): EntityIterable =
-    transact { tx -> tx.find(entityTypeName, propertyName, value) }
-
-  override fun close() {
-    entityStore.close()
-  }
-}

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/update/ModuleManifest.kt

@@ -1,9 +0,0 @@
-package cloud.kubelet.foundation.core.update
-
-import kotlinx.serialization.Serializable
-
-@Serializable
-data class ModuleManifest(
-  val version: String,
-  val artifacts: List<String>,
-)

foundation-core/src/main/kotlin/cloud/kubelet/foundation/core/update/UpdateUtil.kt

@@ -1,59 +0,0 @@
-package cloud.kubelet.foundation.core.update
-
-import kotlinx.serialization.DeserializationStrategy
-import kotlinx.serialization.builtins.MapSerializer
-import kotlinx.serialization.builtins.serializer
-import kotlinx.serialization.json.Json
-import java.net.URI
-import java.net.http.HttpClient
-import java.net.http.HttpRequest
-import java.net.http.HttpResponse
-import java.nio.file.Path
-
-object UpdateUtil {
-  private val client = HttpClient.newBuilder().followRedirects(HttpClient.Redirect.NORMAL).build()
-
-  // TODO: Add environment variable override. Document it.
-  private const val basePath =
-    "https://git.gorence.io/lgorence/foundation/-/jobs/artifacts/main/raw"
-  private const val basePathQueryParams = "job=build"
-  private const val manifestPath = "build/manifests/update.json"
-
-  fun fetchManifest() = fetchFile(
-    getUrl(manifestPath), MapSerializer(String.serializer(), ModuleManifest.serializer()),
-  )
-
-  fun getUrl(path: String) = "$basePath/$path?$basePathQueryParams"
-
-  private inline fun <reified T> fetchFile(url: String, strategy: DeserializationStrategy<T>): T {
-    val request = HttpRequest
-      .newBuilder()
-      .GET()
-      .uri(URI.create(url))
-      .build()
-
-    val response = client.send(
-      request,
-      HttpResponse.BodyHandlers.ofString()
-    )
-
-    return Json.decodeFromString(
-      strategy,
-      response.body()
-    )
-  }
-
-  fun downloadArtifact(path: String, outPath: Path) {
-    val request = HttpRequest
-      .newBuilder()
-      .GET()
-      .uri(URI.create(getUrl(path)))
-      .build()
-
-    val response = client.send(
-      request,
-      HttpResponse.BodyHandlers.ofFile(outPath)
-    )
-    response.body()
-  }
-}

foundation-core/src/main/kotlin/gay/pizza/foundation/concrete/ExtensibleManifest.kt

@@ -0,0 +1,60 @@
+package gay.pizza.foundation.concrete
+
+import kotlinx.serialization.Serializable
+
+/**
+ * The extensible update manifest format.
+ */
+@Serializable
+data class ExtensibleManifest(
+  /**
+   * The items the manifest describes.
+   */
+  val items: List<ExtensibleManifestItem>
+)
+
+/**
+ * An item in the update manifest.
+ */
+@Serializable
+data class ExtensibleManifestItem(
+  /**
+   * The name of the item.
+   */
+  val name: String,
+  /**
+   * The type of item.
+   */
+  val type: String,
+  /**
+   * The version of the item.
+   */
+  val version: String,
+  /**
+   * The dependencies of the item.
+   */
+  val dependencies: List<String>,
+  /**
+   * The files that are required to install the item.
+   */
+  val files: List<ExtensibleManifestItemFile>
+)
+
+/**
+ * A file built from the item.
+ */
+@Serializable
+data class ExtensibleManifestItemFile(
+  /**
+   * The name of the file.
+   */
+  val name: String,
+  /**
+   * A type of file.
+   */
+  val type: String,
+  /**
+   * The relative path to download the file.
+   */
+  val path: String
+)

foundation-core/src/main/kotlin/gay/pizza/foundation/core/FoundationCorePlugin.kt

@@ -0,0 +1,61 @@
+package gay.pizza.foundation.core
+
+import gay.pizza.foundation.core.abstraction.FoundationPlugin
+import gay.pizza.foundation.core.features.backup.BackupFeature
+import gay.pizza.foundation.core.features.gameplay.GameplayFeature
+import gay.pizza.foundation.core.features.persist.PersistenceFeature
+import gay.pizza.foundation.core.features.player.PlayerFeature
+import gay.pizza.foundation.core.features.scheduler.SchedulerFeature
+import gay.pizza.foundation.core.features.stats.StatsFeature
+import gay.pizza.foundation.core.features.update.UpdateFeature
+import gay.pizza.foundation.core.features.world.WorldFeature
+import gay.pizza.foundation.shared.IFoundationCore
+import gay.pizza.foundation.shared.PluginMainClass
+import gay.pizza.foundation.shared.PluginPersistence
+import org.koin.dsl.module
+import java.nio.file.Path
+
+@PluginMainClass
+class FoundationCorePlugin : IFoundationCore, FoundationPlugin() {
+  private lateinit var _pluginDataPath: Path
+
+  override var pluginDataPath: Path
+    /**
+     * Data path of the core plugin.
+     * Can be used as a check of sorts for dependencies to be sure the plugin is loaded.
+     */
+    get() {
+      if (!::_pluginDataPath.isInitialized) {
+        throw Exception("Foundation Core is not loaded!")
+      }
+      return _pluginDataPath
+    }
+    private set(value) {
+      _pluginDataPath = value
+    }
+
+  override val persistence: PluginPersistence = PluginPersistence(this)
+
+  override fun onEnable() {
+    // Create core plugin directory.
+    pluginDataPath = dataFolder.toPath()
+    pluginDataPath.toFile().mkdir()
+
+    super.onEnable()
+  }
+
+  override fun createFeatures() = listOf(
+    SchedulerFeature(),
+    PersistenceFeature(),
+    BackupFeature(),
+    GameplayFeature(),
+    PlayerFeature(),
+    StatsFeature(),
+    UpdateFeature(),
+    WorldFeature(),
+  )
+
+  override fun createModule() = module {
+    single { this@FoundationCorePlugin }
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/abstraction/CoreFeature.kt

@@ -0,0 +1,7 @@
+package gay.pizza.foundation.core.abstraction
+
+interface CoreFeature {
+  fun enable()
+  fun disable()
+  fun module() = org.koin.dsl.module {}
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/abstraction/Feature.kt

@@ -0,0 +1,17 @@
+package gay.pizza.foundation.core.abstraction
+
+import gay.pizza.foundation.core.FoundationCorePlugin
+import org.bukkit.event.Listener
+import org.koin.core.component.KoinComponent
+import org.koin.core.component.inject
+import org.koin.dsl.module
+import org.quartz.Scheduler
+
+abstract class Feature : CoreFeature, KoinComponent, Listener {
+  protected val plugin by inject<FoundationCorePlugin>()
+  protected val scheduler by inject<Scheduler>()
+
+  override fun enable() {}
+  override fun disable() {}
+  override fun module() = module {}
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/abstraction/FoundationPlugin.kt

@@ -0,0 +1,68 @@
+package gay.pizza.foundation.core.abstraction
+
+import gay.pizza.foundation.common.BaseFoundationPlugin
+import org.koin.core.KoinApplication
+import org.koin.core.context.startKoin
+import org.koin.core.context.stopKoin
+import org.koin.core.module.Module
+import org.koin.dsl.module
+
+abstract class FoundationPlugin : BaseFoundationPlugin() {
+  private lateinit var pluginModule: Module
+  private lateinit var pluginApplication: KoinApplication
+  private lateinit var features: List<CoreFeature>
+  private lateinit var module: Module
+
+  override fun onEnable() {
+    pluginModule = module {
+      single { this@FoundationPlugin }
+      single { server }
+      single { config }
+      single { slF4JLogger }
+    }
+
+    features = createFeatures()
+    module = createModule()
+
+    // TODO: If we have another plugin using Koin, we may need to use context isolation and ensure
+    //  it uses the same context so they can fetch stuff from us.
+    //  https://insert-koin.io/docs/reference/koin-core/context-isolation
+    pluginApplication = startKoin {
+      modules(pluginModule)
+      modules(module)
+    }
+
+    // This is probably a bit of a hack.
+    pluginApplication.modules(module {
+      single { pluginApplication }
+    })
+
+    features.forEach {
+      pluginApplication.modules(it.module())
+    }
+
+    features.forEach {
+      try {
+        slF4JLogger.info("Enabling feature: ${it.javaClass.simpleName}")
+        it.enable()
+        // TODO: May replace this check with a method in the interface, CoreFeature would no-op.
+        if (it is Feature) {
+          server.pluginManager.registerEvents(it, this)
+        }
+      } catch (e: Exception) {
+        slF4JLogger.error("Failed to enable feature: ${it.javaClass.simpleName}", e)
+      }
+    }
+  }
+
+  override fun onDisable() {
+    features.forEach {
+      it.disable()
+    }
+
+    stopKoin()
+  }
+
+  protected open fun createModule() = module {}
+  protected abstract fun createFeatures(): List<CoreFeature>
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/backup/BackupCommand.kt

@@ -0,0 +1,168 @@
+package gay.pizza.foundation.core.features.backup
+
+import gay.pizza.foundation.shared.Platform
+import gay.pizza.foundation.core.FoundationCorePlugin
+import gay.pizza.foundation.shared.MessageUtil
+import net.kyori.adventure.text.Component
+import net.kyori.adventure.text.format.TextColor
+import org.bukkit.Server
+import org.bukkit.command.Command
+import org.bukkit.command.CommandExecutor
+import org.bukkit.command.CommandSender
+import software.amazon.awssdk.services.s3.S3Client
+import software.amazon.awssdk.services.s3.model.PutObjectRequest
+import java.io.BufferedOutputStream
+import java.io.FileInputStream
+import java.io.FileOutputStream
+import java.io.IOException
+import java.nio.file.FileSystems
+import java.nio.file.Files
+import java.nio.file.Path
+import java.nio.file.Paths
+import java.time.Instant
+import java.util.concurrent.atomic.AtomicBoolean
+import java.util.zip.ZipEntry
+import java.util.zip.ZipOutputStream
+
+// TODO: Clean up dependency injection.
+class BackupCommand(
+  private val plugin: FoundationCorePlugin,
+  private val backupFilePath: Path,
+  private val config: BackupConfig,
+  private val s3Client: S3Client,
+) : CommandExecutor {
+  override fun onCommand(
+    sender: CommandSender, command: Command, label: String, args: Array<String>
+  ): Boolean {
+    if (running.get()) {
+      sender.sendMessage(
+        Component
+          .text("Backup is already running.")
+          .color(TextColor.fromHexString("#FF0000"))
+      )
+      return true
+    }
+
+    val server = sender.server
+    server.scheduler.runTaskAsynchronously(plugin) { ->
+      runBackup(server, sender)
+    }
+    return true
+  }
+
+  // TODO: Pull backup creation code into a separate service.
+  private fun runBackup(server: Server, sender: CommandSender? = null) = try {
+    running.set(true)
+
+    server.scheduler.runTask(plugin) { ->
+      server.sendMessage(MessageUtil.formatSystemMessage("Backup started."))
+    }
+
+    val backupTime = Instant.now()
+    val backupIdentifier = if (Platform.isWindows()) {
+      backupTime.toEpochMilli().toString()
+    } else {
+      backupTime.toString()
+    }
+    val backupFileName = String.format("backup-%s.zip", backupIdentifier)
+    val backupPath = backupFilePath.resolve(backupFileName)
+    val backupFile = backupPath.toFile()
+
+    FileOutputStream(backupFile).use { zipFileStream ->
+      ZipOutputStream(BufferedOutputStream(zipFileStream)).use { zipStream ->
+        backupPlugins(server, zipStream)
+        backupWorlds(server, zipStream)
+      }
+    }
+
+    // TODO: Pull upload code out into a separate service.
+    if (config.s3.accessKeyId.isNotEmpty()) {
+      s3Client.putObject(
+        PutObjectRequest.builder().apply {
+          bucket(config.s3.bucket)
+          key("${config.s3.baseDirectory}/$backupFileName")
+        }.build(),
+        backupPath
+      )
+    }
+    Unit
+  } catch (e: Exception) {
+    if (sender != null) {
+      server.scheduler.runTask(plugin) { ->
+        sender.sendMessage(String.format("Failed to backup: %s", e.message))
+      }
+    }
+    plugin.slF4JLogger.warn("Failed to backup.", e)
+  } finally {
+    running.set(false)
+    server.scheduler.runTask(plugin) { ->
+      server.sendMessage(MessageUtil.formatSystemMessage("Backup finished."))
+    }
+  }
+
+  private fun backupPlugins(server: Server, zipStream: ZipOutputStream) {
+    try {
+      addDirectoryToZip(zipStream, server.pluginsFolder.toPath())
+    } catch (e: IOException) {
+      // TODO: Add error handling.
+      plugin.slF4JLogger.warn("Failed to backup plugins.", e)
+    }
+  }
+
+  private fun backupWorlds(server: Server, zipStream: ZipOutputStream) {
+    val worlds = server.worlds
+    for (world in worlds) {
+      val worldPath = world.worldFolder.toPath()
+
+      // Save the world, must be run on the main thread.
+      server.scheduler.runTask(plugin, Runnable {
+        world.save()
+      })
+
+      // Disable auto saving to prevent any world corruption while creating a ZIP.
+      world.isAutoSave = false
+      try {
+        addDirectoryToZip(zipStream, worldPath)
+      } catch (e: IOException) {
+        // TODO: Add error handling.
+        e.printStackTrace()
+      }
+
+      // Re-enable auto saving for this world.
+      world.isAutoSave = true
+    }
+  }
+
+  private fun addDirectoryToZip(zipStream: ZipOutputStream, directoryPath: Path) {
+    val matchers = config.ignore.map { FileSystems.getDefault().getPathMatcher("glob:$it") }
+    val paths = Files.walk(directoryPath)
+      .filter { path: Path -> Files.isRegularFile(path) }
+      .filter { path -> !matchers.any { it.matches(Paths.get(path.normalize().toString())) } }
+      .toList()
+    val buffer = ByteArray(16 * 1024)
+    val backupsPath = backupFilePath.toRealPath()
+
+    for (path in paths) {
+      val realPath = path.toRealPath()
+
+      if (realPath.startsWith(backupsPath)) {
+        plugin.slF4JLogger.info("Skipping file for backup: {}", realPath)
+        continue
+      }
+
+      FileInputStream(path.toFile()).use { fileStream ->
+        val entry = ZipEntry(path.toString())
+        zipStream.putNextEntry(entry)
+
+        var n: Int
+        while (fileStream.read(buffer).also { n = it } > -1) {
+          zipStream.write(buffer, 0, n)
+        }
+      }
+    }
+  }
+
+  companion object {
+    private val running = AtomicBoolean()
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/backup/BackupConfig.kt

@@ -0,0 +1,27 @@
+package gay.pizza.foundation.core.features.backup
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class BackupConfig(
+  val schedule: ScheduleConfig = ScheduleConfig(),
+  val ignore: List<String> = listOf(
+    "plugins/dynmap/web/**"
+  ),
+  val s3: S3Config = S3Config(),
+)
+
+@Serializable
+data class ScheduleConfig(
+  val cron: String = "",
+)
+
+@Serializable
+data class S3Config(
+  val accessKeyId: String = "",
+  val secretAccessKey: String = "",
+  val region: String = "",
+  val endpointOverride: String = "",
+  val bucket: String = "",
+  val baseDirectory: String = "",
+)

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/backup/BackupFeature.kt

@@ -0,0 +1,76 @@
+package gay.pizza.foundation.core.features.backup
+
+import gay.pizza.foundation.core.abstraction.Feature
+import gay.pizza.foundation.core.features.scheduler.cancel
+import gay.pizza.foundation.core.features.scheduler.cron
+import org.koin.core.component.inject
+import org.koin.dsl.module
+import software.amazon.awssdk.auth.credentials.AwsSessionCredentials
+import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider
+import software.amazon.awssdk.regions.Region
+import software.amazon.awssdk.services.s3.S3Client
+import java.net.URI
+
+class BackupFeature : Feature() {
+  private val s3Client by inject<S3Client>()
+  private val config by inject<BackupConfig>()
+  private lateinit var scheduleId: String
+
+  override fun enable() {
+    // Create backup directory.
+    val backupPath = plugin.pluginDataPath.resolve(BACKUPS_DIRECTORY)
+    backupPath.toFile().mkdir()
+
+    plugin.registerCommandExecutor("fbackup", BackupCommand(plugin, backupPath, config, s3Client))
+
+    if (config.schedule.cron.isNotEmpty()) {
+      // Assume the user never wants to modify the second. I'm not sure why this is enforced in Quartz.
+      val expr = "0 ${config.schedule.cron}"
+      scheduleId = scheduler.cron(expr) {
+        plugin.server.scheduler.runTask(plugin) { ->
+          plugin.server.dispatchCommand(plugin.server.consoleSender, "fbackup")
+        }
+      }
+    }
+  }
+
+  override fun disable() {
+    if (::scheduleId.isInitialized) {
+      scheduler.cancel(scheduleId)
+    }
+  }
+
+  override fun module() = module {
+    single {
+      plugin.loadConfigurationWithDefault(
+        plugin,
+        BackupConfig.serializer(),
+        "backup.yaml"
+      )
+    }
+    single {
+      val config = get<BackupConfig>()
+
+      val creds = StaticCredentialsProvider.create(
+        AwsSessionCredentials.create(config.s3.accessKeyId, config.s3.secretAccessKey, "")
+      )
+      val builder = S3Client.builder().credentialsProvider(creds)
+
+      if (config.s3.endpointOverride.isNotEmpty()) {
+        builder.endpointOverride(URI.create(config.s3.endpointOverride))
+      }
+
+      if (config.s3.region.isNotEmpty()) {
+        builder.region(Region.of(config.s3.region))
+      } else {
+        builder.region(Region.US_WEST_1)
+      }
+
+      builder.build()
+    }
+  }
+
+  companion object {
+    private const val BACKUPS_DIRECTORY = "backups"
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/gameplay/GameplayConfig.kt

@@ -0,0 +1,15 @@
+package gay.pizza.foundation.core.features.gameplay
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class GameplayConfig(
+  val mobs: MobsConfig = MobsConfig(),
+)
+
+@Serializable
+data class MobsConfig(
+  val disableEndermanGriefing: Boolean = false,
+  val disableFreezeDamage: Boolean = false,
+  val allowLeads: Boolean = false,
+)

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/gameplay/GameplayFeature.kt

@@ -0,0 +1,83 @@
+package gay.pizza.foundation.core.features.gameplay
+
+import gay.pizza.foundation.core.abstraction.Feature
+import org.bukkit.Bukkit
+import org.bukkit.Material
+import org.bukkit.entity.EntityType
+import org.bukkit.entity.LivingEntity
+import org.bukkit.entity.Mob
+import org.bukkit.event.EventHandler
+import org.bukkit.event.EventPriority
+import org.bukkit.event.entity.EntityChangeBlockEvent
+import org.bukkit.event.entity.EntityDamageEvent
+import org.bukkit.event.player.PlayerInteractEntityEvent
+import org.bukkit.inventory.ItemStack
+import org.koin.core.component.inject
+import org.koin.dsl.module
+
+class GameplayFeature : Feature() {
+  private val config by inject<GameplayConfig>()
+
+  override fun module() = module {
+    single {
+      plugin.loadConfigurationWithDefault(
+        plugin,
+        GameplayConfig.serializer(),
+        "gameplay.yaml"
+      )
+    }
+  }
+
+  @EventHandler(priority = EventPriority.HIGHEST)
+  private fun onEntityDamage(e: EntityDamageEvent) {
+    // If freeze damage is disabled, cancel the event.
+    if (config.mobs.disableFreezeDamage) {
+      if (e.entity is Mob && e.cause == EntityDamageEvent.DamageCause.FREEZE) {
+        e.isCancelled = true
+      }
+    }
+  }
+
+  @EventHandler(priority = EventPriority.HIGHEST)
+  private fun onEntityChangeBlock(event: EntityChangeBlockEvent) {
+    // If enderman griefing is disabled, cancel the event.
+    if (config.mobs.disableEndermanGriefing) {
+      if (event.entity.type == EntityType.ENDERMAN) {
+        event.isCancelled = true
+      }
+    }
+  }
+
+  @EventHandler(priority = EventPriority.HIGHEST)
+  private fun onPlayerInteractEntity(event: PlayerInteractEntityEvent) {
+    val mainHandItem = event.player.inventory.itemInMainHand
+    val hasLead = mainHandItem.type == Material.LEAD
+    val livingEntity = event.rightClicked as? LivingEntity
+
+    // If leads are allowed on all mobs, then start leading the mob.
+    if (config.mobs.allowLeads && hasLead && livingEntity != null) {
+      // Something to do with Bukkit, leashes must happen after the event.
+      Bukkit.getScheduler().runTask(plugin) { ->
+        // If the entity is already leashed, don't do anything.
+        if (livingEntity.isLeashed) return@runTask
+
+        // Interacted with the entity, don't despawn it.
+        livingEntity.removeWhenFarAway = false
+
+        val leashSuccess = livingEntity.setLeashHolder(event.player)
+
+        if (leashSuccess) {
+          val newStack = if (mainHandItem.amount == 1) {
+            null
+          } else {
+            ItemStack(mainHandItem.type, mainHandItem.amount - 1)
+          }
+          event.player.inventory.setItemInMainHand(newStack)
+        }
+      }
+
+      event.isCancelled = true
+      return
+    }
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/persist/PersistenceFeature.kt

@@ -0,0 +1,21 @@
+package gay.pizza.foundation.core.features.persist
+
+import gay.pizza.foundation.core.FoundationCorePlugin
+import gay.pizza.foundation.core.abstraction.Feature
+import gay.pizza.foundation.shared.PluginPersistence
+import org.koin.core.component.inject
+import org.koin.core.module.Module
+import org.koin.dsl.module
+
+class PersistenceFeature : Feature() {
+  private val persistence by inject<PluginPersistence>()
+  private val core by inject<FoundationCorePlugin>()
+
+  override fun disable() {
+    persistence.unload()
+  }
+
+  override fun module(): Module = module {
+    single { core.persistence }
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/persist/PersistentStoreCommand.kt

@@ -0,0 +1,94 @@
+package gay.pizza.foundation.core.features.persist
+
+import gay.pizza.foundation.core.features.stats.StatsFeature
+import org.bukkit.command.Command
+import org.bukkit.command.CommandExecutor
+import org.bukkit.command.CommandSender
+import org.bukkit.command.TabCompleter
+
+class PersistentStoreCommand(
+  private val statsFeature: StatsFeature
+) : CommandExecutor, TabCompleter {
+  private val allSubCommands = mutableListOf("stats", "sample", "delete-all-entities")
+
+  override fun onCommand(
+    sender: CommandSender,
+    command: Command,
+    label: String,
+    args: Array<out String>
+  ): Boolean {
+    if (args.isEmpty()) {
+      sender.sendMessage("Invalid Command Usage.")
+      return true
+    }
+
+    when (args[0]) {
+      "stats" -> {
+        statsFeature.persistence.stores.forEach { (name, store) ->
+          val counts = store.transact {
+            entityTypes.associateWith { type -> getAll(type).size() }.toSortedMap()
+          }
+
+          sender.sendMessage(
+            "Store $name ->",
+            *counts.map { "  ${it.key} -> ${it.value} entries" }.toTypedArray()
+          )
+        }
+      }
+      "sample" -> {
+        if (args.size != 3) {
+          sender.sendMessage("Invalid Subcommand Usage.")
+          return true
+        }
+
+        val storeName = args[1]
+        val entityTypeName = args[2]
+        val store = statsFeature.persistence.store(storeName)
+        store.transact {
+          val entities = getAll(entityTypeName).take(3)
+          for (entity in entities) {
+            sender.sendMessage(
+              "Entity ${entity.id.localId} ->",
+              *entity.propertyNames.map { "  ${it}: ${entity.getProperty(it)}" }.toTypedArray()
+            )
+          }
+        }
+      }
+      "delete-all-entities" -> {
+        if (args.size != 3) {
+          sender.sendMessage("Invalid Subcommand Usage.")
+          return true
+        }
+
+        val storeName = args[1]
+        val entityTypeName = args[2]
+        val store = statsFeature.persistence.store(storeName)
+        store.transact {
+          store.deleteAllEntities(entityTypeName)
+        }
+        sender.sendMessage("Deleted all entities for $storeName $entityTypeName")
+      }
+      else -> {
+        sender.sendMessage("Unknown Subcommand.")
+      }
+    }
+    return true
+  }
+
+  override fun onTabComplete(
+    sender: CommandSender,
+    command: Command,
+    alias: String,
+    args: Array<out String>
+  ): MutableList<String> = when {
+    args.isEmpty() -> {
+      allSubCommands
+    }
+    args.size == 1 -> {
+      allSubCommands.filter { it.startsWith(args[0]) }.toMutableList()
+    }
+    else -> {
+      mutableListOf()
+    }
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/persist/XodusExtensions.kt

@@ -1,7 +1,7 @@
-package cloud.kubelet.foundation.core.persist
+package gay.pizza.foundation.core.features.persist
 
 import jetbrains.exodus.entitystore.Entity
 
-fun <T : Comparable<*>> Entity.setAllProperties(vararg entries: Pair<String, T>) = entries.forEach { entry ->
+fun <T : Comparable<*>> Entity.setAllProperties(vararg entries: Pair<String, T>): Unit = entries.forEach { entry ->
   setProperty(entry.first, entry.second)
 }

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/player/GamemodeCommand.kt

@@ -1,4 +1,4 @@
-package cloud.kubelet.foundation.core.command
+package gay.pizza.foundation.core.features.player
 
 import org.bukkit.GameMode
 import org.bukkit.command.Command

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/player/GooseCommand.kt

@@ -0,0 +1,25 @@
+package gay.pizza.foundation.core.features.player
+
+import gay.pizza.foundation.common.chat
+import org.bukkit.command.Command
+import org.bukkit.command.CommandExecutor
+import org.bukkit.command.CommandSender
+import org.bukkit.entity.Player
+
+class GooseCommand : CommandExecutor {
+  override fun onCommand(
+    sender: CommandSender,
+    command: Command,
+    label: String,
+    args: Array<out String>): Boolean {
+    if (sender !is Player) {
+      sender.sendMessage("Player is required for this command.")
+      return true
+    }
+    sender.chat(
+      "Goose is the most beautiful kitty to ever exist <3",
+      "I don't know who Nat is but there is no way she can compare to Goose."
+    )
+    return true
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/player/LocalWeatherCommand.kt

@@ -0,0 +1,50 @@
+package gay.pizza.foundation.core.features.player
+
+import org.bukkit.WeatherType
+import org.bukkit.command.Command
+import org.bukkit.command.CommandExecutor
+import org.bukkit.command.CommandSender
+import org.bukkit.command.TabCompleter
+import org.bukkit.entity.Player
+
+class LocalWeatherCommand : CommandExecutor, TabCompleter {
+  private val weatherTypes = WeatherType.values().associateBy { it.name.lowercase() }
+
+  override fun onCommand(
+    sender: CommandSender,
+    command: Command,
+    label: String,
+    args: Array<out String>
+  ): Boolean {
+    if (sender !is Player) {
+      sender.sendMessage("You are not a player.")
+      return true
+    }
+    if (args.size != 1) {
+      return false
+    }
+
+    val name = args[0].lowercase()
+    val weatherType = weatherTypes[name]
+    if (weatherType == null) {
+      sender.sendMessage("Not a valid weather type.")
+      return true
+    }
+
+    sender.setPlayerWeather(weatherType)
+    sender.sendMessage("Weather set to \"$name\"")
+
+    return true
+  }
+
+  override fun onTabComplete(
+    sender: CommandSender,
+    command: Command,
+    alias: String,
+    args: Array<out String>
+  ): List<String> = when {
+    args.isEmpty() -> weatherTypes.keys.toList()
+    args.size == 1 -> weatherTypes.filterKeys { it.startsWith(args[0]) }.keys.toList()
+    else -> listOf()
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/player/MegaTntCommand.kt

@@ -0,0 +1,25 @@
+package gay.pizza.foundation.core.features.player
+
+import gay.pizza.foundation.common.spawn
+import org.bukkit.command.Command
+import org.bukkit.command.CommandExecutor
+import org.bukkit.command.CommandSender
+import org.bukkit.entity.Player
+import org.bukkit.entity.TNTPrimed
+
+class MegaTntCommand : CommandExecutor {
+  override fun onCommand(
+    sender: CommandSender,
+    command: Command,
+    label: String,
+    args: Array<out String>): Boolean {
+    if (sender !is Player) {
+      sender.sendMessage("Player is required for this command.")
+      return true
+    }
+    val tnt = sender.spawn(TNTPrimed::class)
+    tnt.fuseTicks = 1
+    tnt.yield = 50.0f
+    return true
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/player/PlayerConfig.kt

@@ -0,0 +1,17 @@
+package gay.pizza.foundation.core.features.player
+
+import kotlinx.serialization.SerialName
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class PlayerConfig(
+  @SerialName("anti-idle")
+  val antiIdle: AntiIdleConfig = AntiIdleConfig(),
+)
+
+@Serializable
+data class AntiIdleConfig(
+  val enabled: Boolean = false,
+  val idleDuration: Int = 3600,
+  val ignore: List<String> = listOf(),
+)

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/player/PlayerFeature.kt

@@ -0,0 +1,82 @@
+package gay.pizza.foundation.core.features.player
+
+import com.google.common.cache.Cache
+import com.google.common.cache.CacheBuilder
+import com.google.common.cache.RemovalCause
+import gay.pizza.foundation.core.abstraction.Feature
+import net.kyori.adventure.text.Component
+import org.bukkit.GameMode
+import org.bukkit.event.EventHandler
+import org.bukkit.event.player.PlayerJoinEvent
+import org.bukkit.event.player.PlayerKickEvent
+import org.bukkit.event.player.PlayerMoveEvent
+import org.bukkit.event.player.PlayerQuitEvent
+import org.koin.core.component.inject
+import java.time.Duration
+
+class PlayerFeature : Feature() {
+  private val config by inject<PlayerConfig>()
+  private lateinit var playerActivity: Cache<String, String>
+
+  override fun enable() {
+    playerActivity = CacheBuilder.newBuilder()
+      .expireAfterWrite(Duration.ofSeconds(config.antiIdle.idleDuration.toLong()))
+      .removalListener<String, String> z@{
+        if (!config.antiIdle.enabled) return@z
+        if (it.cause == RemovalCause.EXPIRED) {
+          if (!config.antiIdle.ignore.contains(it.key!!)) {
+            plugin.server.scheduler.runTask(plugin) { ->
+              plugin.server.getPlayer(it.key!!)
+                ?.kick(Component.text("Kicked for idling"), PlayerKickEvent.Cause.IDLING)
+            }
+          }
+        }
+      }.build()
+
+    // Expire player activity tokens occasionally.
+    plugin.server.scheduler.scheduleSyncRepeatingTask(plugin, {
+      playerActivity.cleanUp()
+    }, 20, 100)
+
+    plugin.registerCommandExecutor(listOf("survival", "s"), GamemodeCommand(GameMode.SURVIVAL))
+    plugin.registerCommandExecutor(listOf("creative", "c"), GamemodeCommand(GameMode.CREATIVE))
+    plugin.registerCommandExecutor(listOf("adventure", "a"), GamemodeCommand(GameMode.ADVENTURE))
+    plugin.registerCommandExecutor(listOf("spectator", "sp"), GamemodeCommand(GameMode.SPECTATOR))
+    plugin.registerCommandExecutor(listOf("localweather", "lw"), LocalWeatherCommand())
+    plugin.registerCommandExecutor(listOf("goose", "the_most_wonderful_kitty_ever"), GooseCommand())
+    plugin.registerCommandExecutor(listOf("megatnt"), MegaTntCommand())
+  }
+
+  override fun module() = org.koin.dsl.module {
+    single {
+      plugin.loadConfigurationWithDefault(
+        plugin,
+        PlayerConfig.serializer(),
+        "player.yaml"
+      )
+    }
+  }
+
+  @EventHandler
+  private fun onPlayerJoin(e: PlayerJoinEvent) {
+    if (!config.antiIdle.enabled) return
+
+    playerActivity.put(e.player.name, e.player.name)
+  }
+
+  @EventHandler
+  private fun onPlayerQuit(e: PlayerQuitEvent) {
+    if (!config.antiIdle.enabled) return
+
+    playerActivity.invalidate(e.player.name)
+  }
+
+  @EventHandler
+  private fun onPlayerMove(e: PlayerMoveEvent) {
+    if (!config.antiIdle.enabled) return
+
+    if (e.hasChangedPosition() || e.hasChangedOrientation()) {
+      playerActivity.put(e.player.name, e.player.name)
+    }
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/scheduler/SchedulerExtensions.kt

@@ -0,0 +1,30 @@
+package gay.pizza.foundation.core.features.scheduler
+
+import org.quartz.CronScheduleBuilder.cronSchedule
+import org.quartz.JobBuilder.newJob
+import org.quartz.JobDataMap
+import org.quartz.Scheduler
+import org.quartz.TriggerBuilder.newTrigger
+import org.quartz.TriggerKey.triggerKey
+import java.util.UUID
+
+fun Scheduler.cron(cronExpression: String, f: () -> Unit): String {
+  val id = UUID.randomUUID().toString()
+  val job = newJob(SchedulerRunner::class.java).apply {
+    setJobData(JobDataMap().apply {
+      set("function", f)
+    })
+  }.build()
+
+  val trigger = newTrigger()
+    .withIdentity(triggerKey(id))
+    .withSchedule(cronSchedule(cronExpression))
+    .build()
+
+  scheduleJob(job, trigger)
+  return id
+}
+
+fun Scheduler.cancel(id: String) {
+  unscheduleJob(triggerKey(id))
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/scheduler/SchedulerFeature.kt

@@ -0,0 +1,22 @@
+package gay.pizza.foundation.core.features.scheduler
+
+import gay.pizza.foundation.core.abstraction.CoreFeature
+import org.koin.dsl.module
+import org.quartz.Scheduler
+import org.quartz.impl.StdSchedulerFactory
+
+class SchedulerFeature : CoreFeature {
+  private val scheduler: Scheduler = StdSchedulerFactory.getDefaultScheduler()
+
+  override fun enable() {
+    scheduler.start()
+  }
+
+  override fun disable() {
+    scheduler.shutdown(true)
+  }
+
+  override fun module() = module {
+    single { scheduler }
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/scheduler/SchedulerRunner.kt

@@ -0,0 +1,12 @@
+package gay.pizza.foundation.core.features.scheduler
+
+import org.quartz.Job
+import org.quartz.JobExecutionContext
+
+class SchedulerRunner : Job {
+  override fun execute(context: JobExecutionContext) {
+    @Suppress("UNCHECKED_CAST")
+    val function = context.jobDetail.jobDataMap["function"] as () -> Unit
+    function()
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/stats/LeaderboardCommand.kt

@@ -1,18 +1,23 @@
-package cloud.kubelet.foundation.core.command
+package gay.pizza.foundation.core.features.stats
 
-import cloud.kubelet.foundation.core.SortOrder
-import cloud.kubelet.foundation.core.allPlayerStatisticsOf
+import gay.pizza.foundation.common.SortOrder
+import gay.pizza.foundation.common.allPlayerStatisticsOf
 import org.bukkit.Statistic
 import org.bukkit.command.Command
 import org.bukkit.command.CommandExecutor
 import org.bukkit.command.CommandSender
+import org.bukkit.command.TabCompleter
 
-class LeaderboardCommand : CommandExecutor {
+class LeaderboardCommand : CommandExecutor, TabCompleter {
   private val leaderboards = listOf(
     LeaderboardType("player-kills", Statistic.PLAYER_KILLS, "Player Kills", "kills"),
     LeaderboardType("mob-kills", Statistic.MOB_KILLS, "Mob Kills", "kills"),
     LeaderboardType("animals-bred", Statistic.ANIMALS_BRED, "Animals Bred", "animals"),
-    LeaderboardType("chest-opens", Statistic.CHEST_OPENED, "Chest Opens", "opens")
+    LeaderboardType("chest-opens", Statistic.CHEST_OPENED, "Chest Opens", "opens"),
+    LeaderboardType("raid-wins", Statistic.RAID_WIN, "Raid Wins", "wins"),
+    LeaderboardType("item-enchants", Statistic.ITEM_ENCHANTED, "Item Enchants", "enchants"),
+    LeaderboardType("damage-dealt", Statistic.DAMAGE_DEALT, "Damage Dealt", "damage"),
+    LeaderboardType("fish-caught", Statistic.FISH_CAUGHT, "Fish Caught", "fish")
   )
 
   override fun onCommand(sender: CommandSender, command: Command, label: String, args: Array<out String>): Boolean {
@@ -30,10 +35,28 @@ class LeaderboardCommand : CommandExecutor {
     val topFivePlayers = statistics.take(5)
     sender.sendMessage(
       "${leaderboardType.friendlyName} Leaderboard:",
-      *topFivePlayers.map { "* ${it.first.name}: ${it.second} ${leaderboardType.unit}" }.toTypedArray()
+      *topFivePlayers.withIndex()
+        .map { "(#${it.index + 1}) ${it.value.first.name}: ${it.value.second} ${leaderboardType.unit}" }.toTypedArray()
     )
     return true
   }
 
   class LeaderboardType(val id: String, val statistic: Statistic, val friendlyName: String, val unit: String)
+
+  override fun onTabComplete(
+    sender: CommandSender,
+    command: Command,
+    alias: String,
+    args: Array<out String>
+  ): MutableList<String> = when {
+    args.isEmpty() -> {
+      leaderboards.map { it.id }.toMutableList()
+    }
+    args.size == 1 -> {
+      leaderboards.map { it.id }.filter { it.startsWith(args[0]) }.toMutableList()
+    }
+    else -> {
+      mutableListOf()
+    }
+  }
 }

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/stats/StatsFeature.kt

@@ -0,0 +1,45 @@
+package gay.pizza.foundation.core.features.stats
+
+import gay.pizza.foundation.core.abstraction.Feature
+import gay.pizza.foundation.core.features.persist.PersistentStoreCommand
+import gay.pizza.foundation.core.features.persist.setAllProperties
+import gay.pizza.foundation.shared.PersistentStore
+import gay.pizza.foundation.shared.PluginPersistence
+import io.papermc.paper.event.player.AsyncChatEvent
+import net.kyori.adventure.text.TextComponent
+import org.bukkit.event.EventHandler
+import org.koin.core.component.inject
+import java.time.Instant
+
+@Suppress("IdentifierGrammar")
+class StatsFeature : Feature() {
+  internal val persistence by inject<PluginPersistence>()
+  private lateinit var chatLogStore: PersistentStore
+
+  override fun enable() {
+    chatLogStore = persistence.store("chat-logs")
+
+    plugin.registerCommandExecutor(listOf("leaderboard", "lb"), LeaderboardCommand())
+    plugin.registerCommandExecutor("pstore", PersistentStoreCommand(this))
+  }
+
+  @EventHandler
+  private fun logOnChatMessage(e: AsyncChatEvent) {
+    val player = e.player
+    val message = e.message()
+
+    if (message !is TextComponent) {
+      return
+    }
+
+    val content = message.content()
+    chatLogStore.create("ChatMessageEvent") {
+      setAllProperties(
+        "timestamp" to Instant.now().toEpochMilli(),
+        "player.id" to player.identity().uuid().toString(),
+        "player.name" to player.name,
+        "message.content" to content
+      )
+    }
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/update/UpdateCommand.kt

@@ -0,0 +1,24 @@
+package gay.pizza.foundation.core.features.update
+
+import org.bukkit.command.Command
+import org.bukkit.command.CommandExecutor
+import org.bukkit.command.CommandSender
+import org.bukkit.plugin.Plugin
+
+class UpdateCommand(val plugin: Plugin) : CommandExecutor {
+  override fun onCommand(
+    sender: CommandSender,
+    command: Command,
+    label: String,
+    args: Array<out String>
+  ): Boolean {
+    val shouldRestart = args.isNotEmpty() && args[0] == "restart"
+    UpdateService.updatePlugins(plugin, sender, onFinish = { updated ->
+      if (!updated) return@updatePlugins
+      if (shouldRestart) {
+        sender.server.shutdown()
+      }
+    })
+    return true
+  }
+}

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/update/UpdateConfig.kt

@@ -0,0 +1,13 @@
+package gay.pizza.foundation.core.features.update
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class UpdateConfig(
+  val autoUpdateSchedule: AutoUpdateSchedule
+)
+
+@Serializable
+class AutoUpdateSchedule(
+  val cron: String = ""
+)

foundation-core/src/main/kotlin/gay/pizza/foundation/core/features/update/UpdateFeature.kt

@@ -0,0 +1,41 @@
+package gay.pizza.foundation.core.features.update
+
+import gay.pizza.foundation.core.abstraction.Feature
+import gay.pizza.foundation.core.features.scheduler.cancel
+import gay.pizza.foundation.core.features.scheduler.cron
+import org.koin.core.component.inject
+import org.koin.core.module.Module
+import org.koin.dsl.module
+
+class UpdateFeature : Feature() {
+  private val config by inject<UpdateConfig>()
+  lateinit var autoUpdateScheduleId: String
+
+  override fun enable() {
+    plugin.registerCommandExecutor("fupdate", UpdateCommand(plugin))
+
+    if (config.autoUpdateSchedule.cron.isNotEmpty()) {
+      autoUpdateScheduleId = scheduler.cron(config.autoUpdateSchedule.cron) {
+        plugin.server.scheduler.runTask(plugin) { ->
+          plugin.server.dispatchCommand(plugin.server.consoleSender, "fupdate restart")
+        }
+      }
+    }
+  }
+
+  override fun disable() {
+    if (::autoUpdateScheduleId.isInitialized) {
+      scheduler.cancel(autoUpdateScheduleId)
+    }
+  }
+
+  override fun module(): Module = module {
+    single {
+      plugin.loadConfigurationWithDefault(
+        plugin,
+        UpdateConfig.serializer(),
+        "update.yaml"
+      )
+    }
+  }
+}