Function createConnections

packages/node-core/src/api.service.ts:88–137

(
    network: ProjectNetworkConfig<EndpointConfig> & {chainId: string},
    createConnection: (endpoint: string, config: EndpointConfig) => Promise<Connection>,
    /* Used to monitor the state of the connection */
    postConnectedHook?: (connection: Connection, endpoint: string, index: number) => void
  )

  }

  async createConnections(
    network: ProjectNetworkConfig<EndpointConfig> & {chainId: string},
    createConnection: (endpoint: string, config: EndpointConfig) => Promise<Connection>,
    /* Used to monitor the state of the connection */
    postConnectedHook?: (connection: Connection, endpoint: string, index: number) => void
  ): Promise<void> {
    const endpointToApiIndex: Record<string, Connection> = {};

    const failedConnections: Map<number, [string, EndpointConfig]> = new Map();

    const endpoints = normalizeNetworkEndpoints<EndpointConfig>(network.endpoint);

    const connectionPromises = Object.entries(endpoints).map(async ([endpoint, config], i) => {
      try {
        const connection = await this.performConnection(
          createConnection,
          network,
          i,
          endpoint,
          config,
          postConnectedHook
        );

        void this.connectionPoolService.addToConnections(connection, endpoint);
      } catch (e) {
        logger.error(`Failed to init ${endpoint}: ${e}`);
        endpointToApiIndex[endpoint] = null as unknown as Connection;

        // Don't reconnect if connection is for wrong network
        if (!(e instanceof MetadataMismatchError)) {
          failedConnections.set(i, [endpoint, config]);
        }

        throw e;
      }
    });

    try {
      await Promise.any(connectionPromises);
    } catch (e) {
      throw new Error('All endpoints failed to initialize. Please add healthier endpoints', {cause: e});
    }

    void Promise.allSettled(connectionPromises).then((res) => {
      // Retry failed connections in the background
      for (const [index, [endpoint, config]] of failedConnections) {
        this.retryConnection(createConnection, network, index, endpoint, config, postConnectedHook);
      }
    });
  }

  private async performConnection(
    createConnection: (endpoint: string, config: EndpointConfig) => Promise<Connection>,