feat(amount-shares): re-calculate amount from shares with BigInt

thematters · May 14, 2024 · 50e77c1 · 50e77c1
1 parent 7e4ea7b
commit 50e77c1
Show file tree

Hide file tree

Showing 5 changed files with 354 additions and 364 deletions.
diff --git a/bin/qf-calculate.ts b/bin/qf-calculate.ts
@@ -2,7 +2,7 @@
 
 import {
   calculateQFScore,
-  checkDropEventsAndNotifs,
+  // checkDropEventsAndNotifs,
 } from '../lib/qf-calculate.js'
 
 async function main() {
@@ -16,9 +16,7 @@ async function main() {
       args.shift()
       break
   }
-  if (mode === 'checkDropEventsAndNotifs') {
-    return checkDropEventsAndNotifs()
-  }
+  // if (mode === 'checkDropEventsAndNotifs') { return checkDropEventsAndNotifs() }
 
   const amountTotal = BigInt(+(args?.[0] || 10_000))
 

diff --git a/handlers/qf-calculate.ts b/handlers/qf-calculate.ts
@@ -4,11 +4,13 @@ import { formatUnits } from 'viem'
 import * as d3 from 'd3-array'
 import {
   calculateQFScore,
-  sendQfNotifications, //  sendQfNotificationNEmails,
   MattersBillboardS3Bucket,
   isProd,
   s3FilePathPrefix,
 } from '../lib/qf-calculate.js'
+import {
+  sendQfNotifications, //  sendQfNotificationNEmails,
+} from '../lib/qf-notify.js'
 import { s3GetFile } from '../lib/utils/aws.js'
 import { SLACK_MESSAGE_STATE, Slack } from '../lib/utils/slack.js'
 
@@ -92,7 +94,12 @@ export const handler = async (
     }
   } else if (method === 'POST' && path === '/send-notifications' && accept) {
     // get distrib.json and send notifications;
-    let { key = 'latest', roundEnd, amountTotal = '' } = queryStringParameters
+    let {
+      key = 'latest',
+      roundEnd,
+      amountTotal = '',
+      sharesTotal = 10_000,
+    } = queryStringParameters
     // let key = (queryStringParameters?.key || 'latest') as string
     // get latest round path to distrib.json
     try {
@@ -114,6 +121,7 @@ export const handler = async (
           }
           if (!amountTotal && latestRound?.amountTotal) {
             amountTotal = latestRound?.amountTotal
+            sharesTotal = latestRound?.sharesTotal
           }
         }
       }
@@ -144,6 +152,8 @@ export const handler = async (
       const distribs = JSON.parse(await res1.Body.transformToString())
       const sent = await sendQfNotifications(
         distribs,
+        amountTotal,
+        sharesTotal,
         roundEnd,
         queryStringParameters?.doNotify === 'true'
       )