🔀 Merge next

[Sone.git] / src / main / kotlin / net / pterodactylus / sone / freenet / plugin / FredPluginConnector.kt

diff --git a/src/main/kotlin/net/pterodactylus/sone/freenet/plugin/FredPluginConnector.kt b/src/main/kotlin/net/pterodactylus/sone/freenet/plugin/FredPluginConnector.kt
new file mode 100644 (file)
index 0000000..98849c4
--- /dev/null
+++ b/src/main/kotlin/net/pterodactylus/sone/freenet/plugin/FredPluginConnector.kt
@@ -0,0 +1,35 @@
+/* Fred’s plugin stuff is mostly deprecated. ¯\_(ツ)_/¯ */
+@file:Suppress("DEPRECATION")
+
+package net.pterodactylus.sone.freenet.plugin
+
+import freenet.pluginmanager.*
+import freenet.support.*
+import freenet.support.api.*
+import kotlinx.coroutines.*
+import kotlinx.coroutines.channels.*
+import javax.inject.*
+
+/**
+ * [PluginConnector] implementation that uses a [PluginRespiratorFacade] and coroutines to send
+ * a request to another plugin and receive a reply.
+ */
+class FredPluginConnector @Inject constructor(private val pluginRespiratorFacade: PluginRespiratorFacade) : PluginConnector {
+
+       override suspend fun sendRequest(pluginName: String, fields: SimpleFieldSet, data: Bucket?): PluginReply {
+               val receivedReply = Channel<PluginReply>()
+               val responseReceiver = FredPluginTalker { _, _, responseFields, responseData ->
+                       GlobalScope.launch {
+                               receivedReply.send(PluginReply(responseFields, responseData))
+                       }
+               }
+               try {
+                       val pluginTalker = pluginRespiratorFacade.getPluginTalker(responseReceiver, pluginName, "")
+                       pluginTalker.send(fields, data)
+                       return receivedReply.receive()
+               } catch (e: PluginNotFoundException) {
+                       throw PluginException(cause = e)
+               }
+       }
+
+}