New syncen

Hover effectjes

backend/src/models/event.js

@@ -21,6 +21,10 @@ const EventSchema = new mongoose.Schema({
     type: Object,
     required: true
   },
+  blockNumber: {
+    type: Number,
+    required: true
+  }
 }, { timestamps: true });
 
 const Event = mongoose.model('Event', EventSchema);

backend/src/routes/livepeer.js

@@ -68,8 +68,9 @@ let orchestratorCache = [];
 // Listen to smart contract emitters. Resync with DB every 5 minutes
 const timeoutEvents = 300000;
 let eventsCache = [];
+let latestMissedDuringSync = 0;
+let lastBlockDataAdded = 0;
 let syncCache = [];
-let isSyncing = false;
 let eventsGet = 0;
 // Set to true to drop the entire collection on boot and get all events
 const fullSync = false;
@@ -79,82 +80,134 @@ const BondingManagerTargetAbi = JSON.parse(BondingManagerTargetJson);
 const BondingManagerProxyAddr = "0x35Bcf3c30594191d53231E4FF333E8A770453e40";
 const contractInstance = new web3layer2WS.eth.Contract(BondingManagerTargetAbi.abi, BondingManagerProxyAddr);
 
+// If fullsync: drop collection on DB
+if (fullSync) {
+  console.log("dropping old data due to full synchronization");
+  Event.collection.drop();
+}
+// Set special flag to make sure also get blocks that pass us by while we are syncing
+let isSyncing = true;
+let isSyncRunning = false;
+// Start Listening for live updates
 var BondingManagerProxyListener = contractInstance.events.allEvents(async (error, event) => {
   try {
     if (error) {
       throw error
     }
-    console.log('New event emitted on', BondingManagerProxyAddr);
+    if (isSyncing) {
+      console.log('Received new Event on block ' + event.blockNumber + " during sync");
+    } else {
+      console.log('Received new Event on block ' + event.blockNumber);
+    }
     // Push obj of event to cache and create a new entry for it in the DB
     const eventObj = {
       address: event.address,
       transactionHash: event.transactionHash,
       transactionUrl: "https://arbiscan.io/tx/" + event.transactionHash,
       name: event.event,
-      data: event.returnValues
+      data: event.returnValues,
+      blockNumber: event.blockNumber
     }
-    if(isSyncing){
-      syncCache.push(eventObj);
-    }else{
+    if(!isSyncing){
       const dbObj = new Event(eventObj);
       await dbObj.save();
       eventsCache.push(eventObj);
+    }else{
+      syncCache.push(eventObj);
     }
   }
   catch (err) {
     console.log("FATAL ERROR: ", err);
   }
 });
-console.log("listening for events on", BondingManagerProxyAddr);
+console.log("Listening for events on " + BondingManagerProxyAddr);
 
-if(fullSync){
-  console.log("dropping old data");
-  Event.collection.drop();
-  console.log("getting all events");
-  isSyncing = true;
-  contractInstance.getPastEvents("allEvents", {fromBlock: 0, toBlock: 'latest'}, async (error, events) => {
+// Does the syncing
+const doSync = function () {
+  console.log("Starting sync process");
+  isSyncRunning = true;
+  // Then do a sync from last found until latest known
+  contractInstance.getPastEvents("allEvents", { fromBlock: lastBlockDataAdded + 1, toBlock: 'latest' }, async (error, events) => {
     try {
       if (error) {
         throw error
       }
-      let counter = 1;
       let size = events.length;
+      console.log("Parsing " + size + " events");
       for (const event of events) {
-        console.log("Parsing " + counter + " out of " + size + " events");
+        if (event.blockNumber > lastBlockDataAdded) {
+          lastBlockDataAdded = event.blockNumber;
+        }
         const eventObj = {
           address: event.address,
           transactionHash: event.transactionHash,
           transactionUrl: "https://arbiscan.io/tx/" + event.transactionHash,
           name: event.event,
-          data: event.returnValues
+          data: event.returnValues,
+          blockNumber: event.blockNumber
         }
         const dbObj = new Event(eventObj);
         await dbObj.save();
         eventsCache.push(eventObj);
-        counter++;
       }
     }
     catch (err) {
       console.log("FATAL ERROR: ", err);
     }
-    isSyncing = false;
-    let counter = 1;
-    let size = syncCache.length;
-    for (const event of syncCache) {
-      console.log("Parsing " + counter + " out of " + size + " events received while syncing");
-      const eventObj = {
-        address: event.address,
-        transactionHash: event.transactionHash,
-        transactionUrl: "https://arbiscan.io/tx/" + event.transactionHash,
-        name: event.event,
-        data: event.returnValues
+    isSyncRunning = false;
+  });
 }
+function sleep(ms) {
+  return new Promise((resolve) => {
+    setTimeout(resolve, ms);
+  });
+}
+
+const handleSync = async function () {
+  // First collection -> cache
+  eventsCache = await Event.find({}, {
+    address: 1,
+    transactionHash: 1,
+    transactionUrl: 1,
+    name: 1,
+    data: 1,
+    blockNumber: 1,
+    _id: 0
+  });
+  console.log("Retrieved existing Events of size " + eventsCache.length);
+  // Then determine latest block number parsed based on collection
+  for (var idx = 0; idx < eventsCache.length; idx++) {
+    const thisBlock = eventsCache[idx];
+    if (thisBlock.blockNumber > lastBlockDataAdded) {
+      lastBlockDataAdded = thisBlock.blockNumber;
+    }
+  }
+  // Get latest block in chain
+  const latestBlock = await web3layer2.eth.getBlockNumber();
+  if (latestBlock > latestMissedDuringSync) {
+    latestMissedDuringSync = latestBlock;
+  }
+  console.log("Parsed up to block " + lastBlockDataAdded + " out of " + latestMissedDuringSync + " blocks");
+  doSync();
+  while (isSyncRunning) {
+    await sleep(1000);
+    console.log("Parsed " + lastBlockDataAdded + " out of " + latestMissedDuringSync + " blocks");
+  }
+  while(syncCache.length){
+    const liveEvents = syncCache;
+    syncCache = [];
+    for (const eventObj of liveEvents) {
+      console.log("Parsing event received while syncing");
       const dbObj = new Event(eventObj);
       await dbObj.save();
       eventsCache.push(eventObj);
-      counter++;
     }
-  });
+  }
+  console.log('done syncing')
+  isSyncing = false;
+};
+if (!isSyncRunning) {
+  handleSync();
 }
 
 // Splits of raw CMC object into coin quote data

src/eventButton.js

@@ -36,10 +36,10 @@ const EventButton = (obj) => {
   return (
     <div className="rowAlignLeft" style={{ backgroundColor: obj.eventObj.eventColour, borderRadius: "1.2em", width: 'unset' }}>
       <div className="rowAlignLeft" style={{ width: 'unset' }}>
-        <a href={obj.eventObj.transactionUrl}>
+        <a className="selectOrch"  href={obj.eventObj.transactionUrl}>
           <img alt="" src="arb.svg" width="30" height="30" />
         </a>
-        <a href={"https://explorer.livepeer.org/accounts/" + obj.eventObj.eventCaller}>
+        <a className="selectOrch"  href={"https://explorer.livepeer.org/accounts/" + obj.eventObj.eventCaller}>
           <img alt="" src="livepeer.png" width="30" height="30" />
         </a>
         {eventCaller}

src/style.css

@@ -1,4 +1,4 @@
-.selectOrch:hover, a:hover, a:visited, a:link, a:active{
+a:hover, a:visited, a:link, a:active{
   text-decoration: none;
   color: rgba(0, 0, 0, 0.875);
   text-align: center;
@@ -44,11 +44,17 @@ h2, h3, h1, h4, h5, h6 {
 
 .selectOrch, a {
   text-shadow: 0.5px 0.5px 0.8px #948dff;
-  color: #1a1b26;
   background-color: transparent;
   border: none;
 }
 
+.selectOrch:hover{
+  text-decoration: none;
+  cursor: pointer;
+  backdrop-filter: blur(6px);
+  border-radius: 1em;
+}
+
 p {
   text-shadow: 0.5px 0.5px 0.8px #948dff;
   color: #1a1b26;
@@ -226,6 +232,16 @@ svg {
   margin-right: 10px;
 }
 
+.withWrap {
+  flex-wrap: wrap;
+}
+
+.alignEnd {
+  justify-content: flex-start;
+  align-items: flex-start;
+  justify-content: flex-start;
+}
+
 .rowAlignLeft {
   box-sizing: border-box;
   width: 100%;