closeSubscription method

Implementation

Future<void> closeSubscription(String subId, {String debugLabel = ""}) async {
  final relayUrls = _globalState.inFlightRequests[subId]?.requests.keys;

  if (relayUrls == null) {
    Logger.log.w(
        "no relay urls found for subscription $subId, cannot close :: debug: $debugLabel");
    return;
  }
  Iterable<RelayConnectivity> relays = _relayManager.connectedRelays
      .whereType<RelayConnectivity>()
      .where((relay) => relayUrls.contains(relay.url));

  for (final relay in relays) {
    _relayManager.sendCloseToRelay(relay.url, subId);
  }

  final state = _globalState.inFlightRequests[subId];

  if (state == null) {
    Logger.log
        .w("no request state found for subscription $subId, cannot close");
    return;
  }

  await state.close();
  _globalState.inFlightRequests.remove(subId);
}