Class PiDataService

Implementation of the Pi Data Service that provides streaming data capabilities

Implements

IPiDataService

Index

Constructors

Methods

getAllPiDelegationMessages getAllPiDelegationPreferences getAllPiDelegationPreferencesWithBalances getCurrentDelegationsForAddress getFLPYieldHistory getMintReportMessages autoConfiguration

Constructors

constructor

new PiDataService(
reactiveMessageService: IReactiveMessageService,
arweaveDataService: IArweaveDataService,
): PiDataService
Parameters
- reactiveMessageService: IReactiveMessageService
- arweaveDataService: IArweaveDataService
Returns PiDataService
- Defined in services/autonomous-finance/pi-data-service/PiDataService.ts:19

Methods

getAllPiDelegationMessages

getAllPiDelegationMessages(): Observable<Partial<FullArweaveTransaction>[]>
Retrieves all pi delegation messages without filtering

Returns Observable<Partial<FullArweaveTransaction>[]>
Observable stream of all pi delegation messages
- Defined in services/autonomous-finance/pi-data-service/PiDataService.ts:151

getAllPiDelegationPreferences

getAllPiDelegationPreferences(): Observable<DelegationPreferencesResponse[]>
Gets all current delegations with their allocation responses

Returns Observable<DelegationPreferencesResponse[]>
Observable stream of allocation response messages
Implementation of IPiDataService.getAllPiDelegationPreferences
- Defined in services/autonomous-finance/pi-data-service/PiDataService.ts:41

getAllPiDelegationPreferencesWithBalances

getAllPiDelegationPreferencesWithBalances(): Observable<
DelegationPreferencesResponseWithBalance[],
>
Gets all current delegations with their allocation responses and wallet balances

Returns Observable<DelegationPreferencesResponseWithBalance[]>
Observable stream of allocation response messages with balances
Implementation of IPiDataService.getAllPiDelegationPreferencesWithBalances
- Defined in services/autonomous-finance/pi-data-service/PiDataService.ts:53

getCurrentDelegationsForAddress

getCurrentDelegationsForAddress(
delegatedTo: string,
): Observable<SimplifiedDelegationResponse[]>
Gets current delegations for a specific delegated address with simplified response format
Parameters
- delegatedTo: string
  The wallet address to get delegations for
Returns Observable<SimplifiedDelegationResponse[]>
Observable stream of simplified delegation responses where walletTo matches delegatedTo
Implementation of IPiDataService.getCurrentDelegationsForAddress
- Defined in services/autonomous-finance/pi-data-service/PiDataService.ts:64

getFLPYieldHistory

getFLPYieldHistory(): Observable<FLPYieldHistoryEntry[]>
Gets all FLP yield history entries with timestamps

Returns Observable<FLPYieldHistoryEntry[]>
Observable stream of FLP yield history entries
Implementation of IPiDataService.getFLPYieldHistory
- Defined in services/autonomous-finance/pi-data-service/PiDataService.ts:248

getMintReportMessages

getMintReportMessages(): Observable<Partial<FullArweaveTransaction>[]>
Gets all messages with the Add-Own-Mint-Report action between PI_TOKEN_PROCESS_ID endpoints

Returns Observable<Partial<FullArweaveTransaction>[]>
Observable stream of Arweave transactions matching the criteria
Implementation of IPiDataService.getMintReportMessages
- Defined in services/autonomous-finance/pi-data-service/PiDataService.ts:230

`Static`autoConfiguration

autoConfiguration(): PiDataService
Creates a pre-configured instance of PiDataService

Returns PiDataService
A pre-configured PiDataService instance
- Defined in services/autonomous-finance/pi-data-service/PiDataService.ts:28