Intrinio Web and NodeJS SDK for Real-Time Stock Prices

SDK for working with Intrinio's realtime Multi-Exchange prices feed. Intrinio’s feed provides flexibility by providing the same interface from the IEX, NASDAQ Basic, and delayed SIP sources.

Intrinio provides real-time stock prices via a two-way WebSocket connection. To get started, subscribe to a real-time data feed and follow the instructions below.

Requirements

- NodeJS 20.7.0 (for NodeJS usage)

Docker

Add your API key to the realtime.js file, then
``
docker compose build
docker compose run client
`

Features

* Receive streaming, real-time price quotes (last trade, bid, ask)
* Subscribe to updates from individual securities
* Subscribe to updates for all securities
* Multiple sources of data - IEX/REALTIME, DELAYED_SIP, NASDAQ_BASIC, CBOE_ONE, or Equities Edge

NodeJS Installation

`
npm install intrinio-realtime --save
`

Example Usage (NodeJS)

`javascript
"use strict"
const Client = require("./index").RealtimeClient; //local development
//const Client = require("intrinio-realtime").RealtimeClient; //load from package
//const Client = require("./index").ReplayClient;
const accessKey = "";

const config = {
provider: 'IEX', //IEX, REALTIME (interchangable with IEX), DELAYED_SIP, NASDAQ_BASIC, CBOE_ONE, EQUITIES_EDGE, or MANUAL
ipAddress: undefined,
tradesOnly: false,
isPublicKey: false,
delayed: false //set to true if you have realtime access and want to force delayed mode. Otherwise, if you only have delayed, you'll get delayed not matter if you set this or not.
};

// const config = { //replay config
// provider: 'IEX', //IEX, REALTIME (interchangable with IEX), DELAYED_SIP, NASDAQ_BASIC, CBOE_ONE, EQUITIES_EDGE, or MANUAL
// ipAddress: undefined,
// tradesOnly: false,
// isPublicKey: false,
// replayDate: '2023-10-06',
// replayAsIfLive: false,
// replayDeleteFileWhenDone: true
// };

let trades = new Map();
let quotes = new Map();
let maxTradeCount = 0;
let maxCountTrade = null;
let maxQuoteCount = 0;
let maxCountQuote = null;

function onTrade(trade) {
let key = trade.Symbol;
if (trades.has(key)) {
let value = trades.get(key);
if (value + 1 > maxTradeCount) {
trades.set(key, value + 1);
maxTradeCount = value + 1;
maxCountTrade = trade;
}
}
else trades.set(key, 1);
}

function onQuote(quote) {
let key = quote.Symbol + ":" + quote.Type;
if (quotes.has(key)) {
let value = quotes.get(key);
if (value + 1 > maxQuoteCount) {
quotes.set(key, value + 1);
maxQuoteCount = value + 1;
maxCountQuote = quote;
}
}
else quotes.set(key, 1);
}

let client = new Client(accessKey, onTrade, onQuote, config);
await client.join("AAPL", false); //use $lobby for firehose.

setInterval(() => {
if (maxTradeCount > 0) {
console.log("Most active security (by trade frequency): %s (%i updates)", JSON.stringify(maxCountTrade, (key, value) =>
typeof value === 'bigint'
? value.toString()
: value // return everything else unchanged
), maxTradeCount);
}
if (maxQuoteCount > 0) {
console.log("Most active security (by quote frequency): %s (%i updates)", JSON.stringify(maxCountQuote, (key, value) =>
typeof value === 'bigint'
? value.toString()
: value // return everything else unchanged
), maxQuoteCount);
}
let totalMsgCount = client.getTotalMsgCount();
if (totalMsgCount > 0) {
console.log("Total updates received = %i", totalMsgCount);
}
else {
console.log("No updates");
}
}, 10000);

`

Make sure to use your API key as the accessKey parameter.

Data Format

$3

| Value | Description |
|-------|---------------------------------------------------|
| @ | Regular Sale |
| A | Acquisition |
| B | Bunched Trade |
| C | Cash Sale |
| D | Distribution |
| E | Placeholder |
| F | Intermarket Sweep |
| G | Bunched Sold Trade |
| H | Priced Variation Trade |
| I | Odd Lot Trade |
| K | Rule 155 Trade (AMEX) |
| L | Sold Last |
| M | Market Center Official Close |
| N | Next Day |
| O | Opening Prints |
| P | Prior Reference Price |
| Q | Market Center Official Open |
| R | Seller |
| S | Split Trade |
| T | Form T |
| U | Extended Trading Hours (Sold Out of Sequence) |
| V | Contingent Trade |
| W | Average Price Trade |
| X | Cross/Periodic Auction Trade |
| Y | Yellow Flag Regular Trade |
| Z | Sold (Out of Sequence) |
| 1 | Stopped Stock (Regular Trade) |
| 4 | Derivatively Priced |
| 5 | Re-Opening Prints |
| 6 | Closing Prints |
| 7 | Qualified Contingent Trade (QCT) |
| 8 | Placeholder for 611 Exempt |
| 9 | Corrected Consolidated Close (Per Listing Market) |




$3

Trade conditions for CBOE One are represented as the integer representation of a bit flag.

None = 0,
UpdateHighLowConsolidated = 1,
UpdateLastConsolidated = 2,
UpdateHighLowMarketCenter = 4,
UpdateLastMarketCenter = 8,
UpdateVolumeConsolidated = 16,
OpenConsolidated = 32,
OpenMarketCenter = 64,
CloseConsolidated = 128,
CloseMarketCenter = 256,
UpdateVolumeMarketCenter = 512

$3

| Value | Description |
|-------|---------------------------------------------|
| R | Regular |
| A | Slow on Ask |
| B | Slow on Bid |
| C | Closing |
| D | News Dissemination |
| E | Slow on Bid (LRP or Gap Quote) |
| F | Fast Trading |
| G | Trading Range Indication |
| H | Slow on Bid and Ask |
| I | Order Imbalance |
| J | Due to Related - News Dissemination |
| K | Due to Related - News Pending |
| O | Open |
| L | Closed |
| M | Volatility Trading Pause |
| N | Non-Firm Quote |
| O | Opening |
| P | News Pending |
| S | Due to Related |
| T | Resume |
| U | Slow on Bid and Ask (LRP or Gap Quote) |
| V | In View of Common |
| W | Slow on Bid and Ask (Non-Firm) |
| X | Equipment Changeover |
| Y | Sub-Penny Trading |
| Z | No Open / No Resume |
| 1 | Market Wide Circuit Breaker Level 1 |
| 2 | Market Wide Circuit Breaker Level 2 |
| 3 | Market Wide Circuit Breaker Level 3 |
| 4 | On Demand Intraday Auction |
| 45 | Additional Information Required (CTS) |
| 46 | Regulatory Concern (CTS) |
| 47 | Merger Effective |
| 49 | Corporate Action (CTS) |
| 50 | New Security Offering (CTS) |
| 51 | Intraday Indicative Value Unavailable (CTS) |

Example Replay Client Usage (NodeJS)

Used to replay a specific day's data by downloading the replay file from the REST API and then playing it back.
`javascript
"use strict"
//const Client = require("./index").RealtimeClient;
const Client = require("./index").ReplayClient;
const accessKey = "";

// const config = {
// provider: 'IEX', //IEX, REALTIME (interchangable with IEX), DELAYED_SIP, NASDAQ_BASIC, CBOE_ONE, EQUITIES_EDGE, or MANUAL
// ipAddress: undefined,
// tradesOnly: false,
// isPublicKey: false,
// delayed: false //set to true if you have realtime access and want to force delayed mode. Otherwise, if you only have delayed, you'll get delayed not matter if you set this or not.
// };

const config = { //replay config
provider: 'IEX', //IEX, REALTIME (interchangable with IEX), DELAYED_SIP, NASDAQ_BASIC, CBOE_ONE, EQUITIES_EDGE, or MANUAL
ipAddress: undefined,
tradesOnly: false,
isPublicKey: false,
replayDate: '2023-10-06',
replayAsIfLive: false,
replayDeleteFileWhenDone: true
};

let trades = new Map();
let quotes = new Map();
let maxTradeCount = 0;
let maxCountTrade = null;
let maxQuoteCount = 0;
let maxCountQuote = null;

function onTrade(trade) {
let key = trade.Symbol;
if (trades.has(key)) {
let value = trades.get(key);
if (value + 1 > maxTradeCount) {
trades.set(key, value + 1);
maxTradeCount = value + 1;
maxCountTrade = trade;
}
}
else trades.set(key, 1);
}

function onQuote(quote) {
let key = quote.Symbol + ":" + quote.Type;
if (quotes.has(key)) {
let value = quotes.get(key);
if (value + 1 > maxQuoteCount) {
quotes.set(key, value + 1);
maxQuoteCount = value + 1;
maxCountQuote = quote;
}
}
else quotes.set(key, 1);
}

let client = new Client(accessKey, onTrade, onQuote, config);
await client.join("AAPL", false); //use $lobby for firehose.

setInterval(() => {
if (maxTradeCount > 0) {
console.log("Most active security (by trade frequency): %s (%i updates)", JSON.stringify(maxCountTrade, (key, value) =>
typeof value === 'bigint'
? value.toString()
: value // return everything else unchanged
), maxTradeCount);
}
if (maxQuoteCount > 0) {
console.log("Most active security (by quote frequency): %s (%i updates)", JSON.stringify(maxCountQuote, (key, value) =>
typeof value === 'bigint'
? value.toString()
: value // return everything else unchanged
), maxQuoteCount);
}
let totalMsgCount = client.getTotalMsgCount();
if (totalMsgCount > 0) {
console.log("Total updates received = %i", totalMsgCount);
}
else {
console.log("No updates");
}
}, 10000);

`

Make sure to use your API key as the accessKey parameter, and changing the replayDate parameter

Handling Quotes

There are thousands of securities, each with their own feed of activity. We highly encourage you to make your trade and quote handlers has short as possible and follow a queue pattern so your app can handle the volume of activity.

#### Trade Message

`javascript
{
Symbol: "AAPL",
Price: 150.99,
Size: 20,
Timestamp: 1637092835566268084,
TotalVolume: 2728543,
SubProvider: "IEX",
MarketCenter: "",
Condition: ""
}
`

* Symbol - Stock 'ticker' symbol for the security
* Price - The price in USD
* Size - The number of shares exchanged on the last trade
* TotalVolume - The total number of shares traded so far today, for the given symbol
* Timestamp - A unix timestamp (the number of nanoseconds since the unix epoch)
* SubProvider - Denotes the detailed source within grouped sources.
* NONE - No subtype specified.
* CTA_A - CTA_A in the DELAYED_SIP provider.
* CTA_B - CTA_B in the DELAYED_SIP provider.
* UTP - UTP in the DELAYED_SIP provider.
* OTC - OTC in the DELAYED_SIP provider.
* NASDAQ_BASIC - NASDAQ Basic in the NASDAQ_BASIC provider.
* IEX - From the IEX exchange in the REALTIME provider.
* CBOE_ONE - From the CBOE One exchanges provider.
* EQUITIES_ONE - From the Equities Edge provider.
* MarketCenter - Provides the market center
* Condition - Provides the condition

#### Quote Message

`javascript
{
Symbol: "GOOG",
Type: 1,
Price: 2994.78,
Size: 105,
Timestamp: 1637092847907710010,
SubProvider: "IEX",
MarketCenter: "",
Condition: ""
}
`

* Symbol - Stock 'ticker' symbol for the security
* Type - The quote type (either 'ask' or 'bid')
* 1 - represents an 'ask' type
* 2 - represents a 'bid' type
* Price - The price in USD
* Size - The size of the last ask or bid
* Timestamp - A unix timestamp (the number of nanoseconds since the unix epoch)
* SubProvider - Denotes the detailed source within grouped sources.
* NONE - No subtype specified.
* CTA_A - CTA_A in the DELAYED_SIP provider.
* CTA_B - CTA_B in the DELAYED_SIP provider.
* UTP - UTP in the DELAYED_SIP provider.
* OTC - OTC in the DELAYED_SIP provider.
* NASDAQ_BASIC - NASDAQ Basic in the NASDAQ_BASIC provider.
* IEX - From the IEX exchange in the REALTIME provider.
* CBOE_ONE - From the CBOE One exchanges provider.
* EQUITIES_ONE - From the Equities Edge provider.
* MarketCenter - Provides the market center
* Condition - Provides the condition

API Keys

You will receive your Intrinio API Key after creating an account. You will need a subscription to the Real-Time Data Feed as well.

Methods

constructor(accessKey, onTrade, ?onQuote, ?config) - Creates a new instance of the IntrinioRealtime client.
* Parameter accessKey: Your API key. See the section on API Keys, above.
* Parameter onTrade: A callback invoked when a 'trade' has been received. The trade will be passed as an argument to the callback.
* Parameter onQuote: Optional. A callback invoked when a 'quote' has been received. The quote will be passed as an argument to the callback. If 'onQuote' is not provided, the client will NOT request to receive quote updates from the server.
* Parameter config: Optional. An object with properties provider, ipAddress, and tradesOnly corresponding to a provider code ("REALTIME" (default) or "MANUAL"), the ipAddress of the websocket server (only necessay when provider = "MANUAL"), and a boolean value indicating whether the server should return trade data only (as opposed to trade and quote data).
`javascript
function onTrade(trade) {
console.log("TRADE: ", trade)
}
function onQuote(quote) {
console.log("QUOTE: ", quote)
}
const client = new IntrinioRealtimeClient("INTRINIO_API_KEY", onTrade, onQuote, { tradesOnly: true, delayed: false })
`
---------

stop() - Closes the WebSocket, stops the self-healing and heartbeat intervals. You MUST call this to dispose of the client. Called automatically on 'SIGINT'.

---------

join(symbols, tradesOnly) - Joins the given channels. This can be called at any time. The client will automatically register joined channels and establish the proper subscriptions with the WebSocket connection.
* Parameter symbols - A string representing a single ticker symbol (e.g. "AAPL") or an array of ticker symbols (e.g. ["AAPL", "MSFT", "GOOG"]) to join. You can also use the special symbol, "$lobby" to join the firehose channel and recieved updates for all ticker symbols. You must have a valid "firehose" subscription.
* Parameter tradesOnly - Optional (default: false). A boolean value indicating whether the server should return trade data only (as opposed to trade and quote data).
`javascript
client.join(["AAPL", "MSFT", "GOOG"])
client.join("GE", true)
client.join("$lobby") //must have a valid 'firehose' subscription
`

---------

leave(symbols) - Leaves the given channels.
* Parameter symbols - Optional (default = all channels). A string representing a single ticker symbol (e.g. "AAPL") or an array of ticker symbols (e.g. ["AAPL", "MSFT", "GOOG"]) to leave. If not provided, all subscribed channels will be unsubscribed.
`javascript
client.leave(["AAPL", "MSFT", "GOOG"])
client.leave("GE")
client.leave("$lobby")
client.leave()
`

Web Page Usage (DEPRECIATED)


To use the Web SDK (non-NodeJS), include the index.js script (found in this repository) at the end of your tag:

`html

`
and use/create the public access key (NOT your normal API Key) from your account page.

Example Usage (Web)


`javascript
const accessKey = ""

function onTrade(trade) {
let tradeElement = $.parseHTML('

' + trade.Symbol + '(trade): $' + trade.Price + '

')
$('.container').prepend(tradeElement)
}

function onQuote(quote) {
let quoteType = null
if (quote.Type === 1) quoteType = "ask"
else if (quote.Type === 2) quoteType = "bid"
let quoteElement = $.parseHTML('

' + quote.Symbol + '(' + quote.Type + '): $' + quote.Price + '

')
$('.container').prepend(quoteElement)
}

let config = {
isPublicKey: true
}

let client = new IntrinioRealtime(accessKey, onTrade, onQuote, config)

client.join("GOOG", true)
`

For another example, see the /sample` folder. Make sure to substitute your own Public Access Key.

Public Access Key

You can create a Public Access Key after creating an account. On your Account page, scroll down to Access Keys, click Add New Key, name it, and specify Public. The key will appear on your Account page, which you will need for to use the SDK. You will also need a subscription to a real-time data feed for one of the providers listed below. You may also need to contact support to set up CORS. This data access pattern is not recommended for obvious security and rate limitation purposes.