Support multiple webhooks (#72)

The `webhook` option can now be used multiple times. Fixes #71.
ACINQ · Jul 15, 2024 · 867998a · 867998a
1 parent 4743a7e
commit 867998a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/src/commonMain/kotlin/fr/acinq/lightning/bin/Api.kt b/src/commonMain/kotlin/fr/acinq/lightning/bin/Api.kt
@@ -64,7 +64,7 @@ class Api(
     private val peer: Peer,
     private val eventsFlow: SharedFlow<ApiEvent>,
     private val password: String,
-    private val webhookUrl: Url?,
+    private val webhookUrls: List<Url>,
     private val webhookSecret: String,
     private val loggerFactory: LoggerFactory,
 ) {
@@ -372,7 +372,7 @@ class Api(
             }
         }
 
-        webhookUrl?.let { url ->
+        webhookUrls.forEach { url ->
             val client = HttpClient {
                 install(io.ktor.client.plugins.contentnegotiation.ContentNegotiation) {
                     json(json = Json {

diff --git a/src/commonMain/kotlin/fr/acinq/lightning/bin/Main.kt b/src/commonMain/kotlin/fr/acinq/lightning/bin/Main.kt
@@ -111,8 +111,9 @@ class Phoenixd : CliktCommand() {
             terminal.println(white("done"))
             value
         }
-    private val webHookUrl by option("--webhook", help = "Webhook http endpoint for push notifications (alternative to websocket)")
+    private val webHookUrls by option("--webhook", help = "Webhook http endpoint for push notifications (alternative to websocket)")
         .convert { Url(it) }
+        .multiple()
     private val webHookSecret by option("--webhook-secret", help = "Secret used to authenticate webhook calls")
         .defaultLazy {
             // if we are here then no value is defined in phoenix.conf
@@ -364,7 +365,7 @@ class Phoenixd : CliktCommand() {
                 reuseAddress = true
             },
             module = {
-                Api(nodeParams, peer, eventsFlow, httpPassword, webHookUrl, webHookSecret, loggerFactory).run { module() }
+                Api(nodeParams, peer, eventsFlow, httpPassword, webHookUrls, webHookSecret, loggerFactory).run { module() }
             }
         )
         val serverJob = scope.launch {