Skip to content

Beneficiary downsync Criteria Update #691

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Parent: Console 2.0-beta
wants to merge 4 commits into
base: develop
Choose a base branch
from
Open

Beneficiary downsync Criteria Update #691

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
e608673
Update bulk create method to work both incase of replace and ignore
Mar 10, 2025
a016616
Updated lock files for downsync update
Mar 10, 2025
9f8403e
Added mdms value to force downsync
Mar 19, 2025
eb9c347
Updated lock files
Mar 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 8 additions & 2 deletions ...ld_worker_app/lib/blocs/projects_beneficiary_downsync/project_beneficiaries_downsync.dart
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,7 @@ class BeneficiaryDownSyncBloc
);
emit(BeneficiaryDownSyncState.getBatchSize(
configuredBatchSize,
event.appConfiguration.first.forceDownSync ?? false,
event.projectId,
event.boundaryCode,
event.pendingSyncCount,
Expand All @@ -101,7 +102,7 @@ class BeneficiaryDownSyncBloc
DownSyncCheckTotalCountEvent event,
BeneficiaryDownSyncEmitter emit,
) async {
if (event.pendingSyncCount > 0) {
if (event.pendingSyncCount > 0 && event.forceDownSync == false) {
emit(const BeneficiaryDownSyncState.loading(true));
emit(const BeneficiaryDownSyncState.pendingSync());
} else {
Expand Down Expand Up @@ -136,6 +137,7 @@ class BeneficiaryDownSyncBloc
emit(BeneficiaryDownSyncState.dataFound(
serverTotalCount,
event.batchSize,
event.forceDownSync
));
} else {
await LocalSecureStore.instance.setManualSyncTrigger(false);
Expand Down Expand Up @@ -211,7 +213,7 @@ class BeneficiaryDownSyncBloc
taskLocalRepository,
sideEffectLocalRepository,
referralLocalRepository,
]);
], event.forceDownSync ?? false);
// Update the local downSync data for the boundary with the new values
totalCount = downSyncResults["DownsyncCriteria"]["totalCount"];

Expand Down Expand Up @@ -277,13 +279,15 @@ class BeneficiaryDownSyncEvent with _$BeneficiaryDownSyncEvent {
required int batchSize,
required int initialServerCount,
required String boundaryName,
bool? forceDownSync,
}) = DownSyncBeneficiaryEvent;

const factory BeneficiaryDownSyncEvent.checkForData({
required String projectId,
required String boundaryCode,
required int pendingSyncCount,
required int batchSize,
required bool forceDownSync,
required String boundaryName,
}) = DownSyncCheckTotalCountEvent;

Expand Down Expand Up @@ -313,6 +317,7 @@ class BeneficiaryDownSyncState with _$BeneficiaryDownSyncState {
) = _DownSyncSuccessState;
const factory BeneficiaryDownSyncState.getBatchSize(
int batchSize,
bool forceDownSync,
String projectId,
String boundaryCode,
int pendingSyncCount,
Expand All @@ -325,6 +330,7 @@ class BeneficiaryDownSyncState with _$BeneficiaryDownSyncState {
const factory BeneficiaryDownSyncState.dataFound(
int initialServerCount,
int batchSize,
bool forceDownSync
) = _DownSyncDataFoundState;
const factory BeneficiaryDownSyncState.resetState() = _DownSyncResetState;
const factory BeneficiaryDownSyncState.totalCountCheckFailed() =
Expand Down
Loading
Loading