Add method to let some lower-level actions try to generically update counts, but not to go lower than original counts were.

qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/actions/async/AsyncJobCallback.java

@@ -95,6 +95,23 @@ public class AsyncJobCallback
 
 
 
+   /*******************************************************************************
+    ** Update the current and total fields, but ONLY if the new values are
+    ** both >= the previous values.
+    *******************************************************************************/
+   public void updateStatusOnlyUpwards(int current, int total)
+   {
+      boolean currentIsOkay = (this.asyncJobStatus.getCurrent() == null || this.asyncJobStatus.getCurrent() <= current);
+      boolean totalIsOkay   = (this.asyncJobStatus.getTotal() == null || this.asyncJobStatus.getTotal() <= total);
+
+      if(currentIsOkay && totalIsOkay)
+      {
+         updateStatus(current, total);
+      }
+   }
+
+
+
    /*******************************************************************************
     ** Increase the 'current' value in the '1 of 2' sense.
     *******************************************************************************/

qqq-backend-core/src/test/java/com/kingsrook/qqq/backend/core/actions/async/AsyncJobCallbackTest.java

@@ -84,4 +84,36 @@ class AsyncJobCallbackTest extends BaseTest
       assertEquals(3, asyncJobStatus.getCurrent());
    }
 
+
+
+   /*******************************************************************************
+    **
+    *******************************************************************************/
+   @Test
+   void testUpdateStatusOnlyUpwards()
+   {
+      AsyncJobStatus   asyncJobStatus   = new AsyncJobStatus();
+      AsyncJobCallback asyncJobCallback = new AsyncJobCallback(UUID.randomUUID(), asyncJobStatus);
+
+      asyncJobCallback.updateStatusOnlyUpwards(10, 100);
+      assertEquals(10, asyncJobStatus.getCurrent());
+      assertEquals(100, asyncJobStatus.getTotal());
+
+      asyncJobCallback.updateStatusOnlyUpwards(5, 100);
+      assertEquals(10, asyncJobStatus.getCurrent());
+      assertEquals(100, asyncJobStatus.getTotal());
+
+      asyncJobCallback.updateStatusOnlyUpwards(11, 99);
+      assertEquals(10, asyncJobStatus.getCurrent());
+      assertEquals(100, asyncJobStatus.getTotal());
+
+      asyncJobCallback.updateStatusOnlyUpwards(11, 100);
+      assertEquals(11, asyncJobStatus.getCurrent());
+      assertEquals(100, asyncJobStatus.getTotal());
+
+      asyncJobCallback.updateStatusOnlyUpwards(11, 101);
+      assertEquals(11, asyncJobStatus.getCurrent());
+      assertEquals(101, asyncJobStatus.getTotal());
+   }
+
 }