supabase-flutter
supabase-flutter copied to clipboard
Published
20 hours ago •
supabase
supabase
Exception: Realtime was unable to connect to the project database
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
Sometimes there is also this exception:
[ERROR:flutter/runtime/dart_vm_initializer.cc(41)] Unhandled Exception: Exception: "Invalid JWT Token"
#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)
I believe that this happens when the JWT expires while the system is asleep.
After the application gets into active/resumed state again I can read: **** onAuthStateChange: AuthChangeEvent.tokenRefreshed in the log. But the stream is not recovering.
Your first issue sounds like an issue with your Supabase instance, which may be solved by pausing and restoring your project or contacting Supabase support. Your second issue should be solved now with #1019 being merged. You can try it by upgrading supabase_flutter to 2.7.0. If you still experience any issues, please create a new issue.
