From 1e7805482ca426a29590b9e6124d62d68b962545 Mon Sep 17 00:00:00 2001
From: Mutesasira Moses <mozzymutesa@gmail.com>
Date: Fri, 20 Oct 2023 14:29:33 +0300
Subject: [PATCH] TaskRequest Object should only be created if incoming task is
 persisted (#39)

---
 .../api/scheduler/FetchTaskUpdates.java          | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git a/api/src/main/java/org/openmrs/module/labonfhir/api/scheduler/FetchTaskUpdates.java b/api/src/main/java/org/openmrs/module/labonfhir/api/scheduler/FetchTaskUpdates.java
index 13d4289..8a343f3 100644
--- a/api/src/main/java/org/openmrs/module/labonfhir/api/scheduler/FetchTaskUpdates.java
+++ b/api/src/main/java/org/openmrs/module/labonfhir/api/scheduler/FetchTaskUpdates.java
@@ -126,11 +126,12 @@ public void execute() {
 				taskBundle = client.loadPage().next(taskBundle).execute();
 				taskBundles.add(taskBundle);
 			}
-			updateTasksInBundle(taskBundles);
-			
-			TaskRequest request = new TaskRequest();
-			request.setRequestDate(newDate);
-			labOnFhirService.saveOrUpdateTaskRequest(request);
+			Boolean tasksUpdated = updateTasksInBundle(taskBundles);
+			if (tasksUpdated) {
+				TaskRequest request = new TaskRequest();
+				request.setRequestDate(newDate);
+				labOnFhirService.saveOrUpdateTaskRequest(request);
+			}
 		}
 		catch (Exception e) {
 			log.error("ERROR executing FetchTaskUpdates : " + e.toString() + getStackTrace(e));
@@ -146,7 +147,8 @@ public void shutdown() {
 		this.stopExecuting();
 	}
 
-	private void updateTasksInBundle(List<Bundle> taskBundles) {
+	private Boolean updateTasksInBundle(List<Bundle> taskBundles) {
+		Boolean tasksUpdated = false;
 		for (Bundle bundle : taskBundles) {
 			for (Iterator tasks = bundle.getEntry().iterator(); tasks.hasNext();) {
 				String openmrsTaskUuid = null;
@@ -170,6 +172,7 @@ private void updateTasksInBundle(List<Bundle> taskBundles) {
 						}
 						if (taskOutPutUpdated) {
 							taskService.update(openmrsTaskUuid, openmrsTask);
+							tasksUpdated = taskOutPutUpdated;
 						}
 					}
 				}
@@ -178,6 +181,7 @@ private void updateTasksInBundle(List<Bundle> taskBundles) {
 				}
 			}
 		}
+		return tasksUpdated;
 	}
 
 	private Boolean updateOutput(List<Task.TaskOutputComponent> output, Task openmrsTask) {