eNotaryoPH/enotaryo-landing
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

new ConferenceSheduleService

Browse Source
This commit is contained in:
jojo aquino 2025-03-24 09:10:06 +00:00
parent 45f6a7ee6c
commit 3b621227cf
2 changed files with 174 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

163
EnotaryoPH/EnotaryoPH.Web/Common/Services/ConferenceSheduleService.cs Normal file
View File

@ -0,0 +1,163 @@
using Azure;
using Azure.Communication;
using Azure.Communication.CallAutomation;
using Azure.Communication.Identity;
using Azure.Communication.Rooms;
using EnotaryoPH.Data;
using EnotaryoPH.Data.Entities;
namespace EnotaryoPH.Web.Common.Services
{
public class ConferenceSheduleService : IConferenceSheduleService
{
private readonly NotaryoDBContext _dbContext;
private readonly CommunicationIdentityClient _communicationIdentityClient;
private readonly RoomsClient _roomsClient;
private readonly CallAutomationClient _callAutomationClient;
public ConferenceSheduleService(NotaryoDBContext dbContext, CommunicationIdentityClient communicationIdentityClient, RoomsClient roomsClient, CallAutomationClient callAutomationClient)
{
_dbContext = dbContext;
_communicationIdentityClient = communicationIdentityClient;
_roomsClient = roomsClient;
_callAutomationClient = callAutomationClient;
}
public async Task<Guid> GetOrCreateScheduleIDAsync(Guid transaction_UID)
{
if (transaction_UID == Guid.Empty)
{
return Guid.Empty;
}
var transactionEntity = _dbContext.Transactions
.Include(t => t.TransactionSignatories)
.FirstOrDefault(t => t.Transaction_UID == transaction_UID);
if (transactionEntity == null)
{
return Guid.Empty;
}
var existingSchedule = _dbContext.LawyerVideoConferenceSchedules.FirstOrDefault(sched => sched.TransactionID == transactionEntity.TransactionID);
if (existingSchedule != null)
{
return existingSchedule.LawyerVideoConferenceSchedule_UID;
}
var schedule_UID = Guid.Empty;
var isReadyForVideoCall = transactionEntity.TransactionSignatories.All(signatory => signatory.Status == nameof(SignatoryStatus.FaceMatch));
var isAcceptedByLawyer = transactionEntity.Status == nameof(TransactionState.Accepted) && transactionEntity.LawyerID > 0;
if (isReadyForVideoCall && isAcceptedByLawyer)
{
var schedule = _dbContext.LawyerVideoConferenceSchedules.FirstOrDefault(sched => sched.TransactionID == transactionEntity.TransactionID);
if (schedule == null)
{
var participants = transactionEntity.TransactionSignatories.ConvertAll(signatory => new LawyerVideoConferenceParticipant
{
CreatedOn = DateTime.UtcNow,
Status = nameof(VideoConferenceStatus.New),
LawyerVideoConferenceParticipant_UID = Guid.CreateVersion7(DateTime.UtcNow),
ParticipantID = signatory.UserID,
});
participants.Add(new LawyerVideoConferenceParticipant
{
CreatedOn = DateTime.UtcNow,
Status = nameof(VideoConferenceStatus.New),
LawyerVideoConferenceParticipant_UID = Guid.CreateVersion7(DateTime.UtcNow),
ParticipantID = transactionEntity.PrincipalID,
});
schedule = new LawyerVideoConferenceSchedule
{
LawyerVideoConferenceSchedule_UID = Guid.CreateVersion7(DateTime.UtcNow),
CreatedOn = DateTime.UtcNow,
LawyerID = transactionEntity.LawyerID.GetValueOrDefault(),
TransactionID = transactionEntity.TransactionID,
MeetingDate = DateTime.UtcNow,
Status = nameof(VideoConferenceStatus.New),
};
var roomParticipants = new List<RoomParticipant>();
foreach (var participant in participants)
{
var attendee = await _communicationIdentityClient.CreateUserAsync();
participant.MeetingRoomTokenID = await GetTokenResponseAsync(attendee);
participant.MeetingRoomUserID = attendee.Value.Id;
roomParticipants.Add(new RoomParticipant(attendee) { Role = ParticipantRole.Attendee });
}
var presenter = await _communicationIdentityClient.CreateUserAsync();
schedule.MeetingRoomTokenID = await GetTokenResponseAsync(presenter);
schedule.MeetingRoomUserID = presenter.Value.Id;
roomParticipants.Add(new RoomParticipant(presenter) { Role = ParticipantRole.Presenter });
CommunicationRoom room = await _roomsClient.CreateRoomAsync(DateTime.Now, DateTime.Now.AddHours(2), roomParticipants);
schedule.MeetingRoomID = room.Id;
schedule.LawyerVideoConferenceParticipants = participants.ToList();
if (schedule.LawyerVideoConferenceScheduleID == 0)
{
_dbContext.Add(schedule);
}
else
{
_dbContext.Update(schedule);
}
_dbContext.SaveChanges();
}
}
return schedule_UID;
}
public async Task StartRecordingAsync(Guid transaction_UID)
{
var transactionEntity = _dbContext.Transactions
.FirstOrDefault(t => t.Transaction_UID == transaction_UID) ?? throw new ArgumentException("Transaction not found.");
var existingSchedule = _dbContext.LawyerVideoConferenceSchedules.FirstOrDefault(sched => sched.TransactionID == transactionEntity.TransactionID) ?? throw new ArgumentException("Schedule not found.");
if (string.IsNullOrEmpty(existingSchedule.ServerCallID))
{
throw new ArgumentException("ServerCallID is not set for this transaction.");
}
if (!string.IsNullOrEmpty(existingSchedule.RecordingID))
{
return;
}
CallLocator callLocator = new ServerCallLocator(existingSchedule.ServerCallID);
var recordingResult = await _callAutomationClient.GetCallRecording().StartAsync(new StartRecordingOptions(callLocator) { RecordingStorage = RecordingStorage.CreateAzureBlobContainerRecordingStorage(new Uri("")) });
existingSchedule.RecordingID = recordingResult.Value.RecordingId;
_dbContext.Update(existingSchedule);
_dbContext.SaveChanges();
}
public async Task StopRecordingAsync(Guid transaction_UID)
{
var transactionEntity = _dbContext.Transactions
.FirstOrDefault(t => t.Transaction_UID == transaction_UID) ?? throw new ArgumentException("Transaction not found.");
var existingSchedule = _dbContext.LawyerVideoConferenceSchedules.FirstOrDefault(sched => sched.TransactionID == transactionEntity.TransactionID) ?? throw new ArgumentException("Schedule not found.");
if (string.IsNullOrEmpty(existingSchedule.ServerCallID))
{
throw new ArgumentException("ServerCallID is not set for this transaction.");
}
if (string.IsNullOrEmpty(existingSchedule.RecordingID))
{
throw new ArgumentException("Recording ID is not set for this transaction.");
}
CallLocator callLocator = new ServerCallLocator(existingSchedule.ServerCallID);
await _callAutomationClient.GetCallRecording().StopAsync(existingSchedule.RecordingID);
}
private async Task<string> GetTokenResponseAsync(Response<CommunicationUserIdentifier> user)
{
var tokenResponse = await _communicationIdentityClient.GetTokenAsync(user, new[] { CommunicationTokenScope.VoIP });
return tokenResponse.Value.Token;
}
}
}

11
EnotaryoPH/EnotaryoPH.Web/Common/Services/IConferenceSheduleService.cs Normal file
View File

@ -0,0 +1,11 @@
namespace EnotaryoPH.Web.Common.Services
{
public interface IConferenceSheduleService
{
Task<Guid> GetOrCreateScheduleIDAsync(Guid transaction_UID);
Task StartRecordingAsync(Guid transaction_UID);
Task StopRecordingAsync(Guid transaction_UID);
}
}