Remove Left Over Lease Logic/Rearrange Packages (#40)

* remove lease logic

* update package

Author: SentryMan

pom.xml

@@ -87,11 +87,11 @@
 			<artifactId>spring-security-messaging</artifactId>
 		</dependency>
 
-		<dependency>
+	<!--/	<dependency>
 			<groupId>com.netflix.concurrency-limits</groupId>
 			<artifactId>concurrency-limits-core</artifactId>
 			<version>0.3.6</version>
-		</dependency>
+		</dependency> -->
 
 
 		<!--/Boot Dependencies -->

src/main/java/com/mangasite/MangaBackendApplication.java

@@ -24,12 +24,11 @@
 import org.springframework.nativex.hint.TypeHint;
 
 import com.mangasite.domain.init.AppInitializer;
-import com.mangasite.domain.lease.LeaseManager;
-import com.mangasite.record.ChapterChangeRequest;
 import com.mangasite.record.DeviceInfo;
-import com.mangasite.record.MangaChangeRequest;
-import com.mangasite.record.PageChangeRequest;
 import com.mangasite.record.ServerMessage;
+import com.mangasite.record.changerequests.ChapterChangeRequest;
+import com.mangasite.record.changerequests.MangaChangeRequest;
+import com.mangasite.record.changerequests.PageChangeRequest;
 import com.mongodb.client.model.changestream.ChangeStreamDocument;
 
 import reactor.core.publisher.Hooks;
@@ -40,7 +39,6 @@
         @TypeHint(
             access = PUBLIC_CONSTRUCTORS | PUBLIC_METHODS,
             types = {
-              LeaseManager.class,
               ChangeStreamDocument.class,
               ChapterChangeRequest.class,
               MangaChangeRequest.class,

src/main/java/com/mangasite/config/ServerConfig.java

@@ -23,13 +23,8 @@
 @Configuration
 public class ServerConfig implements WebFluxConfigurer {
 
-  //  private static final int CONCURRENT_WORKERS_COUNT = 5;
-  //  private static final int QUEUE_CAPACITY = 10;
-  //  private static final int LEASE_TTL_MILLI = 5_000;
-
   public static final RSocketServerCustomizer serverCustomizer() {
 
-    // final var leaseManager = new LeaseManager(CONCURRENT_WORKERS_COUNT, LEASE_TTL_MILLI);
     final var resume =
         new Resume()
             .cleanupStoreOnKeepAlive()
@@ -38,16 +33,6 @@ public static final RSocketServerCustomizer serverCustomizer() {
                     .doBeforeRetry(s -> System.out.println("Disconnected. Trying to resume...")));
     return rsocketServer -> {
       rsocketServer.resume(resume);
-      //          .lease(
-      //              config ->
-      //                  config.sender(
-      //                      new LimitBasedLeaseSender(
-      //                          UUID.randomUUID().toString(),
-      //                          leaseManager,
-      //                          VegasLimit.newBuilder()
-      //                              .initialLimit(CONCURRENT_WORKERS_COUNT)
-      //                              .maxConcurrency(QUEUE_CAPACITY)
-      //                              .build())))
     };
   }
 

src/main/java/com/mangasite/domain/Manga.java

@@ -8,7 +8,7 @@
 import org.springframework.data.annotation.PersistenceConstructor;
 import org.springframework.data.mongodb.core.mapping.Document;
 
-import com.mangasite.record.MangaChangeRequest;
+import com.mangasite.record.changerequests.MangaChangeRequest;
 
 /**
  * A class that represents a single manga <br>

src/main/java/com/mangasite/domain/lease/LeaseManager.java

@@ -1,4 +1,4 @@
-package com.mangasite.record;
+package com.mangasite.record.changerequests;
 
 public record ChapterChangeRequest(
       Integer mangaId,

src/main/java/com/mangasite/domain/lease/LimitBasedLeaseSender.java

@@ -1,4 +1,4 @@
-package com.mangasite.record;
+package com.mangasite.record.changerequests;
 
 import java.util.List;
 

src/main/java/com/mangasite/domain/lease/LimitBasedStatsCollector.java

@@ -1,4 +1,4 @@
-package com.mangasite.record;
+package com.mangasite.record.changerequests;
 
 public record PageChangeRequest (
       Integer mangaId,