diff --git a/src/main/kotlin/at/hannibal2/skyhanni/discord/BotConfig.kt b/src/main/kotlin/at/hannibal2/skyhanni/discord/BotConfig.kt
index 63b0650..750f7ae 100644
--- a/src/main/kotlin/at/hannibal2/skyhanni/discord/BotConfig.kt
+++ b/src/main/kotlin/at/hannibal2/skyhanni/discord/BotConfig.kt
@@ -11,6 +11,8 @@ data class BotConfig(
     val githubTokenOwn: String,
     val githubTokenPullRequests: String,
     val editPermissionRoleIds: Map<String, String>,
+	val githubWebhookUserId: String,
+	val openPrTagId: String
 )
 
 object ConfigLoader {
@@ -24,7 +26,9 @@ object ConfigLoader {
 		"TODO: github token with sh mod repo access",
 		mapOf(
 			"user friendly (non important) name" to "TODO: role id"
-		)
+		),
+		"TODO: github webhook 'user' id",
+		"TODO: discord forum open pull request tag id"
 	)
 	fun load(filePath: String): BotConfig {
 	    try {
diff --git a/src/main/kotlin/at/hannibal2/skyhanni/discord/CommandListener.kt b/src/main/kotlin/at/hannibal2/skyhanni/discord/CommandListener.kt
index 3220900..55a3acf 100644
--- a/src/main/kotlin/at/hannibal2/skyhanni/discord/CommandListener.kt
+++ b/src/main/kotlin/at/hannibal2/skyhanni/discord/CommandListener.kt
@@ -7,6 +7,7 @@ import at.hannibal2.skyhanni.discord.Utils.logAction
 import at.hannibal2.skyhanni.discord.Utils.reply
 import at.hannibal2.skyhanni.discord.command.*
 import at.hannibal2.skyhanni.discord.utils.ErrorManager.handleError
+import net.dv8tion.jda.api.entities.channel.ChannelType
 import net.dv8tion.jda.api.events.message.MessageReceivedEvent
 import org.reflections.Reflections
 import java.lang.reflect.Modifier
@@ -38,6 +39,9 @@ object CommandListener {
             if (this.author.id == BOT_ID) {
                 BotMessageHandler.handle(this)
             }
+            if (this.author.id == BOT.config.githubWebhookUserId) {
+                LinkListener.onMessage(bot, this)
+            }
             return
         }
 
@@ -66,7 +70,7 @@ object CommandListener {
             return
         }
 
-        if (!command.userCommand) {
+        if (!command.userCommand && channelType != ChannelType.GUILD_PUBLIC_THREAD) {
             if (!hasAdminPermissions()) {
                 reply("No permissions $PLEADING_FACE")
                 return
@@ -78,7 +82,7 @@ object CommandListener {
             }
         }
 
-        // allows to use `!<command> -help` instaed of `!help -<command>`
+        // allows to use `!<command> -help` instead of `!help -<command>`
         if (args.size == 1 && args.first() == "-help") {
             with(HelpCommand) {
                 sendUsageReply(literal)
diff --git a/src/main/kotlin/at/hannibal2/skyhanni/discord/Database.kt b/src/main/kotlin/at/hannibal2/skyhanni/discord/Database.kt
index d3605b9..d69b668 100644
--- a/src/main/kotlin/at/hannibal2/skyhanni/discord/Database.kt
+++ b/src/main/kotlin/at/hannibal2/skyhanni/discord/Database.kt
@@ -8,6 +8,7 @@ data class Tag(val keyword: String, var response: String, var uses: Int)
 object Database {
     private val connection: Connection = DriverManager.getConnection("jdbc:sqlite:bot.db")
     private val tags = mutableMapOf<String, Tag>()
+    private val linkedForumPosts = mutableMapOf<String, Int>() // key = channel id, value = pr number
 
     init {
         val statement = connection.createStatement()
@@ -19,7 +20,16 @@ object Database {
             append("response TEXT, ")
             append("count INTEGER DEFAULT 0)")
         })
+
+        statement.execute(buildString {
+            append("CREATE TABLE IF NOT EXISTS linked_posts (")
+            append("id INTEGER PRIMARY KEY AUTOINCREMENT, ")
+            append("channel_id STRING UNIQUE, ")
+            append("pull_request_id INTEGER UNIQUE)")
+        })
+
         loadTagCache()
+        loadLinkCache()
     }
 
     private fun loadTagCache() {
@@ -34,6 +44,17 @@ object Database {
         resultSet.close()
     }
 
+    private fun loadLinkCache() {
+        val statement = connection.prepareStatement("SELECT channel_id, pull_request_id FROM linked_posts")
+        val resultSet = statement.executeQuery()
+        while (resultSet.next()) {
+            val channelId = resultSet.getString("channel_id")
+            val pr = resultSet.getInt("pull_request_id")
+            linkedForumPosts[channelId] = pr
+        }
+        resultSet.close()
+    }
+
     private fun ensureCountColumnExists() {
         val statement = connection.prepareStatement("PRAGMA table_info(keywords)")
         val resultSet = statement.executeQuery()
@@ -66,6 +87,19 @@ object Database {
         return updated
     }
 
+    fun addLink(channelId: String, pr: Int): Boolean {
+        val statement = connection.prepareStatement(
+            "INSERT OR REPLACE INTO linked_posts (channel_id, pull_request_id) VALUES (?, ?)"
+        )
+        statement.setString(1, channelId)
+        statement.setInt(2, pr)
+        val updated = statement.executeUpdate() > 0
+        if (updated) {
+            linkedForumPosts[channelId] = pr
+        }
+        return updated
+    }
+
     fun getResponse(keyword: String, increment: Boolean = false): String? {
         val key = keyword.lowercase()
         val kObj = tags[key] ?: return null
@@ -81,6 +115,10 @@ object Database {
         return kObj.response
     }
 
+    fun getChannelId(prNumber: Int): String? = linkedForumPosts.entries.find { it.value == prNumber }?.key
+
+    fun getPullrequest(channelId: String): Int? = linkedForumPosts[channelId]
+
     fun deleteTag(keyword: String): Boolean {
         val key = keyword.lowercase()
         val statement = connection.prepareStatement("DELETE FROM keywords WHERE keyword = ?")
@@ -90,8 +128,18 @@ object Database {
         return updated
     }
 
+    fun deleteLink(channelId: String): Boolean {
+        val statement = connection.prepareStatement("DELETE FROM linked_posts WHERE channel_id = ?")
+        statement.setString(1, channelId)
+        val updated = statement.executeUpdate() > 0
+        if (updated) linkedForumPosts.remove(channelId)
+        return updated
+    }
+
     fun listTags(): List<Tag> = tags.values.toList()
 
+    fun listLinks(): Map<String, Int> = linkedForumPosts
+
     fun getTagCount(keyword: String): Int? {
         return tags[keyword.lowercase()]?.uses
     }
diff --git a/src/main/kotlin/at/hannibal2/skyhanni/discord/LinkListener.kt b/src/main/kotlin/at/hannibal2/skyhanni/discord/LinkListener.kt
new file mode 100644
index 0000000..ba5ffe5
--- /dev/null
+++ b/src/main/kotlin/at/hannibal2/skyhanni/discord/LinkListener.kt
@@ -0,0 +1,33 @@
+package at.hannibal2.skyhanni.discord
+
+import at.hannibal2.skyhanni.discord.Utils.messageSend
+import net.dv8tion.jda.api.events.message.MessageReceivedEvent
+
+object LinkListener {
+
+    private val githubPattern =
+        "\\[SkyHanniStudios/DiscordBot] (New comment on pull request|Pull request review submitted:) #(?<pr>\\d+):? .+".toPattern()
+
+    fun onMessage(bot: DiscordBot, event: MessageReceivedEvent) {
+        event.onMessage(bot)
+    }
+
+    private fun MessageReceivedEvent.onMessage(bot: DiscordBot) {
+        val embed = this.message.embeds[0]
+        val title = embed.title ?: return
+
+        val prNumber = getPr(title)?.toInt() ?: return
+        val channelId = Database.getChannelId(prNumber) ?: return
+
+        val guild = bot.jda.getGuildById(BOT.config.allowedServerId) ?: return
+        val channel = guild.getThreadChannelById(channelId) ?: return
+
+        channel.messageSend(this.message.embeds[0])
+    }
+
+    private fun getPr(title: String): String? {
+        val matcher = githubPattern.matcher(title)
+        if (!matcher.matches()) return null
+        return matcher.group("pr")
+    }
+}
\ No newline at end of file
diff --git a/src/main/kotlin/at/hannibal2/skyhanni/discord/Utils.kt b/src/main/kotlin/at/hannibal2/skyhanni/discord/Utils.kt
index 354f3b3..48abd6b 100644
--- a/src/main/kotlin/at/hannibal2/skyhanni/discord/Utils.kt
+++ b/src/main/kotlin/at/hannibal2/skyhanni/discord/Utils.kt
@@ -46,6 +46,10 @@ object Utils {
         logAction("Error: $text")
     }
 
+    fun MessageReceivedEvent.userSuccess(text: String) {
+        message.messageReply("✅ $text")
+    }
+
     fun MessageReceivedEvent.reply(embed: MessageEmbed) {
         message.messageReply(embed)
     }
@@ -81,6 +85,14 @@ object Utils {
         }
     }
 
+    fun MessageChannel.messageSend(embed: MessageEmbed, instantly: Boolean = false) {
+        if (instantly) {
+            sendMessageEmbeds(embed).complete()
+        } else {
+            sendMessageEmbeds(embed).queue()
+        }
+    }
+
     fun Message.replyWithConsumer(text: String, consumer: (MessageReceivedEvent) -> Unit) {
         BotMessageHandler.log(text, consumer)
         messageReply(text)
diff --git a/src/main/kotlin/at/hannibal2/skyhanni/discord/command/LinkCommands.kt b/src/main/kotlin/at/hannibal2/skyhanni/discord/command/LinkCommands.kt
new file mode 100644
index 0000000..69aa825
--- /dev/null
+++ b/src/main/kotlin/at/hannibal2/skyhanni/discord/command/LinkCommands.kt
@@ -0,0 +1,129 @@
+package at.hannibal2.skyhanni.discord.command
+
+import at.hannibal2.skyhanni.discord.BOT
+import at.hannibal2.skyhanni.discord.Database
+import at.hannibal2.skyhanni.discord.Option
+import at.hannibal2.skyhanni.discord.PLEADING_FACE
+import at.hannibal2.skyhanni.discord.Utils.logAction
+import at.hannibal2.skyhanni.discord.Utils.reply
+import at.hannibal2.skyhanni.discord.Utils.userError
+import at.hannibal2.skyhanni.discord.Utils.userSuccess
+import at.hannibal2.skyhanni.discord.command.LinkCommand.setTags
+import at.hannibal2.skyhanni.discord.command.LinkCommand.setTitle
+import at.hannibal2.skyhanni.discord.command.PullRequestCommand.parseValidPrNumber
+import at.hannibal2.skyhanni.discord.github.GitHubClient
+import net.dv8tion.jda.api.entities.channel.ChannelType
+import net.dv8tion.jda.api.entities.channel.concrete.ForumChannel
+import net.dv8tion.jda.api.entities.channel.concrete.ThreadChannel
+import net.dv8tion.jda.api.entities.channel.forums.ForumTag
+import net.dv8tion.jda.api.events.message.MessageReceivedEvent
+import net.dv8tion.jda.api.managers.channel.concrete.ThreadChannelManager
+
+object LinkCommand : BaseCommand() {
+    override val name = "link"
+
+    override val description = "Link a forum post to a pull request."
+    override val options: List<Option> = listOf(
+        Option("number", "Number of the pull request you want the post to be linked to.")
+    )
+
+    override fun MessageReceivedEvent.execute(args: List<String>) {
+        if (args.size != 1) return wrongUsage("<number>")
+        val prNumber = parseValidPrNumber(args.first()) ?: return
+
+        if (!isValidPrNumber(prNumber)) return
+
+        val post = channel.asThreadChannel()
+        val manager = post.manager
+
+        Database.getPullrequest(channel.id)?.let {
+            reply("Post already linked to $it $PLEADING_FACE")
+            return
+        }
+
+        Database.addLink(post.id, prNumber)
+        logAction("linked pr #$prNumber to this channel")
+
+        val titleFormat = prNumber.titleFormat()
+        if (!post.name.contains(titleFormat)) {
+            manager.setTitle("${post.name}$titleFormat")
+        }
+
+        post.updateTags(true)
+
+        userSuccess("Successfully linked PR $prNumber to this post.")
+    }
+
+    fun ThreadChannelManager.setTags(tags: List<ForumTag>) {
+        setAppliedTags(tags).queue()
+    }
+
+    fun ThreadChannelManager.setTitle(name: String) {
+        setName(name).queue()
+    }
+
+    private const val USER = "hannibal002"
+    private const val REPO = "SkyHanni"
+    private val github = GitHubClient(USER, REPO, BOT.config.githubTokenPullRequests)
+
+    private fun MessageReceivedEvent.isValidPrNumber(number: Int): Boolean {
+        if (!isFromType(ChannelType.GUILD_PUBLIC_THREAD)) {
+            userError("Wrong channel $PLEADING_FACE")
+            return false
+        }
+
+        try {
+            github.findPullRequest(number) ?: run {
+                userError("Pull request with number $number not found")
+                return false
+            }
+        } catch (e: Exception) {
+            userError("Pull request with number $number not found")
+            return false
+        }
+        return true
+    }
+}
+
+private fun ThreadChannel.updateTags(add: Boolean) {
+    val tags = appliedTags
+    val tag = parentChannel.asForumChannel().getAvailableTagById(BOT.config.openPrTagId) ?: return
+    if (add && tag !in tags) tags.add(tag) else if (!add && tag in tags) tags.remove(tag)
+
+    manager.setTags(tags)
+}
+
+private fun Int.titleFormat() = " (PR #$this)"
+
+object UnlinkCommand : BaseCommand() {
+    override val name = "unlink"
+
+    override val description = "Unlink a forum post from a pull request."
+
+    override fun MessageReceivedEvent.execute(args: List<String>) {
+        if (!isFromType(ChannelType.GUILD_PUBLIC_THREAD)) {
+            userError("Wrong channel $PLEADING_FACE")
+            return
+        }
+
+        val pr = Database.getPullrequest(channel.id) ?: run {
+            userError("Post isn't linked to any pull request $PLEADING_FACE")
+            return
+        }
+
+        val post = channel.asThreadChannel()
+        val manager = post.manager
+
+        Database.deleteLink(post.id)
+        logAction("unlinked pr #$pr from this channel")
+
+        val titleFormat = pr.titleFormat()
+        if (post.name.contains(titleFormat)) {
+            manager.setTitle(post.name.replace(titleFormat, ""))
+        }
+
+        post.updateTags(false)
+
+        userSuccess("Successfully unlinked this post.")
+    }
+}
\ No newline at end of file
diff --git a/src/main/kotlin/at/hannibal2/skyhanni/discord/command/PullRequestCommand.kt b/src/main/kotlin/at/hannibal2/skyhanni/discord/command/PullRequestCommand.kt
index c517a3c..4bdcb7b 100644
--- a/src/main/kotlin/at/hannibal2/skyhanni/discord/command/PullRequestCommand.kt
+++ b/src/main/kotlin/at/hannibal2/skyhanni/discord/command/PullRequestCommand.kt
@@ -19,6 +19,7 @@ import at.hannibal2.skyhanni.discord.json.discord.Conclusion
 import at.hannibal2.skyhanni.discord.json.discord.PullRequestJson
 import at.hannibal2.skyhanni.discord.json.discord.RunStatus
 import at.hannibal2.skyhanni.discord.utils.ErrorManager.handleError
+import net.dv8tion.jda.api.entities.channel.ChannelType
 import net.dv8tion.jda.api.events.message.MessageReceivedEvent
 import java.awt.Color
 import java.io.File
@@ -49,17 +50,26 @@ object PullRequestCommand : BaseCommand() {
     private val cleanPullRequestPattern = "#(?<pr>\\d+),?".toPattern()
 
     override fun MessageReceivedEvent.execute(args: List<String>) {
-        if (args.size != 1) return wrongUsage("<number>")
-        val first = args.first().removePrefix("#")
-        val prNumber = first.toIntOrNull() ?: run {
-            userError("Unknown number $PLEADING_FACE ($first})")
-            return
+        val prNumber = if (args.isEmpty()) {
+            if (!isFromType(ChannelType.GUILD_PUBLIC_THREAD)) return
+            Database.getPullrequest(channel.id) ?: return
+        } else {
+            parseValidPrNumber(args.first().removePrefix("#")) ?: return
+        }
+        loadPrInfos(prNumber)
+    }
+
+    fun MessageReceivedEvent.parseValidPrNumber(rawNumber: String): Int? {
+        val number = rawNumber.toIntOrNull() ?: run {
+            userError("Unknown number $PLEADING_FACE ($rawNumber)")
+            return null
         }
-        if (prNumber < 1) {
+        if (number < 1) {
             userError("PR number needs to be positive $PLEADING_FACE")
-            return
+            return null
         }
-        loadPrInfos(prNumber)
+
+        return number
     }
 
     private fun MessageReceivedEvent.loadPrInfos(prNumber: Int, showError: Boolean = true) {
@@ -243,7 +253,7 @@ object PullRequestCommand : BaseCommand() {
     private fun appendLabelCategory(
         labelType: String, labels: Set<String>, stringBuilder: StringBuilder, suffix: String = ""
     ): StringBuilder {
-        val labelsWithType = labels.intersect(labelTypes[labelType] ?: setOf())
+        val labelsWithType = labels.intersect((labelTypes[labelType] ?: setOf()).toSet())
         if (labelsWithType.isEmpty()) return stringBuilder.append(if (suffix.isNotEmpty()) "> $labelType: $suffix\n" else "")
         return stringBuilder.append("> $labelType: `${labelsWithType.joinToString("` `")}`$suffix\n")
     }
@@ -275,7 +285,7 @@ object PullRequestCommand : BaseCommand() {
             return
         }
         val prNumber = args[1].toIntOrNull() ?: run {
-            reply("unknwon number $PLEADING_FACE (${args[1]})")
+            reply("unknown number $PLEADING_FACE (${args[1]})")
             return
         }
 
@@ -305,7 +315,7 @@ object PullRequestCommand : BaseCommand() {
         val (_, downloadTime) = timeExecution {
             github.downloadArtifact(artifactId, fileRaw)
         }
-        reply("artifact downnloaded in ${downloadTime.format()}")
+        reply("artifact downloaded in ${downloadTime.format()}")
 
         Utils.unzipFile(fileRaw, fileUnzipped)
         fileRaw.delete()
@@ -358,4 +368,4 @@ object PullRequestCommand : BaseCommand() {
         return false
     }
 
-}
+}
\ No newline at end of file