From 1423e1961e0fb8cd189184be16905b73de72d483 Mon Sep 17 00:00:00 2001
From: garrettmills <shout@garrettmills.dev>
Date: Sat, 10 Apr 2021 14:42:39 -0500
Subject: [PATCH] Properly trylock consensus DB writes

---
 src/app/FirebaseResource.ts | 3 ---
 src/app/units/Blockchain.ts | 2 ++
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/src/app/FirebaseResource.ts b/src/app/FirebaseResource.ts
index fccd8ae..715fb6d 100644
--- a/src/app/FirebaseResource.ts
+++ b/src/app/FirebaseResource.ts
@@ -79,8 +79,6 @@ export class FirebaseResource<T extends FirebaseResourceItem> extends Iterable<T
      * @param item
      */
     async push(item: T): Promise<T> {
-        await this.firebase.trylock(this.refName)
-
         await this.ref().transaction((collection) => {
             if ( !collection ) collection = []
             item.seqID = this.findNextId(collection)
@@ -103,7 +101,6 @@ export class FirebaseResource<T extends FirebaseResourceItem> extends Iterable<T
                 })
         })
 
-        await this.firebase.unlock(this.refName)
         return item
     }
 
diff --git a/src/app/units/Blockchain.ts b/src/app/units/Blockchain.ts
index a9eee85..b528dd6 100644
--- a/src/app/units/Blockchain.ts
+++ b/src/app/units/Blockchain.ts
@@ -281,6 +281,7 @@ export class Blockchain extends Unit {
             this.isSubmitting = true
         }
 
+        await this.firebase.trylock('block')
         const validSeqID = (await this.read()).reverse()[0]?.seqID
 
         const peers = await this.getPeers()
@@ -347,6 +348,7 @@ export class Blockchain extends Unit {
             await this.attemptSubmit()
         }
 
+        await this.firebase.unlock('block')
         this.isSubmitting = false
     }