Time Series

/* global activOneApi */
// You may have to update the userId and password fields below.
const user = "__ACTIV_SESSION_USER_ID__";
const password = "__ACTIV_SESSION_PASSWORD__";
const host = "aop-ny4-replay.activfinancial.com";

(async function() {
    try {
        const session = await activOneApi.connect({
            host,
            user,
            password,
            onLogMessage(logType, message) {
                console.log(message);
            }
        });

        // Initiate a tick request for a days worth of ticks.
        session.timeSeriesTicks({
            dataSourceId: activOneApi.DataSourceId.activ,
            symbologyId: activOneApi.SymbologyId.native,
            symbol: "CSIQ.Q"
        },
        {
            start: activOneApi.DateTime.MAX,
            count: -20,
            filter: activOneApi.TickFilter.allTrades
        },
        {
            onTimeSeriesMessage (message) {
                console.log(`\nTick received for ${message.symbol}`);
        
                // Iterate through the fields in the response.
                for (const field of message.fieldData) {
                    let value = field.value;
                    if (field.id == activOneApi.FieldId.FID_TICK_TYPE)
                        value = activOneApi.TickType[value];
                    console.log(`${activOneApi.FieldId[field.id]}  =  ${value}`);
                }
            },
            onTimeSeriesFailure (message) {
                console.log(`Failure: ${activOneApi.StatusCode[message.statusCode]}`);
            }
        });
    } catch (e) {
        console.error(`Failure: ${activOneApi.StatusCode[e]}`);
    }
})();

/* global activOneApi */
// You may have to update the userId and password fields below.
const user = "__ACTIV_SESSION_USER_ID__";
const password = "__ACTIV_SESSION_PASSWORD__";
const host = "aop-ny4-replay.activfinancial.com";

(async function() {
    try {
        const session = await activOneApi.connect({
            host,
            user,
            password,
            onLogMessage(logType, message) {
                console.log(message);
            }
        });

        // Initiate a intraday bar request.
        session.timeSeriesIntradayBars({
            dataSourceId: activOneApi.DataSourceId.activ,
            symbologyId: activOneApi.SymbologyId.native,
            symbol: "CSIQ.Q"
        },
        {
            start: new Date(new Date().toDateString() + " 00:00:00"),
            end: new Date(new Date().toDateString() + " 23:59:59"),
            barInterval: activOneApi.IntradayInterval.thirtyMinute
        },
        {
            onTimeSeriesMessage (message) {
                console.log(`\nIntraday bar received for ${message.symbol}`);
        
                // Iterate through the fields in the response.
                for (const field of message.fieldData) {
                    console.log(`${activOneApi.FieldId[field.id]}  =  ${field.value}`);
                }
            },
            onTimeSeriesFailure (message) {
                console.log(`Failure: ${activOneApi.StatusCode[message.statusCode]}`);
            }
        });
    } catch (e) {
        console.error(`Failure: ${activOneApi.StatusCode[e]}`);
    }
})();

/* global activOneApi */
// You may have to update the userId and password fields below.
const user = "__ACTIV_SESSION_USER_ID__";
const password = "__ACTIV_SESSION_PASSWORD__";
const host = "aop-ny4-replay.activfinancial.com";

(async function() {
    try {
        const session = await activOneApi.connect({
            host,
            user,
            password,
            onLogMessage(logType, message) {
                console.log(message);
            }
        });

        // Get the date from a month ago for the data start.
        const startDate = new Date();
        startDate.setMonth(startDate.getMonth() - 1);

        // Initiate a history bar request.
        session.timeSeriesHistoryBars({
            dataSourceId: activOneApi.DataSourceId.activ,
            symbologyId: activOneApi.SymbologyId.native,
            symbol: "CSIQ.Q"
        },
        {
            start: startDate,
            end: activOneApi.Date.MAX,
            barInterval: activOneApi.HistoryInterval.daily
        },
        {
            onTimeSeriesMessage (message) {
                console.log(`\nHistory bar received for ${message.symbol}`);
        
                // Iterate through the fields in the response.
                for (const field of message.fieldData) {
                    console.log(`${activOneApi.FieldId[field.id]}  =  ${field.value}`);
                }
            },
            onTimeSeriesFailure (message) {
                console.log(`Failure: ${activOneApi.StatusCode[message.statusCode]}`);
            }
        });
    } catch (e) {
        console.error(`Failure: ${activOneApi.StatusCode[e]}`);
    }
})();