Log messages start with ""Program log: " - need to account for this when parsing.

src/parseTransactions.ts

@@ -1379,12 +1379,11 @@ function parseUpdateFunding(
   const perpMarketConfig = groupConfig.perpMarkets.find(
     (p) => p.publicKey.toString() === perpMarketPk,
   ) as PerpMarketConfig;
-  const parsed = JSON.parse(logMessage);
+  const parsed = JSON.parse(logMessage.slice("Program log: ".length));
   if ('long_funding' in parsed && 'short_funding' in parsed) {
     return [
       {
         symbol: perpMarketConfig.baseSymbol,
-        market_index: perpMarketConfig.marketIndex,
         long_funding: parsed.long_funding,
         short_funding: parsed.short_funding,
         instruction_num: instructionNum,
@@ -1410,7 +1409,7 @@ function extractUpdateFundings(
   blockDatetime,
 ) {
   const fundingLogs = result.meta.logMessages.filter((line) =>
-    line.startsWith('{"long_funding":'),
+    line.startsWith('Program log: {"long_funding":'),
   );
   const fundingInstructions = instructions.filter((ix) => {
     return ix.instructionName === 'UpdateFunding';

src/tests/testParseTransactions.ts

@@ -70,17 +70,13 @@ async function consumeTransactions() {
     },
   });
 
-  console.log('Initialized');
+  let transactionsParsingLimit = 50000;
-  while (true) {
+  await processMangoTransactions(
-    console.log('Refreshing transactions ' + Date());
+    rawTransactionsPool,
+    schema,
+    transactionsParsingLimit,
+  );
 
-    let transactionsParsingLimit = 50000;
-    await processMangoTransactions(
-      rawTransactionsPool,
-      schema,
-      transactionsParsingLimit,
-    );
-  }
 }
 
 consumeTransactions();