Refactor

src/rendezvous/MSC3906Rendezvous.ts

@@ -212,12 +212,14 @@ export class MSC3906Rendezvous {
 
         const masterPublicKey = (await crypto.getCrossSigningKeyId(CrossSigningKey.Master)) ?? undefined;
 
+        const ourDeviceId = this.client.getDeviceId();
+        const ourDevice = ourDeviceId ? await this.getOwnDevice(ourDeviceId) : undefined;
+
         await this.send({
             type: PayloadType.Finish,
             outcome: Outcome.Verified,
-            verifying_device_id: this.client.getDeviceId()!,
-            // FIXME: this needs fixing too
-            verifying_device_key: this.client.crypto!.getDeviceEd25519Key()!,
+            verifying_device_id: ourDevice?.deviceId,
+            verifying_device_key: ourDevice?.getFingerprint(),
             master_key: masterPublicKey,
         });
 
@@ -252,16 +254,12 @@ export class MSC3906Rendezvous {
             throw new Error("No user ID set");
         }
 
-        // TODO: is this correct?
-        let deviceInfo: Device | undefined = (await crypto.getUserDeviceInfo([userId], true))
-            .get(userId)
-            ?.get(this.newDeviceId);
+        let deviceInfo = await this.getOwnDevice(this.newDeviceId);
 
         if (!deviceInfo) {
             logger.info("Going to wait for new device to be online");
             await sleep(timeout);
-            // TODO: is this correct?
-            deviceInfo = (await crypto.getUserDeviceInfo([userId], true)).get(userId)?.get(this.newDeviceId);
+            deviceInfo = await this.getOwnDevice(this.newDeviceId);
         }
 
         if (deviceInfo) {
@@ -271,6 +269,14 @@ export class MSC3906Rendezvous {
         throw new Error("Device not online within timeout");
     }
 
+    private async getOwnDevice(deviceId: string): Promise<Device | undefined> {
+        const userId = this.client.getUserId();
+        if (!userId) {
+            return undefined;
+        }
+        return (await this.client.getCrypto()?.getUserDeviceInfo([userId], true))?.get(userId)?.get(deviceId);
+    }
+
     public async cancel(reason: RendezvousFailureReason): Promise<void> {
         this.onFailure?.(reason);
         await this.channel.cancel(reason);