Initial independent version of CrAPP

src/lib/mvp-voti.ts

@@ -0,0 +1,86 @@
+import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query";
+import { supabase } from "@/integrations/supabase/client";
+
+export type VotoMvp = {
+  match_id: string;
+  votante_id: string;
+  votato_id: string;
+  votato_nome: string;
+};
+
+const CHIAVE = ["mvp-voti"] as const;
+
+/** Tutti i voti MVP della squadra (poche righe, si carica tutto).
+ *  Nessun polling: la lista si aggiorna dopo il proprio voto o al rientro sull'app. */
+export function useVotiMvp() {
+  return useQuery({
+    queryKey: CHIAVE,
+    staleTime: 10 * 60_000,
+    queryFn: async (): Promise<VotoMvp[]> => {
+      const { data, error } = await supabase
+        .from("mvp_voti")
+        .select("match_id, votante_id, votato_id, votato_nome");
+      if (error) throw error;
+      return (data ?? []) as VotoMvp[];
+    },
+  });
+}
+
+export function useVotaMvp() {
+  const qc = useQueryClient();
+  return useMutation({
+    mutationFn: async (voto: VotoMvp) => {
+      const { error } = await supabase
+        .from("mvp_voti")
+        .upsert(voto, { onConflict: "match_id,votante_id" });
+      if (error) throw error;
+      return voto;
+    },
+    // Aggiorna la cache localmente: nessuna rilettura dal database.
+    onSuccess: (voto) => {
+      qc.setQueryData<VotoMvp[]>(CHIAVE, (prec) => {
+        const altri = (prec ?? []).filter(
+          (v) => !(v.match_id === voto.match_id && v.votante_id === voto.votante_id),
+        );
+        return [...altri, voto];
+      });
+    },
+  });
+}
+
+export type ConteggioMvp = { id: string; nome: string; voti: number };
+
+/** Conteggio voti di una partita, dal più votato. */
+export function conteggioPartita(voti: VotoMvp[], matchId: string): ConteggioMvp[] {
+  const map = new Map<string, ConteggioMvp>();
+  for (const v of voti) {
+    if (v.match_id !== matchId) continue;
+    const cur = map.get(v.votato_id) ?? { id: v.votato_id, nome: v.votato_nome, voti: 0 };
+    cur.voti += 1;
+    map.set(v.votato_id, cur);
+  }
+  return [...map.values()].sort((a, b) => b.voti - a.voti || a.nome.localeCompare(b.nome));
+}
+
+/** Vincitore per ogni partita votata: matchId -> nome MVP. */
+export function vincitoriMvp(voti: VotoMvp[]): Record<string, string> {
+  const perMatch = new Map<string, VotoMvp[]>();
+  for (const v of voti) {
+    const arr = perMatch.get(v.match_id) ?? [];
+    arr.push(v);
+    perMatch.set(v.match_id, arr);
+  }
+  const out: Record<string, string> = {};
+  for (const [matchId] of perMatch) {
+    const top = conteggioPartita(voti, matchId);
+    // In caso di parità nessun MVP assegnato finché il voto non si sblocca.
+    if (top.length > 0 && (top.length === 1 || top[0]!.voti > top[1]!.voti)) {
+      out[matchId] = top[0]!.nome;
+    }
+  }
+  return out;
+}
+
+export function mioVoto(voti: VotoMvp[], matchId: string, votanteId: string) {
+  return voti.find((v) => v.match_id === matchId && v.votante_id === votanteId) ?? null;
+}