Method constructor

src/client.ts:233–333

* Initialize a client * @link https://getstream.io/activity-feeds/docs/node/#setup * @method initialize * @memberof StreamClient.prototype * @param {string} apiKey - the api key * @param {string} [apiSecret] - the api secret * @param {string} [appId] - id of the app * @param {Cl

(apiKey: string, apiSecretOrToken: string | null, appId?: string, options: ClientOptions = {})

   * stream.connect(apiKey, null, appId);
   */
  constructor(apiKey: string, apiSecretOrToken: string | null, appId?: string, options: ClientOptions = {}) {
    this.baseUrl = 'https://api.stream-io-api.com/api/';
    this.baseAnalyticsUrl = 'https://analytics.stream-io-api.com/analytics/';
    this.apiKey = apiKey;
    this.usingApiSecret = apiSecretOrToken != null && !apiSecretOrToken.includes(`.`);
    this.apiSecret = this.usingApiSecret ? apiSecretOrToken : null;
    this.userToken = this.usingApiSecret ? null : apiSecretOrToken;
    this.enrichByDefault = !this.usingApiSecret;

    if (this.userToken != null) {
      const jwtBody: { user_id?: string } = jwtDecode(this.userToken);
      if (!jwtBody.user_id) {
        throw new TypeError('user_id is missing in user token');
      }
      this.userId = jwtBody.user_id;
      this.currentUser = this.user(this.userId);
    }

    this.appId = appId;
    this.options = options;
    this.version = this.options.version || 'v1.0';
    this.fayeUrl = this.options.fayeUrl || 'https://faye-us-east.stream-io-api.com/faye';
    this.fayeClient = null;
    // track a source name for the api calls, ie get started or databrowser
    this.group = this.options.group || 'unspecified';
    // track subscriptions made on feeds created by this client
    this.subscriptions = {};
    this.expireTokens = this.options.expireTokens ? this.options.expireTokens : false;
    // which data center to use
    this.location = this.options.location as string;
    this.baseUrl = this.getBaseUrl();

    if (typeof process !== 'undefined') {
      if (process.env?.LOCAL_FAYE) {
        this.fayeUrl = 'http://localhost:9999/faye/';
      }
      if (process.env?.STREAM_ANALYTICS_BASE_URL) {
        this.baseAnalyticsUrl = process.env.STREAM_ANALYTICS_BASE_URL;
      }
    }

    this.handlers = {};
    this.node = typeof window === 'undefined'; // use for real browser vs node behavior
    // use for browser warnings
    this.browser = typeof this.options.browser !== 'undefined' ? this.options.browser : !this.node;

    if (this.node) {
      const keepAlive = this.options.keepAlive === undefined ? true : this.options.keepAlive;
      const keepAliveMsecs = this.options.keepAliveMsecs ?? 3000;
      const agentOptions: http.AgentOptions = {
        keepAlive,
        keepAliveMsecs,
      };
      if (this.options.maxSockets !== undefined) {
        agentOptions.maxSockets = this.options.maxSockets;
      }
      if (this.options.maxFreeSockets !== undefined) {
        agentOptions.maxFreeSockets = this.options.maxFreeSockets;