style: fix spotless formatting violations and remove unwanted files

Signed-off-by: Twiineenock <Twiineenock@users.noreply.github.com>

Author: Twiineenock

hiero-enterprise-base/src/main/java/org/hiero/base/mirrornode/MirrorNodeClient.java

@@ -184,8 +184,8 @@ default Optional<Nft> queryNftsByAccountAndTokenIdAndSerial(
    * @return a page of transaction information
    * @throws HieroException if an error occurs during the query
    */
-  @NonNull Page<TransactionInfo> queryTransactionsByAccount(@NonNull AccountId accountId, @NonNull Instant after)
-      throws HieroException;
+  @NonNull Page<TransactionInfo> queryTransactionsByAccount(
+      @NonNull AccountId accountId, @NonNull Instant after) throws HieroException;
 
   /**
    * Queries all transactions for a specific account and transaction type.

hiero-enterprise-base/src/main/java/org/hiero/base/mirrornode/TopicRepository.java

@@ -78,7 +78,8 @@ default Page<TopicMessage> getMessages(String topicId) throws HieroException {
    * @return Page of TopicMessage
    * @throws HieroException if the search fails
    */
-  @NonNull default Page<TopicMessage> getMessages(@NonNull String topicId, @NonNull Instant after)
+  @NonNull
+  default Page<TopicMessage> getMessages(@NonNull String topicId, @NonNull Instant after)
       throws HieroException {
     Objects.requireNonNull(topicId, "topicId must not be null");
     Objects.requireNonNull(after, "after must not be null");

hiero-enterprise-base/src/main/java/org/hiero/base/mirrornode/TransactionRepository.java

@@ -58,7 +58,8 @@ default Page<TransactionInfo> findByAccount(@NonNull String accountId) throws Hi
    * @return page of transactions
    * @throws HieroException if the search fails
    */
-  @NonNull default Page<TransactionInfo> findByAccount(@NonNull String accountId, @NonNull Instant after)
+  @NonNull
+  default Page<TransactionInfo> findByAccount(@NonNull String accountId, @NonNull Instant after)
       throws HieroException {
     Objects.requireNonNull(accountId, "accountId must not be null");
     Objects.requireNonNull(after, "after must not be null");

hiero-enterprise-base/src/main/java/org/hiero/base/observer/AbstractPollingObserver.java

@@ -1,7 +1,6 @@
 package org.hiero.base.observer;
 
 import java.time.Duration;
-import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -12,90 +11,86 @@
 /**
  * Base implementation for observers that poll the Mirror Node at regular intervals.
  *
- * <p>This class handles the lifecycle of the background polling task, including
- * starting, stopping, and handling unexpected errors during polling.
+ * <p>This class handles the lifecycle of the background polling task, including starting, stopping,
+ * and handling unexpected errors during polling.
  *
  * @param <T> The type of event being observed.
  */
 public abstract class AbstractPollingObserver<T> {
 
-    private static final Logger log = LoggerFactory.getLogger(AbstractPollingObserver.class);
+  private static final Logger log = LoggerFactory.getLogger(AbstractPollingObserver.class);
 
-    private final ScheduledExecutorService executorService;
-    private final Duration pollingInterval;
-    private final EventObserver<T> listener;
-    private final AtomicBoolean running = new AtomicBoolean(false);
+  private final ScheduledExecutorService executorService;
+  private final Duration pollingInterval;
+  private final EventObserver<T> listener;
+  private final AtomicBoolean running = new AtomicBoolean(false);
 
-    /**
-     * Creates a new polling observer.
-     *
-     * @param executorService The shared executor service to use for polling.
-     * @param pollingInterval How often to check for new events.
-     * @param listener The callback to trigger when an event is found.
-     */
-    protected AbstractPollingObserver(
-            @NonNull ScheduledExecutorService executorService,
-            @NonNull Duration pollingInterval,
-            @NonNull EventObserver<T> listener) {
-        this.executorService = executorService;
-        this.pollingInterval = pollingInterval;
-        this.listener = listener;
-    }
+  /**
+   * Creates a new polling observer.
+   *
+   * @param executorService The shared executor service to use for polling.
+   * @param pollingInterval How often to check for new events.
+   * @param listener The callback to trigger when an event is found.
+   */
+  protected AbstractPollingObserver(
+      @NonNull ScheduledExecutorService executorService,
+      @NonNull Duration pollingInterval,
+      @NonNull EventObserver<T> listener) {
+    this.executorService = executorService;
+    this.pollingInterval = pollingInterval;
+    this.listener = listener;
+  }
 
-    /**
-     * Starts the background polling task.
-     */
-    public void start() {
-        if (running.compareAndSet(false, true)) {
-            log.info("Starting Hiero observer: {}", getClass().getSimpleName());
-            scheduleNext(0);
-        }
+  /** Starts the background polling task. */
+  public void start() {
+    if (running.compareAndSet(false, true)) {
+      log.info("Starting Hiero observer: {}", getClass().getSimpleName());
+      scheduleNext(0);
     }
+  }
 
-    private void scheduleNext(long delayMs) {
-        if (running.get()) {
-            executorService.schedule(this::pollSafe, delayMs, TimeUnit.MILLISECONDS);
-        }
+  private void scheduleNext(long delayMs) {
+    if (running.get()) {
+      executorService.schedule(this::pollSafe, delayMs, TimeUnit.MILLISECONDS);
     }
+  }
 
-    /**
-     * Stops the background polling task.
-     */
-    public void stop() {
-        running.set(false);
-        log.info("Stopping Hiero observer: {}", getClass().getSimpleName());
-    }
+  /** Stops the background polling task. */
+  public void stop() {
+    running.set(false);
+    log.info("Stopping Hiero observer: {}", getClass().getSimpleName());
+  }
 
-    private void pollSafe() {
-        try {
-            boolean hasMore = poll();
-            // If there's more data (pagination), poll again immediately.
-            // Otherwise, wait for the polling interval.
-            scheduleNext(hasMore ? 0 : pollingInterval.toMillis());
-        } catch (Exception e) {
-            log.error("Unexpected error during Hiero polling in {}", getClass().getSimpleName(), e);
-            scheduleNext(pollingInterval.toMillis());
-        }
+  private void pollSafe() {
+    try {
+      boolean hasMore = poll();
+      // If there's more data (pagination), poll again immediately.
+      // Otherwise, wait for the polling interval.
+      scheduleNext(hasMore ? 0 : pollingInterval.toMillis());
+    } catch (Exception e) {
+      log.error("Unexpected error during Hiero polling in {}", getClass().getSimpleName(), e);
+      scheduleNext(pollingInterval.toMillis());
     }
+  }
 
-    /**
-     * The actual polling logic to be implemented by subclasses.
-     *
-     * @return true if there is more data to poll immediately (pagination), false otherwise.
-     * @throws Exception if polling fails.
-     */
-    public abstract boolean poll() throws Exception;
+  /**
+   * The actual polling logic to be implemented by subclasses.
+   *
+   * @return true if there is more data to poll immediately (pagination), false otherwise.
+   * @throws Exception if polling fails.
+   */
+  public abstract boolean poll() throws Exception;
 
-    /**
-     * Notifies the listener of a new event.
-     *
-     * @param event The event to notify.
-     */
-    protected void notifyListener(@NonNull T event) {
-        try {
-            listener.onEvent(event);
-        } catch (Exception e) {
-            log.error("Error in event listener callback", e);
-        }
+  /**
+   * Notifies the listener of a new event.
+   *
+   * @param event The event to notify.
+   */
+  protected void notifyListener(@NonNull T event) {
+    try {
+      listener.onEvent(event);
+    } catch (Exception e) {
+      log.error("Error in event listener callback", e);
     }
+  }
 }

hiero-enterprise-base/src/main/java/org/hiero/base/observer/EventObserver.java

@@ -3,18 +3,18 @@
 /**
  * Functional interface for a component that observes events on the Hiero network.
  *
- * <p>Implementations of this interface typically run in a background thread or are
- * triggered by a scheduler to check for new network activities.
+ * <p>Implementations of this interface typically run in a background thread or are triggered by a
+ * scheduler to check for new network activities.
  *
  * @param <T> The type of event being observed (e.g., TransactionInfo, TopicMessage).
  */
 @FunctionalInterface
 public interface EventObserver<T> {
 
-    /**
-     * Called when a new event is detected.
-     *
-     * @param event The detected event.
-     */
-    void onEvent(T event);
+  /**
+   * Called when a new event is detected.
+   *
+   * @param event The detected event.
+   */
+  void onEvent(T event);
 }

hiero-enterprise-base/src/main/java/org/hiero/base/observer/TopicObserver.java

@@ -13,73 +13,71 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-/**
- * Observer that polls for new messages on a specific Hiero Consensus Service (HCS) topic.
- */
+/** Observer that polls for new messages on a specific Hiero Consensus Service (HCS) topic. */
 public class TopicObserver extends AbstractPollingObserver<TopicMessage> {
 
-    private static final Logger log = LoggerFactory.getLogger(TopicObserver.class);
+  private static final Logger log = LoggerFactory.getLogger(TopicObserver.class);
 
-    private final TopicRepository repository;
-    private final TopicId topicId;
-    private Instant lastSeenTimestamp;
+  private final TopicRepository repository;
+  private final TopicId topicId;
+  private Instant lastSeenTimestamp;
 
-    /**
-     * Creates a new topic observer.
-     *
-     * @param executorService The shared executor service to use for polling.
-     * @param repository The repository to use for polling.
-     * @param topicId The topic to monitor.
-     * @param pollingInterval How often to poll the mirror node.
-     * @param listener The callback for new messages.
-     */
-    public TopicObserver(
-            @NonNull ScheduledExecutorService executorService,
-            @NonNull TopicRepository repository,
-            @NonNull TopicId topicId,
-            @NonNull Duration pollingInterval,
-            @NonNull EventObserver<TopicMessage> listener) {
-        super(executorService, pollingInterval, listener);
-        this.repository = repository;
-        this.topicId = topicId;
-        this.lastSeenTimestamp = Instant.now();
-    }
+  /**
+   * Creates a new topic observer.
+   *
+   * @param executorService The shared executor service to use for polling.
+   * @param repository The repository to use for polling.
+   * @param topicId The topic to monitor.
+   * @param pollingInterval How often to poll the mirror node.
+   * @param listener The callback for new messages.
+   */
+  public TopicObserver(
+      @NonNull ScheduledExecutorService executorService,
+      @NonNull TopicRepository repository,
+      @NonNull TopicId topicId,
+      @NonNull Duration pollingInterval,
+      @NonNull EventObserver<TopicMessage> listener) {
+    super(executorService, pollingInterval, listener);
+    this.repository = repository;
+    this.topicId = topicId;
+    this.lastSeenTimestamp = Instant.now();
+  }
 
-    @Override
-    public boolean poll() throws Exception {
-        log.trace("Polling messages for topic {} after {}", topicId, lastSeenTimestamp);
+  @Override
+  public boolean poll() throws Exception {
+    log.trace("Polling messages for topic {} after {}", topicId, lastSeenTimestamp);
 
-        Page<TopicMessage> page = repository.getMessages(topicId, lastSeenTimestamp);
-        processPage(page);
+    Page<TopicMessage> page = repository.getMessages(topicId, lastSeenTimestamp);
+    processPage(page);
 
-        return page.hasNext();
-    }
+    return page.hasNext();
+  }
 
-    private void processPage(Page<TopicMessage> page) {
-        List<TopicMessage> messages = new java.util.ArrayList<>(page.getData());
-        if (messages.isEmpty()) {
-            return;
-        }
+  private void processPage(Page<TopicMessage> page) {
+    List<TopicMessage> messages = new java.util.ArrayList<>(page.getData());
+    if (messages.isEmpty()) {
+      return;
+    }
 
-        // Sort by timestamp to ensure chronological delivery
-        messages.sort(Comparator.comparing(TopicMessage::consensusTimestamp));
+    // Sort by timestamp to ensure chronological delivery
+    messages.sort(Comparator.comparing(TopicMessage::consensusTimestamp));
 
-        for (TopicMessage msg : messages) {
-            if (msg.consensusTimestamp().isAfter(lastSeenTimestamp)) {
-                notifyListener(msg);
-                lastSeenTimestamp = msg.consensusTimestamp();
-            }
-        }
+    for (TopicMessage msg : messages) {
+      if (msg.consensusTimestamp().isAfter(lastSeenTimestamp)) {
+        notifyListener(msg);
+        lastSeenTimestamp = msg.consensusTimestamp();
+      }
     }
+  }
 
-    /**
-     * Sets the starting timestamp for the observer.
-     *
-     * @param timestamp The timestamp to start from.
-     * @return this observer for chaining.
-     */
-    public TopicObserver startFrom(@NonNull Instant timestamp) {
-        this.lastSeenTimestamp = timestamp;
-        return this;
-    }
+  /**
+   * Sets the starting timestamp for the observer.
+   *
+   * @param timestamp The timestamp to start from.
+   * @return this observer for chaining.
+   */
+  public TopicObserver startFrom(@NonNull Instant timestamp) {
+    this.lastSeenTimestamp = timestamp;
+    return this;
+  }
 }