feat: pendle

packages/adapters-library/src/adapters/aave-v2/common/aaveBasePoolAdapter.ts

@@ -176,18 +176,6 @@ export abstract class AaveBasePoolAdapter implements IProtocolAdapter {
     const metadataObject: ProtocolToken[] = []
 
     const promises = reserveTokens.map(async ({ tokenAddress }) => {
-      const reserveConfigurationData =
-        await protocolDataProviderContract.getReserveConfigurationData(
-          tokenAddress,
-        )
-
-      if (
-        !reserveConfigurationData.isActive ||
-        reserveConfigurationData.isFrozen
-      ) {
-        return
-      }
-
       const reserveTokenAddresses =
         await protocolDataProviderContract.getReserveTokensAddresses(
           tokenAddress,

packages/adapters-library/src/adapters/pendle/products/yield-token/pendleYieldTokenAdapter.ts

@@ -1,9 +1,9 @@
-import { getAddress } from 'ethers'
+import { Block, getAddress } from 'ethers'
 import { AdaptersController } from '../../../../core/adaptersController'
 import { Chain } from '../../../../core/constants/chains'
 import { CacheToDb } from '../../../../core/decorators/cacheToDb'
 import { CustomJsonRpcProvider } from '../../../../core/provider/CustomJsonRpcProvider'
-import { filterMapAsync } from '../../../../core/utils/filters'
+import { filterMapAsync, filterMapSync } from '../../../../core/utils/filters'
 import { getTokenMetadata } from '../../../../core/utils/getTokenMetadata'
 import { Helpers } from '../../../../scripts/helpers'
 import {
@@ -34,6 +34,7 @@ import { RouterStatic__factory, YieldToken__factory } from '../../contracts'
 
 type AdditionalMetadata = {
   marketAddress: string
+  expiry: string
 }
 
 export class PendleYieldTokenAdapter implements IProtocolAdapter {
@@ -78,6 +79,32 @@ export class PendleYieldTokenAdapter implements IProtocolAdapter {
     }
   }
 
+  async isExpiredAtBlock(
+    expiry: string,
+    blockNumber?: number,
+  ): Promise<boolean> {
+    let comparisonDate: Date
+
+    if (blockNumber) {
+      // Get the block details if a block number is provided
+      const block = await this.provider.getBlock(blockNumber)
+
+      if (!block) {
+        throw new Error(`Block ${blockNumber} not found`)
+      }
+
+      comparisonDate = new Date(block.timestamp * 1000) // Convert seconds to milliseconds
+    } else {
+      // If no block number is provided, use today's date
+      comparisonDate = new Date()
+    }
+
+    const expiryDate = new Date(expiry)
+
+    // Compare the expiry date with either the block date or today's date
+    return comparisonDate > expiryDate
+  }
+
   @CacheToDb
   async getProtocolTokens(): Promise<ProtocolToken<AdditionalMetadata>[]> {
     const resp = await fetchAllMarkets(this.chainId)
@@ -103,14 +130,26 @@ export class PendleYieldTokenAdapter implements IProtocolAdapter {
         ...yt,
         underlyingTokens: [sy],
         marketAddress,
+        expiry: value.expiry,
       }
     })
   }
 
   async getPositions(input: GetPositionsInput): Promise<ProtocolPosition[]> {
+    const tokens = await filterMapAsync(
+      await this.getProtocolTokens(),
+      async (protocolToken) => {
+        if (await this.isExpiredAtBlock(protocolToken.expiry)) {
+          return undefined
+        }
+
+        return protocolToken
+      },
+    )
+
     return this.helpers.getBalanceOfTokens({
       ...input,
-      protocolTokens: await this.getProtocolTokens(),
+      protocolTokens: tokens,
     })
   }