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

also load session keys when requesting history

Browse source
This commit is contained in:
Sorunome 2020-05-30 14:09:47 +02:00
parent 9971e7377e
commit 03beffbb46
No known key found for this signature in database
GPG key ID: B19471D07FC9BE9C
1 changed files with 48 additions and 45 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

93
lib/src/room.dart
View file

@ -1024,58 +1024,61 @@ class Room {
if (onHistoryReceived != null) onHistoryReceived();
prev_batch = resp['end'];
final dbActions = <Future<dynamic> Function()>[];
if (client.database != null) {
dbActions.add(
() => client.database.setRoomPrevBatch(prev_batch, client.id, id));
}
final loadFn = () async {
if (!(resp['chunk'] is List<dynamic> &&
resp['chunk'].length > 0 &&
resp['end'] is String)) return;
if (!(resp['chunk'] is List<dynamic> &&
resp['chunk'].length > 0 &&
resp['end'] is String)) return;
if (resp['state'] is List<dynamic>) {
for (final state in resp['state']) {
var eventUpdate = EventUpdate(
type: 'state',
roomID: id,
eventType: state['type'],
content: state,
sortOrder: oldSortOrder,
).decrypt(this);
client.onEvent.add(eventUpdate);
if (client.database != null) {
dbActions.add(
() => client.database.storeEventUpdate(client.id, eventUpdate));
if (resp['state'] is List<dynamic>) {
for (final state in resp['state']) {
var eventUpdate = EventUpdate(
type: 'state',
roomID: id,
eventType: state['type'],
content: state,
sortOrder: oldSortOrder,
).decrypt(this);
if (eventUpdate.eventType == 'm.room.encrypted' &&
client.database != null) {
await loadInboundGroupSessionKey(
state['content']['session_id'], state['content']['sender_key']);
eventUpdate = eventUpdate.decrypt(this);
}
client.onEvent.add(eventUpdate);
await client.database?.storeEventUpdate(client.id, eventUpdate);
}
}
}
List<dynamic> history = resp['chunk'];
for (final hist in history) {
var eventUpdate = EventUpdate(
type: 'history',
roomID: id,
eventType: hist['type'],
content: hist,
sortOrder: oldSortOrder,
).decrypt(this);
client.onEvent.add(eventUpdate);
if (client.database != null) {
dbActions.add(
() => client.database.storeEventUpdate(client.id, eventUpdate));
List<dynamic> history = resp['chunk'];
for (final hist in history) {
var eventUpdate = EventUpdate(
type: 'history',
roomID: id,
eventType: hist['type'],
content: hist,
sortOrder: oldSortOrder,
).decrypt(this);
if (eventUpdate.eventType == 'm.room.encrypted' &&
client.database != null) {
await loadInboundGroupSessionKey(
hist['content']['session_id'], hist['content']['sender_key']);
eventUpdate = eventUpdate.decrypt(this);
}
client.onEvent.add(eventUpdate);
await client.database?.storeEventUpdate(client.id, eventUpdate);
}
}
};
if (client.database != null) {
dbActions.add(
() => client.database.setRoomPrevBatch(resp['end'], client.id, id));
await client.database?.transaction(() async {
await client.database.setRoomPrevBatch(prev_batch, client.id, id);
await loadFn();
await client.database.setRoomPrevBatch(resp['end'], client.id, id);
await updateSortOrder();
});
} else {
await loadFn();
}
await client.database?.transaction(() async {
for (final f in dbActions) {
await f();
}
await updateSortOrder();
});
client.onRoomUpdate.add(
RoomUpdate(
id: id,