mirror of
https://github.com/domfelipe/mika-agent-assist.git
synced 2026-08-07 11:16:46 +00:00
Changes
Co-authored-by: domfelipe <53182096+domfelipe@users.noreply.github.com>
This commit is contained in:
parent
3a689e1cad
commit
343cd0234e
1 changed files with 42 additions and 0 deletions
42
src/hooks/use-subscription-realtime.ts
Normal file
42
src/hooks/use-subscription-realtime.ts
Normal file
|
|
@ -0,0 +1,42 @@
|
||||||
|
"use client";
|
||||||
|
|
||||||
|
import { useEffect } from "react";
|
||||||
|
import { useQueryClient } from "@tanstack/react-query";
|
||||||
|
import { supabase } from "@/integrations/supabase/client";
|
||||||
|
import { useAuth } from "@/hooks/use-auth";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Subscribes to realtime changes on the user's subscription row.
|
||||||
|
* When the payments webhook upserts a subscription, the affected
|
||||||
|
* queries are invalidated so the UI updates without a page reload.
|
||||||
|
*/
|
||||||
|
export function useSubscriptionRealtime() {
|
||||||
|
const { user } = useAuth();
|
||||||
|
const queryClient = useQueryClient();
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
if (!user?.id) return;
|
||||||
|
|
||||||
|
const channel = supabase
|
||||||
|
.channel(`subscriptions:user:${user.id}`)
|
||||||
|
.on(
|
||||||
|
"postgres_changes",
|
||||||
|
{
|
||||||
|
event: "*",
|
||||||
|
schema: "public",
|
||||||
|
table: "subscriptions",
|
||||||
|
filter: `user_id=eq.${user.id}`,
|
||||||
|
},
|
||||||
|
() => {
|
||||||
|
queryClient.invalidateQueries({ queryKey: ["subscription", user.id] });
|
||||||
|
queryClient.invalidateQueries({ queryKey: ["has-active-subscription", user.id] });
|
||||||
|
queryClient.invalidateQueries({ queryKey: ["plan"] });
|
||||||
|
},
|
||||||
|
)
|
||||||
|
.subscribe();
|
||||||
|
|
||||||
|
return () => {
|
||||||
|
supabase.removeChannel(channel);
|
||||||
|
};
|
||||||
|
}, [user?.id, queryClient]);
|
||||||
|
}
|
||||||
Loading…
Add table
Add a link
Reference in a new issue