init method

Implementation

Future<void> init({
  int port = kDefaultPort,
  int maxPlayers = 10,
  bool verbose = false,
  bool autosave = false,
  bool multiWorld = false,
  String description = '',
}) async {
  if (verbose) {
    consoler.minLogLevel = LogLevel.verbose;
  }
  log("Starting server on port $port", level: LogLevel.info);
  log('Verbose logging activated', level: LogLevel.verbose);
  try {
    await initPluginSystem();
    log('Plugin system initialized', level: LogLevel.info);
  } catch (e) {
    log('Error initializing plugin system: $e, continuing without',
        level: LogLevel.warning);
  }
  this.autosave = autosave;
  _multiWorld = multiWorld;
  _maxPlayers = maxPlayers;
  SecurityContext? securityContext;
  try {
    final privateKey = await File('certs/server.key').readAsBytes();
    final certificate = await File('certs/server.crt').readAsBytes();
    securityContext = SecurityContext()
      ..usePrivateKeyBytes(privateKey)
      ..useCertificateChainBytes(certificate);
    log('Certificates found, using secure connection', level: LogLevel.info);
  } on PathNotFoundException catch (_) {
    log('No certificates found, using insecure connection',
        level: LogLevel.warning);
  }
  final server = _server = NetworkerSocketServer(
      InternetAddress.anyIPv4, port,
      securityContext: securityContext,
      filterConnections: buildFilterConnections(
          loadProperty: (request) =>
              getWorld(request.uri.path)?.eventSystem.runPing(
                  request,
                  GameProperty.defaultProperty.copyWith(
                    description: description,
                    maxPlayers: maxPlayers,
                    currentPlayers: _server?.clientConnections.length,
                  ))));

  final transformer = _pipe = NetworkerPipeTransformer<String, WorldEvent>(
      WorldEventMapper.fromJson, (e) => e.toJson());
  transformer.read.listen(_onClientEvent);
  server
    ..clientConnect.listen(_onJoin)
    ..clientDisconnect.listen(_onLeave)
    ..connect(StringNetworkerPlugin()..connect(transformer));
  await _server?.init();

  consoler.registerPrograms({
    'stop': StopProgram(this),
    'save': SaveProgram(this),
    'packs': PacksProgram(this),
    'players': PlayersProgram(this),
    'say': SayProgram(this),
    'reset': ResetProgram(this),
    null: UnknownProgram(),
  });
}