Build next-generation DeFi products using real world economic data and indexes

import { NodeTNClient, StreamId, EthereumAddress, type StreamLocator } from '@trufnetwork/sdk-js';
import { Wallet } from 'ethers';

// Initialize client 
const wallet = new Wallet('YOUR_PRIVATE_KEY');
const client = new NodeTNClient({
  endpoint: 'TSN_PROVIDER',
  signerInfo: {
    address: wallet.address,
    signer: wallet,
  },
  chainId: 'TSN_CHAIN_ID',
});

// Get composed stream data
async function getComposedStreamData(
  streamId: string,
  dataProviderAddress: string,
  from: number,
  to: number
) {
  const streamLocatorNew: StreamLocator = {
    streamId: StreamId.fromString(streamId).throw(),
    dataProvider: EthereumAddress.fromString(dataProviderAddress).throw(),
  }
  const streamApi = client.loadComposedAction()

  const streamData = await streamApi.getRecord({ stream: streamLocatorNew, from, to })

  return streamData
}