closeSubscription method

@override Future<void> closeSubscription(String id)

close a relay subscription, the relay connection will be kept open and closed automatically (garbage collected)

Implementation

@override
closeSubscription(String id) async {
  final relayUrls = globalState.inFlightRequests[id]?.requests.keys;
  if (relayUrls == null) {
    Logger.log.w("no relay urls found for subscription $id, cannot close");
    return;
  }
  Iterable<RelayConnectivity<JitEngineRelayConnectivityData>> relays =
      relayManagerLight.connectedRelays
          .whereType<RelayConnectivity<JitEngineRelayConnectivityData>>()
          .where((relay) => relayUrls.contains(relay.url));

  for (final relay in relays) {
    this
        .relayManagerLight
        .send(relay, ClientMsg(ClientMsgType.CLOSE, id: id));
  }

  // remove from in flight requests
  globalState.inFlightRequests.remove(id);
}