leemuzi/real-time-fund
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat：为减轻服务器压力，临时关闭实时订阅 user 表

Browse Source
This commit is contained in:
hzm
2026-03-10 23:26:31 +08:00
parent 5200b9292b
commit bcfbc2bcde
1 changed files with 24 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
app/page.jsx
View File

@@ -2082,29 +2082,30 @@ export default function HomePage() {
return () => subscription.unsubscribe();
}, []);
useEffect(() => {
if (!isSupabaseConfigured || !user?.id) return;
const channel = supabase
.channel(`user-configs-${user.id}`)
.on('postgres_changes', { event: 'INSERT', schema: 'public', table: 'user_configs', filter: `user_id=eq.${user.id}` }, async (payload) => {
const incoming = payload?.new?.data;
if (!isPlainObject(incoming)) return;
const incomingComparable = getComparablePayload(incoming);
if (!incomingComparable || incomingComparable === lastSyncedRef.current) return;
await applyCloudConfig(incoming, payload.new.updated_at);
})
.on('postgres_changes', { event: 'UPDATE', schema: 'public', table: 'user_configs', filter: `user_id=eq.${user.id}` }, async (payload) => {
const incoming = payload?.new?.data;
if (!isPlainObject(incoming)) return;
const incomingComparable = getComparablePayload(incoming);
if (!incomingComparable || incomingComparable === lastSyncedRef.current) return;
await applyCloudConfig(incoming, payload.new.updated_at);
})
.subscribe();
return () => {
supabase.removeChannel(channel);
};
}, [user?.id]);
// 实时同步
// useEffect(() => {
// if (!isSupabaseConfigured || !user?.id) return;
// const channel = supabase
// .channel(`user-configs-${user.id}`)
// .on('postgres_changes', { event: 'INSERT', schema: 'public', table: 'user_configs', filter: `user_id=eq.${user.id}` }, async (payload) => {
// const incoming = payload?.new?.data;
// if (!isPlainObject(incoming)) return;
// const incomingComparable = getComparablePayload(incoming);
// if (!incomingComparable || incomingComparable === lastSyncedRef.current) return;
// await applyCloudConfig(incoming, payload.new.updated_at);
// })
// .on('postgres_changes', { event: 'UPDATE', schema: 'public', table: 'user_configs', filter: `user_id=eq.${user.id}` }, async (payload) => {
// const incoming = payload?.new?.data;
// if (!isPlainObject(incoming)) return;
// const incomingComparable = getComparablePayload(incoming);
// if (!incomingComparable || incomingComparable === lastSyncedRef.current) return;
// await applyCloudConfig(incoming, payload.new.updated_at);
// })
// .subscribe();
// return () => {
// supabase.removeChannel(channel);
// };
// }, [user?.id]);
const handleSendOtp = async (e) => {
e.preventDefault();