From 7bae5eb6f6cd402e1ebfca979a75122fbc87e4d7 Mon Sep 17 00:00:00 2001 From: Jacob Nguyen <76754747+jacoobes@users.noreply.github.com> Date: Thu, 18 Aug 2022 14:51:16 -0500 Subject: [PATCH] feat: pull requests can make comments now! --- src/main/kotlin/EventEmitter.kt | 1 - src/main/kotlin/HttpClientExtensions.kt | 1 - src/main/kotlin/Main.kt | 3 +-- 3 files changed, 1 insertion(+), 4 deletions(-) diff --git a/src/main/kotlin/EventEmitter.kt b/src/main/kotlin/EventEmitter.kt index 9978d47..b025067 100644 --- a/src/main/kotlin/EventEmitter.kt +++ b/src/main/kotlin/EventEmitter.kt @@ -8,7 +8,6 @@ class EventEmitter { val events = _events.asSharedFlow() // publicly exposed as read-only shared flow suspend fun produceEvent(event: String) { - print(event) _events.emit(event) // suspends until all subscribers receive it } } \ No newline at end of file diff --git a/src/main/kotlin/HttpClientExtensions.kt b/src/main/kotlin/HttpClientExtensions.kt index 742b2db..8112df6 100644 --- a/src/main/kotlin/HttpClientExtensions.kt +++ b/src/main/kotlin/HttpClientExtensions.kt @@ -28,7 +28,6 @@ fun Routing.pullRequests() { call.respond(HttpStatusCode.Unauthorized, "Nice try") } launch(Dispatchers.Default) { - Client.eventEmitter.produceEvent(text) }.join() } diff --git a/src/main/kotlin/Main.kt b/src/main/kotlin/Main.kt index 536b8a6..369ff05 100644 --- a/src/main/kotlin/Main.kt +++ b/src/main/kotlin/Main.kt @@ -8,8 +8,7 @@ fun main() = runBlocking { val repo = client.fetchRepoAsync("awesome-plugins").await() client.on("pull_request") { - - println(it) + repo.getPullRequest(it.number).comment("Hello, I just saw that you did something to this pull request") } println("Start program") client.startWebhookListener()