/**
* HttpManager.ts
* @author Abhilash Panwar (abpanwar); Hector Hernandez (hectorh); Nev Wylie (newylie)
* @copyright Microsoft 2018-2020
*/
import dynamicProto from "@microsoft/dynamicproto-js";
import EVTClockSkewManager from "./ClockSkewManager";
import EVTKillSwitch from "./KillSwitch";
import {
    EventSendType, FullVersionString, ICookieMgr, IDiagnosticLogger, IExtendedAppInsightsCore, IExtendedConfiguration, IPerfEvent,
    SendRequestReason, TransportType, _eExtendedInternalMessageId, _eInternalMessageId, _throwInternal, _warnToConsole, arrForEach, dateNow,
    doPerf, dumpObj, eLoggingSeverity, extend, getLocation, getNavigator, getTime, hasOwnProperty, isArray, isBeaconsSupported,
    isFetchSupported, isNullOrUndefined, isNumber, isReactNative, isString, isUndefined, isValueAssigned, isXhrSupported, objForEachKey,
    objKeys, openXhr, strTrim, strUndefined, useXDomainRequest
} from "@microsoft/1ds-core-js";
import { BatchNotificationAction, BatchNotificationActions } from "./BatchNotificationActions";
import {
    EventBatchNotificationReason, ICollectorResult, IPayloadData, IPostChannel, IPostTransmissionTelemetryItem, IXHROverride,
    PayloadListenerFunction, PayloadPreprocessorFunction, SendPOSTFunction
} from "./DataModels";
import { EventBatch } from "./EventBatch";
import { IChannelConfiguration } from "./Index";
import {
    DEFAULT_CACHE_CONTROL, DEFAULT_CONTENT_TYPE, STR_API_KEY, STR_AUTH_XTOKEN, STR_CACHE_CONTROL, STR_CLIENT_ID, STR_CLIENT_VERSION,
    STR_CONTENT_TYPE_HEADER, STR_DISABLED_PROPERTY_NAME, STR_DROPPED, STR_EMPTY, STR_KILL_DURATION_HEADER, STR_KILL_DURATION_SECONDS_HEADER,
    STR_KILL_TOKENS_HEADER, STR_MSA_DEVICE_TICKET, STR_MSFPC, STR_NO_RESPONSE_BODY, STR_OTHER, STR_POST_METHOD, STR_REQUEUE,
    STR_RESPONSE_FAIL, STR_SENDING, STR_TIME_DELTA_HEADER, STR_TIME_DELTA_TO_APPLY, STR_UPLOAD_TIME
} from "./InternalConstants";
import { retryPolicyGetMillisToBackoffForRetry, retryPolicyShouldRetryForStatus } from "./RetryPolicy";
import { ISerializedPayload, Serializer } from "./Serializer";
import { ITimeoutOverrideWrapper } from "./TimeoutOverrideWrapper";
import { XDomainRequest as IXDomainRequest } from "./typings/XDomainRequest";

const strSendAttempt = "sendAttempt";

const _noResponseQs =  "&" + STR_NO_RESPONSE_BODY + "=true";

// TypeScript removed this interface so we need to declare the global so we can check for it's existence.
declare var XDomainRequest: {
    prototype: IXDomainRequest;
    new(): IXDomainRequest;
};

interface IRequestUrlDetails {
    url: string,
    hdrs: { [key: string]: string },
    useHdrs: boolean
}    

/**
 * Identifies the default notification reason to the action names
 */
const _eventActionMap: any = {
    [EventBatchNotificationReason.Paused]: STR_REQUEUE,
    [EventBatchNotificationReason.RequeueEvents]: STR_REQUEUE,
    [EventBatchNotificationReason.Complete]: "sent",
    [EventBatchNotificationReason.KillSwitch]: STR_DROPPED,
    [EventBatchNotificationReason.SizeLimitExceeded]: STR_DROPPED
};

const _collectorQsHeaders = { };
const _collectorHeaderToQs = { };

function _addCollectorHeaderQsMapping(qsName: string, headerName: string, allowQs?: boolean) {
    _collectorQsHeaders[qsName] = headerName;
    if (allowQs !== false) {
        _collectorHeaderToQs[headerName] = qsName;
    }
}

_addCollectorHeaderQsMapping(STR_MSA_DEVICE_TICKET, STR_MSA_DEVICE_TICKET, false);
_addCollectorHeaderQsMapping(STR_CLIENT_VERSION, STR_CLIENT_VERSION);
_addCollectorHeaderQsMapping(STR_CLIENT_ID, "Client-Id");
_addCollectorHeaderQsMapping(STR_API_KEY, STR_API_KEY);
_addCollectorHeaderQsMapping(STR_TIME_DELTA_TO_APPLY, STR_TIME_DELTA_TO_APPLY);
_addCollectorHeaderQsMapping(STR_UPLOAD_TIME, STR_UPLOAD_TIME);
_addCollectorHeaderQsMapping(STR_AUTH_XTOKEN, STR_AUTH_XTOKEN);

type OnCompleteCallback = (status: number, headers: { [headerName: string]: string }, response?: string) => void;

function _getResponseText(xhr: XMLHttpRequest | IXDomainRequest) {
    try {
        return xhr.responseText;
    } catch (e) {
        // Best effort, as XHR may throw while XDR wont so just ignore
    }

    return STR_EMPTY;
}

interface IInternalXhrOverride extends IXHROverride {
    _transport?: TransportType;
    _isSync?: boolean;
}

interface IInternalPayloadData extends IPayloadData {
    _thePayload: ISerializedPayload;
    _sendReason: SendRequestReason;
}

function _hasHeader(headers: any, header: string) {
    let hasHeader = false;
    if (headers && header) {
        const keys = objKeys(headers);
        if (keys && keys.length > 0) {
            const lowerHeader = header.toLowerCase();
            for (let lp = 0; lp < keys.length; lp++) {
                const value = keys[lp];
                if (value && hasOwnProperty(header, value) &&
                        value.toLowerCase() === lowerHeader) {
                    hasHeader = true;
                    break;
                }
            }
        }
    }

    return hasHeader;
}

function _addRequestDetails(details: IRequestUrlDetails, name: string, value: string, useHeaders: boolean) {
    if (name && value && value.length > 0) {
        if (useHeaders && _collectorQsHeaders[name]) {
            details.hdrs[_collectorQsHeaders[name]] = value;
            details.useHdrs = true;
        } else {
            details.url += "&" + name + "=" + value;
        }
    }
}

function _prependTransports(theTransports: TransportType[], newTransports: TransportType | TransportType[]) {
    if (newTransports) {
        if (isNumber(newTransports)) {
            theTransports = [newTransports as TransportType].concat(theTransports);
        } else if (isArray(newTransports)) {
            theTransports = newTransports.concat(theTransports);
        }
    }

    return theTransports;
}


/**
 * Class managing the sending of requests.
 */
export class HttpManager {
    public sendHook: PayloadPreprocessorFunction | undefined;
    public sendListener: PayloadListenerFunction | undefined;
    public _responseHandlers: Array<(responseText: string) => void> = [];

    /**
     * @constructor
     * @param requestQueue   - The queue that contains the requests to be sent.
     */
    constructor(maxEventsPerBatch: number, maxConnections: number, maxRequestRetriesBeforeBackoff: number, actions: BatchNotificationActions, timeoutOverride: ITimeoutOverrideWrapper) {
        let _urlString: string = "?cors=true&" + STR_CONTENT_TYPE_HEADER.toLowerCase() + "=" + DEFAULT_CONTENT_TYPE;
        let _killSwitch: EVTKillSwitch = new EVTKillSwitch();
        let _paused = false;
        let _clockSkewManager = new EVTClockSkewManager();
        let _useBeacons = false;
        let _outstandingRequests = 0;           // Holds the number of outstanding async requests that have not returned a response yet
        let _postManager: IPostChannel;
        let _logger: IDiagnosticLogger;
        let _sendInterfaces: { [key: number]: IInternalXhrOverride };
        let _core: IExtendedAppInsightsCore;
        let _customHttpInterface = true;
        let _queryStringParameters: Array<{ name: string, value: string }> = [];
        let _headers: { [name: string]: string } = {};
        let _batchQueue: EventBatch[] = [];
        let _serializer: Serializer = null;
        let _enableEventTimings = false;
        let _cookieMgr: ICookieMgr;
        let _isUnloading = false;
        let _useHeaders = false;
        let _xhrTimeout: number;
        let _disableXhrSync: boolean;
        let _disableFetchKeepAlive: boolean;
        let _canHaveReducedPayload: boolean;
        let _addNoResponse: boolean;

        dynamicProto(HttpManager, this, (_self) => {
            let _sendCredentials = true;

            _self.initialize = (
                    endpointUrl: string,
                    core: IExtendedAppInsightsCore,
                    postChannel: IPostChannel,
                    httpInterface: IXHROverride,
                    channelConfig?: IChannelConfiguration) => {

                if (!channelConfig) {
                    channelConfig = {};
                }

                _urlString = endpointUrl + _urlString;

                _useHeaders = !isUndefined(channelConfig.avoidOptions) ? !channelConfig.avoidOptions : true;
                _core = core;
                _cookieMgr = core.getCookieMgr();
                _enableEventTimings = !(_core.config as IExtendedConfiguration).disableEventTimings;
                let enableCompoundKey = !!(_core.config as IExtendedConfiguration).enableCompoundKey;
                _postManager = postChannel;
                _logger = _postManager.diagLog();
                let valueSanitizer = channelConfig.valueSanitizer;
                let stringifyObjects = channelConfig.stringifyObjects;
                if (!isUndefined(channelConfig.enableCompoundKey)) {
                    enableCompoundKey = !!channelConfig.enableCompoundKey;
                }

                _xhrTimeout = channelConfig.xhrTimeout;
                _disableXhrSync = !!channelConfig.disableXhrSync;
                _disableFetchKeepAlive = !!channelConfig.disableFetchKeepAlive;
                _addNoResponse = channelConfig.addNoResponse !== false;

                _useBeacons = !isReactNative(); // Only use beacons if not running in React Native
                _serializer = new Serializer(_core, valueSanitizer, stringifyObjects, enableCompoundKey);

                if (!isNullOrUndefined(channelConfig.useSendBeacon)) {
                    _useBeacons = !!channelConfig.useSendBeacon;
                }

                let syncHttpInterface = httpInterface;
                let beaconHttpInterface: IXHROverride = channelConfig.alwaysUseXhrOverride ? httpInterface : null;
                let fetchSyncHttpInterface: IXHROverride = channelConfig.alwaysUseXhrOverride ? httpInterface : null;
                let beaconUnloadTransports: TransportType[] = [TransportType.Beacon, TransportType.Fetch];

                if (!httpInterface) {
                    _customHttpInterface = false;

                    let location = getLocation();
                    if (location && location.protocol && location.protocol.toLowerCase() === "file:") {
                        // Special case where a local html file fails with a CORS error on Chromium browsers
                        _sendCredentials = false;
                    }

                    let theTransports: TransportType[] = [];
                    if (isReactNative()) {
                        // Use Fetch or XDR/XHR
                        theTransports = [TransportType.Fetch, TransportType.Xhr];
                        beaconUnloadTransports = [TransportType.Fetch, TransportType.Xhr, TransportType.Beacon];
                    } else {
                        // Use XDR/XHR, Fetch or beacons
                        theTransports = [TransportType.Xhr, TransportType.Fetch, TransportType.Beacon];
                    }

                    // Prefix any user requested transport(s) values
                    theTransports = _prependTransports(theTransports, channelConfig.transports);

                    httpInterface = _getSenderInterface(theTransports, false);
                    if (!httpInterface) {
                        _warnToConsole(_logger, "No available transport to send events");
                    }

                    syncHttpInterface = _getSenderInterface(theTransports, true);
                }

                if (!beaconHttpInterface) {
                    // Allow overriding the usage of sendBeacon
                    beaconUnloadTransports = _prependTransports(beaconUnloadTransports, channelConfig.unloadTransports);
                    beaconHttpInterface = _getSenderInterface(beaconUnloadTransports, true);
                }

                _canHaveReducedPayload = !_customHttpInterface && ((_useBeacons && isBeaconsSupported()) || (!_disableFetchKeepAlive && isFetchSupported(true)));

                _sendInterfaces = {
                    [EventSendType.Batched]: httpInterface,
                    [EventSendType.Synchronous]: syncHttpInterface || _getSenderInterface([TransportType.Xhr, TransportType.Fetch, TransportType.Beacon], true),
                    [EventSendType.SendBeacon]: beaconHttpInterface || syncHttpInterface || _getSenderInterface([TransportType.Xhr], true),
                    [EventSendType.SyncFetch]: fetchSyncHttpInterface || _getSenderInterface([TransportType.Fetch, TransportType.Beacon], true) || syncHttpInterface || _getSenderInterface([TransportType.Xhr], true)
                };
            };

            // Special internal method to allow the DebugPlugin to hook embedded objects
            function _getSenderInterface(transports: TransportType[], syncSupport: boolean): IInternalXhrOverride {
                let transportType: TransportType = TransportType.NotSet;
                let sendPostFunc: SendPOSTFunction = null;
                let lp = 0;
                while (sendPostFunc == null && lp < transports.length) {
                    transportType = transports[lp];
                    if (transportType === TransportType.Xhr) {
                        if (useXDomainRequest()) {
                            sendPostFunc = _xdrSendPost;
                        } else if (isXhrSupported()) {
                            sendPostFunc = _xhrSendPost;
                        }
                    } else if (transportType === TransportType.Fetch && isFetchSupported(syncSupport) && (!syncSupport || (syncSupport && !_disableFetchKeepAlive))) {
                        sendPostFunc = _fetchSendPost;
                    } else if (_useBeacons && transportType === TransportType.Beacon && isBeaconsSupported()) {
                        sendPostFunc = _beaconSendPost;
                    }

                    lp++;
                }

                if (sendPostFunc) {
                    return {
                        _transport: transportType,
                        _isSync: syncSupport,
                        sendPOST: sendPostFunc
                    };
                }

                return null;
            }

            _self["_getDbgPlgTargets"] = () => {
                return [_sendInterfaces[EventSendType.Batched], _killSwitch, _serializer, _sendInterfaces];
            };

            function _xdrSendPost(payload: IPayloadData, oncomplete: OnCompleteCallback, sync?: boolean) {
                // It doesn't support custom headers, so no action is taken with current requestHeaders
                let xdr = new XDomainRequest();
                xdr.open(STR_POST_METHOD, payload.urlString);
                if (payload.timeout) {
                    xdr.timeout = payload.timeout;
                }

                // can't get the status code in xdr.
                xdr.onload = () => {
                    // we will assume onload means the request succeeded.
                    let response = _getResponseText(xdr);
                    _doOnComplete(oncomplete, 200, {}, response);
                    _handleCollectorResponse(response);
                };

                // we will assume onerror means we need to drop the events.
                xdr.onerror = () => {
                    _doOnComplete(oncomplete, 400, {});
                };
                // we will assume ontimeout means we need to retry the events.
                xdr.ontimeout = () => {
                    _doOnComplete(oncomplete, 500, {});
                };

                // https://cypressnorth.com/web-programming-and-development/internet-explorer-aborting-ajax-requests-fixed/
                // tslint:disable-next-line:no-empty
                xdr.onprogress = () => { };

                if (sync) {
                    xdr.send(payload.data);
                } else {
                    timeoutOverride.set(() => {
                        xdr.send(payload.data);
                    }, 0);
                }
            }

            function _fetchSendPost(payload: IPayloadData, oncomplete: OnCompleteCallback, sync?: boolean) {
                let theUrl = payload.urlString;
                let ignoreResponse = false;
                let responseHandled = false;
                let requestInit: RequestInit = {
                    body: payload.data,
                    method: STR_POST_METHOD,
                    [STR_DISABLED_PROPERTY_NAME]: true
                };

                if (sync) {
                    requestInit.keepalive = true;
                    if ((payload as IInternalPayloadData)._sendReason === SendRequestReason.Unload) {
                        // As a sync request (during unload), it is unlikely that we will get a chance to process the response so
                        // just like beacon send assume that the events have been accepted and processed
                        ignoreResponse = true;
                        if (_addNoResponse) {
                            theUrl += _noResponseQs;
                        }
                    }
                }

                if (_sendCredentials) {
                    // Don't send credentials when URL is file://
                    requestInit.credentials = "include";
                }

                // Only add headers if there are headers to add, due to issue with some polyfills
                if (payload.headers && objKeys(payload.headers).length > 0) {
                    requestInit.headers = payload.headers;
                }

                fetch(theUrl, requestInit).then((response) => {
                    let headerMap = {};
                    let responseText = STR_EMPTY;
                    var headers = response.headers;
                    if (headers) {
                        headers["forEach"]((value: string, name: string) => {
                            headerMap[name] = value;
                        });
                    }
                    if (response.body) {
                        response.text().then(function(text) {
                            responseText = text;
                        });
                    }

                    if (!responseHandled) {
                        responseHandled = true;
                        _doOnComplete(oncomplete, response.status, headerMap, responseText);
                        _handleCollectorResponse(responseText);
                    }
                }).catch((error) => {
                    // In case there is an error in the request. Set the status to 0
                    // so that the events can be retried later.
                    if (!responseHandled) {
                        responseHandled = true;
                        _doOnComplete(oncomplete, 0, {});
                    }
                });

                if (ignoreResponse && !responseHandled) {
                    // Assume success during unload processing
                    responseHandled = true;
                    _doOnComplete(oncomplete, 200, {});
                }

                if (!responseHandled && payload.timeout > 0) {
                    // Simulate timeout
                    timeoutOverride.set(() => {
                        if (!responseHandled) {
                            // Assume a 500 response (which will cause a retry)
                            responseHandled = true;
                            _doOnComplete(oncomplete, 500, {});
                        }
                    }, payload.timeout);                    
                }
            }

            function _xhrSendPost(payload: IPayloadData, oncomplete: OnCompleteCallback, sync?: boolean) {
                let theUrl = payload.urlString;

                function _appendHeader(theHeaders, xhr, name) {
                    if (!theHeaders[name] && xhr && xhr.getResponseHeader) {
                        let value = xhr.getResponseHeader(name);
                        if (value) {
                            theHeaders[name] = strTrim(value);
                        }
                    }

                    return theHeaders;
                }

                function _getAllResponseHeaders(xhr) {
                    let theHeaders = {};

                    if (!xhr.getAllResponseHeaders) {
                        // Firefox 2-63 doesn't have getAllResponseHeaders function but it does have getResponseHeader
                        // Only call these if getAllResponseHeaders doesn't exist, otherwise we can get invalid response errors
                        // as collector is not currently returning the correct header to allow JS to access these headers
                        theHeaders = _appendHeader(theHeaders, xhr, STR_TIME_DELTA_HEADER);
                        theHeaders = _appendHeader(theHeaders, xhr, STR_KILL_DURATION_HEADER);
                        theHeaders = _appendHeader(theHeaders, xhr, STR_KILL_DURATION_SECONDS_HEADER);
                    } else {
                        theHeaders = _convertAllHeadersToMap(xhr.getAllResponseHeaders());
                    }

                    return theHeaders;
                }

                function xhrComplete(xhr, responseTxt?) {
                    _doOnComplete(oncomplete, xhr.status, _getAllResponseHeaders(xhr), responseTxt);
                }
                if (sync && payload.disableXhrSync) {
                    sync = false;
                }

                let xhrRequest = openXhr(STR_POST_METHOD, theUrl, _sendCredentials, true, sync, payload.timeout);

                // Set custom headers (e.g. gzip) here (after open())
                objForEachKey(payload.headers, (name, value) => {
                    xhrRequest.setRequestHeader(name, value);
                });
                xhrRequest.onload = () => {
                    let response = _getResponseText(xhrRequest);
                    xhrComplete(xhrRequest, response);
                    _handleCollectorResponse(response);
                };
                xhrRequest.onerror = () => {
                    xhrComplete(xhrRequest);
                };
                xhrRequest.ontimeout = () => {
                    xhrComplete(xhrRequest);
                };
                xhrRequest.send(payload.data);
            }

            function _doOnComplete(oncomplete: OnCompleteCallback, status: number, headers: { [headerName: string]: string }, response?: string) {
                try {
                    oncomplete(status, headers, response);
                } catch (e) {
                    _throwInternal(_logger,
                        eLoggingSeverity.WARNING,
                        _eExtendedInternalMessageId.SendPostOnCompleteFailure, dumpObj(e));
                }
            }

            function _beaconSendPost(payload: IPayloadData, oncomplete: OnCompleteCallback, sync?: boolean) {
                // Custom headers not supported in sendBeacon payload.headers would be ignored
                let internalPayloadData = payload as IInternalPayloadData;
                let status = 200;
                let thePayload = internalPayloadData._thePayload;
                let theUrl = payload.urlString + (_addNoResponse ? _noResponseQs : STR_EMPTY);

                try {
                    let nav = getNavigator();
                    if (!nav.sendBeacon(theUrl, payload.data)) {
                        if (thePayload) {
                            // Failed to send entire payload so try and split data and try to send as much events as possible
                            let droppedBatches: EventBatch[] = [];
                            arrForEach(thePayload.batches, (theBatch) => {
                                if (droppedBatches && theBatch && theBatch.count() > 0) {
                                    let theEvents = theBatch.events();
                                    for (let lp = 0; lp < theEvents.length; lp++) {
                                        if (!nav.sendBeacon(theUrl, _serializer.getEventBlob(theEvents[lp]))) {
                                            // Can't send anymore, so split the batch and drop the rest
                                            droppedBatches.push(theBatch.split(lp));
                                            break;
                                        }
                                    }
                                } else {
                                    // Remove all of the events from the existing batch in the payload as the copy includes the original
                                    droppedBatches.push(theBatch.split(0));
                                }
                            });

                            _sendBatchesNotification(droppedBatches, EventBatchNotificationReason.SizeLimitExceeded, thePayload.sendType, true);
                        } else {
                            status = 0;
                        }
                    }

                } catch (ex) {
                    _warnToConsole(_logger, "Failed to send telemetry using sendBeacon API. Ex:" + dumpObj(ex));
                    status = 0;
                } finally {
                    _doOnComplete(oncomplete, status, {}, STR_EMPTY);
                }
            }

            function _isBeaconPayload(sendType: EventSendType) {
                // Sync Fetch has the same payload limitation as sendBeacon -- 64kb limit, so treat both as a beacon send
                return sendType === EventSendType.SendBeacon || sendType === EventSendType.SyncFetch;
            }

            function _adjustSendType(sendType: EventSendType) {
                if (_isUnloading && _isBeaconPayload(sendType)) {
                    sendType = EventSendType.SendBeacon;
                }

                return sendType;
            }

            _self.addQueryStringParameter = (name: string, value: string) => {
                for (let i = 0; i < _queryStringParameters.length; i++) {
                    if (_queryStringParameters[i].name === name) {
                        _queryStringParameters[i].value = value;
                        return;
                    }
                }
                _queryStringParameters.push({ name: name, value: value });
            };

            _self.addHeader = (name: string, value: string) => {
                _headers[name] = value;
            };

            _self.canSendRequest = () => {
                return _hasIdleConnection() && _clockSkewManager.allowRequestSending();
            };

            _self.sendQueuedRequests = (sendType?: EventSendType, sendReason?: SendRequestReason) => {
                if (isUndefined(sendType)) {
                    sendType = EventSendType.Batched;
                }

                if (_isUnloading) {
                    sendType = _adjustSendType(sendType);
                    sendReason = SendRequestReason.Unload;
                }

                if (_canSendPayload(_batchQueue, sendType, 0)) {
                    _sendBatches(_clearQueue(), 0, false, sendType, sendReason || SendRequestReason.Undefined);
                }
            };

            _self.isCompletelyIdle = (): boolean => {
                return !_paused && _outstandingRequests === 0 && _batchQueue.length === 0;
            };

            _self.setUnloading = (value: boolean): void => {
                _isUnloading = value;
            };

            _self.addBatch = (theBatch: EventBatch) => {
                if (theBatch && theBatch.count() > 0) {
                    // Try and kill the event faster
                    if (_killSwitch.isTenantKilled(theBatch.iKey())) {
                        return false;
                    }

                    _batchQueue.push(theBatch);
                }

                return true;
            };

            /**
             * Queue all the remaining requests to be sent. The requests will be
             * sent using HTML5 Beacons if they are available.
             */
            _self.teardown = () => {
                if (_batchQueue.length > 0) {
                    _sendBatches(_clearQueue(), 0, true, EventSendType.SendBeacon, SendRequestReason.Unload);
                }
            };

            /**
             * Pause the sending of requests. No new requests will be sent.
             */
            _self.pause = () => {
                _paused = true;
            };

            /**
             * Resume the sending of requests.
             */
            _self.resume = () => {
                _paused = false;
                _self.sendQueuedRequests(EventSendType.Batched, SendRequestReason.Resumed);
            };

            /**
             * Sends a request synchronously to the Aria collector. This api is used to send
             * a request containing a single immediate event.
             *
             * @param batch - The request to be sent.
             * @param sendReason   - The token used to send the request.
             */
            _self.sendSynchronousBatch = (batch: EventBatch, sendType?: EventSendType, sendReason?: SendRequestReason) => {
                // This will not take into account the max connections restriction. Since this is sync, we can
                // only send one of this request at a time and thus should not worry about multiple connections
                // being used to send synchronous events.
                // Increment active connection since we are still going to use a connection to send the request.
                if (batch && batch.count() > 0) {
                    if (isNullOrUndefined(sendType)) {
                        sendType = EventSendType.Synchronous;
                    }

                    if (_isUnloading) {
                        sendType = _adjustSendType(sendType);
                        sendReason = SendRequestReason.Unload;
                    }

                    // For sync requests we will not wait for the clock skew.
                    _sendBatches([batch], 0, false, sendType, sendReason || SendRequestReason.Undefined);
                }
            };

            function _hasIdleConnection(): boolean {
                return !_paused && _outstandingRequests < maxConnections;
            }

            function _clearQueue() {
                let theQueue = _batchQueue;
                _batchQueue = [];
                return theQueue;
            }

            function _canSendPayload(theBatches: EventBatch[], sendType: EventSendType, retryCnt: number) {
                let result = false;
                if (theBatches && theBatches.length > 0 && !_paused && _sendInterfaces[sendType] && _serializer) {
                    // Always attempt to send synchronous events don't wait for idle or clockSkew
                    // and don't block retry requests if clockSkew is not yet set
                    result = (sendType !== EventSendType.Batched) || (_hasIdleConnection() && (retryCnt > 0 || _clockSkewManager.allowRequestSending()));
                }

                return result;
            }

            function _createDebugBatches(theBatches: EventBatch[]) {
                let values = {};

                if (theBatches) {
                    arrForEach(theBatches, (theBatch, idx) => {
                        values[idx] = {
                            iKey: theBatch.iKey(),
                            evts: theBatch.events()
                        };
                    });
                }

                return values;
            }

            function _sendBatches(theBatches: EventBatch[], retryCount: number, isTeardown: boolean, sendType: EventSendType, sendReason: SendRequestReason) {
                if (!theBatches || theBatches.length === 0) {
                    // Nothing to do
                    return;
                }

                if (_paused) {
                    _sendBatchesNotification(theBatches, EventBatchNotificationReason.Paused, sendType);
                    return;
                }

                // Make sure that if we are unloading the sendType is a supported version
                sendType = _adjustSendType(sendType);

                try {
                    let orgBatches = theBatches;
                    let isSynchronous = sendType !== EventSendType.Batched;
                    doPerf(_core, () => "HttpManager:_sendBatches", (perfEvt?: IPerfEvent) => {
                        if (perfEvt) {
                            // Perf Monitoring is enabled, so create a "Quick" copy of the original batches so we still report
                            // the original values as part of the perfEvent. This is because theBatches uses .shift() to remove each
                            // batch as they are processed - removing from the original array, so by the time the _createDebugBatches()
                            // function is called the passed in value has changed and therefore the reported value for the perfEvent is incorrect
                            theBatches = theBatches.slice(0);
                        }

                        let droppedBatches: EventBatch[] = [];
                        let thePayload: ISerializedPayload = null;
                        let serializationStart = getTime();
                        let sendInterface = _sendInterfaces[sendType] || (isSynchronous ? _sendInterfaces[EventSendType.Synchronous] : _sendInterfaces[EventSendType.Batched]);
                        let sendTransport = sendInterface && sendInterface._transport;

                        // Sync Fetch has the same payload limitation as sendBeacon -- 64kb limit
                        let isReducedPayload = _canHaveReducedPayload && (_isUnloading || _isBeaconPayload(sendType) || (sendTransport === TransportType.Beacon || (sendInterface._isSync && sendTransport === TransportType.Fetch)));

                        while (_canSendPayload(theBatches, sendType, retryCount)) {
                            let theBatch = theBatches.shift();
                            if (theBatch && theBatch.count() > 0) {
                                if (!_killSwitch.isTenantKilled(theBatch.iKey())) {

                                    // Make sure we have a payload object
                                    thePayload = thePayload || _serializer.createPayload(retryCount, isTeardown, isSynchronous, isReducedPayload, sendReason, sendType);

                                    // Add the batch to the current payload
                                    if (!_serializer.appendPayload(thePayload, theBatch, maxEventsPerBatch)) {
                                        // Entire batch was not added so send the payload and retry adding this batch
                                        _doPayloadSend(thePayload, serializationStart, getTime(), sendReason);
                                        serializationStart = getTime();
                                        theBatches = [theBatch].concat(theBatches);
                                        thePayload = null;
                                    } else if (thePayload.overflow !== null) {
                                        // Total Payload size was exceeded so send the payload and add the unsent as the next batch to send
                                        theBatches = [thePayload.overflow].concat(theBatches);
                                        thePayload.overflow = null;
                                        _doPayloadSend(thePayload, serializationStart, getTime(), sendReason);
                                        serializationStart = getTime();
                                        thePayload = null;
                                    }
                                } else {
                                    droppedBatches.push(theBatch);
                                }
                            }
                        }

                        // Make sure to flush any remaining payload
                        if (thePayload) {
                            _doPayloadSend(thePayload, serializationStart, getTime(), sendReason);
                        }

                        if (theBatches.length > 0) {
                            // Add any unsent batches back to the head of the queue
                            _batchQueue = theBatches.concat(_batchQueue);
                        }

                        // Now send notification about any dropped events
                        _sendBatchesNotification(droppedBatches, EventBatchNotificationReason.KillSwitch, sendType);
                    }, () => ({ batches: _createDebugBatches(orgBatches), retryCount, isTeardown, isSynchronous, sendReason, useSendBeacon: _isBeaconPayload(sendType), sendType }), !isSynchronous);
                } catch (ex) {
                    _throwInternal(_logger,
                        eLoggingSeverity.WARNING,
                        _eInternalMessageId.CannotSerializeObject, "Unexpected Exception sending batch: " + dumpObj(ex));
                }
            }

            function _buildRequestDetails(thePayload: ISerializedPayload, useHeaders: boolean): IRequestUrlDetails {
                let requestDetails: IRequestUrlDetails = {
                    url: _urlString,
                    hdrs: {},
                    useHdrs: false          // Assume no headers
                };

                if (!useHeaders) {
                    // Attempt to map headers to a query string if possible
                    objForEachKey(_headers, (name, value) => {
                        if (_collectorHeaderToQs[name]) {
                            _addRequestDetails(requestDetails, _collectorHeaderToQs[name], value, false);
                        } else {
                            // No mapping, so just include in the headers anyway (may not get sent if using sendBeacon())
                            requestDetails.hdrs[name] = value;
                            requestDetails.useHdrs = true;
                        }
                    });
                } else {
                    // Copy the pre-defined headers into the payload headers
                    requestDetails.hdrs = extend(requestDetails.hdrs, _headers);
                    requestDetails.useHdrs = (objKeys(requestDetails.hdrs).length > 0);
                }

                _addRequestDetails(requestDetails, STR_CLIENT_ID, "NO_AUTH", useHeaders);
                _addRequestDetails(requestDetails, STR_CLIENT_VERSION, FullVersionString, useHeaders);

                let apiQsKeys = STR_EMPTY;
                arrForEach(thePayload.apiKeys, (apiKey) => {
                    if (apiQsKeys.length > 0) {
                        apiQsKeys += ",";
                    }

                    apiQsKeys += apiKey;
                });

                _addRequestDetails(requestDetails, STR_API_KEY, apiQsKeys, useHeaders);
                _addRequestDetails(requestDetails, STR_UPLOAD_TIME, dateNow().toString(), useHeaders);

                let msfpc = _getMsfpc(thePayload);
                if (isValueAssigned(msfpc)) {
                    requestDetails.url += "&ext.intweb.msfpc=" + msfpc;
                }

                if (_clockSkewManager.shouldAddClockSkewHeaders()) {
                    _addRequestDetails(requestDetails, STR_TIME_DELTA_TO_APPLY, _clockSkewManager.getClockSkewHeaderValue(), useHeaders);
                }

                if (_core.getWParam) {
                    let wParam = _core.getWParam();
                    if (wParam >= 0) {
                        requestDetails.url += "&w=" + wParam;
                    }
                }

                for (let i = 0; i < _queryStringParameters.length; i++) {
                    requestDetails.url += "&" + _queryStringParameters[i].name + "=" + _queryStringParameters[i].value;
                }

                return requestDetails;
            }

            function _setTimingValue(timings: any, name: string, value: number) {
                timings[name] = timings[name] || {};
                timings[name][_postManager.identifier] = value;
            }

            function _doPayloadSend(thePayload: ISerializedPayload, serializationStart: number, serializationCompleted: number, sendReason: SendRequestReason) {

                if (thePayload && thePayload.payloadBlob && thePayload.payloadBlob.length > 0) {
                    let useSendHook = !!_self.sendHook;
                    let sendInterface = _sendInterfaces[thePayload.sendType];

                    // Send all data using a beacon style transport if closing mode is on or channel was teared down
                    if (!_isBeaconPayload(thePayload.sendType) && thePayload.isBeacon && thePayload.sendReason === SendRequestReason.Unload) {
                        sendInterface = _sendInterfaces[EventSendType.SendBeacon] || _sendInterfaces[EventSendType.SyncFetch] || sendInterface;
                    }

                    let useHeaders = _useHeaders;

                    // Disable header usage if we know we are using sendBeacon as additional headers are not supported
                    if (thePayload.isBeacon || sendInterface._transport === TransportType.Beacon) {
                        useHeaders = false;
                    }

                    let requestDetails = _buildRequestDetails(thePayload, useHeaders);
                    useHeaders = useHeaders || requestDetails.useHdrs;

                    let sendEventStart = getTime();

                    doPerf(_core, () => "HttpManager:_doPayloadSend", () => {
                        // Increment the send attempt count and add timings after packaging (So it's not serialized in the 1st attempt)
                        for (let batchLp = 0; batchLp < thePayload.batches.length; batchLp++) {
                            let theBatch = thePayload.batches[batchLp];
                            let theEvents: IPostTransmissionTelemetryItem[] = theBatch.events();
                            for (let evtLp = 0; evtLp < theEvents.length; evtLp++) {
                                let telemetryItem: IPostTransmissionTelemetryItem = theEvents[evtLp];
                                if (_enableEventTimings) {
                                    let timings = telemetryItem.timings = telemetryItem.timings || {};
                                    _setTimingValue(timings, "sendEventStart", sendEventStart);
                                    _setTimingValue(timings, "serializationStart", serializationStart);
                                    _setTimingValue(timings, "serializationCompleted", serializationCompleted);
                                }

                                telemetryItem[strSendAttempt] > 0 ? telemetryItem[strSendAttempt]++ : telemetryItem[strSendAttempt] = 1;
                            }
                        }

                        // Note: always sending this notification in a synchronous manner.
                        _sendBatchesNotification(
                            thePayload.batches,
                            (EventBatchNotificationReason.SendingUndefined + (sendReason || SendRequestReason.Undefined)),
                            thePayload.sendType,
                            true);

                        // Disabling the use of const because of Issue: 
                        // - Task 9227844: [1DS] Some environments and packagers automatically "freeze" objects which are defined as const which causes any mutations to throw
                        // eslint-disable-next-line prefer-const
                        let orgPayloadData: IInternalPayloadData = {
                            data: thePayload.payloadBlob,
                            urlString: requestDetails.url,
                            headers: requestDetails.hdrs,
                            _thePayload: thePayload,
                            _sendReason: sendReason,
                            timeout: _xhrTimeout,
                            disableXhrSync: _disableXhrSync,
                            disableFetchKeepAlive: _disableFetchKeepAlive
                        };

                        // Only automatically add the following headers if already sending headers and we are not attempting to avoid an options call
                        if (useHeaders) {
                            if (!_hasHeader(orgPayloadData.headers, STR_CACHE_CONTROL)) {
                                orgPayloadData.headers[STR_CACHE_CONTROL] = DEFAULT_CACHE_CONTROL;
                            }
    
                            if (!_hasHeader(orgPayloadData.headers, STR_CONTENT_TYPE_HEADER)) {
                                orgPayloadData.headers[STR_CONTENT_TYPE_HEADER] = DEFAULT_CONTENT_TYPE;
                            }
                        }

                        let sender: (payload: IPayloadData) => void = null;

                        if (sendInterface) {
                            // Send sync requests if the request is immediate or we are tearing down telemetry.
                            sender = (payload: IPayloadData) => {
                                // Notify the clock skew manager that we are sending the first request (Potentially blocking all further requests)
                                _clockSkewManager.firstRequestSent();

                                let onComplete = (status, headers) => {
                                    _retryRequestIfNeeded(status, headers, thePayload, sendReason);
                                };

                                let isSync = thePayload.isTeardown || thePayload.isSync;
                                try {
                                    sendInterface.sendPOST(payload, onComplete, isSync);
                                    if (_self.sendListener) {
                                        // Send the original payload to the listener
                                        _self.sendListener(orgPayloadData, payload, isSync, thePayload.isBeacon);
                                    }
                                } catch (ex) {
                                    _warnToConsole(_logger, "Unexpected exception sending payload. Ex:" + dumpObj(ex));

                                    _doOnComplete(onComplete, 0, {});
                                }
                            };
                        }

                        doPerf(_core, () => "HttpManager:_doPayloadSend.sender", () => {
                            if (sender) {
                                if (thePayload.sendType === EventSendType.Batched) {
                                    _outstandingRequests ++;
                                }

                                // Only call the hook if it's defined and we are not using sendBeacon as additional headers are not supported
                                if (useSendHook && !thePayload.isBeacon && sendInterface._transport !== TransportType.Beacon) {
                                    // Create a new IPayloadData that is sent into the hook method, so that the hook method
                                    // can't change the object references to the orgPayloadData (it can still change the content -- mainly the headers)

                                    // Disabling the use of const because of Issue: 
                                    // - Task 9227844: [1DS] Some environments and packagers automatically "freeze" objects which are defined as const which causes any mutations to throw
                                    // eslint-disable-next-line prefer-const
                                    let hookData: IPayloadData = {
                                        data: orgPayloadData.data,
                                        urlString: orgPayloadData.urlString,
                                        headers: extend({}, orgPayloadData.headers),
                                        timeout: orgPayloadData.timeout,
                                        disableXhrSync: orgPayloadData.disableXhrSync,
                                        disableFetchKeepAlive: orgPayloadData.disableFetchKeepAlive
                                    };

                                    let senderCalled = false;
                                    doPerf(_core, () => "HttpManager:_doPayloadSend.sendHook", () => {
                                        try {
                                            _self.sendHook(
                                                hookData,
                                                (payload: IInternalPayloadData) => {
                                                    senderCalled = true;
                                                    // Add back the internal properties
                                                    if (!_customHttpInterface && !payload._thePayload) {
                                                        payload._thePayload = payload._thePayload || orgPayloadData._thePayload;
                                                        payload._sendReason = payload._sendReason || orgPayloadData._sendReason;
                                                    }

                                                    sender(payload);
                                                },
                                                thePayload.isSync || thePayload.isTeardown);
                                        } catch (ex) {
                                            if (!senderCalled) {
                                                // The hook never called the sender -- assume that it never will
                                                sender(orgPayloadData);
                                            }
                                        }
                                    });
                                } else {
                                    sender(orgPayloadData);
                                }
                            }
                        });

                    }, () => ({ thePayload, serializationStart, serializationCompleted, sendReason }), thePayload.isSync);
                }

                if (thePayload.sizeExceed && thePayload.sizeExceed.length > 0) {
                    // Ensure that we send any discard events for oversize events even when there was no payload to send
                    _sendBatchesNotification(thePayload.sizeExceed, EventBatchNotificationReason.SizeLimitExceeded, thePayload.sendType);
                }

                if (thePayload.failedEvts && thePayload.failedEvts.length > 0) {
                    // Ensure that we send any discard events for events that could not be serialized even when there was no payload to send
                    _sendBatchesNotification(thePayload.failedEvts, EventBatchNotificationReason.InvalidEvent, thePayload.sendType);
                }
            }

            function _addEventCompletedTimings(theEvents: IPostTransmissionTelemetryItem[], sendEventCompleted: number) {
                if (_enableEventTimings) {
                    arrForEach(theEvents, (theEvent) => {
                        let timings = theEvent.timings = theEvent.timings || {};
                        _setTimingValue(timings, "sendEventCompleted", sendEventCompleted);
                    });
                }
            }

            function _retryRequestIfNeeded(status: number, headers: { [headerName: string]: string }, thePayload: ISerializedPayload, sendReason: SendRequestReason) {
                let reason: EventBatchNotificationReason = EventBatchNotificationReason.ResponseFailure;
                let droppedBatches: EventBatch[] = null;
                let isRetrying = false;
                let backOffTrans = false;

                try {
                    let shouldRetry = true;

                    if (typeof status !== strUndefined) {
                        if (headers) {
                            _clockSkewManager.setClockSkew(headers[STR_TIME_DELTA_HEADER]);
                            let killDuration = headers[STR_KILL_DURATION_HEADER] || headers["kill-duration-seconds"];
                            arrForEach(_killSwitch.setKillSwitchTenants(headers[STR_KILL_TOKENS_HEADER], killDuration), (killToken) => {
                                arrForEach(thePayload.batches, (theBatch) => {
                                    if (theBatch.iKey() === killToken) {
                                        // Make sure we have initialized the array
                                        droppedBatches = droppedBatches || [];

                                        // Create a copy of the batch with all of the events (and more importantly the action functions)
                                        let removedEvents = theBatch.split(0);
                                        // And then remove the events for the payload batch and reduce the actual number of processed
                                        thePayload.numEvents -= removedEvents.count();
                                        droppedBatches.push(removedEvents);
                                    }
                                });
                            });
                        }

                        // Disabling triple-equals rule to avoid httpOverrides from failing because they are returning a string value
                        // tslint:disable-next-line:triple-equals
                        if (status == 200 || status == 204) {
                            // Response was successfully sent
                            reason = EventBatchNotificationReason.Complete;
                            return;
                        }

                        if (!retryPolicyShouldRetryForStatus(status) || thePayload.numEvents <= 0) {
                            // Only retry for specific response codes and if there is still events after kill switch processing
                            shouldRetry = false;
                        }

                        // Derive the notification response from the HttpStatus Code
                        reason = EventBatchNotificationReason.ResponseFailure + (status % 1000);
                    }

                    if (shouldRetry) {
                        // The events should be retried -- so change notification to requeue them
                        reason = EventBatchNotificationReason.RequeueEvents;
                        let retryCount = thePayload.retryCnt;
                        if (thePayload.sendType === EventSendType.Batched) {
                            // attempt to resend the entire batch
                            if (retryCount < maxRequestRetriesBeforeBackoff) {
                                isRetrying = true;
                                _doAction(() => {
                                    // try to resend the same batches
                                    if (thePayload.sendType === EventSendType.Batched) {
                                        // Reduce the outstanding request count (if this was an async request) as we didn't reduce the count
                                        // previously and we are about to reschedule our retry attempt and we want an attempt to send
                                        // to occur, it's also required to ensure that a follow up handleRequestFinished() call occurs
                                        _outstandingRequests--;
                                    }

                                    _sendBatches(thePayload.batches, retryCount + 1, thePayload.isTeardown, _isUnloading ? EventSendType.SendBeacon : thePayload.sendType, SendRequestReason.Retry);
                                }, _isUnloading, retryPolicyGetMillisToBackoffForRetry(retryCount));
                            } else {
                                backOffTrans = true;
                                if (_isUnloading) {
                                    // we are unloading so don't try and requeue the events otherwise let the events get requeued and resent during the backoff sending
                                    // This will also cause the events to be purged based on the priority (if necessary)
                                    reason = EventBatchNotificationReason.NonRetryableStatus;
                                }
                            }
                        }
                    }

                } finally {
                    if (!isRetrying) {
                        // Make sure the clockSkewManager doesn't blocking further sending of requests once we have a proper response
                        // This won't override any previously sent clock Skew value
                        _clockSkewManager.setClockSkew();

                        _handleRequestFinished(thePayload, reason, sendReason, backOffTrans);
                    }

                    _sendBatchesNotification(droppedBatches, EventBatchNotificationReason.KillSwitch, thePayload.sendType);
                }
            }

            function _handleRequestFinished(
                    thePayload: ISerializedPayload,
                    batchReason: EventBatchNotificationReason,
                    sendReason: SendRequestReason,
                    backOffTrans: boolean) {

                try {
                    if (backOffTrans) {
                        // Slow down the transmission requests
                        _postManager._backOffTransmission();
                    }

                    if (batchReason === EventBatchNotificationReason.Complete) {
                        if (!backOffTrans && !thePayload.isSync) {
                            // We have a successful async response, so the lets open the floodgates
                            // The reason for checking isSync is to avoid unblocking if beacon send occurred as it
                            // doesn't wait for a response.
                            _postManager._clearBackOff();
                        }

                        _addCompleteTimings(thePayload.batches);
                    }

                    // Send the notifications synchronously
                    _sendBatchesNotification(thePayload.batches, batchReason, thePayload.sendType, true);

                } finally {
                    if (thePayload.sendType === EventSendType.Batched) {
                        // we always need to decrement this value otherwise the httpmanager locks up and won't send any more events
                        _outstandingRequests--;

                        // Don't try to send additional queued events if this is a retry operation as the retried
                        // response will eventually call _handleRequestFinished for the retried event
                        if (sendReason !== SendRequestReason.Retry) {
                            // Try and send any other queued batched events
                            _self.sendQueuedRequests(thePayload.sendType, sendReason);
                        }
                    }
                }
            }

            function _addCompleteTimings(theBatches: EventBatch[]) {
                if (_enableEventTimings) {
                    let sendEventCompleted = getTime();
                    arrForEach(theBatches, (theBatch) => {
                        if (theBatch && theBatch.count() > 0) {
                            _addEventCompletedTimings(theBatch.events(), sendEventCompleted);
                        }
                    });
                }
            }

            function _doAction(cb: VoidFunction, isSync: boolean, interval: number) {
                if (isSync) {
                    cb();
                } else {
                    timeoutOverride.set(cb, interval);
                }
            }

            /**
            * Converts the XHR getAllResponseHeaders to a map containing the header key and value.
            */
           // tslint:disable-next-line: align
           function _convertAllHeadersToMap(headersString: string): { [headerName: string]: string } {
                let headers = {};
                if (isString(headersString)) {
                    let headersArray = strTrim(headersString).split(/[\r\n]+/);
                    arrForEach(headersArray, (headerEntry) => {
                        if (headerEntry) {
                            let idx = headerEntry.indexOf(": ");
                            if (idx !== -1) {
                                // The new spec has the headers returning all as lowercase -- but not all browsers do this yet
                                let header = strTrim(headerEntry.substring(0, idx)).toLowerCase();
                                let value = strTrim(headerEntry.substring(idx + 1));
                                headers[header] = value;
                            } else {
                                headers[strTrim(headerEntry)] = 1;
                            }
                        }
                    });
                }

                return headers;
            }

            function _getMsfpc(thePayload: ISerializedPayload): string {
                for (let lp = 0; lp < thePayload.batches.length; lp++) {
                    let msfpc = thePayload.batches[lp].Msfpc();
                    if (msfpc) {
                        return encodeURIComponent(msfpc);
                    }
                }

                return STR_EMPTY;
            }

            function _handleCollectorResponse(responseText: string): void {
                let responseHandlers = _self._responseHandlers;
                try {
                    for (let i = 0; i < responseHandlers.length; i++) {
                        try {
                            responseHandlers[i](responseText);
                        } catch (e) {
                            _throwInternal(_logger,
                                eLoggingSeverity.CRITICAL,
                                _eExtendedInternalMessageId.PostResponseHandler,
                                "Response handler failed: " + e);
                        }
                    }
                    if (responseText) {
                        let response = JSON.parse(responseText) as ICollectorResult;
                        if (isValueAssigned(response.webResult) && isValueAssigned(response.webResult[STR_MSFPC])) {
                            // Set cookie
                            _cookieMgr.set("MSFPC", response.webResult[STR_MSFPC], 365 * 86400);
                        }
                    }
                } catch (ex) {
                    // Doing nothing
                }
            }

            function _sendBatchesNotification(theBatches: EventBatch[], batchReason: EventBatchNotificationReason, sendType: EventSendType, sendSync?: boolean) {
                if (theBatches && theBatches.length > 0 && actions) {
                    let theAction: BatchNotificationAction = actions[_getNotificationAction(batchReason)];
                    if (theAction) {
                        let isSyncRequest = sendType !== EventSendType.Batched;

                        doPerf(_core, () => "HttpManager:_sendBatchesNotification", () => {
                            _doAction(() => {
                                try {
                                    theAction.call(actions, theBatches, batchReason, isSyncRequest, sendType);
                                } catch (e) {
                                    _throwInternal(_logger,
                                        eLoggingSeverity.CRITICAL,
                                        _eInternalMessageId.NotificationException,
                                        "send request notification failed: " + e);
                                }
                            }, sendSync || isSyncRequest, 0);
                        }, () => ({ batches: _createDebugBatches(theBatches), reason: batchReason, isSync: isSyncRequest, sendSync: sendSync, sendType: sendType }), !isSyncRequest);
                    }
                }
            }

            function _getNotificationAction(reason: EventBatchNotificationReason): string {
                let action = _eventActionMap[reason];
                if (!isValueAssigned(action)) {
                    action = STR_OTHER;
                    if (reason >= EventBatchNotificationReason.ResponseFailure && reason <= EventBatchNotificationReason.ResponseFailureMax) {
                        action = STR_RESPONSE_FAIL;
                    } else if (reason >= EventBatchNotificationReason.EventsDropped && reason <= EventBatchNotificationReason.EventsDroppedMax) {
                        action = STR_DROPPED;
                    } else if (reason >= EventBatchNotificationReason.SendingUndefined && reason <= EventBatchNotificationReason.SendingEventMax) {
                        action = STR_SENDING;
                    }
                }

                return action;
            }
        });
    }

    /**
     * @constructor
     * @param requestQueue   - The queue that contains the requests to be sent.
     * @param endpointUrl   - The collector url to which the requests must be sent.
     * @param postManager   - The post manager that we should add requests back to if needed.
     * @param httpInterface - The http interface that should be used to send HTTP requests.
     * @param channelConfig - The IChannelConfiguration the should be used to get additional configuration
     */
    public initialize(endpointUrl: string, core: IExtendedAppInsightsCore, postChannel: IPostChannel, httpInterface: IXHROverride, channelConfig?: IChannelConfiguration) {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }

    /**
     * Add query string parameter to url
     * @param name   - Query string name.
     * @param value  - Query string value.
     */
    public addQueryStringParameter(name: string, value: string) {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }

    /**
     * Add header to request
     * @param name   - Header name.
     * @param value  - Header value.
     */
    public addHeader(name: string, value: string) {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }

    /**
     * Add the batch of events to the queue for sending
     * @param batch The batch with the events to send
     * @returns True if the http manager has accepted the batch (including if the batch is empty) otherwise false
     */
    public addBatch(batch: EventBatch): boolean {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
        return false;
    }

    /**
     * Check if there is an idle connection and we can send a request.
     * @returns True if there is an idle connection, false otherwise.
     */
    public canSendRequest(): boolean {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
        return false;
    }

    /**
     * Send requests in the request queue up if there is an idle connection, sending is
     * not pause and clock skew manager allows sending request.
     * @param sendType - Identifies how the batched events should be send, defaults to Batched
     * @param sendReason   - The reason the batch is being sent
     */
    public sendQueuedRequests(sendType?: EventSendType, sendReason?: SendRequestReason) {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }

    /**
     * Check if there are no active requests being sent.
     * @returns True if idle, false otherwise.
     */
    public isCompletelyIdle(): boolean {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
        return false;
    }

    /**
     * Inform the HttpManager that a page unload event was received
     */
    public setUnloading(value: boolean): void {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }

    /**
     * Queue all the remaining requests to be sent. The requests will be
     * sent using HTML5 Beacons if they are available.
     */
    public teardown() {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }

    /**
     * Pause the sending of requests. No new requests will be sent.
     */
    public pause() {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }

    /**
     * Resume the sending of requests.
     */
    public resume() {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }

    /**
     * Sends the batches synchronously to the collector. This api is used to send a batches immediate event.
     *
     * @param batch - The batch of events to be sent.
     * @param sendReason   - The reason the batch is being sent
     * @param sendType - Identifies the sending type to use when sending the batch
     */
    public sendSynchronousBatch(batch: EventBatch, sendType?: EventSendType, sendReason?: SendRequestReason) {
        // @DynamicProtoStub - DO NOT add any code as this will be removed during packaging
    }
}