johrpan/musicus_mobile
1
0
Fork 0
mirror of https://github.com/johrpan/musicus_mobile.git synced 2025-10-25 19:27:24 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

client: Don't sync database twice

Browse source
This commit is contained in:
Elias Projahn 2020-06-03 20:03:35 +02:00
parent a13f78cdd5
commit f1c8196894
1 changed files with 18 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

23
client/lib/src/database.dart
View file

@ -72,20 +72,26 @@ class MusicusClientDatabase extends _$MusicusClientDatabase {
for (final person in await newSyncPersons().get()) {
await client.putPerson(person);
await updatePerson(person.copyWith(synced: true));
}
for (final instrument in await newSyncInstruments().get()) {
await client.putInstrument(instrument);
await updateInstrument(instrument.copyWith(synced: true));
}
for (final work in await newSyncWorks().get()) {
final workInfo = await getWorkInfo(work);
await client.putWork(workInfo);
await into(works).insertOnConflictUpdate(work.copyWith(synced: true));
}
for (final ensemble in await newSyncEnsembles().get()) {
await client.putEnsemble(ensemble);
await updateEnsemble(ensemble.copyWith(synced: true));
}
for (final recording in await newSyncRecordings().get()) {
final recordingInfo = await getRecordingInfo(recording);
await client.putRecording(recordingInfo);
await into(recordings)
.insertOnConflictUpdate(recording.copyWith(synced: true));
}
}
@ -115,7 +121,8 @@ class MusicusClientDatabase extends _$MusicusClientDatabase {
);
if (person.sync) {
await sync();
await client.putPerson(person);
await updatePerson(person.copyWith(synced: true));
}
}
@ -158,7 +165,8 @@ class MusicusClientDatabase extends _$MusicusClientDatabase {
);
if (instrument.sync) {
await sync();
await client.putInstrument(instrument);
await updateInstrument(instrument.copyWith(synced: true));
}
}
@ -289,7 +297,9 @@ class MusicusClientDatabase extends _$MusicusClientDatabase {
});
if (workInfo.work.sync) {
await sync();
await client.putWork(workInfo);
await into(works)
.insertOnConflictUpdate(workInfo.work.copyWith(synced: true));
}
}
@ -334,7 +344,8 @@ class MusicusClientDatabase extends _$MusicusClientDatabase {
);
if (ensemble.sync) {
await sync();
await client.putEnsemble(ensemble);
await updateEnsemble(ensemble.copyWith(synced: true));
}
}
@ -387,7 +398,9 @@ class MusicusClientDatabase extends _$MusicusClientDatabase {
});
if (recordingInfo.recording.sync) {
await sync();
await client.putRecording(recordingInfo);
await into(recordings).insertOnConflictUpdate(
recordingInfo.recording.copyWith(synced: true));
}
}