Exception: Realtime was unable to connect to the project database #982
Description
Describe the bug
I initialised a realtime channel and after a while of inactivity I get the following Exception.
The channel doesn't receive data after that and does not recover on its own.
[ERROR:flutter/runtime/dart_vm_initializer.cc(41)] Unhandled Exception: Exception: "Realtime was unable to connect to the project database"
#0 SupabaseStreamBuilder._addException (package:supabase/src/supabase_stream_builder.dart:293:67)
#1 SupabaseStreamBuilder._getStreamData.<anonymous closure> (package:supabase/src/supabase_stream_builder.dart:199:9)
#2 RealtimeChannel.subscribe.<anonymous closure> (package:realtime_client/src/realtime_channel.dart:207:19)
#3 Push._matchReceive.<anonymous closure> (package:realtime_client/src/push.dart:133:17)
#4 Iterable.forEach (dart:core/iterable.dart:347:35)
#5 Push._matchReceive (package:realtime_client/src/push.dart:132:48)
#6 Push.startTimeout.<anonymous closure> (package:realtime_client/src/push.dart:96:7)
#7 RealtimeChannel.trigger (package:realtime_client/src/realtime_channel.dart:694:22)
#8 new RealtimeChannel.<anonymous closure> (package:realtime_client/src/realtime_channel.dart:93:7)
#9 RealtimeChannel.trigger (package:realtime_client/src/realtime_channel.dart:694:22)
#10 RealtimeClient.onConnMessage.<anonymous closure>.<anonymous closure> (package:realtime_client/src/realtime_client.dart:319:41)
#11 Iterable.forEach (dart:core/iterable.dart:347:35)
#12 RealtimeClient.onConnMessage.<anonymous closure> (package:realtime_client/src/realtime_client.dart:319:12)
#13 new RealtimeClient.<anonymous closure> (package:realtime_client/src/realtime_client.dart:135:21)
#14 RealtimeClient.onConnMessage (package:realtime_client/src/realtime_client.dart:302:11)
#15 RealtimeClient.connect.<anonymous closure> (package:realtime_client/src/realtime_client.dart:165:22)
#16 _RootZone.runUnaryGuarded (dart:async/zone.dart:1594:10)
#17 _BufferingStreamSubscription._sendData (dart:async/stream_impl.dart:365:11)
#18 _BufferingStreamSubscription._add (dart:async/stream_impl.dart:297:7)
#19 _ForwardingStreamSubscription._add (dart:async/stream_pipe.dart:123:11)
#20 _HandleErrorStream._handleData (dart:async/stream_pipe.dart:253:10)
#21 _ForwardingStreamSubscription._handleData (dart:async/stream_pipe.dart:153:13)
#22 _RootZone.runUnaryGuarded (dart:async/zone.dart:1594:10)
#23 _BufferingStreamSubscription._sendData (dart:async/stream_impl.dart:365:11)
#24 _BufferingStreamSubscription._add (dart:async/stream_impl.dart:297:7)
#25 _SyncStreamControllerDispatch._sendData (dart:async/stream_controller.dart:784:19)
#26 _StreamController._add (dart:async/stream_controller.dart:658:7)
#27 _RootZone.runUnaryGuarded (dart:async/zone.dart:1594:10)
#28 _BufferingStreamSubscription._sendData (dart:async/stream_impl.dart:365:11)
#29 _BufferingStreamSubscription._add (dart:async/stream_impl.dart:297:7)
#30 _SyncStreamControllerDispatch._sendData (dart:async/stream_controller.dart:784:19)
#31 _StreamController._add (dart:async/stream_controller.dart:658:7)
#32 _StreamController.add (dart:async/stream_controller.dart:606:5)
#33 new _WebSocketImpl._fromSocket.<anonymous closure> (dart:_http/websocket_impl.dart:1144:21)
#34 _RootZone.runUnaryGuarded (dart:async/zone.dart:1594:10)
#35 _BufferingStreamSubscription._sendData (dart:async/stream_impl.dart:365:11)
#36 _BufferingStreamSubscription._add (dart:async/stream_impl.dart:297:7)
#37 _SinkTransformerStreamSubscription._add (dart:async/stream_transformers.dart:63:11)
#38 _EventSinkWrapper.add (dart:async/stream_transformers.dart:13:11)
#39 _WebSocketProtocolTransformer._messageFrameEnd (dart:_http/websocket_impl.dart:332:23)
#40 _WebSocketProtocolTransformer.add (dart:_http/websocket_impl.dart:226:46)
#41 _SinkTransformerStreamSubscription._handleData (dart:async/stream_transformers.dart:111:24)
#42 _RootZone.runUnaryGuarded (dart:async/zone.dart:1594:10)
#43 _BufferingStreamSubscription._sendData (dart:async/stream_impl.dart:365:11)
#44 _BufferingStreamSubscription._add (dart:async/stream_impl.dart:297:7)
#45 _SyncStreamControllerDispatch._sendData (dart:async/stream_controller.dart:784:19)
#46 _StreamController._add (dart:async/stream_controller.dart:658:7)
#47 _StreamController.add (dart:async/stream_controller.dart:606:5)
#48 _Socket._onData (dart:io-patch/socket_patch.dart:2449:41)
#49 _RootZone.runUnaryGuarded (dart:async/zone.dart:1594:10)
#50 _BufferingStreamSubscription._sendData (dart:async/stream_impl.dart:365:11)
#51 _BufferingStreamSubscription._add (dart:async/stream_impl.dart:297:7)
#52 _SyncStreamControllerDispatch._sendData (dart:async/stream_controller.dart:784:19)
#53 _StreamController._add (dart:async/stream_controller.dart:658:7)
#54 _StreamController.add (dart:async/stream_controller.dart:606:5)
#55 _RawSecureSocket._sendReadEvent (dart:io/secure_socket.dart:1116:19)
#56 Timer._createTimer.<anonymous closure> (dart:async-patch/timer_patch.dart:18:15)
#57 _Timer._runTimers (dart:isolate-patch/timer_impl.dart:398:19)
#58 _Timer._handleMessage (dart:isolate-patch/timer_impl.dart:429:5)
#59 _RawReceivePort._handleMessage (dart:isolate-patch/isolate_patch.dart:184:12)
To Reproduce
Steps to reproduce the behavior:
I'm testing on Flutter for macOS.
- Initialise Stream
var channel = Supabase.instance.client
.channel('notifications')
.onPostgresChanges(
event: PostgresChangeEvent.all,
schema: 'xxx',
table: 'notifications',
callback: (payload) {
print('Change received: ${payload.toString()}');
if (payload.errors != null && payload.errors.isNotEmpty) {
payload.errors.forEach((element) {
print('Error: ${element.message}');
});
}
},
)
.subscribe();
- Leave Computer unattended for a while
- See error
Expected behavior
I expect the channel to reconnect and to get notified about it by an onReconnect event or something like that.
Version (please complete the following information):
supabase_test 1.0.0+1
├── supabase_flutter 2.5.8
│ ├── supabase 2.2.4
│ │ ├── functions_client 2.2.0
│ │ ├── gotrue 2.8.3
│ │ ├── postgrest 2.1.2
│ │ ├── realtime_client 2.2.0
│ │ ├── storage_client 2.0.2