3126 refactor config registry

android/engine/src/main/java/org/smartregister/fhircore/engine/sync/CompListItemSyncWorker.kt

@@ -0,0 +1,59 @@
+/*
+ * Copyright 2021-2024 Ona Systems, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.smartregister.fhircore.engine.sync
+
+import android.content.Context
+import androidx.hilt.work.HiltWorker
+import androidx.work.WorkerParameters
+import com.google.android.fhir.FhirEngine
+import com.google.android.fhir.sync.AcceptLocalConflictResolver
+import com.google.android.fhir.sync.ConflictResolver
+import com.google.android.fhir.sync.DownloadWorkManager
+import com.google.android.fhir.sync.FhirSyncWorker
+import com.google.android.fhir.sync.upload.UploadStrategy
+import dagger.assisted.Assisted
+import dagger.assisted.AssistedInject
+import org.hl7.fhir.r4.model.ResourceType
+
+@HiltWorker
+class CompListItemSyncWorker
+@AssistedInject
+constructor(
+  @Assisted appContext: Context,
+  @Assisted workerParams: WorkerParameters,
+  private val openSrpFhirEngine: FhirEngine,
+  private val appTimeStampContext: AppTimeStampContext,
+  private val syncParamSource: SyncParamSource
+) : FhirSyncWorker(appContext, workerParams) {
+
+  override fun getConflictResolver(): ConflictResolver = AcceptLocalConflictResolver
+
+  override fun getDownloadWorkManager(): DownloadWorkManager =
+    OpenSrpDownloadManager(
+      syncParams = loadCompositionListParams(),
+      context = appTimeStampContext,
+    )
+
+  override fun getFhirEngine(): FhirEngine = openSrpFhirEngine
+
+  override fun getUploadStrategy(): UploadStrategy = UploadStrategy.AllChangesSquashedBundlePut
+
+  private fun loadCompositionListParams(): Map<ResourceType, Map<String, String>> {
+    return syncParamSource.compListItemRequestQue.pop()
+  }
+
+}

android/engine/src/main/java/org/smartregister/fhircore/engine/sync/CompositionConfigSyncWorker.kt

@@ -0,0 +1,60 @@
+/*
+ * Copyright 2021-2024 Ona Systems, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.smartregister.fhircore.engine.sync
+
+import android.content.Context
+import androidx.hilt.work.HiltWorker
+import androidx.work.WorkerParameters
+import com.google.android.fhir.FhirEngine
+import com.google.android.fhir.sync.AcceptLocalConflictResolver
+import com.google.android.fhir.sync.ConflictResolver
+import com.google.android.fhir.sync.DownloadWorkManager
+import com.google.android.fhir.sync.FhirSyncWorker
+import com.google.android.fhir.sync.upload.UploadStrategy
+import dagger.assisted.Assisted
+import dagger.assisted.AssistedInject
+import org.hl7.fhir.r4.model.ResourceType
+
+@HiltWorker
+class CompositionConfigSyncWorker
+@AssistedInject
+constructor(
+  @Assisted appContext: Context,
+  @Assisted workerParams: WorkerParameters,
+  private val openSrpFhirEngine: FhirEngine,
+  private val appTimeStampContext: AppTimeStampContext,
+  private val syncParamSource: SyncParamSource
+) : FhirSyncWorker(appContext, workerParams) {
+
+  override fun getConflictResolver(): ConflictResolver = AcceptLocalConflictResolver
+
+  override fun getDownloadWorkManager(): DownloadWorkManager =
+    OpenSrpDownloadManager(
+      syncParams = loadCompositionConfigParams(),
+      context = appTimeStampContext,
+    )
+
+  override fun getFhirEngine(): FhirEngine = openSrpFhirEngine
+
+  override fun getUploadStrategy(): UploadStrategy = UploadStrategy.AllChangesSquashedBundlePut
+
+  private fun loadCompositionConfigParams(): Map<ResourceType, Map<String, String>> {
+    return syncParamSource.compConfigRequestQue.pop()
+//    return syncParamSource.compositionConfigSyncParameters
+  }
+
+}

android/engine/src/main/java/org/smartregister/fhircore/engine/sync/CompositionListSyncWorker.kt

@@ -0,0 +1,59 @@
+/*
+ * Copyright 2021-2024 Ona Systems, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.smartregister.fhircore.engine.sync
+
+import android.content.Context
+import androidx.hilt.work.HiltWorker
+import androidx.work.WorkerParameters
+import com.google.android.fhir.FhirEngine
+import com.google.android.fhir.sync.AcceptLocalConflictResolver
+import com.google.android.fhir.sync.ConflictResolver
+import com.google.android.fhir.sync.DownloadWorkManager
+import com.google.android.fhir.sync.FhirSyncWorker
+import com.google.android.fhir.sync.upload.UploadStrategy
+import dagger.assisted.Assisted
+import dagger.assisted.AssistedInject
+import org.hl7.fhir.r4.model.ResourceType
+
+@HiltWorker
+class CompositionListSyncWorker
+@AssistedInject
+constructor(
+  @Assisted appContext: Context,
+  @Assisted workerParams: WorkerParameters,
+  private val openSrpFhirEngine: FhirEngine,
+  private val appTimeStampContext: AppTimeStampContext,
+  private val syncParamSource: SyncParamSource
+) : FhirSyncWorker(appContext, workerParams) {
+
+  override fun getConflictResolver(): ConflictResolver = AcceptLocalConflictResolver
+
+  override fun getDownloadWorkManager(): DownloadWorkManager =
+    OpenSrpDownloadManager(
+      syncParams = loadCompositionListParams(),
+      context = appTimeStampContext,
+    )
+
+  override fun getFhirEngine(): FhirEngine = openSrpFhirEngine
+
+  override fun getUploadStrategy(): UploadStrategy = UploadStrategy.AllChangesSquashedBundlePut
+
+  private fun loadCompositionListParams(): Map<ResourceType, Map<String, String>> {
+    return syncParamSource.compListRequestQue.pop()
+  }
+
+}

android/engine/src/main/java/org/smartregister/fhircore/engine/sync/CompositionManifestSyncWorker.kt

@@ -0,0 +1,59 @@
+/*
+ * Copyright 2021-2024 Ona Systems, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.smartregister.fhircore.engine.sync
+
+import android.content.Context
+import androidx.hilt.work.HiltWorker
+import androidx.work.WorkerParameters
+import com.google.android.fhir.FhirEngine
+import com.google.android.fhir.sync.AcceptLocalConflictResolver
+import com.google.android.fhir.sync.ConflictResolver
+import com.google.android.fhir.sync.DownloadWorkManager
+import com.google.android.fhir.sync.FhirSyncWorker
+import com.google.android.fhir.sync.upload.UploadStrategy
+import dagger.assisted.Assisted
+import dagger.assisted.AssistedInject
+import org.hl7.fhir.r4.model.ResourceType
+
+@HiltWorker
+class CompositionManifestSyncWorker
+@AssistedInject
+constructor(
+  @Assisted appContext: Context,
+  @Assisted workerParams: WorkerParameters,
+  private val openSrpFhirEngine: FhirEngine,
+  private val appTimeStampContext: AppTimeStampContext,
+  private val syncParamSource: SyncParamSource
+) : FhirSyncWorker(appContext, workerParams) {
+
+  override fun getConflictResolver(): ConflictResolver = AcceptLocalConflictResolver
+
+  override fun getDownloadWorkManager(): DownloadWorkManager =
+    OpenSrpDownloadManager(
+      syncParams = loadCompositionManifestParams(),
+      context = appTimeStampContext,
+    )
+
+  override fun getFhirEngine(): FhirEngine = openSrpFhirEngine
+
+  override fun getUploadStrategy(): UploadStrategy = UploadStrategy.AllChangesSquashedBundlePut
+
+  private fun loadCompositionManifestParams(): Map<ResourceType, Map<String, String>> {
+    return syncParamSource.compositionManifestSyncPairs
+  }
+
+}

android/engine/src/main/java/org/smartregister/fhircore/engine/sync/CompositionSyncWorker.kt

@@ -0,0 +1,85 @@
+/*
+ * Copyright 2021-2024 Ona Systems, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.smartregister.fhircore.engine.sync
+
+import android.content.Context
+import androidx.hilt.work.HiltWorker
+import androidx.work.WorkerParameters
+import com.google.android.fhir.FhirEngine
+import com.google.android.fhir.sync.AcceptLocalConflictResolver
+import com.google.android.fhir.sync.ConflictResolver
+import com.google.android.fhir.sync.DownloadWorkManager
+import com.google.android.fhir.sync.FhirSyncWorker
+import com.google.android.fhir.sync.upload.UploadStrategy
+import dagger.assisted.Assisted
+import dagger.assisted.AssistedInject
+import org.hl7.fhir.r4.model.Composition
+import org.hl7.fhir.r4.model.ResourceType
+import org.smartregister.fhircore.engine.configuration.ConfigurationRegistry
+import org.smartregister.fhircore.engine.util.SharedPreferenceKey
+import org.smartregister.fhircore.engine.util.SharedPreferencesHelper
+import timber.log.Timber
+
+@HiltWorker
+class CompositionSyncWorker
+@AssistedInject
+constructor(
+  @Assisted appContext: Context,
+  @Assisted workerParams: WorkerParameters,
+  private val openSrpFhirEngine: FhirEngine,
+  private val appTimeStampContext: AppTimeStampContext,
+  val sharedPreferencesHelper: SharedPreferencesHelper,
+  private val syncParamSource: SyncParamSource
+) : FhirSyncWorker(appContext, workerParams) {
+
+  override fun getConflictResolver(): ConflictResolver = AcceptLocalConflictResolver
+
+  override fun getDownloadWorkManager(): DownloadWorkManager =
+    OpenSrpDownloadManager(
+      syncParams = loadConfigSyncParams(),
+      context = appTimeStampContext,
+    )
+
+  override fun getFhirEngine(): FhirEngine = openSrpFhirEngine
+
+  override fun getUploadStrategy(): UploadStrategy = UploadStrategy.AllChangesSquashedBundlePut
+
+  private fun loadConfigSyncParams(): Map<ResourceType, Map<String, String>> {
+
+    Timber.d("Composition loadConfigSyncParams")
+    val pairs = mutableListOf<Pair<ResourceType, Map<String, String>>>()
+      // val urlPath =
+      // "${ResourceType.Composition.name}?${Composition.SP_IDENTIFIER}=$appId&_count=${ConfigurationRegistry.DEFAULT_COUNT}"
+    sharedPreferencesHelper.read(SharedPreferenceKey.APP_ID.name, null)?.let { appId ->
+      val parsedAppId = appId.substringBefore(ConfigurationRegistry.TYPE_REFERENCE_DELIMITER).trim()
+      pairs.add(
+        Pair(
+          ResourceType.Composition,
+          mapOf(Composition.SP_IDENTIFIER to parsedAppId),
+        ),
+      )
+      pairs.add(
+        Pair(
+          ResourceType.Composition,
+          mapOf("_count" to ConfigurationRegistry.DEFAULT_COUNT.toString()),
+        ),
+      )
+    }
+    // GET /StructureMap?_count=37
+    return mapOf(*pairs.toTypedArray())
+  }
+}

android/engine/src/main/java/org/smartregister/fhircore/engine/sync/ConfigDownloadManager.kt

@@ -0,0 +1,42 @@
+/*
+ * Copyright 2021-2024 Ona Systems, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.smartregister.fhircore.engine.sync
+
+import com.google.android.fhir.sync.DownloadWorkManager
+import com.google.android.fhir.sync.download.DownloadRequest
+import com.google.android.fhir.sync.download.ResourceParamsBasedDownloadWorkManager
+import com.google.android.fhir.sync.download.ResourceSearchParams
+import org.hl7.fhir.r4.model.Resource
+import org.hl7.fhir.r4.model.ResourceType
+import org.smartregister.fhircore.engine.util.extension.updateLastUpdated
+
+class ConfigDownloadManager(
+  syncParams: ResourceSearchParams,
+  val context: ResourceParamsBasedDownloadWorkManager.TimestampContext
+) : DownloadWorkManager {
+
+  private val downloadWorkManager = ResourceParamsBasedDownloadWorkManager(syncParams, context)
+
+  override suspend fun getNextRequest(): DownloadRequest? = downloadWorkManager.getNextRequest()
+
+  override suspend fun getSummaryRequestUrls(): Map<ResourceType, String> =
+    downloadWorkManager.getSummaryRequestUrls()
+
+  override suspend fun processResponse(response: Resource): Collection<Resource> {
+    return downloadWorkManager.processResponse(response).onEach { it.updateLastUpdated() }
+  }
+}

android/engine/src/main/java/org/smartregister/fhircore/engine/sync/ResTypeId.kt

@@ -0,0 +1,21 @@
+/*
+ * Copyright 2021-2024 Ona Systems, Inc
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.smartregister.fhircore.engine.sync
+
+import org.hl7.fhir.r4.model.ResourceType
+
+data class ResTypeId(val type: ResourceType, var id: String)