Use unnest approach instead of jsonb_to_recordset in updateDailyMinerDealsChecked

Co-authored-by: bajtos <[email protected]>

Author: Copilot

lib/public-stats.js

@@ -417,23 +417,23 @@ const updateDailyMinerDealsChecked = async (pgClient, committees) => {
   }
 
   // Convert the map to arrays for the query
-  const flatStats = Array.from(minerPayloadCids.entries()).map(
-    // eslint-disable-next-line camelcase
-    ([minerId, payloadCids]) => ({
-      miner_id: minerId,
-      payload_cids: Array.from(payloadCids)
-    })
-  )
+  const minerIds = []
+  const payloadCidsArrays = []
+
+  for (const [minerId, payloadCids] of minerPayloadCids.entries()) {
+    minerIds.push(minerId)
+    payloadCidsArrays.push(Array.from(payloadCids))
+  }
 
   if (debug.enabled) {
     debug(
       'Updating public stats - daily miner deals checked: miners count = %s, total payload CIDs = %s',
-      flatStats.length,
-      flatStats.reduce((sum, stat) => sum + stat.payload_cids.length, 0)
+      minerIds.length,
+      payloadCidsArrays.reduce((sum, cids) => sum + cids.length, 0)
     )
   }
 
-  if (flatStats.length === 0) {
+  if (minerIds.length === 0) {
     debug('No miner deals to record')
     return
   }
@@ -443,19 +443,19 @@ const updateDailyMinerDealsChecked = async (pgClient, committees) => {
       day,
       miner_id,
       payload_cids
-    )
-    SELECT
+    ) VALUES (
       now(),
-      miner_id,
-      payload_cids
-    FROM jsonb_to_recordset($1::jsonb) AS t (miner_id text, payload_cids text[])
+      unnest($1::text[]),
+      unnest($2::text[][])
+    )
     ON CONFLICT(day, miner_id) DO UPDATE SET
       payload_cids = array(
         SELECT DISTINCT unnest(
           array_cat(daily_miner_deals_checked.payload_cids, EXCLUDED.payload_cids)
         )
       )
   `, [
-    JSON.stringify(flatStats)
+    minerIds,
+    payloadCidsArrays
   ])
 }