inex/famedlysdk
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

refactor: Database first to single

Browse source
This commit is contained in:
Christian Pauly 2020-10-07 13:42:23 +02:00
parent c571fe4dd5
commit 0761d33b6f
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
lib/src/database/database.dart
View file

@ -164,8 +164,8 @@ class Database extends _$Database {
Future<DbClient> getClient(String name) async { Future<DbClient> getClient(String name) async {
final res = await dbGetClient(name).get(); final res = await dbGetClient(name).get();
if (res.isEmpty) return null; if (res.isEmpty) return null;
await markPendingEventsAsError(res.first.clientId); await markPendingEventsAsError(res.single.clientId);
return res.first; return res.single;
} }
Future<Map<String, sdk.DeviceKeysList>> getUserDeviceKeys( Future<Map<String, sdk.DeviceKeysList>> getUserDeviceKeys(
@ -216,7 +216,7 @@ class Database extends _$Database {
if (res.isEmpty) { if (res.isEmpty) {
return null; return null;
} }
return res.first; return res.single;
} }
Future<List<DbInboundGroupSession>> getDbInboundGroupSessions( Future<List<DbInboundGroupSession>> getDbInboundGroupSessions(
@ -231,7 +231,7 @@ class Database extends _$Database {
if (res.isEmpty) { if (res.isEmpty) {
return null; return null;
} }
return res.first; return res.single;
} }
Future<DbSSSSCache> getSSSSCache(int clientId, String type) async { Future<DbSSSSCache> getSSSSCache(int clientId, String type) async {
@ -239,7 +239,7 @@ class Database extends _$Database {
if (res.isEmpty) { if (res.isEmpty) {
return null; return null;
} }
return res.first; return res.single;
} }
Future<List<sdk.Room>> getRoomList(sdk.Client client, Future<List<sdk.Room>> getRoomList(sdk.Client client,
@ -563,7 +563,7 @@ class Database extends _$Database {
if (event.isEmpty) { if (event.isEmpty) {
return null; return null;
} }
return sdk.Event.fromDb(event.first, room); return sdk.Event.fromDb(event.single, room);
} }
Future<bool> redactMessage(int clientId, sdk.EventUpdate eventUpdate) async { Future<bool> redactMessage(int clientId, sdk.EventUpdate eventUpdate) async {
@ -649,7 +649,7 @@ class Database extends _$Database {
if (res.isEmpty) { if (res.isEmpty) {
return null; return null;
} }
return sdk.Event.fromDb(res.first, room).asUser; return sdk.Event.fromDb(res.single, room).asUser;
} }
Future<List<sdk.User>> getUsers(int clientId, sdk.Room room) async { Future<List<sdk.User>> getUsers(int clientId, sdk.Room room) async {
@ -673,6 +673,6 @@ class Database extends _$Database {
Future<Uint8List> getFile(String mxcUri) async { Future<Uint8List> getFile(String mxcUri) async {
final res = await dbGetFile(mxcUri).get(); final res = await dbGetFile(mxcUri).get();
if (res.isEmpty) return null; if (res.isEmpty) return null;
return res.first.bytes; return res.single.bytes;
} }
} }