Implement dialog for resending local echo transactions

src/stores/local-echo/CachedEcho.ts

@@ -59,13 +59,18 @@ export abstract class CachedEcho<C extends EchoContext, K, V> extends EventEmitt
 
     private decacheKey(key: K) {
         if (this.cache.has(key)) {
-            this.cache.get(key).txn.cancel(); // should be safe to call
+            this.context.disownTransaction(this.cache.get(key).txn);
             this.cache.delete(key);
             this.emit(PROPERTY_UPDATED, key);
         }
     }
 
     protected markEchoReceived(key: K) {
+        if (this.cache.has(key)) {
+            const txn = this.cache.get(key).txn;
+            this.context.disownTransaction(txn);
+            txn.cancel();
+        }
         this.decacheKey(key);
     }
 
@@ -79,7 +84,6 @@ export abstract class CachedEcho<C extends EchoContext, K, V> extends EventEmitt
         this.cacheVal(key, targetVal, txn); // set the cache now as it won't be updated by the .when() ladder below.
 
         txn.when(TransactionStatus.Pending, () => this.cacheVal(key, targetVal, txn))
-            .when(TransactionStatus.DoneError, () => this.decacheKey(key))
             .when(TransactionStatus.DoneError, () => revertFn());
 
         txn.run();

src/stores/local-echo/EchoContext.ts

@@ -28,7 +28,6 @@ export enum ContextTransactionState {
 export abstract class EchoContext extends Whenable<ContextTransactionState> implements IDestroyable {
     private _transactions: EchoTransaction[] = [];
     private _state = ContextTransactionState.NotStarted;
-    public readonly startTime: Date = new Date();
 
     public get transactions(): EchoTransaction[] {
         return arrayFastClone(this._transactions);
@@ -38,6 +37,19 @@ export abstract class EchoContext extends Whenable<ContextTransactionState> impl
         return this._state;
     }
 
+    public get firstFailedTime(): Date {
+        const failedTxn = this.transactions.find(t => t.didPreviouslyFail || t.status === TransactionStatus.DoneError);
+        if (failedTxn) return failedTxn.startTime;
+        return null;
+    }
+
+    public disownTransaction(txn: EchoTransaction) {
+        const idx = this._transactions.indexOf(txn);
+        if (idx >= 0) this._transactions.splice(idx, 1);
+        txn.destroy();
+        this.checkTransactions();
+    }
+
     public beginTransaction(auditName: string, runFn: RunFn): EchoTransaction {
         const txn = new EchoTransaction(auditName, runFn);
         this._transactions.push(txn);

src/stores/local-echo/EchoStore.ts

@@ -22,7 +22,7 @@ import { RoomEchoContext } from "./RoomEchoContext";
 import { AsyncStoreWithClient } from "../AsyncStoreWithClient";
 import defaultDispatcher from "../../dispatcher/dispatcher";
 import { ActionPayload } from "../../dispatcher/payloads";
-import { ContextTransactionState } from "./EchoContext";
+import { ContextTransactionState, EchoContext } from "./EchoContext";
 import NonUrgentToastStore, { ToastReference } from "../NonUrgentToastStore";
 import NonUrgentEchoFailureToast from "../../components/views/toasts/NonUrgentEchoFailureToast";
 
@@ -50,6 +50,10 @@ export class EchoStore extends AsyncStoreWithClient<IState> {
         return EchoStore._instance;
     }
 
+    public get contexts(): EchoContext[] {
+        return Array.from(this.caches.values()).map(e => e.context);
+    }
+
     public getOrCreateEchoForRoom(room: Room): RoomCachedEcho {
         if (this.caches.has(roomContextKey(room))) {
             return this.caches.get(roomContextKey(room)) as RoomCachedEcho;

src/stores/local-echo/EchoTransaction.ts

@@ -28,6 +28,8 @@ export class EchoTransaction extends Whenable<TransactionStatus> {
     private _status = TransactionStatus.Pending;
     private didFail = false;
 
+    public readonly startTime = new Date();
+
     public constructor(
         public readonly auditName,
         public runFn: RunFn,