connectRelay method

Future<bool> connectRelay(String dirtyUrl, { int connectTimeout = DEFAULT_WEB_SOCKET_CONNECT_TIMEOUT, })

Connect a new relay

Implementation

Future<bool> connectRelay(String dirtyUrl,
    {int connectTimeout = DEFAULT_WEB_SOCKET_CONNECT_TIMEOUT}) async {
  String? url = cleanRelayUrl(dirtyUrl);
  if (url == null) {
    return false;
  }
  if (blockedRelays.contains(url)) {
    return false;
  }
  try {
    if (relays[url] == null) {
      relays[url] = Relay(url);
    }
    relays[url]!.tryingToConnect();
    if (url.startsWith("wss://brb.io")) {
      relays[url]!.failedToConnect();
      relays[url]!.stats.connectionErrors++;
      return false;
    }
    // var connectionOptions = SocketConnectionOptions(
    //   timeoutConnectionMs: connectTimeout*1000,
    //   skipPingMessages: true,
    //   pingRestrictionForce: true,
    //   reconnectionDelay: const Duration(seconds:5),
    // );
    // webSockets[url] = IWebSocketHandler<String, String>.createClient(
    //   url,
    //   SocketSimpleTextProcessor(),
    //   connectionOptions: connectionOptions
    // );

    transports[url] = nostrTransportFactory(url);
    await transports[url]!
        .ready
        .timeout(Duration(seconds: connectTimeout),
            onTimeout: () {
      print("timed out connecting to relay $url");
    });

    startListeningToSocket(url);

    developer.log("connected to relay: $url");
    relays[url]!.succeededToConnect();
    relays[url]!.stats.connections++;
    getRelayInfo(url);
    return true;
  } catch (e) {
    print("!! could not connect to $url -> $e");
    transports.remove(url);
  }
  relays[url]!.failedToConnect();
  relays[url]!.stats.connectionErrors++;
  return false;
}