wip super oeth otoken2 processing, yield forwarding tracking, performance

Author: apexearth

.gitignore

@@ -2,6 +2,7 @@
 /lib
 /builds
 /dump
+/data
 
 /**Versions.json
 

db/migrations/1741720109548-Data.js renamed to db/migrations/1741896005366-Data.js

@@ -1,3 +1,4 @@
+NODE_ENV=development
 TS_NODE_BASEURL=./lib
 DB_NAME=squid
 DB_PORT=23798

dev.env

@@ -649,6 +649,17 @@ type OTokenWithdrawalRequest @entity {
   txHash: String! @index
 }
 
+type OTokenYieldForwarded @entity {
+  id: ID!
+  chainId: Int! @index
+  blockNumber: Int! @index
+  timestamp: DateTime! @index
+  otoken: String! @index
+  from: String!
+  to: String!
+  amount: BigInt!
+}
+
 enum RebasingOption {
   OptIn
   OptOut

package-lock.json

@@ -3,20 +3,20 @@ import { base } from 'viem/chains'
 
 import * as erc20Abi from '@abi/erc20'
 import { getPositions } from '@templates/aerodrome/lp'
-import { createOTokenLegacyProcessor } from '@templates/otoken'
 import { createOTokenActivityProcessor } from '@templates/otoken/activity-processor/activity-processor'
+import { createOTokenProcessor2 } from '@templates/otoken/otoken-2'
 import { createOTokenWithdrawalsProcessor } from '@templates/withdrawals'
 import { aerodromePools, baseAddresses } from '@utils/addresses-base'
 import { tokensByChain } from '@utils/tokensByChain'
 
 import { baseCurveAMO } from './strategies'
 
-const otokenProcessor = createOTokenLegacyProcessor({
+const otokenProcessor = createOTokenProcessor2({
   name: 'Super OETHb',
   symbol: 'superOETHb',
   from: 17819702,
   vaultFrom: 17819702,
-  // fee: 20n,
+  fee: 20n,
   otokenAddress: baseAddresses.tokens.superOETHb,
   wotoken: {
     address: baseAddresses.tokens.wsuperOETHb,

schema.graphql

@@ -55,6 +55,7 @@ export * from "./oTokenDripperState.model"
 export * from "./oTokenHarvesterYieldSent.model"
 export * from "./oTokenRewardTokenCollected.model"
 export * from "./oTokenWithdrawalRequest.model"
+export * from "./oTokenYieldForwarded.model"
 export * from "./arm.model"
 export * from "./armState.model"
 export * from "./armDailyStat.model"

src/base/super-oeth-b.ts

@@ -0,0 +1,36 @@
+import {Entity as Entity_, Column as Column_, PrimaryColumn as PrimaryColumn_, IntColumn as IntColumn_, Index as Index_, DateTimeColumn as DateTimeColumn_, StringColumn as StringColumn_, BigIntColumn as BigIntColumn_} from "@subsquid/typeorm-store"
+
+@Entity_()
+export class OTokenYieldForwarded {
+    constructor(props?: Partial<OTokenYieldForwarded>) {
+        Object.assign(this, props)
+    }
+
+    @PrimaryColumn_()
+    id!: string
+
+    @Index_()
+    @IntColumn_({nullable: false})
+    chainId!: number
+
+    @Index_()
+    @IntColumn_({nullable: false})
+    blockNumber!: number
+
+    @Index_()
+    @DateTimeColumn_({nullable: false})
+    timestamp!: Date
+
+    @Index_()
+    @StringColumn_({nullable: false})
+    otoken!: string
+
+    @StringColumn_({nullable: false})
+    from!: string
+
+    @StringColumn_({nullable: false})
+    to!: string
+
+    @BigIntColumn_({nullable: false})
+    amount!: bigint
+}