padelclub_backend/tournaments/views.py

from django.shortcuts import render, get_object_or_404
from django.http import HttpResponse
from django.utils.encoding import force_str
from django.utils.http import urlsafe_base64_encode, urlsafe_base64_decode
from django.urls import reverse

from django.views.decorators.csrf import csrf_exempt
from django.core.files.storage import default_storage
from django.core.files.base import ContentFile

from tournaments.models.device_token import DeviceToken

from .models import Court, DateInterval, Club, Tournament, CustomUser, Event, Round, GroupStage, Match, TeamScore, TeamRegistration, PlayerRegistration, Purchase, FailedApiCall
from .models import TeamSummon
from datetime import datetime, timedelta
import time

from django.template import loader
from datetime import date
from django.http import JsonResponse, HttpResponse
from django.db.models import Q
import json
import asyncio
import csv

from api.tokens import account_activation_token

from qr_code.qrcode.utils import QRCodeOptions
from .utils.apns import send_push_notification
import os

from .forms import SimpleForm
from django.core.mail import EmailMessage
from datetime import timedelta
from django.utils import timezone
from django.shortcuts import render, redirect
from django.contrib.auth.forms import UserCreationForm
from django.contrib.auth import login

from django.urls import reverse
from django.contrib import messages
from .forms import TournamentRegistrationForm, AddPlayerForm

from .utils.licence_validator import LicenseValidator
from .utils.player_search import get_player_name_from_csv

from django.contrib.auth.decorators import login_required
from .forms import SimpleCustomUserCreationForm
from django.contrib.sites.shortcuts import get_current_site
from django.template.loader import render_to_string
from django.utils.http import urlsafe_base64_encode, urlsafe_base64_decode
from django.utils.encoding import force_bytes

def index(request):

    club_id = request.GET.get('club')
    future = future_tournaments(club_id)
    live = live_tournaments(club_id)
    finished = finished_tournaments(club_id)

    club = None
    if club_id:
        club = get_object_or_404(Club, pk=club_id)

    return render(
        request,
        "tournaments/tournaments.html",
        {
            'future': future[:10],
            'live': live[:10],
            'ended': finished[:10],
            'club': club,
        }
    )

def tournaments_query(query, club_id, ascending):
    queries = [query, Q(is_private=False, is_deleted=False, event__club__isnull=False)]

    club = None
    if club_id:
        club = get_object_or_404(Club, pk=club_id)
        q_club = Q(event__club=club)
        queries.append(q_club)

    sortkey = 'start_date'
    if not ascending:
        sortkey = '-start_date'
    return Tournament.objects.filter(*queries).order_by(sortkey)

def finished_tournaments(club_id):
    ended_tournaments = tournaments_query(Q(end_date__isnull=False), club_id, False)
    return [t for t in ended_tournaments if t.display_tournament()]

def live_tournaments(club_id):
    tournaments = tournaments_query(Q(end_date__isnull=True), club_id, True)
    return [t for t in tournaments if t.display_tournament() and t.supposedly_in_progress()]

def future_tournaments(club_id):
    tomorrow = datetime.now().date() + timedelta(days=1)
    tournaments = tournaments_query(Q(end_date__isnull=True, start_date__gte=tomorrow), club_id, True)
    return [t for t in tournaments if t.display_tournament()]

def tournament_info(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    is_registered = False

    if request.user.is_authenticated:
        # Assuming user's licence_id is stored in the user profile (e.g., request.user.profile.licence_id)
        user_licence_id = request.user.licence_id
        # Check if there is a PlayerRegistration for this user in this tournament
        is_registered = PlayerRegistration.objects.filter(
            licence_id__startswith=user_licence_id,
            team_registration__tournament=tournament
        ).exists()

    return render(request, 'tournaments/tournament_info.html', {
        'tournament': tournament,
        'is_registered': is_registered,
    })


def tournaments(request):

    filter = int(request.GET.get('filter'))
    club_id = request.GET.get('club')

    title = ''
    tournaments = []
    if filter==0:
        title = 'À venir'
        tournaments = future_tournaments(club_id)
    elif filter==1:
        title = 'En cours'
        tournaments = live_tournaments(club_id)
    elif filter==2:
        title = 'Terminés'
        tournaments = finished_tournaments(club_id)

    return render(
        request,
        "tournaments/tournaments_list.html",
        {
            'tournaments': tournaments,
            'title': title,
            'club': club_id,
        }
    )

def clubs(request):
    all_clubs = Club.objects.all().order_by('name')
    clubs = []
    for club in all_clubs:
        if club.events_count() > 0:
            clubs.append(club)

    return render(request, 'tournaments/clubs.html', {
        'clubs': clubs,
    })

def club(request, club_id):
    club = get_object_or_404(Club, pk=club_id)
    return render(request, 'tournaments/summons.html', {
        'tournament': tournament,
        'team_summons': team_summons,
    })

def tournament(request, tournament_id):

    tournament = get_object_or_404(Tournament, pk=tournament_id)

    round_id = request.GET.get('round')
    group_stage_id = request.GET.get('group_stage')
    match_groups = tournament.match_groups(False, group_stage_id, round_id)


    bracket_rounds = tournament.round_set.filter(parent=None, group_stage_loser_bracket=False).order_by('-index')
    rounds = list(tournament.round_set.filter(group_stage_loser_bracket=True))
    rounds.extend(bracket_rounds)

    group_stages = sorted(tournament.get_computed_group_stage(), key=lambda s: (s.step, s.index))

    if tournament.display_matches() or tournament.display_group_stages():
        return render(request, 'tournaments/matches.html', {
            'tournament': tournament,
            'rounds': rounds,
            'group_stages': group_stages,
            'match_groups': match_groups,
        })
    else:
        return tournament_info(request, tournament_id)

def tournament_teams(request, tournament_id):

    tournament = get_object_or_404(Tournament, pk=tournament_id)
    teams = tournament.teams(True)

    return render(request, 'tournaments/teams.html', {
        'tournament': tournament,
        'teams': teams,
    })

def tournament_summons(request, tournament_id):

    tournament = get_object_or_404(Tournament, pk=tournament_id)
    team_summons = tournament.team_summons()

    return render(request, 'tournaments/summons.html', {
        'tournament': tournament,
        'team_summons': team_summons,
    })

def tournament_broadcasted_summons(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    return render(request, 'tournaments/broadcast/broadcasted_summons.html', {
        'tournament': tournament,
        'qr_code_url': qr_code_url(request, tournament_id),
        'qr_code_options': qr_code_options(),
    })

def tournament_summons_json(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    team_summons = [summon.to_dict() for summon in tournament.team_summons()]
    data = json.dumps(team_summons)
    return HttpResponse(data, content_type='application/json')

def tournament_broadcast_home(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    return render(request, 'tournaments/broadcast/broadcast.html', {
        'tournament': tournament,
        'qr_code_url': qr_code_url(request, tournament_id),
        'qr_code_options': qr_code_options(),
    })

def automatic_broadcast(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    return render(request, 'tournaments/broadcast/broadcasted_auto.html', {
        'tournament': tournament,
        'qr_code_url': qr_code_url(request, tournament_id),
        'qr_code_options': qr_code_options(),
    })

def automatic_broadcast_event(request, event_id):
    event = get_object_or_404(Event, pk=event_id)
    tournaments = Tournament.objects.filter(event=event)
    tournament_ids = [str(tournament.id) for tournament in tournaments]
    return render(request, 'tournaments/broadcast/broadcasted_auto_event.html', {
        'tournament_ids': tournament_ids,
    })

def qr_code_url(request, tournament_id):
    qr_code_url = reverse('tournament', args=[tournament_id])
    return request.build_absolute_uri(qr_code_url)

def qr_code_url_with_query(request, club_id):
    url_with_query = f"{request.build_absolute_uri('/')}?club={str(club_id)}"
    return url_with_query

def qr_code_options():
    return QRCodeOptions(size=10, border=4, error_correction='L')

def tournament_matches(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    return render(request, 'tournaments/broadcast/broadcasted_matches.html', {
        'tournament': tournament,
        'qr_code_url': qr_code_url(request, tournament_id),
        'qr_code_options': qr_code_options(),
    })

def broadcast_json(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    broadcast = tournament.broadcast_content()
    data = json.dumps(broadcast)
    return HttpResponse(data, content_type='application/json')

def tournament_matches_json(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    matches, group_stages = tournament.broadcasted_matches_and_group_stages()
    live_matches = [match.live_match() for match in matches]

    data = json.dumps(live_matches, default=vars)
    return HttpResponse(data, content_type='application/json')

def tournament_group_stages(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    live_group_stages = list(tournament.live_group_stages())
    unique_steps = sorted(set(gs.step for gs in live_group_stages), reverse=True)

    return render(request, 'tournaments/group_stages.html', {
        'tournament': tournament,
        'group_stages': live_group_stages,
        'unique_steps': unique_steps,
    })

def tournament_broadcasted_group_stages(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    return render(request, 'tournaments/broadcast/broadcasted_group_stages.html', {
        'tournament': tournament,
        'qr_code_url': qr_code_url(request, tournament_id),
        'qr_code_options': qr_code_options(),
    })

def tournament_live_group_stage_json(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)

    # Get all live group stages and filter for the last running step
    live_group_stages = [gs.live_group_stages() for gs in tournament.last_group_stage_step()]

    gs_dicts = [gs.to_dict() for gs in live_group_stages]
    data = json.dumps(gs_dicts)
    return HttpResponse(data, content_type='application/json')

def tournament_rankings(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    rankings = tournament.rankings()

    return render(request, 'tournaments/rankings.html', {
        'tournament': tournament,
        'rankings': rankings,
    })

def tournament_rankings_json(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    rankings = tournament.rankings()

    data = json.dumps(rankings, default=vars)
    return HttpResponse(data, content_type='application/json')

def tournament_broadcast_rankings(request, tournament_id):
    tournament = get_object_or_404(Tournament, pk=tournament_id)
    return render(request, 'tournaments/broadcast/broadcasted_rankings.html', {
        'tournament': tournament,
        'qr_code_url': qr_code_url(request, tournament_id),
        'qr_code_options': qr_code_options(),
    })

def players(request):
    return render(request, 'tournaments/test.html')

def activate(request, uidb64, token):
    try:
        uid = force_str(urlsafe_base64_decode(uidb64))
        user = CustomUser.objects.get(pk=uid)
    except(TypeError, ValueError, OverflowError, CustomUser.DoesNotExist):
        user = None
    if user is not None and account_activation_token.check_token(user, token):
        user.is_active = True
        user.save()
        login(request, user)
        return redirect('index')  # Redirect to the homepage or any other page you prefer
    else:
        return HttpResponse('Le lien est invalide.')

def club_broadcast(request, broadcast_code):
    club = get_object_or_404(Club, broadcast_code=broadcast_code)
    q_not_deleted = Q(is_deleted=False, event__club=club)
    tournaments = Tournament.objects.filter(q_not_deleted).order_by('-start_date')

    return render(request, 'tournaments/broadcast/broadcast_club.html', {
        'club': club,
        'tournaments': tournaments,
    })

def club_broadcast_auto(request, broadcast_code):
    club = get_object_or_404(Club, broadcast_code=broadcast_code)
    q_not_deleted = Q(is_deleted=False, event__club=club)
    now = timezone.now().replace(hour=0, minute=0, second=0, microsecond=0)

    recent_time_window = now - timedelta(hours=4)

    tournaments = Tournament.objects.filter(
        q_not_deleted,
        Q(is_private=False),  # Exclude private tournaments
        (
            (
                Q(end_date__isnull=True) &  # Include ongoing tournaments
                (Q(start_date__gte=now - timedelta(days=3)) & Q(start_date__lt=now + timedelta(days=3)))  # Include tournaments that are ongoing and start within 3 days
            ) |
            (Q(end_date__isnull=False) & Q(end_date__gte=recent_time_window))  # Include tournaments finished within the last 4 hours
        )
    )

    tournament_ids = [str(tournament.id) for tournament in tournaments]
    #print(tournament_ids)
    return render(request, 'tournaments/broadcast/broadcasted_auto_event.html', {
        'tournament_ids': tournament_ids,
        'club_name': club.name,
        'qr_code_url': qr_code_url_with_query(request, club.id),
        'qr_code_options': qr_code_options(),

    })

def download(request):
    return render(request, 'tournaments/download.html')

def test_apns(request):
    token = DeviceToken.objects.first()

    asyncio.run(send_push_notification(token.value, 'hello!'))

    return HttpResponse('OK!')

def test_websocket(request):
    return render(request, 'tournaments/test_websocket.html')

def terms_of_use(request):
    return render(request, 'terms_of_use.html')

import pandas as pd
from .utils.extensions import create_random_filename

@csrf_exempt
def xls_to_csv(request):
    if request.method == 'POST':
        # Check if the request has a file
        if 'file' in request.FILES:
            uploaded_file = request.FILES['file']

            # Save the uploaded file
            directory = 'tmp/csv/'
            file_path = os.path.join(directory, uploaded_file.name)
            file_name = default_storage.save(file_path, ContentFile(uploaded_file.read()))

            # convert to csv and save
            data_xls = pd.read_excel(file_name, sheet_name=0, index_col=None)
            csv_file_name = create_random_filename('players', 'csv')
            output_path = os.path.join(directory, csv_file_name)
            data_xls.to_csv(output_path, sep=';', index=False, encoding='utf-8')

            # Send the processed file back
            with default_storage.open(output_path, 'rb') as file:
                response = HttpResponse(file.read(), content_type='application/octet-stream')
                response['Content-Disposition'] = f'attachment; filename="players.csv"'

            # Clean up: delete both files
            default_storage.delete(file_path)
            default_storage.delete(output_path)

            return response
        else:
            return HttpResponse("No file was uploaded", status=400)
    else:
        return HttpResponse("Only POST requests are allowed", status=405)


def simple_form_view(request):

    if request.method == 'POST':
        # If this is a POST request, we need to process the form data
        form = SimpleForm(request.POST)
        if form.is_valid():
            # Process the data in form.cleaned_data
            name = form.cleaned_data['name']
            # Do something with the data (e.g., save to the database)
            send_email_to_jap_list()
            # send_email('laurent@staxriver.com', 'Laurent')
            return HttpResponse(f"Hello, {name}!")  # Simple response with name
    else:
        form = SimpleForm()
        # print(request.method)
        # If this is a GET request, we display an empty form

    return render(request, 'tournaments/admin/mail_test.html', {'form': form})

def send_email_to_jap_list():

    # Open the CSV file
    with open('tournaments/static/misc/jap-test.csv', 'r') as file:
        csv_reader = csv.reader(file)

        def log_error(message):
            with open('email_errors.log', 'a') as log_file:
                timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
                log_file.write(f"{timestamp}: {message}\n")

        batch = []
        for row in csv_reader:
            if len(row) >= 4:
                name = row[2]
                mail = row[3]
                batch.append((mail, name))

                if len(batch) == 10:
                    for email, recipient_name in batch:
                        try:
                            send_email(email, recipient_name)
                            print(f"Name: {recipient_name}, mail: {email}")
                        except Exception as e:
                            error_message = f"Error sending email to {email}: {str(e)}"
                            log_error(error_message)
                            print(error_message)

                    batch = []
                    time.sleep(2)
            else:
                print(f"Row doesn't have enough elements: {row}")

        # Send any remaining emails in the last batch
        for email, recipient_name in batch:
            try:
                send_email(email, recipient_name)
                print(f"Name: {recipient_name}, mail: {email}")
            except Exception as e:
                error_message = f"Error sending email to {email}: {str(e)}"
                log_error(error_message)
                print(error_message)


def send_email(mail, name):
    if name.lower() not in mail.lower():
        name = ""

    subject = "Tes tournois en toute simplicité avec Padel Club"
    body = f"Salut {name} !\n\nJe me permets de t'écrire car je suis JAP2 en région PACA et développeur, et je viens de lancer Padel Club, une app iOS qui facilite enfin l'organisation des tournois.\n\nAvec elle, tu peux convoquer rapidement, simuler et programmer tes structures, diffuser tous les résultats à tous les joueurs, et ce depuis un iPhone.\n\nTu peux l'essayer gratuitement pour découvrir tout son potentiel ! Télécharge l'app ici et teste la dès ton prochain tournoi: https://padelclub.app/download/\n\nJe suis disponible pour échanger avec toi par mail ou téléphone au 06 81 59 81 93 et voir ce que tu en penses.\nÀ bientôt j'espère !\n\nRazmig"

    email = EmailMessage(subject, body, to=[mail])
    email.send()

@csrf_exempt
def signup(request):
    if request.method == 'POST':
        form = SimpleCustomUserCreationForm(request.POST)
        if form.is_valid():
            user = form.save(commit=False)
            user.is_active = False  # Deactivate account until email is verified
            user.save()

            # Send verification email
            send_verification_email(request, user)
            request.session['pre_login_username'] = user.username
            request.session['pre_login_password'] = user.password  # Store hashed password, or handle with caution

            messages.success(request, "Votre compte a été créé ! Veuillez vérifier votre e-mail pour confirmer votre compte.")
            return redirect('login')  # Redirect to login page or a custom message page
    else:
        form = SimpleCustomUserCreationForm()
    return render(request, 'registration/signup.html', {'form': form})

def send_verification_email(request, user):

    current_site = get_current_site(request)
    mail_subject = 'Activez votre compte Padel Club !'
    message = render_to_string('tournaments/acc_active_email.html', {
        'user': user,
        'domain': current_site.domain,
        'uid': urlsafe_base64_encode(force_bytes(user.pk)),
        'token': account_activation_token.make_token(user),
    })
    email = EmailMessage(mail_subject, message, to=[user.email])
    email.send()

@login_required
def profile(request):
    user = request.user  # Get the currently authenticated user

    # Query tournaments where the user is registered
    tournaments = Tournament.objects.all()

    return render(request, 'registration/profile.html', {
        'tournaments': tournaments,
        'user_name': user.username
    })

def register_tournament(request, tournament_id):
    tournament = get_object_or_404(Tournament, id=tournament_id)
    registration_successful = False  # Flag for registration status
    team_form = None
    add_player_form = None

    # Process forms
    if request.method == 'POST':
        team_form = TournamentRegistrationForm(request.POST)
        add_player_form = AddPlayerForm(request.POST)
        # Check if the add player form is submitted
        if 'add_player' in request.POST and add_player_form.is_valid():
            player_data = add_player_form.cleaned_data

            # Validate the license ID before adding the player
            licence_id = player_data['licence_id'].upper()

            # Instantiate your custom validator and validate the license ID
            validator = LicenseValidator(licence_id)

            if validator.validate_license() is False:
                messages.error(request, f"Le numéro de licence est invalide, la lettre ne correspond pas. {validator.computed_license_key}")
                return render(request, 'register_tournament.html', {
                    'team_form': team_form,
                    'add_player_form': add_player_form,
                    'tournament': tournament,
                    'registration_successful': registration_successful,
                    'current_players': request.session['team_registration'],
                })

            # Check if the player with the same licence_id already exists in the session
            existing_players = [player['licence_id'] for player in request.session['team_registration']]
            if licence_id in existing_players:
                messages.error(request, 'This player is already added to the team.')
                return render(request, 'register_tournament.html', {
                    'team_form': team_form,
                    'add_player_form': add_player_form,
                    'tournament': tournament,
                    'registration_successful': registration_successful,
                    'current_players': request.session['team_registration'],
                })
            else:
                # Check if a PlayerRegistration with the same licence_id already exists in the database
                stripped_license = validator.stripped_license
                if validate_license_id(stripped_license, tournament):
                    messages.error(request, 'A player with this licence ID is already registered in a team.')
                    return render(request, 'register_tournament.html', {
                        'team_form': team_form,
                        'add_player_form': add_player_form,
                        'tournament': tournament,
                        'registration_successful': registration_successful,
                        'current_players': request.session['team_registration'],
                    })
                elif add_player_form.names_is_valid():
                    request.session['team_registration'].append(player_data)
                    request.session.modified = True  # Ensure session is updated
                else:
                    if add_player_form.first_tournament is False:
                        # Retrieve player names from the CSV file
                        first_name, last_name = get_player_name_from_csv(licence_id)
                        if first_name and last_name:
                            player_data['first_name'] = first_name
                            player_data['last_name'] = last_name
                            # If validation passes, add the player to the session without clearing previous ones
                            request.session['team_registration'].append(player_data)
                            request.session.modified = True  # Ensure session is updated
                        else:
                            add_player_form.first_tournament = True



        # Check if the team registration form is valid and finalize the registration
        elif 'register_team' in request.POST and team_form.is_valid():
            team_registration = TeamRegistration.objects.create(
                tournament=tournament,
                registration_date=timezone.now()
            )
            # Create PlayerRegistration objects for each player in the session
            for player_data in request.session['team_registration']:
                player_registration = PlayerRegistration.objects.create(
                    team_registration=team_registration,
                    first_name=player_data['first_name'],
                    last_name=player_data['last_name'],
                    licence_id=player_data['licence_id'],
                    email = player_data.get('email', None),
                    phone_number = player_data.get('phone_number', None)
                )

            request.session['team_registration'] = []
            registration_successful = True
    else:
        request.session['team_registration'] = []
        initial_data = {}
        # Add the authenticated user to the session as the first player if not already added
        if request.user.is_authenticated:
            initial_data = {
                'email': request.user.email,
                'phone': request.user.phone,
            }
            existing_players = [player['licence_id'] for player in request.session['team_registration']]
            if request.user.licence_id not in existing_players:
                # Add the authenticated user as the first player in the session
                player_data = {
                    'first_name': request.user.first_name,
                    'last_name': request.user.last_name.upper(),
                    'email': request.user.email,
                    'phone': request.user.phone,
                    'licence_id': request.user.licence_id,
                }
                request.session['team_registration'].insert(0, player_data)  # Add them as the first player
                request.session.modified = True  # Ensure session is updated

        team_form = TournamentRegistrationForm(initial=initial_data)
        add_player_form = AddPlayerForm()

    return render(request, 'register_tournament.html', {
        'team_form': team_form,
        'add_player_form': add_player_form,
        'tournament': tournament,
        'registration_successful': registration_successful,
        'current_players': request.session['team_registration'],
    })




@login_required
def unregister_tournament(request, tournament_id):
    user_licence_id = request.user.licence_id
    player_registration = PlayerRegistration.objects.filter(
        licence_id__startswith=user_licence_id,
        team_registration__tournament_id=tournament_id
    ).first()  # Get the first match, if any

    if player_registration:
        team_registration = player_registration.team_registration  # Get the related TeamRegistration
        team_registration.delete()  # Delete the team registration

    request.session['team_registration'] = []

    return redirect('tournament-info', tournament_id=tournament_id)

def validate_license_id(licence_id, tournament):
    teams = TeamRegistration.objects.filter(tournament=tournament)

    # Check if any player in any team in the tournament already has this licence_id
    # Normalize the licence ID before querying
    # Loop through each team and check if any of its players has the same licence_id
    for team in teams:
        for player in team.playerregistration_set.all():
            if player.licence_id.startswith(licence_id):
                return True

    # If all checks pass, return True (you can add further logic here if needed)
    return False