points redistribution

app.py

@@ -31,6 +31,10 @@ outcomes_file = Path("outcomes") / f"match_outcomes.json"
 OUTCOMES_FOLDER = outcomes_file.parent
 OUTCOMES_FOLDER.mkdir(parents=True, exist_ok=True)
 
+REDISTRIBUTED_JSON = Path("redistributed_matches.json")
+if not REDISTRIBUTED_JSON.exists():
+    REDISTRIBUTED_JSON.write_text("[]")
+
 # Initialize CommitScheduler
 scheduler = CommitScheduler(
     repo_id="DIS_IPL_Preds",
@@ -286,25 +290,97 @@ def display_predictions():
         else:
             st.write("No predictions for today's matches yet.")
 
+def redistribute_lost_points(match_id) -> dict:
+    # Load already processed matches
+    with open(REDISTRIBUTED_JSON, "r") as f:
+        done_matches = json.load(f)
+
+    if match_id in done_matches:
+        return {}
+
+    users = load_users(USERS_JSON)
+    predictions = []
+
+    for file in PREDICTIONS_FOLDER.glob(f"prediction_{match_id}_*.json"):
+        with open(file, "r") as f:
+            for line in f:
+                predictions.append(json.loads(line.strip()))
+
+    outcomes = load_data(OUTCOMES_JSON)
+    outcome = next((m for m in outcomes if m["match_id"] == match_id), None)
+    if not outcome:
+        st.error("Match outcome not found.")
+        return {}
+
+    correct_winner = outcome["winner"]
+    correct_motm = outcome["man_of_the_match"]
+
+    user_losses = {}
+    for pred in predictions:
+        user = pred["user_name"]
+        bid = pred["bid_points"]
+        if (pred["predicted_winner"] != correct_winner) or (pred["predicted_motm"] != correct_motm):
+            user_losses[user] = user_losses.get(user, 0) + bid
+
+    top_5_users = sorted(users.items(), key=lambda x: x[1]["points"], reverse=True)[:5]
+    top_5_usernames = [user for user, _ in top_5_users]
+
+    lost_points_by_top5 = sum(user_losses.get(user, 0) for user in top_5_usernames)
+    if lost_points_by_top5 == 0:
+        return {}
+
+    rest_users = [user for user in users if user not in top_5_usernames]
+    total_points_rest_users = sum(users[u]["points"] for u in rest_users if users[u]["points"] > 0)
+
+    bonus_map = {}
+    for user in rest_users:
+        user_points = users[user]["points"]
+        if user_points <= 0:
+            continue
+        share_ratio = user_points / total_points_rest_users
+        bonus = round(share_ratio * lost_points_by_top5)
+        users[user]["points"] += bonus
+        bonus_map[user] = bonus
+
+    with open(USERS_JSON, "w") as f:
+        json.dump(users, f, indent=2)
+
+    # Record this match as done
+    done_matches.append(match_id)
+    with open(REDISTRIBUTED_JSON, "w") as f:
+        json.dump(done_matches, f, indent=2)
+
+    return bonus_map
 
 def display_leaderboard():
     if st.button("Show Leaderboard"):
         try:
             # # Load the 'leaders' configuration
             dataset = load_dataset("Jay-Rajput/DIS_IPL_Leads", split='train')
+            
+            # Load outcomes data from HF instead of local file
+            outcome_dataset = load_dataset("Jay-Rajput/DIS_IPL_Outcomes", split='train')
+            latest_match_id = outcome_dataset[-1]["match_id"] if outcome_dataset else None
+
+            # Redistribute points only once per match
+            bonus_map = {}
+            if latest_match_id:
+                bonus_map = redistribute_lost_points(latest_match_id)
 
             users_data = []
             if dataset:
                 for user, points_dict in dataset[0].items():
                     points = points_dict.get("points", 0)
                     last_5_results = " ".join(points_dict.get("last_5_results", ["⚪"] * 5))  # Default: 5 white circles
-                    users_data.append({'User': user, 'Points': points, "Last 5 Bids": last_5_results})
+                    bonus = bonus_map.get(user, 0)
+                    users_data.append({
+                        'User': user,
+                        'Points': points,
+                        'Last 5 Bids': last_5_results,
+                        'Redistribution Bonus': bonus
+                    })
             else:
-                data = load_users(USERS_JSON)
-                for user, points_dict in data.items():
-                    points = points_dict.get("points", 0)
-                    last_5_results = " ".join(points_dict.get("last_5_results", ["⚪"] * 5))  # Default: 5 white circles
-                    users_data.append({'User': user, 'Points': points, "Last 5 Bids": last_5_results})
+                st.warning("No leaderboard data found.")
 
             leaderboard = pd.DataFrame(users_data)
             
@@ -315,7 +391,7 @@ def display_leaderboard():
             leaderboard['Rank'] = range(1, len(leaderboard) + 1)
             
             # Select and order the columns for display
-            leaderboard = leaderboard[['Rank', 'User', 'Points', 'Last 5 Bids']]
+            leaderboard = leaderboard[['Rank', 'User', 'Points', 'Redistribution Bonus', 'Last 5 Bids']]
             
             st.dataframe(leaderboard, hide_index=True)
         except Exception as e: