|
|
@@ -84,27 +84,22 @@ Future<Response> handleFileUpload(Request request) async {
|
|
|
),
|
|
|
);
|
|
|
|
|
|
- final myChannel = supabase.channel(
|
|
|
- 'csvhichstorage',
|
|
|
- opts: const RealtimeChannelConfig(
|
|
|
- ack: true,
|
|
|
- ),
|
|
|
- );
|
|
|
+ final myChannel = supabase.channel('csvhichstorage');
|
|
|
|
|
|
myChannel.subscribe((status, error) async {
|
|
|
- if (status != RealtimeSubscribeStatus.subscribed) return;
|
|
|
-
|
|
|
- final serverResponse = await myChannel.sendBroadcastMessage(
|
|
|
- event: "upload",
|
|
|
- payload: {
|
|
|
- "filename": filename,
|
|
|
- "updated_at": now,
|
|
|
- },
|
|
|
- );
|
|
|
+ if (status == RealtimeSubscribeStatus.subscribed) {
|
|
|
+ final serverResponse = await myChannel.sendBroadcastMessage(
|
|
|
+ event: "upload",
|
|
|
+ payload: {
|
|
|
+ "filename": filename,
|
|
|
+ "updated_at": now,
|
|
|
+ },
|
|
|
+ );
|
|
|
|
|
|
- print('serverResponse: $serverResponse');
|
|
|
+ print('serverResponse: $serverResponse');
|
|
|
+ }
|
|
|
+ await myChannel.unsubscribe();
|
|
|
});
|
|
|
- await myChannel.unsubscribe();
|
|
|
|
|
|
// No need to subscribe to channel
|
|
|
// final channel = supabase.channel('csvhichstorage');
|
|
|
@@ -126,7 +121,7 @@ Future<Response> handleFileUpload(Request request) async {
|
|
|
});
|
|
|
final end = Jiffy.now();
|
|
|
print(
|
|
|
- " ${DTInterval(start, end).duration.inSeconds} seconds\n");
|
|
|
+ " ${DTInterval(start, end).duration.inMilliseconds / 1000} seconds\n");
|
|
|
// Clean up temporary file
|
|
|
await tempFile.delete();
|
|
|
}
|