erp-platform/api/src/Kurs.Platform.HttpApi.Host/Classroom/ClassroomHub.cs

using System;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.SignalR;
using Volo.Abp.Domain.Repositories;
using Kurs.Platform.Entities;
using Microsoft.Extensions.Logging;
using Volo.Abp.Guids;
using Volo.Abp.Users;

namespace Kurs.Platform.SignalR.Hubs;

[Authorize]
public class ClassroomHub : Hub
{
    private readonly IRepository<Classroom, Guid> _classSessionRepository;
    private readonly IRepository<ClassroomParticipant, Guid> _participantRepository;
    private readonly IRepository<ClassroomChat, Guid> _chatMessageRepository;
    private readonly IRepository<ClassroomAttandance, Guid> _attendanceRepository;
    private readonly ILogger<ClassroomHub> _logger;
    private readonly IGuidGenerator _guidGenerator;
    private readonly ICurrentUser _currentUser;

    public ClassroomHub(
        IRepository<Classroom, Guid> classSessionRepository,
        IRepository<ClassroomParticipant, Guid> participantRepository,
        IRepository<ClassroomChat, Guid> chatMessageRepository,
        IRepository<ClassroomAttandance, Guid> attendanceRepository,
        ILogger<ClassroomHub> logger,
        IGuidGenerator guidGenerator,
        ICurrentUser currentUser)
    {
        _classSessionRepository = classSessionRepository;
        _participantRepository = participantRepository;
        _chatMessageRepository = chatMessageRepository;
        _attendanceRepository = attendanceRepository;
        _logger = logger;
        _guidGenerator = guidGenerator;
        _currentUser = currentUser;
    }

    [HubMethodName("JoinClass")]
    public async Task JoinClassAsync(Guid sessionId, Guid userId, string userName, bool isTeacher)
    {
        var participant = await _participantRepository.FirstOrDefaultAsync(
            x => x.SessionId == sessionId && x.UserId == userId
        );

        if (participant == null)
        {
            participant = new ClassroomParticipant(
                _guidGenerator.Create(),
                sessionId,
                userId,
                userName,
                isTeacher
            );
            participant.UpdateConnectionId(Context.ConnectionId);
            await _participantRepository.InsertAsync(participant, autoSave: true);

            // 🔑 Katılımcı sayısını güncelle
            var classroom = await _classSessionRepository.GetAsync(sessionId);
            var participantCount = await _participantRepository.CountAsync(x => x.SessionId == sessionId);
            classroom.ParticipantCount = participantCount;
            await _classSessionRepository.UpdateAsync(classroom, autoSave: true);
        }
        else
        {
            participant.UpdateConnectionId(Context.ConnectionId);
            await _participantRepository.UpdateAsync(participant, autoSave: true);
        }

        // 🔑 Attendance kaydı aç
        var attendance = new ClassroomAttandance(
            _guidGenerator.Create(),
            sessionId,
            userId,
            userName,
            DateTime.UtcNow
        );
        await _attendanceRepository.InsertAsync(attendance, autoSave: true);

        await Groups.AddToGroupAsync(Context.ConnectionId, sessionId.ToString());

        await Clients.Group(sessionId.ToString())
            .SendAsync("ParticipantJoined", userId, userName);
    }


    [HubMethodName("LeaveClass")]
    public async Task LeaveClassAsync(Guid sessionId)
    {
        await Groups.RemoveFromGroupAsync(Context.ConnectionId, sessionId.ToString());

        var userId = _currentUser.Id;
        if (userId.HasValue)
        {
            var attendance = await _attendanceRepository.FirstOrDefaultAsync(
                x => x.SessionId == sessionId && x.StudentId == userId.Value && x.LeaveTime == null
            );

            if (attendance != null)
            {
                attendance.LeaveTime = DateTime.UtcNow;
                attendance.TotalDurationMinutes = (int)Math.Max(
                    1,
                    (attendance.LeaveTime.Value - attendance.JoinTime).TotalMinutes
                );
                await _attendanceRepository.UpdateAsync(attendance, autoSave: true);

                await Clients.Group(sessionId.ToString())
                    .SendAsync("AttendanceUpdated", attendance);
            }
        }

        await Clients.Group(sessionId.ToString())
            .SendAsync("ParticipantLeft", _currentUser);
        _logger.LogInformation($"User {_currentUser} left class {sessionId}");
    }

    [HubMethodName("MuteParticipant")]
    public async Task MuteParticipantAsync(Guid sessionId, Guid userId, bool isMuted, bool isTeacher)
    {
        var teacherParticipant = await _participantRepository.FirstOrDefaultAsync(
            x => x.SessionId == sessionId && x.UserId == _currentUser.Id
        );

        if (teacherParticipant?.IsTeacher != true)
        {
            await Clients.Caller.SendAsync("Error", "Only teachers can mute participants");
            return;
        }

        var participant = await _participantRepository.FirstOrDefaultAsync(
            x => x.SessionId == sessionId && x.UserId == userId
        );

        if (participant != null)
        {
            if (isMuted) participant.MuteAudio();
            else participant.UnmuteAudio();

            await _participantRepository.UpdateAsync(participant, autoSave: true);

            await Clients.Group(sessionId.ToString())
                .SendAsync("ParticipantMuted", userId, isMuted);
        }
    }

    [HubMethodName("SendChatMessage")]
    public async Task SendChatMessageAsync(
        Guid sessionId,
        Guid senderId,
        string senderName,
        string message,
        bool isTeacher,
        string messageType)
    {
        // Save message to DB
        var chatMessage = new ClassroomChat(
            _guidGenerator.Create(),
            sessionId,
            senderId,
            senderName,
            message,
            null,
            null,
            isTeacher,
            messageType
        );

        await _chatMessageRepository.InsertAsync(chatMessage, autoSave: true);

        // Broadcast to group
        await Clients.Group(sessionId.ToString()).SendAsync("ChatMessage", new
        {
            Id = chatMessage.Id,
            SenderId = senderId,
            SenderName = senderName,
            Message = chatMessage.Message,
            Timestamp = chatMessage.Timestamp,
            IsTeacher = isTeacher,
            MessageType = messageType
        });
    }

    [HubMethodName("SendPrivateMessage")]
    public async Task SendPrivateMessageAsync(
        Guid sessionId,
        Guid senderId,
        string senderName,
        string message,
        Guid recipientId,
        string recipientName,
        bool isTeacher,
        string messageType)
    {
        // Save message to DB
        var chatMessage = new ClassroomChat(
            _guidGenerator.Create(),
            sessionId,
            senderId,
            senderName,
            message,
            recipientId,
            recipientName,
            isTeacher,
            "private"
        );

        await _chatMessageRepository.InsertAsync(chatMessage, autoSave: true);

        await Clients.User(recipientId.ToString()).SendAsync("ChatMessage", new
        {
            Id = Guid.NewGuid(),
            SenderId = senderId,
            SenderName = senderName,
            Message = message,
            Timestamp = DateTime.UtcNow,
            IsTeacher = isTeacher,
            RecipientId = recipientId,
            RecipientName = recipientName,
            MessageType = "private"
        });

        await Clients.Caller.SendAsync("ChatMessage", new
        {
            Id = Guid.NewGuid(),
            SenderId = senderId,
            SenderName = senderName,
            Message = message,
            Timestamp = DateTime.UtcNow,
            IsTeacher = isTeacher,
            RecipientId = recipientId,
            RecipientName = recipientName,
            MessageType = "private"
        });
    }

    [HubMethodName("SendAnnouncement")]
    public async Task SendAnnouncementAsync(Guid sessionId, Guid senderId, string senderName, string message, bool isTeacher)
    {
        // Save message to DB
        var chatMessage = new ClassroomChat(
            _guidGenerator.Create(),
            sessionId,
            senderId,
            senderName,
            message,
            null,
            null,
            isTeacher,
            "announcement"
        );

        await _chatMessageRepository.InsertAsync(chatMessage, autoSave: true);

        await Clients.Group(sessionId.ToString()).SendAsync("ChatMessage", new
        {
            Id = Guid.NewGuid(),
            SenderId = senderId,
            SenderName = senderName,
            Message = message,
            Timestamp = DateTime.UtcNow,
            IsTeacher = isTeacher,
            MessageType = "announcement"
        });
    }

    [HubMethodName("RaiseHand")]
    public async Task RaiseHandAsync(Guid sessionId, Guid studentId, string studentName)
    {
        // 🔑 Participant'ı bul
        var participant = await _participantRepository.FirstOrDefaultAsync(
            x => x.SessionId == sessionId && x.UserId == studentId
        );

        if (participant != null)
        {
            participant.IsHandRaised = true;
            await _participantRepository.UpdateAsync(participant, autoSave: true);
        }

        await Clients.Group(sessionId.ToString()).SendAsync("HandRaiseReceived", new
        {
            Id = Guid.NewGuid(),
            StudentId = studentId,
            StudentName = studentName,
            Timestamp = DateTime.UtcNow,
            IsActive = true
        });
    }

    [HubMethodName("KickParticipant")]
    public async Task KickParticipantAsync(Guid sessionId, Guid participantId)
    {
        // Attendance kapat
        var attendance = await _attendanceRepository.FirstOrDefaultAsync(
            x => x.SessionId == sessionId && x.StudentId == participantId && x.LeaveTime == null
        );

        if (attendance != null)
        {
            attendance.LeaveTime = DateTime.UtcNow;
            attendance.TotalDurationMinutes = (int)Math.Max(
                1,
                (attendance.LeaveTime.Value - attendance.JoinTime).TotalMinutes
            );

            await _attendanceRepository.UpdateAsync(attendance, autoSave: true);

            // Katılım güncellemesini yayınla
            await Clients.Group(sessionId.ToString()).SendAsync("AttendanceUpdated", new
            {
                attendance.Id,
                attendance.SessionId,
                attendance.StudentId,
                attendance.StudentName,
                attendance.JoinTime,
                attendance.LeaveTime,
                attendance.TotalDurationMinutes
            });
        }

        // Katılımcı çıkışını bildir
        await Clients.Group(sessionId.ToString()).SendAsync("ParticipantLeft", participantId);
    }

    [HubMethodName("ApproveHandRaise")]
    public async Task ApproveHandRaiseAsync(Guid sessionId, Guid studentId)
    {
        // 🔑 Öğrencinin parmak kaldırma durumunu sıfırla
        var participant = await _participantRepository.FirstOrDefaultAsync(
            x => x.SessionId == sessionId && x.UserId == studentId
        );

        if (participant != null)
        {
            participant.IsHandRaised = false;
            await _participantRepository.UpdateAsync(participant, autoSave: true);
        }

        await Clients.Group(sessionId.ToString()).SendAsync("HandRaiseDismissed", new { studentId });
    }

    [HubMethodName("DismissHandRaise")]
    public async Task DismissHandRaiseAsync(Guid sessionId, Guid studentId)
    {
        // 🔑 Participant'ı bul ve elini indir
        var participant = await _participantRepository.FirstOrDefaultAsync(
            x => x.SessionId == sessionId && x.UserId == studentId
        );

        if (participant != null)
        {
            participant.IsHandRaised = false;
            await _participantRepository.UpdateAsync(participant, autoSave: true);
        }

        await Clients.Group(sessionId.ToString()).SendAsync("HandRaiseDismissed", new { studentId });
    }

    public override async Task OnDisconnectedAsync(Exception exception)
    {
        try
        {
            if (Context.ConnectionAborted.IsCancellationRequested)
                return;

            var userId = _currentUser.Id;
            if (userId.HasValue)
            {
                // 🔑 1. Katılımcı listesi
                var participants = await _participantRepository
                    .GetListAsync(x => x.UserId == userId.Value && x.ConnectionId == Context.ConnectionId);

                foreach (var participant in participants)
                {
                    // 🔑 2. Attendance kaydını kapat
                    var attendance = await _attendanceRepository.FirstOrDefaultAsync(
                        x => x.SessionId == participant.SessionId &&
                             x.StudentId == userId.Value &&
                             x.LeaveTime == null
                    );

                    if (attendance != null)
                    {
                        attendance.LeaveTime = DateTime.UtcNow;
                        attendance.TotalDurationMinutes = (int)Math.Max(
                            1,
                            (attendance.LeaveTime.Value - attendance.JoinTime).TotalMinutes
                        );

                        await _attendanceRepository.UpdateAsync(attendance, autoSave: true);

                        // Frontend’e bildir
                        await Clients.Group(participant.SessionId.ToString())
                            .SendAsync("AttendanceUpdated", new
                            {
                                attendance.Id,
                                attendance.SessionId,
                                attendance.StudentId,
                                attendance.StudentName,
                                attendance.JoinTime,
                                attendance.LeaveTime,
                                attendance.TotalDurationMinutes
                            });
                    }

                    // 🔑 3. ParticipantLeft event’i
                    await Clients.Group(participant.SessionId.ToString())
                        .SendAsync("ParticipantLeft", userId.Value);
                }
            }
        }
        catch (TaskCanceledException)
        {
            _logger.LogDebug("OnDisconnectedAsync iptal edildi (connection aborted).");
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "OnDisconnectedAsync hata");
        }

        await base.OnDisconnectedAsync(exception);
    }
}

public class SignalingMessageDto
{
    public string Type { get; set; } // offer, answer, ice-candidate
    public string FromUserId { get; set; }
    public string ToUserId { get; set; }
    public object Data { get; set; }
}