123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305
import { Visitor } from '../visitor/Visitor.ts'import { FlagshipStatus } from '../enum/FlagshipStatus.ts'import { DecisionMode, FlagshipConfig, IFlagshipConfig } from '../config/FlagshipConfig.ts'import { DecisionApiConfig } from '../config/DecisionApiConfig.ts'import { ConfigManager, IConfigManager } from '../config/ConfigManager.ts'import { ApiManager } from '../decision/ApiManager.ts'import { TrackingManager } from '../api/TrackingManager.ts'import { FlagshipLogManager } from '../utils/FlagshipLogManager.ts'import { isBrowser, logError, logInfo, sprintf } from '../utils/utils.ts'import {  INITIALIZATION_PARAM_ERROR,  PROCESS_INITIALIZATION,  SDK_STARTED_INFO,  SDK_VERSION} from '../enum/index.ts'import { VisitorDelegate } from '../visitor/VisitorDelegate.ts'import { BucketingConfig } from '../config/index.ts'import { BucketingManager } from '../decision/BucketingManager.ts'import { MurmurHash } from '../utils/MurmurHash.ts'import { DecisionManager } from '../decision/DecisionManager.ts'import { HttpClient } from '../utils/HttpClient.ts'import { FlagDTO, NewVisitor, primitive } from '../types.ts'import { CampaignDTO } from '../decision/api/models.ts'import { DefaultHitCache } from '../cache/DefaultHitCache.ts'import { DefaultVisitorCache } from '../cache/DefaultVisitorCache.ts'
export class Flagship {  // eslint-disable-next-line no-use-before-define  private static _instance: Flagship  private _configManger!: IConfigManager  private _config!: IFlagshipConfig  private _status!: FlagshipStatus  private _visitorInstance?: Visitor
  private set configManager (value: IConfigManager) {    this._configManger = value  }
  private get configManager (): IConfigManager {    return this._configManger  }
  // eslint-disable-next-line no-useless-constructor  private constructor () {    // singleton  }
  protected static getInstance (): Flagship {    if (!this._instance) {      this._instance = new this()    }    return this._instance  }
  /**   * Return true if the SDK is properly initialized, otherwise return false   */  private static isReady (): boolean {    const apiKey = this._instance?.getConfig()?.apiKey    const envId = this._instance?.getConfig()?.envId    const configManager = this._instance?.configManager    return (!!this._instance && !!apiKey && !!envId && !!configManager)  }
  protected setStatus (status: FlagshipStatus): void {    const statusChanged = this.getConfig().statusChangedCallback
    if (this.getConfig() && statusChanged && this._status !== status) {      this._status = status      statusChanged(status)      return    }    this._status = status  }
  /**   * Return current status of Flagship SDK.   */  public static getStatus (): FlagshipStatus {    return this.getInstance()._status  }
  /**   * Return current status of Flagship SDK.   */  public getStatus (): FlagshipStatus {    return this._status  }
  /**   * Return the current config set by the customer and used by the SDK.   */  public static getConfig (): IFlagshipConfig {    return this.getInstance()._config  }
  /**   * Return the current config set by the customer and used by the SDK.   */  public getConfig (): IFlagshipConfig {    return this._config  }
  /**   * Return the last visitor created if isNewInstance key is false. Return undefined otherwise.   */  public getVisitor (): Visitor | undefined {    return this._visitorInstance  }
  /**   * Return the last visitor created if isNewInstance key is false. Return undefined otherwise.   */  public static getVisitor (): Visitor | undefined {    return this.getInstance().getVisitor()  }
  private buildConfig (config?: IFlagshipConfig | FlagshipConfig): FlagshipConfig {    if (config instanceof FlagshipConfig) {      return config    }    let newConfig: FlagshipConfig    if (config?.decisionMode === DecisionMode.BUCKETING) {      newConfig = new BucketingConfig(config)    } else {      newConfig = new DecisionApiConfig(config)    }    return newConfig  }
  private buildDecisionManager (flagship: Flagship, config: FlagshipConfig, httpClient: HttpClient): DecisionManager {    let decisionManager: DecisionManager    const setStatus = (status: FlagshipStatus) => {      flagship.setStatus(status)    }    if (config.decisionMode === DecisionMode.BUCKETING) {      decisionManager = new BucketingManager(httpClient, config, new MurmurHash())      const bucketingManager = decisionManager as BucketingManager      decisionManager.statusChangedCallback(setStatus)      bucketingManager.startPolling()    } else {      decisionManager = new ApiManager(        httpClient,        config      )      decisionManager.statusChangedCallback(setStatus)    }    return decisionManager  }
  /**   * Start the flagship SDK, with a custom configuration implementation   * @param {string} envId : Environment id provided by Flagship.   * @param {string} apiKey : Secure api key provided by Flagship.   * @param {IFlagshipConfig} config : (optional) SDK configuration.   */  public static start (    envId: string,    apiKey: string,    config?: IFlagshipConfig | FlagshipConfig  ): Flagship | null {    const flagship = this.getInstance()
    config = flagship.buildConfig(config)
    config.envId = envId    config.apiKey = apiKey
    flagship._config = config
    flagship.setStatus(FlagshipStatus.STARTING)
    // check custom logger    if (!config.logManager) {      config.logManager = new FlagshipLogManager()    }
    let decisionManager = flagship.configManager?.decisionManager
    if (typeof decisionManager === 'object' && decisionManager instanceof BucketingManager) {      decisionManager.stopPolling()    }
    const httpClient = new HttpClient()
    decisionManager = flagship.buildDecisionManager(flagship, config as FlagshipConfig, httpClient)
    const trackingManager = new TrackingManager(httpClient, config)
    if (flagship.configManager) {      flagship.configManager.config = config      flagship.configManager.decisionManager = decisionManager      flagship.configManager.trackingManager = trackingManager    } else {      flagship.configManager = new ConfigManager(        config,        decisionManager,        trackingManager      )    }
    if (!envId || !apiKey) {      flagship.setStatus(FlagshipStatus.NOT_INITIALIZED)      logError(config, INITIALIZATION_PARAM_ERROR, PROCESS_INITIALIZATION)      return flagship    }
    // eslint-disable-next-line @typescript-eslint/no-explicit-any    if (!config.hitCacheImplementation && isBrowser()) {      config.hitCacheImplementation = new DefaultHitCache()    }
    // eslint-disable-next-line @typescript-eslint/no-explicit-any    if (!config.visitorCacheImplementation && isBrowser()) {      config.visitorCacheImplementation = new DefaultVisitorCache()    }
    if (!this.isReady()) {      flagship.setStatus(FlagshipStatus.NOT_INITIALIZED)      return flagship    }
    if (flagship._status === FlagshipStatus.STARTING) {      flagship.setStatus(FlagshipStatus.READY)    }    logInfo(      config,      sprintf(SDK_STARTED_INFO, SDK_VERSION),      PROCESS_INITIALIZATION    )    return flagship  }
  /**   * Create a new visitor with a context.   * @param {string} visitorId : Unique visitor identifier.   * @param {Record<string, primitive>} context : visitor context. e.g: { isVip: true, country: "UK" }.   * @returns {Visitor} a new visitor instance   */  public newVisitor(visitorId?: string | null, context?: Record<string, primitive>): Visitor | null  public newVisitor(params?: NewVisitor): Visitor | null  public newVisitor (param1?: NewVisitor | string | null, param2?: Record<string, primitive>): Visitor | null {    return Flagship.newVisitor(param1, param2)  }
  /**   * Create a new visitor with a context.   * @param {string} visitorId : Unique visitor identifier.   * @param {Record<string, primitive>} context : visitor context. e.g: { isVip: true, country: "UK" }.   * @returns {Visitor} a new visitor instance   */  public static newVisitor(visitorId?: string | null, context?: Record<string, primitive>): Visitor | null  /**   * Create a new visitor with a context.   * @param {string} visitorId : Unique visitor identifier.   * @param {Record<string, primitive>} context : visitor context. e.g: { isVip: true, country: "UK" }.   * @returns {Visitor} a new visitor instance   */  public static newVisitor(params?: NewVisitor): Visitor | null  public static newVisitor(param1?: NewVisitor | string | null, param2?: Record<string, primitive>): Visitor | null  public static newVisitor (param1?: NewVisitor | string | null, param2?: Record<string, primitive>): Visitor | null {    let visitorId: string | undefined    let context: Record<string, primitive>    let isAuthenticated = false    let hasConsented = true    let initialModifications: Map<string, FlagDTO> | FlagDTO[] | undefined    let initialCampaigns: CampaignDTO[] | undefined    const isServerSide = !isBrowser()    let isNewInstance = isServerSide
    if (typeof param1 === 'string' || param1 === null) {      visitorId = param1 || undefined      context = param2 || {}    } else {      visitorId = param1?.visitorId      context = param1?.context || {}      isAuthenticated = !!param1?.isAuthenticated      hasConsented = param1?.hasConsented ?? true      initialModifications = param1?.initialFlagsData || param1?.initialModifications      initialCampaigns = param1?.initialCampaigns      isNewInstance = param1?.isNewInstance ?? isNewInstance    }
    const visitorDelegate = new VisitorDelegate({      visitorId,      context,      isAuthenticated,      hasConsented,      configManager: this.getInstance().configManager,      initialModifications,      initialCampaigns,      initialFlagsData: initialModifications    })
    const visitor = new Visitor(visitorDelegate)
    this.getInstance()._visitorInstance = !isNewInstance ? visitor : undefined
    if (this.getConfig().fetchNow) {      visitor.fetchFlags()    }    return visitor  }}