crypto: Connect the key request handling to the main state machine.
parent
78badd9af8
commit
2b8d4a21a4
|
@ -790,10 +790,6 @@ impl OlmMachine {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn handle_room_key_request(&self, _: &ToDeviceEvent<RoomKeyRequestEventContent>) {
|
|
||||||
// TODO handle room key requests here.
|
|
||||||
}
|
|
||||||
|
|
||||||
async fn handle_verification_event(&self, mut event: &mut AnyToDeviceEvent) {
|
async fn handle_verification_event(&self, mut event: &mut AnyToDeviceEvent) {
|
||||||
if let Err(e) = self.verification_machine.receive_event(&mut event).await {
|
if let Err(e) = self.verification_machine.receive_event(&mut event).await {
|
||||||
error!("Error handling a verification event: {:?}", e);
|
error!("Error handling a verification event: {:?}", e);
|
||||||
|
@ -884,7 +880,9 @@ impl OlmMachine {
|
||||||
|
|
||||||
*event_result = decrypted_event;
|
*event_result = decrypted_event;
|
||||||
}
|
}
|
||||||
AnyToDeviceEvent::RoomKeyRequest(e) => self.handle_room_key_request(e),
|
AnyToDeviceEvent::RoomKeyRequest(e) => {
|
||||||
|
self.key_request_machine.receive_incoming_key_request(e)
|
||||||
|
}
|
||||||
AnyToDeviceEvent::KeyVerificationAccept(..)
|
AnyToDeviceEvent::KeyVerificationAccept(..)
|
||||||
| AnyToDeviceEvent::KeyVerificationCancel(..)
|
| AnyToDeviceEvent::KeyVerificationCancel(..)
|
||||||
| AnyToDeviceEvent::KeyVerificationKey(..)
|
| AnyToDeviceEvent::KeyVerificationKey(..)
|
||||||
|
@ -896,6 +894,12 @@ impl OlmMachine {
|
||||||
_ => continue,
|
_ => continue,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TODO remove this unwrap.
|
||||||
|
self.key_request_machine
|
||||||
|
.collect_incoming_key_requests()
|
||||||
|
.await
|
||||||
|
.unwrap();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Decrypt an event from a room timeline.
|
/// Decrypt an event from a room timeline.
|
||||||
|
|
Loading…
Reference in New Issue