connect method

Future<ConnectionResult> connect(ServerConfig server)

FR-CONN-001~003, 010

Implementation

Future<ConnectionResult> connect(ServerConfig server) async {
  final existing = _connections[server.id];
  if (existing != null) {
    if (existing.state == ConnectionState.connected) {
      _logger.debug('Reusing connection', {'serverId': server.id});
      return ConnectionResult.success(existing);
    }
    if (existing.state == ConnectionState.connecting) {
      _logger.debug('Awaiting in-flight connection',
          {'serverId': server.id});
      return _waitForConnection(server.id);
    }
  }

  _logger.debug('Creating connection', {'serverId': server.id});
  final info = ConnectionInfo(
    serverId: server.id,
    serverName: server.name,
    serverConfig: server,
    state: ConnectionState.connecting,
  );
  _connections[server.id] = info;
  notifyListeners();

  try {
    final transport = _transportFactory.create(server);
    final client = await _connector(transport);

    info.client = client;
    info.state = ConnectionState.connected;
    info.connectedAt = DateTime.now();
    notifyListeners();

    _logger.info('Connected', {'serverId': server.id});
    return ConnectionResult.success(info);
  } catch (e, st) {
    info.state = ConnectionState.error;
    info.error = e.toString();
    notifyListeners();
    _logger.logError('Connect failed', e, st, {'serverId': server.id});
    return ConnectionResult.failure(e.toString());
  }
}