Function loadSources

src/utils/entropy_source.ts:124–158

(
  sources: TSources,
  sourceOptions: TSourceOptions,
  excludeSources: readonly TExclude[],
  loopReleaseInterval?: number,
)

 * This function is out of Semantic Versioning, i.e. can change unexpectedly. Usage is at your own risk.
 */
export function loadSources<TSourceOptions, TSources extends UnknownSources<TSourceOptions>, TExclude extends string>(
  sources: TSources,
  sourceOptions: TSourceOptions,
  excludeSources: readonly TExclude[],
  loopReleaseInterval?: number,
): () => Promise<Omit<SourcesToComponents<TSources>, TExclude>> {
  const includedSources = Object.keys(sources).filter((sourceKey) => excludes(excludeSources, sourceKey)) as Exclude<
    keyof TSources,
    TExclude
  >[]
  // Using `mapWithBreaks` allows asynchronous sources to complete between synchronous sources
  // and measure the duration correctly
  const sourceGettersPromise = suppressUnhandledRejectionWarning(
    mapWithBreaks(includedSources, (sourceKey) => loadSource(sources[sourceKey], sourceOptions), loopReleaseInterval),
  )

  return async function getComponents() {
    const sourceGetters = await sourceGettersPromise

    const componentPromises = await mapWithBreaks(
      sourceGetters,
      (sourceGetter) => suppressUnhandledRejectionWarning(sourceGetter()),
      loopReleaseInterval,
    )

    const componentArray = await Promise.all(componentPromises)
    // Keeping the component keys order the same as the source keys order
    const components = {} as Omit<SourcesToComponents<TSources>, TExclude>
    for (let index = 0; index < includedSources.length; ++index) {
      components[includedSources[index]] = componentArray[index] as Component<any>
    }

    return components
  }
}

/**
 * Modifies an entropy source by transforming its returned value with the given function.