Pass full json message in account streamer; update README with instru…

…ctions

README.md

@@ -37,6 +37,44 @@ const optionChain = await tastytradeClient.instrumentsService.getOptionChain('AA
 quoteStreamer.subscribe(optionChain[0]['streamer-symbol'], handleMarketDataReceived)
 ```
 
+### Account Streamer
+```js
+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`.
+
+## Running in Node
+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:
+
+```js
+const WebSocket = require('ws')
+
+global.WebSocket = WebSocket
+global.window = { WebSocket, setTimeout, clearTimeout }
+```
+
 ## Building Locally
 `npm run build`
 Outputs everything to `dist/`

examples/package.json

@@ -9,7 +9,6 @@
     "lint": "next lint"
   },
   "dependencies": {
-    "@dxfeed/api": "^1.1.0",
     "@types/lodash": "^4.14.182",
     "axios": "^1.3.4",
     "dayjs": "^1.11.1",

lib/account-streamer.ts

@@ -26,7 +26,7 @@ export type Disposer = () => void
 
 export type StreamerStateObserver = (streamerState: STREAMER_STATE) => void
 
-export type StreamerMessageObserver = (messageType: string, action: string, status: string) => void
+export type StreamerMessageObserver = (json: object) => void
 
 const REQUEST_ID = 'request-id'
 
@@ -368,7 +368,7 @@ export class AccountStreamer {
     this.logger.info(json)
 
     const action = json.action as string
-    this.streamerMessageObservers.forEach(observer => observer(json.type as string, action, json.status as string))
+    this.streamerMessageObservers.forEach(observer => observer(json))
     if (action) {
       if (action === MessageAction.HEARTBEAT) {
         // schedule next heartbeat

tests/unit/service/session-service.test.ts

@@ -83,7 +83,7 @@ describe('logout', () => {
     const client = new TastytradeHttpClient('fakeurl')
     client.session.authToken = 'faketoken'
     const sessionService = new SessionService(client)
-    const response = await sessionService.logout()
+    await sessionService.logout()
     expect(client.session.authToken).toBeNull()
   })
 })