requestRelays method

Future<NdkResponse> requestRelays(String name, Iterable<String> urls, Filter filter, { Duration timeout = kDefaultStreamIdleTimeout, bool closeOnEOSE = true, })

Implementation

Future<NdkResponse> requestRelays(
  String name,
  Iterable<String> urls,
  Filter filter, {
  Duration timeout = kDefaultStreamIdleTimeout,
  bool closeOnEOSE = true,
}) async {
  String id = Helpers.getRandomString(10);
  RequestState state = RequestState(
    closeOnEOSE
        ? NdkRequest.query(
            id,
            name: name,
            filters: [filter],
            timeoutDuration: timeout,
          )
        : NdkRequest.subscription(id, name: name, filters: []),
  );

  for (var url in urls) {
    state.addRequest(url, RelaySet.sliceFilterAuthors(filter));
  }
  _globalState.inFlightRequests[state.id] = state;

  for (MapEntry<String, RelayRequestState> entry in state.requests.entries) {
    doRelayRequest(state.id, entry.value).then((sent) {
      if (!sent) {
        state.requests.remove(entry.value.url);
        // start fix
        if (state.requests.isEmpty) {
          state.networkController.close();
        }
        // end fix
      }
    });
  }

  return NdkResponse(state.id, state.stream);
}