Voting processor for herald votes

Author: madhead

herald/processor/README.adoc

@@ -0,0 +1,3 @@
+= Herald / Processor
+
+link:../../votes/voting-processor/src/main/kotlin/by/jprof/telegram/bot/votes/voting_processor/VotingProcessor.kt[`VotingProcessor`] implementation for this scheduled messages poster.

herald/processor/build.gradle.kts

@@ -0,0 +1,10 @@
+plugins {
+    kotlin("jvm")
+}
+
+dependencies {
+    api(project.projects.core)
+    api(project.projects.votes)
+    api(project.projects.votes.votingProcessor)
+    implementation(libs.log4j.api)
+}

herald/processor/src/main/kotlin/by/jprof/telegram/bot/herald/processor/HeraldVoteUpdateProcessor.kt

@@ -0,0 +1,29 @@
+package by.jprof.telegram.bot.herald.processor
+
+import by.jprof.telegram.bot.core.UpdateProcessor
+import by.jprof.telegram.bot.votes.dao.VotesDAO
+import by.jprof.telegram.bot.votes.voting_processor.VotingProcessor
+import dev.inmo.tgbotapi.bot.RequestsExecutor
+import dev.inmo.tgbotapi.types.update.CallbackQueryUpdate
+import dev.inmo.tgbotapi.types.update.abstracts.Update
+import org.apache.logging.log4j.LogManager
+
+class HeraldVoteUpdateProcessor(
+    votesDAO: VotesDAO,
+    bot: RequestsExecutor,
+) : VotingProcessor(
+    "HERALD",
+    votesDAO,
+    { throw UnsupportedOperationException("Votes should be constructed elsewhere!") },
+    bot,
+), UpdateProcessor {
+    companion object {
+        private val logger = LogManager.getLogger(HeraldVoteUpdateProcessor::class.java)!!
+    }
+
+    override suspend fun process(update: Update) {
+        when (update) {
+            is CallbackQueryUpdate -> processCallbackQuery(update.data)
+        }
+    }
+}

runners/lambda/build.gradle.kts

@@ -20,4 +20,5 @@ dependencies {
     implementation(project.projects.pins.dynamodb)
     implementation(project.projects.pins.sfn)
     implementation(project.projects.currencies)
+    implementation(project.projects.herald.processor)
 }

runners/lambda/src/main/kotlin/by/jprof/telegram/bot/runners/lambda/config/pipeline.kt

@@ -3,8 +3,8 @@ package by.jprof.telegram.bot.runners.lambda.config
 import by.jprof.telegram.bot.core.UpdateProcessingPipeline
 import by.jprof.telegram.bot.core.UpdateProcessor
 import by.jprof.telegram.bot.currencies.CurrenciesUpdateProcessor
-import by.jprof.telegram.bot.currencies.parser.MonetaryAmountParsingPipeline
 import by.jprof.telegram.bot.eval.EvalUpdateProcessor
+import by.jprof.telegram.bot.herald.processor.HeraldVoteUpdateProcessor
 import by.jprof.telegram.bot.jep.JEPUpdateProcessor
 import by.jprof.telegram.bot.jep.JsoupJEPSummary
 import by.jprof.telegram.bot.kotlin.KotlinMentionsUpdateProcessor
@@ -123,4 +123,11 @@ val pipelineModule = module {
             bot = get(),
         )
     }
+
+    single<UpdateProcessor>(named("HeraldVoteUpdateProcessor")) {
+        HeraldVoteUpdateProcessor(
+            votesDAO = get(),
+            bot = get(),
+        )
+    }
 }

settings.gradle.kts

@@ -31,3 +31,4 @@ include(":pins:sfn")
 include(":runners:lambda")
 include(":currencies")
 include(":herald")
+include(":herald:processor")