Skip to content

Call automation version changed to 1.4.0 and made required changes. #223

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 4 commits into
base: users/v-dharmarajv/CallAutomationTestApplication
Choose a base branch
from
Draft

Call automation version changed to 1.4.0 and made required changes. #223

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
1df9af0
Call automation version changed to 1.4.0 and made required changes.
v-pivamshi Jun 20, 2025
9ce0857
Added cognitive service.
v-pivamshi Jun 20, 2025
62caf0b
CognitiveServiceEndpoint change
v-pivamshi Jun 20, 2025
2f6a43f
Removed CognitiveServiceEndpoint changes.
v-pivamshi Jun 23, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
290 changes: 126 additions & 164 deletions Call_Automation_GCCH/Call_Automation_GCCH/CallAutomationService.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,174 +1,136 @@
using Azure.Communication.CallAutomation;
using Call_Automation_GCCH.Controllers;
using Microsoft.Extensions.Logging;

namespace Call_Automation_GCCH.Services
{
public class CallAutomationService
{
private CallAutomationClient _client;
private ILogger<CallAutomationService> _logger;
private static string? _recordingLocation;
private static string _recordingFileFormat = "mp4";
private string _currentPmaEndpoint = string.Empty;

public CallAutomationService(string connectionString, string pmaEndpoint, ILogger<CallAutomationService> logger)
public class CallAutomationService
{
_logger = logger ?? throw new ArgumentNullException(nameof(logger));
_currentPmaEndpoint = pmaEndpoint;

if (!string.IsNullOrEmpty(pmaEndpoint))
{
_client = new CallAutomationClient(pmaEndpoint: new Uri(pmaEndpoint), connectionString: connectionString);
}
else
{
_logger.LogWarning("PmaEndpoint is empty. Creating CallAutomationClient without PmaEndpoint parameter.");
_client = new CallAutomationClient(connectionString: connectionString);
}
}

/// <summary>
/// Gets the call automation client for direct operations
/// </summary>
/// <returns>CallAutomationClient instance</returns>
public CallAutomationClient GetCallAutomationClient()
{
return _client;
}

/// <summary>
/// Gets the recording location
/// </summary>
/// <returns>Recording location string</returns>
public static string GetRecordingLocation()
{
return _recordingLocation;
}

/// <summary>
/// Sets the recording location
/// </summary>
/// <param name="location">The recording location to set</param>
public static void SetRecordingLocation(string location)
{
_recordingLocation = location;
}

/// <summary>
/// Gets the recording file format
/// </summary>
/// <returns>Recording file format string</returns>
public static string GetRecordingFileFormat()
{
return _recordingFileFormat;
}

/// <summary>
/// Sets the recording file format
/// </summary>
/// <param name="format">The recording file format to set</param>
public static void SetRecordingFileFormat(string format)
{
_recordingFileFormat = format;
}

public CallConnection GetCallConnection(string callConnectionId)
{
try
{
return _client.GetCallConnection(callConnectionId);
}
catch (Exception ex)
{
string errorMessage = $"Error in GetCallConnection: {ex.Message}. CallConnectionId: {callConnectionId}";
_logger.LogError(errorMessage);
throw;
}
}
private CallAutomationClient _client;
private ILogger<CallAutomationService> _logger;
private static string? _recordingLocation;
private static string _recordingFileFormat = "mp4";
private string _currentPmaEndpoint = string.Empty;

public CallAutomationService(string connectionString, ILogger<CallAutomationService> logger)
{
_logger = logger ?? throw new ArgumentNullException(nameof(logger));
_client = new CallAutomationClient(connectionString: connectionString);
}

/// <summary>
/// Gets the call automation client for direct operations
/// </summary>
/// <returns>CallAutomationClient instance</returns>
public CallAutomationClient GetCallAutomationClient()
{
return _client;
}

/// <summary>
/// Gets the recording location
/// </summary>
/// <returns>Recording location string</returns>
public static string GetRecordingLocation()
{
return _recordingLocation;
}

/// <summary>
/// Sets the recording location
/// </summary>
/// <param name="location">The recording location to set</param>
public static void SetRecordingLocation(string location)
{
_recordingLocation = location;
}

/// <summary>
/// Gets the recording file format
/// </summary>
/// <returns>Recording file format string</returns>
public static string GetRecordingFileFormat()
{
return _recordingFileFormat;
}

/// <summary>
/// Sets the recording file format
/// </summary>
/// <param name="format">The recording file format to set</param>
public static void SetRecordingFileFormat(string format)
{
_recordingFileFormat = format;
}

public CallConnection GetCallConnection(string callConnectionId)
{
try
{
return _client.GetCallConnection(callConnectionId);
}
catch (Exception ex)
{
string errorMessage = $"Error in GetCallConnection: {ex.Message}. CallConnectionId: {callConnectionId}";
_logger.LogError(errorMessage);
throw;
}
}

public CallMedia GetCallMedia(string callConnectionId)
{
try
{
return _client.GetCallConnection(callConnectionId).GetCallMedia();
}
catch (Exception ex)
{
string errorMessage = $"Error in GetCallMedia: {ex.Message}. CallConnectionId: {callConnectionId}";
_logger.LogError(errorMessage);
throw; // Rethrow so the caller can handle or return an error response
}
}

public CallConnectionProperties GetCallConnectionProperties(string callConnectionId)
{
try
{
return _client.GetCallConnection(callConnectionId).GetCallConnectionProperties();
}
catch (Exception ex)
{
string errorMessage = $"Error in GetCallConnectionProperties: {ex.Message}. CallConnectionId: {callConnectionId}";
_logger.LogError(errorMessage);
throw;
}
}

///// <summary>
///// Updates the CallAutomationClient with new connection settings
///// </summary>
///// <param name="connectionString">The ACS connection string</param>
///// <param name="pmaEndpoint">The PMA endpoint to use</param>
//public void UpdateClient(string connectionString, string pmaEndpoint)
//{
// _logger = _logger ?? throw new InvalidOperationException("Logger is not initialized");
// _currentPmaEndpoint = pmaEndpoint;

// if (!string.IsNullOrEmpty(pmaEndpoint))
// {
// _client = new CallAutomationClient(pmaEndpoint: new Uri(pmaEndpoint), connectionString: connectionString);
// _logger.LogInformation($"CallAutomationClient recreated with PMA endpoint: {pmaEndpoint}");
// }
// else
// {
// _logger.LogWarning("PmaEndpoint is empty. Creating CallAutomationClient without PmaEndpoint parameter.");
// _client = new CallAutomationClient(connectionString: connectionString);
// }
//}

//public string GetCurrentPmaEndpoint()
//{
// return _currentPmaEndpoint;
//}

public CallMedia GetCallMedia(string callConnectionId)
{
try
{
return _client.GetCallConnection(callConnectionId).GetCallMedia();
}
catch (Exception ex)
{
string errorMessage = $"Error in GetCallMedia: {ex.Message}. CallConnectionId: {callConnectionId}";
_logger.LogError(errorMessage);
throw; // Rethrow so the caller can handle or return an error response
}
}

public CallConnectionProperties GetCallConnectionProperties(string callConnectionId)
{
try
{
return _client.GetCallConnection(callConnectionId).GetCallConnectionProperties();
}
catch (Exception ex)
{
string errorMessage = $"Error in GetCallConnectionProperties: {ex.Message}. CallConnectionId: {callConnectionId}";
_logger.LogError(errorMessage);
throw;
}
}

/// <summary>
/// Updates the CallAutomationClient with new connection settings
/// </summary>
/// <param name="connectionString">The ACS connection string</param>
/// <param name="pmaEndpoint">The PMA endpoint to use</param>
public void UpdateClient(string connectionString, string pmaEndpoint)
{
_logger = _logger ?? throw new InvalidOperationException("Logger is not initialized");
_currentPmaEndpoint = pmaEndpoint;

if (!string.IsNullOrEmpty(pmaEndpoint))
{
_client = new CallAutomationClient(pmaEndpoint: new Uri(pmaEndpoint), connectionString: connectionString);
_logger.LogInformation($"CallAutomationClient recreated with PMA endpoint: {pmaEndpoint}");
}
else
{
_logger.LogWarning("PmaEndpoint is empty. Creating CallAutomationClient without PmaEndpoint parameter.");
_client = new CallAutomationClient(connectionString: connectionString);
}
}

public string GetCurrentPmaEndpoint()
{
return _currentPmaEndpoint;
}

//Need Azure Cognitive services for this so in phase 2
//public List<RecognitionChoice> GetChoices()
//{
// return new List<RecognitionChoice> {
// new RecognitionChoice("Confirm", new List<string> {
// "Confirm",
// "First",
// "One"
// }) {
// Tone = DtmfTone.One
// },
// new RecognitionChoice("Cancel", new List<string> {
// "Cancel",
// "Second",
// "Two"
// }) {
// Tone = DtmfTone.Two
// }
//};
//public List<RecognitionChoice> GetChoices() => new List<RecognitionChoice>
// {
// // Only DTMF tones, no speech phrases
// new RecognitionChoice("Confirm", new List<string>()) { Tone = DtmfTone.One },
// new RecognitionChoice("Cancel", new List<string>()) { Tone = DtmfTone.Two }
// };

}
}


Expand Down
2 changes: 1 addition & 1 deletion Call_Automation_GCCH/Call_Automation_GCCH/Call_Automation_GCCH.csproj
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
</PropertyGroup>

<ItemGroup>
<PackageReference Include="Azure.Communication.CallAutomation" Version="1.5.0-alpha.20250605.1" />
<PackageReference Include="Azure.Communication.CallAutomation" Version="1.4.0" />
<PackageReference Include="Azure.Messaging.EventGrid" Version="4.16.0" />
<PackageReference Include="Azure.Storage.Blobs" Version="12.22.0" />
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.6.2" />
Expand Down
Loading