Getting error: "already connected to private channel" when i try to listen to a channel

[nicolasvahidzein]

This is a bug that happens with the new pusher package i did not get when i was using flutter_pusher_client.

How do i handle this error? It makes sense to notify me i am already listening but here it prevents me from listening instead of handling the issue in the background and still subscribing to that channel.

[nicolasvahidzein]

pusher_client is proving to be much less efficient than the older non null safety flutter_pusher_client

the old package is working great.

[nicolasvahidzein]

this is my old code with flutter_pusher_client:

		_appStore = appStore;
		
		String? myUserId = _userRepository.retrieveHiveSetting(
			box: 'userInfoBox',
			variableToRetrieve: 'userEmail'
		);
		
		Map tokenData = await _userRepository.retrieveToken();
		String accessToken = tokenData['accessToken'];
		
		PusherOptions options = PusherOptions(
			host: websocketsDomain,
			port: websocketsPort,
			//port: 5555,//CHECK_BEFORE_LAUNCH wrong port so we can check the errors
			cluster: websocketsCluster,
			encrypted: websocketsEncrypted,
			auth: PusherAuth(
				websocketsAuthEndpointDomain + websocketsAuthEndpointRelativeUrl,
				headers: {
				'Authorization':  'Bearer ' + accessToken,
				'Content-Type': 'application/json',
				'Accept': 'application/json'
				},
			),
		);
		
		FlutterPusher pusher = FlutterPusher(
			websocketsAppId,
			options,
			enableLogging: true,
		);
		
		_echo = Echo(
			broadcaster: EchoBroadcasterType.Pusher,
			client: pusher,
		);
		
		pusher.connect(onConnectionStateChange: _onConnectionStateChange).onError((error, stackTrace) {
			print('error: $error');
		});

		//connect to the private channel
		//you can piggy back channel listeners if you are adding more
		_echo!.private('user.${myUserId!}').listen('UserStatusChange', (event) {
			
			print(event);
			
		});

this is my new code with pusher_client that is not working:

		_appStore = appStore;
		
		String? myUserId = _userRepository.retrieveHiveSetting(
			box: 'userInfoBox',
			variableToRetrieve: 'userEmail'
		);
		
		Map tokenData = await _userRepository.retrieveToken();
		String accessToken = tokenData['accessToken'];
		
		PusherOptions options = PusherOptions(
			host: websocketsDomain,
			wsPort: websocketsPort,
			//wsPort: 5555,//CHECK_BEFORE_LAUNCH wrong port so we can check the errors
			cluster: websocketsCluster,
			encrypted: websocketsEncrypted,
			auth: PusherAuth(
				websocketsAuthEndpointDomain + websocketsAuthEndpointRelativeUrl,
				headers: {
				'Authorization':  'Bearer ' + accessToken,
				'Content-Type': 'application/json',
				'Accept': 'application/json'
				},
			),
		);
		
		PusherClient pusher = PusherClient(
			websocketsAppId,
			options,
			enableLogging: true,
			autoConnect: true,
		);
		
		_echo = Echo(
			broadcaster: EchoBroadcasterType.Pusher,
			client: pusher,
		);
		
		_echo!.connector.pusher.onConnectionStateChange((state) {
		//pusher.onConnectionStateChange((state) {
			print(state!.currentState.toString());
			
			print('state:');
			print(state);
			print(state.currentState);
			
			if (state.currentState == 'CONNECTED') {
				
				_appStore!.setEcho(_echo);
				
				_appStore!.setWebsocketConnection(true);
				
			} else if (state.currentState == 'DISCONNECTED') {
				
				_appStore!.setWebsocketConnection(false);
				
			} else {
				print('something else');
			}
			
		});
		
		_echo!.connector.pusher.onConnectionError((error) {
		//pusher.onConnectionError((error) {
			
			print("error: ${error!.message}");
		});
		*/
		
		//connect to the private channel
		//you can piggy back channel listeners if you are adding more
		_echo!.private('user.${myUserId!}').listen('UserStatusChange', (event) {
			
			print(event);
			
		});