|
|
@@ -84,32 +84,32 @@ Future<Response> handleFileUpload(Request request) async {
|
|
|
),
|
|
|
);
|
|
|
|
|
|
- final myChannel = supabase.channel('csvhichstorage');
|
|
|
-
|
|
|
- myChannel.subscribe((status, error) async {
|
|
|
- if (status == RealtimeSubscribeStatus.subscribed) {
|
|
|
- final serverResponse = await myChannel.sendBroadcastMessage(
|
|
|
- event: "upload",
|
|
|
- payload: {
|
|
|
- "filename": filename,
|
|
|
- "updated_at": now,
|
|
|
- },
|
|
|
- );
|
|
|
-
|
|
|
- print('serverResponse: $serverResponse');
|
|
|
- }
|
|
|
- });
|
|
|
+ // final myChannel = supabase.channel('csvhichstorage');
|
|
|
+ // myChannel.subscribe((status, error) async {
|
|
|
+ // if (status == RealtimeSubscribeStatus.subscribed) {
|
|
|
+ // final serverResponse = await myChannel.sendBroadcastMessage(
|
|
|
+ // event: "upload",
|
|
|
+ // payload: {
|
|
|
+ // "filename": filename,
|
|
|
+ // "updated_at": now,
|
|
|
+ // },
|
|
|
+ // );
|
|
|
+
|
|
|
+ // print('serverResponse: $serverResponse');
|
|
|
+ // }
|
|
|
+ // });
|
|
|
|
|
|
// No need to subscribe to channel
|
|
|
- // final channel = supabase.channel('csvhichstorage');
|
|
|
- // final res = await channel.sendBroadcastMessage(
|
|
|
- // event: "upload",
|
|
|
- // payload: {
|
|
|
- // "filename": filename,
|
|
|
- // "updated_at": now,
|
|
|
- // },
|
|
|
- // );
|
|
|
- // print(" realtime response: $res");
|
|
|
+ final channel = supabase.channel('csvhichstorage');
|
|
|
+
|
|
|
+ final res = await channel.sendBroadcastMessage(
|
|
|
+ event: "upload",
|
|
|
+ payload: {
|
|
|
+ "filename": filename,
|
|
|
+ "updated_at": now,
|
|
|
+ },
|
|
|
+ );
|
|
|
+ print(" realtime response: $res");
|
|
|
|
|
|
await processCsvData(tempFile, supabase);
|
|
|
|