connect method

@override Future<void> connect(AddrInfo pi, { Context? context, })

Connect ensures there is a connection between this host and the peer with given peer.ID. Connect will absorb the addresses in pi into its internal peerstore. If there is not an active connection, Connect will issue a h.Network.Dial, and block until a connection is open, or an error is returned.

If context is not provided, a new Context will be created.

Implementation

@override
Future<void> connect(AddrInfo pi, {Context? context}) async {
  final startTime = DateTime.now();


  // Prevent self-dialing
  if (pi.id == id) {

    return;
  }

  // Phase 1: Address Filtering and Peerstore Update

  final filterStartTime = DateTime.now();

  final filteredAddrs = _addrsFactory(pi.addrs);


  await peerStore.addrBook.addAddrs(pi.id, filteredAddrs, Duration(minutes: 5));

  final filterTime = DateTime.now().difference(filterStartTime);


  // Phase 2: Connection Check

  final connectedness = _network.connectedness(pi.id);


  if (connectedness == Connectedness.connected) {
    final totalTime = DateTime.now().difference(startTime);

    return;
  }

  // Phase 3: Context Creation

  final ctx = context ?? Context();


  // Phase 4: Dial Peer

  final dialStartTime = DateTime.now();

  try {
    await _dialPeer(pi.id, ctx);

    final dialTime = DateTime.now().difference(dialStartTime);
    final totalTime = DateTime.now().difference(startTime);


  } catch (e, stackTrace) {
    final dialTime = DateTime.now().difference(dialStartTime);
    final totalTime = DateTime.now().difference(startTime);
    _log.severe('❌ [CONNECT-ERROR] Connection failed after ${totalTime.inMilliseconds}ms (dial: ${dialTime.inMilliseconds}ms): $e\n$stackTrace');
    rethrow;
  }
}