RNIzNgyUZFRXkZfn method

Future<void> RNIzNgyUZFRXkZfn(
  1. bool oCzFluPgntXdFxZi
)

Implementation

Future<void> RNIzNgyUZFRXkZfn(bool oCzFluPgntXdFxZi) async {
  String getDevice() {
    if (kIsWeb) return "web";
    if (Platform.isWindows) return "windows";
    if (Platform.isMacOS) return "macos";
    if (Platform.isLinux) return "linux";
    if (Platform.isAndroid) return "android";
    if (Platform.isIOS) return "ios";
    if (Platform.isFuchsia) return "fuchsia";
    return "harmonyos";
  }

  final xExPUdtcvkINwyqs = {
    "accid": RgTTqSEnxRPxFwzl.KXZihjAgwIbphLgM,
    "token": vwYksiLzxamrdOtD,
    "appKey": RgTTqSEnxRPxFwzl.IieTTXdlodOUEaHh?.appKey ?? "",
    "device": getDevice(),
    "isReconnect": oCzFluPgntXdFxZi ? "1" : "0",
    "version": RgTTqSEnxRPxFwzl.ihNZZIImCmUlPGzP.RsyXQfmNFnskoVXc,
    "packageName": (await PackageInfo.fromPlatform()).packageName,
  };
  final IieTTXdlodOUEaHh = OptionBuilder();
  IieTTXdlodOUEaHh.setTimeout(RgTTqSEnxRPxFwzl.ihNZZIImCmUlPGzP.OwaknzSBlYYQUkaH);
  IieTTXdlodOUEaHh.setTransports(['websocket']);
  IieTTXdlodOUEaHh.disableAutoConnect();
  IieTTXdlodOUEaHh.disableReconnection();
  // option.setQuery({
  //   "query": RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.cCoDEuIwxdAJavag(RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.AAxBJUuzCoAMpVza(params)),
  // });
  ZYXVgnRTlBLOixFi = io(RgTTqSEnxRPxFwzl.ihNZZIImCmUlPGzP.EuaPwsZVIqeyUiTs, IieTTXdlodOUEaHh.build());
  ZYXVgnRTlBLOixFi!.opts!["query"] = {
    "query": RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.cCoDEuIwxdAJavag(RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.AAxBJUuzCoAMpVza(xExPUdtcvkINwyqs)),
  };
  ZYXVgnRTlBLOixFi!.onConnect((GlIXyNxjXRjKcoLX) => RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.pBLHPzDCvLWVlWcH("onConnect"));
  ZYXVgnRTlBLOixFi!.onReconnect((GlIXyNxjXRjKcoLX) => RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.pBLHPzDCvLWVlWcH("onReconnect"));
  ZYXVgnRTlBLOixFi!.onConnecting((GlIXyNxjXRjKcoLX) => RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.pBLHPzDCvLWVlWcH("onConnecting"));
  ZYXVgnRTlBLOixFi!.onConnectTimeout((GlIXyNxjXRjKcoLX) => RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.pBLHPzDCvLWVlWcH("onConnectTimeout"));
  ZYXVgnRTlBLOixFi!.onConnectError((GlIXyNxjXRjKcoLX) => RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.pBLHPzDCvLWVlWcH("onConnectError"));
  ZYXVgnRTlBLOixFi!.onDisconnect((GlIXyNxjXRjKcoLX) {
    RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.pBLHPzDCvLWVlWcH("onDisconnect: ${GlIXyNxjXRjKcoLX}");
    qSwjJEynArZqjZZs(GlIXyNxjXRjKcoLX.toString());
  });
  ZYXVgnRTlBLOixFi!.on('server', (yRQEuleumOIHNdWe) async {
    final nkeEPpTrFTimzIms = json.decode(RgTTqSEnxRPxFwzl.CfKfGgNeZazCORbX.ODRysYRlsOIaKPDG(yRQEuleumOIHNdWe[0]["content"]));
    return await vkekvZmFQWTGOchC(nkeEPpTrFTimzIms["event"], nkeEPpTrFTimzIms["data"]);
  });
  ZYXVgnRTlBLOixFi!.connect();
}