New share handler again. With catch for error.

7 years ago · 2bbcc70ff1
parent 245bc6454e
commit 2bbcc70ff1
1 changed files with 5 additions and 1 deletions
--- a/lib/local_comms.js
+++ b/lib/local_comms.js
@ -274,7 +274,11 @@ function Database(){
                        let sharesSeen = 0;
                        shares[key].forEach(function(final_share){
                            sharesSeen += 1;
-                            txn.putBinary(global.database.shareDB, parseInt(key), global.protos.Share.encode(final_share));
+                            try {
+                                txn.putBinary(global.database.shareDB, parseInt(key), global.protos.Share.encode(final_share));
+                            } catch (e) {
+                                debug(final_share);
+                            }
                            if (Object.keys(shares).length === blocksSeen && sharesSeen === shares[key].length){
                                debug('Made it to where I can do the insert');
                                txn.commit();