Add a SyncJobStatus result callback amid Sync retries

- google#2049

Author: ndegwamartin

engine/src/main/java/com/google/android/fhir/sync/FhirSyncWorker.kt

@@ -91,6 +91,9 @@ abstract class FhirSyncWorker(appContext: Context, workerParams: WorkerParameter
         )
         .apply { subscribe(flow) }
         .synchronize()
+
+    if (result is SyncJobStatus.Failed) onFailedSyncJobResult(result)
+
     val output = buildWorkData(result)
 
     // await/join is needed to collect states completely
@@ -118,6 +121,32 @@ abstract class FhirSyncWorker(appContext: Context, workerParams: WorkerParameter
     }
   }
 
+  open fun onFailedSyncJobResult(failedSyncJobStatus: SyncJobStatus.Failed) {
+    try {
+      CoroutineScope(Dispatchers.IO).launch {
+        val jsonParser = FhirContext.forR4().newJsonParser()
+
+        (result).exceptions.filterIsInstance<HttpException>().forEach { resourceSyncHTTPException ->
+          val operationOutcome =
+            jsonParser.parseResource(
+              IOUtils.toString(
+                resourceSyncHTTPException.response()?.errorBody()?.byteStream(),
+                StandardCharsets.UTF_8
+              )
+            ) as OperationOutcome
+
+          operationOutcome.issue.forEach { operationOutcome ->
+            Timber.e(
+              "SERVER ${operationOutcome.severity} - HTTP ${resourceSyncHTTPException.code()} | Code - ${operationOutcome.code} | Diagnostics - ${operationOutcome.diagnostics}"
+            )
+          }
+        }
+      }
+    } catch (e: Exception) {
+      Timber.e(e)
+    }
+  }
+
   private fun buildWorkData(state: SyncJobStatus): Data {
     return workDataOf(
       // send serialized state and type so that consumer can convert it back