connectCustomer function

Function connectCustomer({ required String appId, required String atlasId, required Function onMessage, String? userId, String? userHash, Function? onError, })

Implementation

Function connectCustomer(
    {required String appId,
    required String atlasId,
    required Function onMessage,
    String? userId,
    String? userHash,
    Function? onError}) {
  bool killed = false;
  WebSocketChannel? channel;
  int reconnectDelay = 1000;

  bool synced = false;

  void kill() {
    killed = true;
    channel?.sink.close();
  }

  void connect() {
    if (killed) return;
    channel = WebSocketChannel.connect(Uri.parse("$atlasWebSocketBaseUrl/ws/CUSTOMER::$atlasId/$appId"));

    var ch = channel;
    if (ch == null) return;

    ch.stream.listen((message) {
      reconnectDelay = 1000;
      if (killed) return kill();

      if (!synced) {
        synced = true;
        ch.sink.add(jsonEncode({
          'channel_id': atlasId,
          'channel_kind': 'CUSTOMER',
          'packet_type': 'FETCH_DATA',
          'payload': {
            'data': ['conversations']
          },
        }));
      }

      try {
        onMessage(message);
      } catch (error) {
        onError?.call(error);
      }
    }, onDone: () {
      if (killed) return;
      channel = null;
      Future.delayed(Duration(milliseconds: reconnectDelay), connect);
      if (reconnectDelay < 120e3) reconnectDelay *= 2;
    });

    ch.sink.add(jsonEncode({
      'channel_id': atlasId,
      'channel_kind': 'CUSTOMER',
      'packet_type': 'SUBSCRIBE',
      'payload': {
        if (userId != null) 'userId': userId,
        if (userHash != null) 'userHash': userHash,
      },
    }));
  }

  connect();

  return kill;
}