create scheduler for checking reserved domain transactions

src/main/java/com/staketab/minanames/config/SchedulerConfig.java

@@ -0,0 +1,11 @@
+package com.staketab.minanames.config;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@Configuration
+@EnableScheduling
+@ConditionalOnProperty(name = "scheduled.enabled", matchIfMissing = true)
+public class SchedulerConfig {
+}

src/main/java/com/staketab/minanames/repository/PayableTransactionRepository.java

@@ -1,9 +1,14 @@
 package com.staketab.minanames.repository;
 
 import com.staketab.minanames.entity.PayableTransactionEntity;
+import com.staketab.minanames.entity.dto.TxStatus;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 
+import java.util.List;
+
 @Repository
 public interface PayableTransactionRepository extends JpaRepository<PayableTransactionEntity, String> {
+
+ List<PayableTransactionEntity> findAllByTxStatus(TxStatus txStatus);
 }

src/main/java/com/staketab/minanames/scheduler/CheckerReservedTransactionScheduler.java

@@ -0,0 +1,22 @@
+package com.staketab.minanames.scheduler;
+
+import com.staketab.minanames.service.abstraction.TxService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+@ConditionalOnProperty(value = "scheduled.checker-tx-reserve.enabled", havingValue = "true")
+public class CheckerReservedTransactionScheduler {
+
+ private final TxService txService;
+
+ @Scheduled(fixedDelayString = "${scheduled.checker-tx-reserve.upload-mills}")
+ public void updateProjects() {
+ txService.checkTransactions();
+ }
+}

src/main/java/com/staketab/minanames/service/abstraction/TxService.java

@@ -4,4 +4,5 @@
 
 public interface TxService {
  PayableTransactionEntity getOrCreate(String txHash);
+ void checkTransactions();
 }

src/main/java/com/staketab/minanames/service/impl/TxServiceImpl.java

@@ -2,24 +2,46 @@
 
 import com.staketab.minanames.entity.PayableTransactionEntity;
 import com.staketab.minanames.entity.dto.TxStatus;
+import com.staketab.minanames.minascan.TransactionRepository;
 import com.staketab.minanames.repository.PayableTransactionRepository;
 import com.staketab.minanames.service.abstraction.TxService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 @Service
 @RequiredArgsConstructor
 @Slf4j
 public class TxServiceImpl implements TxService {
 
  private final PayableTransactionRepository payableTransactionRepository;
+ private final TransactionRepository transactionRepository;
 
  @Override
  public PayableTransactionEntity getOrCreate(String txHash) {
  return payableTransactionRepository.findById(txHash).orElseGet(() -> createTx(txHash));
  }
 
+ @Override
+ public void checkTransactions() {
+ List<PayableTransactionEntity> resultTxs = payableTransactionRepository
+ .findAllByTxStatus(TxStatus.PENDING)
+ .stream()
+ .filter(this::txStatusPredicate)
+ .peek(payableTransaction -> payableTransaction.setTxStatus(TxStatus.APPLIED))
+ .toList();
+
+ payableTransactionRepository.saveAll(resultTxs);
+ }
+
+ private boolean txStatusPredicate(PayableTransactionEntity payableTransaction) {
+ String txHash = payableTransaction.getTxHash();
+ String txStatusByTxHash = transactionRepository.getTxStatusByTxHash(txHash);
+ return txStatusByTxHash != null && TxStatus.APPLIED.name().equals(txStatusByTxHash.toUpperCase());
+ }
+
  private PayableTransactionEntity createTx(String txHash) {
  return payableTransactionRepository.save(PayableTransactionEntity.builder()
  .txHash(txHash)