Spotless

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

@@ -163,7 +163,7 @@ internal class FhirSynchronizer(
  }
  return if (exceptions.isEmpty()) {
  Result.Success
- }  else {
+ } else {
  emit(State.Glitch(exceptions))
  Result.Error(exceptions)
  }

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

@@ -20,13 +20,12 @@ import com.google.android.fhir.db.impl.dao.LocalChangeToken
 import com.google.android.fhir.db.impl.dao.SquashedLocalChange
 import kotlinx.coroutines.flow.Flow
 
-/**
- * Module for uploading local changes to a [DataSource].
- */
+/** Module for uploading local changes to a [DataSource]. */
 internal interface Uploader {
 
  /**
- * Uploads the local changes to the [DataSource]. Particular implementations should take care of transforming the [SquashedLocalChange]s to particular network operations.
+ * Uploads the local changes to the [DataSource]. Particular implementations should take care of
+ * transforming the [SquashedLocalChange]s to particular network operations.
  */
  suspend fun upload(
  localChanges: List<SquashedLocalChange>,

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

@@ -63,15 +63,18 @@ internal class BundlePayloadGenerator(
 }
 
 /**
- * Splits up all the local changes into individual change lists to be included in particular [Bundle]s.
+ * Splits up all the local changes into individual change lists to be included in particular
+ * [Bundle]s.
  */
 internal interface LocalChangeProvider {
  suspend fun getLocalChanges(): List<List<SquashedLocalChange>>
 }
 
 /**
- * Tells [BundlePayloadGenerator] that all the local changes should be part of a single [Bundle] transaction.
+ * Tells [BundlePayloadGenerator] that all the local changes should be part of a single [Bundle]
+ * transaction.
  */
-internal class DefaultLocalChangeProvider(private val localChanges : List<SquashedLocalChange>) : LocalChangeProvider {
- override suspend fun getLocalChanges(): List<List<SquashedLocalChange>> = listOf(localChanges)
+internal class DefaultLocalChangeProvider(private val localChanges: List<SquashedLocalChange>) :
+ LocalChangeProvider {
+ override suspend fun getLocalChanges(): List<List<SquashedLocalChange>> = listOf(localChanges)
 }

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

@@ -31,18 +31,20 @@ import org.hl7.fhir.r4.model.OperationOutcome
 import org.hl7.fhir.r4.model.Resource
 import org.hl7.fhir.r4.model.ResourceType
 
-/** [Uploader] implementation to work with Fhir [Bundle].*/
+/** [Uploader] implementation to work with Fhir [Bundle]. */
 internal class BundleUploader(val dataSource: DataSource) : Uploader {
 
  override suspend fun upload(
  localChanges: List<SquashedLocalChange>,
  ): Flow<UploadResult> = flow {
  BundlePayloadGenerator(
- createRequest = HttpPutForCreateEntryComponent(FhirContext.forR4().newJsonParser()),
- updateRequest = HttpPatchForUpdateEntryComponent(),
- deleteRequest = HttpDeleteEntryComponent(),
- localChangeProvider = DefaultLocalChangeProvider(localChanges)
- ).generate().forEach { (bundle, localChangeTokens) ->
+ createRequest = HttpPutForCreateEntryComponent(FhirContext.forR4().newJsonParser()),
+ updateRequest = HttpPatchForUpdateEntryComponent(),
+ deleteRequest = HttpDeleteEntryComponent(),
+ localChangeProvider = DefaultLocalChangeProvider(localChanges)
+ )
+ .generate()
+ .forEach { (bundle, localChangeTokens) ->
  try {
  val response =
  dataSource.postBundle(
@@ -60,7 +62,6 @@ internal class BundleUploader(val dataSource: DataSource) : Uploader {
  response is Bundle && response.type == Bundle.BundleType.TRANSACTIONRESPONSE -> {
  UploadResult.Success(LocalChangeToken(localChangeTokens.flatMap { it.ids }))
  }
-
  response is OperationOutcome && response.issue.isNotEmpty() -> {
  UploadResult.Failure(
  ResourceSyncException(
@@ -69,7 +70,6 @@ internal class BundleUploader(val dataSource: DataSource) : Uploader {
  )
  )
  }
-
  else -> {
  UploadResult.Failure(
  ResourceSyncException(

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

@@ -29,9 +29,7 @@ import org.hl7.fhir.r4.model.UriType
  */
 internal abstract class HttpVerbBasedBundleEntryComponent(private val httpVerb: Bundle.HTTPVerb) {
 
- /**
- * Should return [Resource] for the [LocalChangeEntity].
- */
+ /** Should return [Resource] for the [LocalChangeEntity]. */
  abstract fun getEntryResource(localChange: LocalChangeEntity): IBaseResource?
 
  fun getEntry(squashedLocalChange: SquashedLocalChange): Bundle.BundleEntryComponent {

engine/src/test/java/com/google/android/fhir/sync/bundle/BundleTransactionPayloadGeneratorTest.kt

@@ -41,11 +41,12 @@ class BundleTransactionPayloadGeneratorTest {
  createRequest = HttpPutForCreateEntryComponent(FhirContext.forR4().newJsonParser()),
  updateRequest = HttpPatchForUpdateEntryComponent(),
  deleteRequest = HttpDeleteEntryComponent(),
- localChangeProvider = object : LocalChangeProvider {
- override suspend fun getLocalChanges(): List<List<SquashedLocalChange>> {
- return listOf(listOf(), listOf())
- }
- },
+ localChangeProvider =
+ object : LocalChangeProvider {
+ override suspend fun getLocalChanges(): List<List<SquashedLocalChange>> {
+ return listOf(listOf(), listOf())
+ }
+ },
  )
 
  val result = generator.generate()

engine/src/test/java/com/google/android/fhir/sync/bundle/BundleUploaderTest.kt

@@ -76,8 +76,7 @@ class BundleUploaderTest {
  }
 
  @Test
- fun `upload Bundle transaction error during upload should emit Failure`() =
- runBlocking {
+ fun `upload Bundle transaction error during upload should emit Failure`() = runBlocking {
  val result =
  BundleUploader(
  TestingUtils.BundleDataSource { throw ConnectException("Failed to connect to server.") }
@@ -99,7 +98,20 @@ class BundleUploaderTest {
  resourceType = ResourceType.Patient.name,
  resourceId = "Patient-001",
  type = LocalChangeEntity.Type.INSERT,
- payload = FhirContext.forR4().newJsonParser().encodeResourceToString(Patient().apply { id = "Patient-001"; addName(HumanName().apply { addGiven("John"); family = "Doe" }) })
+ payload =
+ FhirContext.forR4()
+ .newJsonParser()
+ .encodeResourceToString(
+ Patient().apply {
+ id = "Patient-001"
+ addName(
+ HumanName().apply {
+ addGiven("John")
+ family = "Doe"
+ }
+ )
+ }
+ )
  )
  )
  )