Merge pull request #76 from Staketab/dev

update logic for create task for zkCloud

Author: MrFoxogen

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

@@ -15,10 +15,10 @@ public class ZkCloudWorkerScheduler {
 
     private final ZkCloudWorkerService zkCloudWorkerService;
 
-    @Scheduled(cron = "${scheduled.zk-cloud-worker.send-task-cron}")
-    public void sendCreateTask() {
-        zkCloudWorkerService.sendCreateTask();
-    }
+//    @Scheduled(cron = "${scheduled.zk-cloud-worker.send-task-cron}")
+//    public void sendCreateTask() {
+//        zkCloudWorkerService.sendCreateTask();
+//    }
 
     @Scheduled(fixedDelayString = "${scheduled.zk-cloud-worker.check-zk-blocks}")
     public void checkBlocksFromZkCloudWorker() {

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

@@ -94,6 +94,10 @@ public void sendTxs(List<PayableTransactionEntity> appliedTxs) {
         List<DomainEntity> entities = domainEntities.stream()
                 .peek(domainEntity -> domainEntity.setIsSendToCloudWorker(true)).toList();
 
+        if (!zkCloudWorkerTransactions.isEmpty()) {
+            sendCreateTask();
+        }
+
         ZkCloudWorkerDataDTO zkCloudWorkerDataDTO = mapToZkCloudWorkerDataDTO(zkCloudWorkerTransactions, SEND_TRANSACTIONS);
         ZkCloudWorkerRequestDTO zkCloudWorkerRequestDTO = mapToZkCloudWorkerRequestDTO(zkCloudWorkerDataDTO, SEND_TRANSACTIONS);
         ResponseEntity<String> stringResponseEntity = zkCloudWorkerClient.sendToZkCloudWorker(zkCloudWorkerRequestDTO);