String cluster = 'ap1';
String? token = await TokenService.getToken();
if (token == null) {
showSimpleSnackbar("Error: Token is not present");
return;
}
await pusher.init(
apiKey: pusherAppKey,
cluster: cluster,
logToConsole: true,
onEvent: (event) {
debugPrint("Event: $event");
},
onConnectionStateChange: (currentState, previousState) {
print("Connection: $previousState -> $currentState");
},
onError: (message, code, e) {
print("Error: $message ($code)");
},
authEndpoint: "https://lifenavi.com/broadcasting/auth",
authParams: {
'headers': {
'Authorization': 'Bearer $token',
'Content-Type': 'application/json',
},
},
);
await pusher.connect();