twonly/twonly-app
1
0
Fork 0
mirror of https://github.com/twonlyapp/twonly-app.git synced 2026-05-25 07:02:12 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

add try catch

Browse source
This commit is contained in:
otsmr 2026-05-13 15:04:32 +02:00
parent a1ca45c2b9
commit 0818fd0a75
1 changed files with 23 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
lib/src/database/daos/key_verification.dao.dart
View file

@ -6,6 +6,7 @@ import 'package:twonly/src/database/tables/contacts.table.dart';
import 'package:twonly/src/database/tables/groups.table.dart'; import 'package:twonly/src/database/tables/groups.table.dart';
import 'package:twonly/src/database/tables/user_discovery.table.dart'; import 'package:twonly/src/database/tables/user_discovery.table.dart';
import 'package:twonly/src/database/twonly.db.dart'; import 'package:twonly/src/database/twonly.db.dart';
import 'package:twonly/src/utils/log.dart';
part 'key_verification.dao.g.dart'; part 'key_verification.dao.g.dart';
@ -82,14 +83,14 @@ class KeyVerificationDao extends DatabaseAccessor<TwonlyDB>
final query = final query =
(select(contacts)..where((u) => u.userId.equals(contactId).not())).join( (select(contacts)..where((u) => u.userId.equals(contactId).not())).join(
[ [
innerJoin( innerJoin(
ur, ur,
ur.fromContactId.equalsExp(contacts.userId), ur.fromContactId.equalsExp(contacts.userId),
), ),
innerJoin(kv, kv.contactId.equalsExp(ur.fromContactId)), innerJoin(kv, kv.contactId.equalsExp(ur.fromContactId)),
], ],
) )
..where( ..where(
ur.announcedUserId.equals(contactId) & ur.announcedUserId.equals(contactId) &
ur.publicKeyVerifiedTimestamp.isNotNull(), ur.publicKeyVerifiedTimestamp.isNotNull(),
@ -176,17 +177,21 @@ class KeyVerificationDao extends DatabaseAccessor<TwonlyDB>
} }
Future<void> addKeyVerification(int contactId, VerificationType type) async { Future<void> addKeyVerification(int contactId, VerificationType type) async {
await into(keyVerifications).insertOnConflictUpdate( try {
KeyVerificationsCompanion( await into(keyVerifications).insertOnConflictUpdate(
contactId: Value(contactId), KeyVerificationsCompanion(
type: Value(type), contactId: Value(contactId),
), type: Value(type),
); ),
if (userService.currentUser.isUserDiscoveryEnabled) {
await FlutterUserDiscovery.updateVerificationStateForUser(
contactId: contactId,
publicKeyVerifiedTimestamp: clock.now().millisecondsSinceEpoch,
); );
if (userService.currentUser.isUserDiscoveryEnabled) {
await FlutterUserDiscovery.updateVerificationStateForUser(
contactId: contactId,
publicKeyVerifiedTimestamp: clock.now().millisecondsSinceEpoch,
);
}
} catch (e) {
Log.error(e);
} }
} }
} }