From afb8c57c44b33d1e588623effb85cd25e0c8b047 Mon Sep 17 00:00:00 2001
From: Marco van Dijk <marco@stronk.rocks>
Date: Wed, 13 Jul 2022 14:33:03 +0200
Subject: [PATCH] store separate winning tickets cache with epoch * 1000 so
 grafana can convert it to local time

---
 backend/src/routes/livepeer.js | 21 +++++++++++++++++++--
 1 file changed, 19 insertions(+), 2 deletions(-)

diff --git a/backend/src/routes/livepeer.js b/backend/src/routes/livepeer.js
index 6648ab0..c2f1fc1 100644
--- a/backend/src/routes/livepeer.js
+++ b/backend/src/routes/livepeer.js
@@ -195,6 +195,7 @@ let transferTicketEventCache = [];
 let alreadyHasTransferTicketRefresh = {};
 
 let redeemTicketEventCache = [];
+let winningTicketCache = [];
 let alreadyHasRedeemTicketRefresh = {};
 
 let activateEventCache = [];
@@ -379,9 +380,9 @@ apiRouter.post("/getAllRedeemTicketEvents", async (req, res) => {
   }
 });
 
-apiRouter.get("/getAllRedeemTicketEvents", async (req, res) => {
+apiRouter.get("/getAllWinningTickets", async (req, res) => {
   try {
-    res.send(redeemTicketEventCache);
+    res.send(winningTicketCache);
   } catch (err) {
     res.status(400).send(err);
   }
@@ -1230,6 +1231,13 @@ const parseAnyEvent = async function (thisEvent) {
     updateMonthlyTicketRedeemed(eventObj.blockTime, eventObj.amount, eventObj.address);
     alreadyHasMonthlyStatRefresh = {};
     redeemTicketEventCache.push(eventObj);
+    winningTicketCache.push({
+      address: eventObj.address,
+      amount: eventObj.amount,
+      transactionHash: eventObj.transactionHash,
+      blockNumber: eventObj.blockNumber,
+      blockTime: eventObj.blockTime * 1000
+    });
     alreadyHasAnyRefresh = {};
     alreadyHasRedeemTicketRefresh = {};
   } else {
@@ -1902,6 +1910,15 @@ const initSync = async function () {
     blockRound: 1,
     _id: 0
   });
+  for (const winner of redeemTicketEventCache) {
+    winningTicketCache.push({
+      address: winner.address,
+      amount: winner.amount,
+      transactionHash: winner.transactionHash,
+      blockNumber: winner.blockNumber,
+      blockTime: winner.blockTime * 1000
+    });
+  }
   // Get all parsed orchestrator activation events and cache them
   activateEventCache = await ActivateEvent.find({}, {
     address: 1,