diff --git a/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/EsuPluginBukkit.kt b/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/EsuPluginBukkit.kt
index de7a252e..21779a84 100644
--- a/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/EsuPluginBukkit.kt
+++ b/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/EsuPluginBukkit.kt
@@ -115,6 +115,7 @@ class EsuPluginBukkit(
         ModuleManager.addModule(NewsModule)
         ModuleManager.addModule(OptimizationsModule)
         ModuleManager.addModule(SpoofServerSettingsModule)
+        ModuleManager.addModule(EssentialsModule)
         ModuleManager.addModule(VanillaTweaks)
 
         ModuleManager.addModule(AutoReloadExtensionPluginsModule)
diff --git a/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/EssentialsModule.kt b/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/EssentialsModule.kt
new file mode 100644
index 00000000..311badd3
--- /dev/null
+++ b/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/EssentialsModule.kt
@@ -0,0 +1,17 @@
+package io.github.rothes.esu.bukkit.module
+
+import io.github.rothes.esu.bukkit.module.essentials.Teleports
+import io.github.rothes.esu.core.module.configuration.BaseModuleConfiguration
+import io.github.rothes.esu.core.module.configuration.EmptyConfiguration
+
+object EssentialsModule : BukkitModule<EssentialsModule.ModuleConfig, EmptyConfiguration>() {
+
+    init {
+        registerFeature(Teleports)
+    }
+
+    override fun onEnable() {}
+
+    class ModuleConfig : BaseModuleConfiguration()
+
+}
diff --git a/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/essentials/Teleports.kt b/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/essentials/Teleports.kt
new file mode 100644
index 00000000..3a025063
--- /dev/null
+++ b/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/essentials/Teleports.kt
@@ -0,0 +1,17 @@
+package io.github.rothes.esu.bukkit.module.essentials
+
+import io.github.rothes.esu.bukkit.module.essentials.teleports.Tpa
+import io.github.rothes.esu.core.configuration.ConfigurationPart
+import io.github.rothes.esu.core.module.CommonFeature
+
+object Teleports : CommonFeature<Unit, Teleports.Lang>() {
+
+    init {
+        registerFeature(Tpa)
+    }
+
+    override fun onEnable() {}
+
+    class Lang : ConfigurationPart
+
+}
diff --git a/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/essentials/teleports/Tpa.kt b/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/essentials/teleports/Tpa.kt
new file mode 100644
index 00000000..048b499c
--- /dev/null
+++ b/bukkit/src/main/kotlin/io/github/rothes/esu/bukkit/module/essentials/teleports/Tpa.kt
@@ -0,0 +1,131 @@
+package io.github.rothes.esu.bukkit.module.essentials.teleports
+
+import com.google.common.cache.Cache
+import com.google.common.cache.CacheBuilder
+import io.github.rothes.esu.bukkit.user
+import io.github.rothes.esu.bukkit.user.PlayerUser
+import io.github.rothes.esu.bukkit.util.ComponentBukkitUtils.player
+import io.github.rothes.esu.bukkit.util.ServerCompatibility.tp
+import io.github.rothes.esu.bukkit.util.scheduler.Scheduler.syncTick
+import io.github.rothes.esu.core.command.annotation.ShortPerm
+import io.github.rothes.esu.core.configuration.ConfigurationPart
+import io.github.rothes.esu.core.configuration.data.MessageData
+import io.github.rothes.esu.core.configuration.data.MessageData.Companion.message
+import io.github.rothes.esu.core.module.CommonFeature
+import io.github.rothes.esu.core.module.configuration.FeatureToggle
+import io.github.rothes.esu.core.user.User
+import org.bukkit.Bukkit
+import org.bukkit.entity.Player
+import org.incendo.cloud.annotations.Command
+import java.util.*
+import java.util.concurrent.TimeUnit
+
+object Tpa : CommonFeature<FeatureToggle.DefaultTrue, Tpa.Lang>() {
+
+    data class Lang(
+        val requestSent: MessageData = "<pc>Teleport request sent to <pdc><player></pdc>.".message,
+        val requestReceived: MessageData = "<pc><pdc><player></pdc> has requested to teleport to you.\n<pc>Type <click:run_command:'/tpaccept'><tc>/tpaccept</tc></click> to accept or <click:run_command:'/tpdeny'><tc>/tpdeny</tc></click> to deny.".message,
+        val noPendingRequest: MessageData = "<ec>You have no pending teleport requests.".message,
+        val requestAccepted: MessageData = "<pc>Teleport request accepted.".message,
+        val requestDenied: MessageData = "<pc>Teleport request denied.".message,
+        val requestCancelled: MessageData = "<pc>Teleport request cancelled.".message,
+        val playerNotOnline: MessageData = "<ec>That player is not online.".message,
+        val cannotRequestSelf: MessageData = "<ec>You cannot teleport to yourself.".message,
+        val requestAlreadySent: MessageData = "<ec>You have already sent a teleport request to this player.".message,
+    ) : ConfigurationPart
+
+    // target -> requester
+    private val pendingRequests: Cache<UUID, UUID> = CacheBuilder.newBuilder()
+        .expireAfterWrite(5, TimeUnit.MINUTES)
+        .build()
+
+    override fun onEnable() {
+        registerCommands(object {
+
+            @Command("tpa <target>")
+            @ShortPerm
+            fun tpa(sender: User, target: Player) {
+                if (sender !is PlayerUser) return
+                if (sender.player == target) {
+                    sender.message(lang, { cannotRequestSelf })
+                    return
+                }
+
+                if (pendingRequests.getIfPresent(target.uniqueId) == sender.uuid) {
+                    sender.message(lang, { requestAlreadySent })
+                    return
+                }
+
+                pendingRequests.put(target.uniqueId, sender.uuid)
+                sender.message(lang, { requestSent }, player(target))
+                target.user.message(lang, { requestReceived }, player(sender.player))
+            }
+
+            @Command("tpaccept [requester]")
+            @ShortPerm
+            fun tpaccept(sender: User, requester: Player?) {
+                if (sender !is PlayerUser) return
+
+                val pendingId = pendingRequests.getIfPresent(sender.uuid)
+                val requesterId = requester?.uniqueId ?: pendingId
+                if (requesterId == null || (requester != null && pendingId != requesterId)) {
+                    sender.message(lang, { noPendingRequest })
+                    return
+                }
+
+                val requesterPlayer = requester ?: Bukkit.getPlayer(requesterId)
+                if (requesterPlayer == null) {
+                    sender.message(lang, { playerNotOnline })
+                    pendingRequests.invalidate(sender.uuid)
+                    return
+                }
+
+                pendingRequests.invalidate(sender.uuid)
+                requesterPlayer.syncTick {
+                    requesterPlayer.tp(sender.player.location)
+                }
+                sender.message(lang, { requestAccepted })
+                requesterPlayer.user.message(lang, { requestAccepted })
+            }
+
+            @Command("tpdeny [requester]")
+            @ShortPerm
+            fun tpdeny(sender: User, requester: Player?) {
+                if (sender !is PlayerUser) return
+
+                val pendingId = pendingRequests.getIfPresent(sender.uuid)
+                val requesterId = requester?.uniqueId ?: pendingId
+                if (requesterId == null || (requester != null && pendingId != requesterId)) {
+                    sender.message(lang, { noPendingRequest })
+                    return
+                }
+
+                pendingRequests.invalidate(sender.uuid)
+                sender.message(lang, { requestDenied })
+                Bukkit.getPlayer(requesterId)?.user?.message(lang, { requestDenied })
+            }
+
+            @Command("tpcancel [target]")
+            @ShortPerm
+            fun tpcancel(sender: User, target: Player?) {
+                if (sender !is PlayerUser) return
+
+                val targetId = target?.uniqueId ?: pendingRequests.asMap().entries.find { it.value == sender.uuid }?.key
+                if (targetId == null || (target != null && pendingRequests.getIfPresent(targetId) != sender.uuid)) {
+                    sender.message(lang, { noPendingRequest })
+                    return
+                }
+
+                pendingRequests.invalidate(targetId)
+                sender.message(lang, { requestCancelled })
+                Bukkit.getPlayer(targetId)?.user?.message(lang, { requestCancelled })
+            }
+        })
+    }
+
+    override fun onDisable() {
+        pendingRequests.invalidateAll()
+        super.onDisable()
+    }
+
+}