Extract unpin scheduler interface into a standalone module

Author: madhead

pins/build.gradle.kts

@@ -7,6 +7,7 @@ dependencies {
     api(libs.tgbotapi)
     api(project.projects.monies)
     implementation(project.projects.pins.dto)
+    implementation(project.projects.pins.scheduler)
     implementation(libs.log4j.api)
 
     testImplementation(libs.junit.jupiter.api)

pins/dto/src/main/java/by/jprof/telegram/bot/pins/dto/Unpin.java

@@ -3,63 +3,53 @@
 import java.util.Objects;
 
 public class Unpin {
-	private Long messageId;
-	private Long chatId;
-	private Long userId;
-	private Long ttl;
-
-	public Long getMessageId() {
-		return messageId;
-	}
-
-	public void setMessageId(Long messageId) {
-		this.messageId = messageId;
-	}
-
-	public Long getChatId() {
-		return chatId;
-	}
-
-	public void setChatId(Long chatId) {
-		this.chatId = chatId;
-	}
-
-	public Long getUserId() {
-		return userId;
-	}
-
-	public void setUserId(Long userId) {
-		this.userId = userId;
-	}
-
-	public Long getTtl() {
-		return ttl;
-	}
-
-	public void setTtl(Long ttl) {
-		this.ttl = ttl;
-	}
-
-	@Override
-	public boolean equals(Object o) {
-		if (this == o) return true;
-		if (o == null || getClass() != o.getClass()) return false;
-		Unpin unpin = (Unpin) o;
-		return Objects.equals(messageId, unpin.messageId) && Objects.equals(chatId, unpin.chatId) && Objects.equals(userId, unpin.userId) && Objects.equals(ttl, unpin.ttl);
-	}
-
-	@Override
-	public int hashCode() {
-		return Objects.hash(messageId, chatId, userId, ttl);
-	}
-
-	@Override
-	public String toString() {
-		return "Unpin{" +
-		       "messageId=" + messageId +
-		       ", chatId=" + chatId +
-		       ", userId=" + userId +
-		       ", ttl=" + ttl +
-		       '}';
-	}
+    private Long messageId;
+    private Long chatId;
+    private Long ttl;
+
+    public Long getMessageId() {
+        return messageId;
+    }
+
+    public void setMessageId(Long messageId) {
+        this.messageId = messageId;
+    }
+
+    public Long getChatId() {
+        return chatId;
+    }
+
+    public void setChatId(Long chatId) {
+        this.chatId = chatId;
+    }
+
+    public Long getTtl() {
+        return ttl;
+    }
+
+    public void setTtl(Long ttl) {
+        this.ttl = ttl;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        Unpin unpin = (Unpin) o;
+        return Objects.equals(messageId, unpin.messageId) && Objects.equals(chatId, unpin.chatId) && Objects.equals(ttl, unpin.ttl);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(messageId, chatId, ttl);
+    }
+
+    @Override
+    public String toString() {
+        return "Unpin{" +
+               "messageId=" + messageId +
+               ", chatId=" + chatId +
+               ", ttl=" + ttl +
+               '}';
+    }
 }

pins/scheduler/README.adoc

@@ -0,0 +1,3 @@
+= Pins / Unpin Scheduler
+
+Message unpin scheduler interface.

pins/scheduler/build.gradle.kts

@@ -0,0 +1,7 @@
+plugins {
+    kotlin("jvm")
+}
+
+dependencies {
+    api(project.projects.pins.dto)
+}

pins/src/main/kotlin/by/jprof/telegram/bot/pins/scheduler/UnpinScheduler.kt renamed to pins/scheduler/src/main/kotlin/by/jprof/telegram/bot/pins/scheduler/UnpinScheduler.kt

@@ -5,6 +5,7 @@ plugins {
 dependencies {
     api(project.projects.pins)
     api(project.projects.pins.dto)
+    api(project.projects.pins.scheduler)
     api(libs.sfn)
     implementation(libs.kotlinx.coroutines.jdk8)
 

pins/sfn/build.gradle.kts

@@ -16,7 +16,6 @@ class UnpinScheduler(
             it.input("""{
                 |  "messageId": ${unpin.messageId},
                 |  "chatId": ${unpin.chatId},
-                |  "userId": ${unpin.userId},
                 |  "ttl": ${unpin.ttl}
                 |}""".trimMargin())
         }.await()

pins/sfn/src/main/kotlin/by/jprof/telegram/bot/pins/sfn/scheduler/UnpinScheduler.kt

@@ -88,7 +88,6 @@ class PinCommandUpdateProcessor(
                 unpinScheduler.scheduleUnpin(Unpin().apply {
                     messageId = pin.message.messageId
                     chatId = pin.chat.id.chatId
-                    userId = pin.user.id.chatId
                     ttl = duration.duration.seconds
                 })
             } catch (e: Exception) {

pins/src/main/kotlin/by/jprof/telegram/bot/pins/PinCommandUpdateProcessor.kt

@@ -25,6 +25,7 @@ include(":quizoji:dynamodb")
 include(":eval")
 include(":pins")
 include(":pins:dto")
+include(":pins:scheduler")
 include(":pins:unpin")
 include(":pins:dynamodb")
 include(":pins:sfn")