npm:
npm -i @tastytrade/api
yarn:
yarn add @tastytrade/api
import TastytradeClient from "@tastytrade/api"
const tastytradeClient = new TastytradeClient(baseUrl, accountStreamerUrl)
const loginResponse = await tastytradeClient.sessionService.login(usernameOrEmail, pasword)
const accounts = await tastytradeClient.accountsAndCustomersService.getCustomerAccounts()
const accountPositions = await tastytradeClient.balancesAndPositionsService.getPositionsList(accounts[0].accounts['account-number'])
import TastytradeClient, { QuoteStreamer } from "@tastytrade-api"
const tastytradeClient = new TastytradeClient(baseUrl, accountStreamerUrl)
await tastytradeClient.sessionService.login(usernameOrEmail, pasword)
const tokenResponse = await tastytradeClient.AccountsAndCustomersService.getQuoteStreamerTokens()
const quoteStreamer = new QuoteStreamer(tokenResponse.token, `${tokenResponse['websocket-url']}/cometd`)
quoteStreamer.connect()
function handleMarketDataReceived(event) {
// Triggers every time market data event occurs
console.log(event)
}
// Subscribe to a single equity quote
quoteStreamer.subscribe('AAPL', handleMarketDataReceived)
// Subscribe to a single equity option quote
const optionChain = await tastytradeClient.instrumentsService.getOptionChain('AAPL')
quoteStreamer.subscribe(optionChain[0]['streamer-symbol'], handleMarketDataReceived)
const TastytradeApi = require("@tastytrade/api")
const TastytradeClient = TastytradeApi.default
const { AccountStreamer, QuoteStreamer } = TastytradeApi
const _ = require('lodash')
function handleStreamerMessage(json) {
console.log('streamer message received: ', json)
}
function handleStreamerStateChange(streamerState) {
console.log('streamer state changed: ', streamerState)
}
const tastytradeClient = new TastytradeClient(baseUrl, accountStreamerUrl)
const accountStreamer = tastytradeClient.accountStreamer
const loginResponse = await tastytradeClient.sessionService.login(usernameOrEmail, password)
const accounts = await tastytradeClient.accountsAndCustomersService.getCustomerAccounts()
const accountNumbers = _.map(accounts, account => _.get(account, 'account.account-number'))
await accountStreamer.start()
await accountStreamer.subscribeToAccounts(accountNumbers)
accountStreamer.addMessageObserver(handleStreamerMessage)
accountStreamer.addStreamerStateObserver(handleStreamerStateChange)
You should then be able to place a trade and see live status updates for the order come through via handleStreamerMessage
.
The cometd
package has an explicit reference to window
, so there's not a perfect way to run this code in a NodeJs. You could fake the window
object to get it running. You'll have to npm install ws
and do this:
const WebSocket = require('ws')
global.WebSocket = WebSocket
global.window = { WebSocket, setTimeout, clearTimeout }
npm run build
Outputs everything to dist/
npm run build
cd examples/
npm install
npm run dev
Open http://localhost:3000 with your browser to see the result.
Unit tests are for specific pieces of code and should not make any external calls (http requests). If needed, you can mock out an http response in your unit test.
For testing actual api requests, use the tests/integration
folder.
Directory structure should match the lib
structure. Service tests will go in tests/unit/service/<servicefilename>.test.ts