Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
2 changes: 1 addition & 1 deletion eng/Packages.Data.props
Original file line number Diff line number Diff line change
Expand Up @@ -173,7 +173,7 @@
All should have PrivateAssets="All" set so they don't become package dependencies
-->
<ItemGroup>
<PackageReference Update="Microsoft.Azure.AutoRest.CSharp" Version="3.0.0-beta.20230719.2" PrivateAssets="All" />
<PackageReference Update="Microsoft.Azure.AutoRest.CSharp" Version="3.0.0-beta.20230719.3" PrivateAssets="All" />
<PackageReference Update="Azure.ClientSdk.Analyzers" Version="0.1.1-dev.20230131.1" PrivateAssets="All" />
<PackageReference Update="coverlet.collector" Version="3.2.0" PrivateAssets="All" />
<PackageReference Update="Microsoft.CodeAnalysis.NetAnalyzers" Version="7.0.1" PrivateAssets="All" />
Expand Down
2 changes: 1 addition & 1 deletion eng/emitter-package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"main": "dist/src/index.js",
"dependencies": {
"@azure-tools/typespec-csharp": "0.2.0-beta.20230719.2"
"@azure-tools/typespec-csharp": "0.2.0-beta.20230719.3"
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -167,13 +167,8 @@ public virtual async Task<Response<AnswerCallResult>> AnswerCallAsync(AnswerCall
if (options == null) throw new ArgumentNullException(nameof(options));

AnswerCallRequestInternal request = CreateAnswerCallRequest(options);
var repeatabilityHeaders = new RepeatabilityHeaders();

var answerResponse = await AzureCommunicationServicesRestClient.AnswerCallAsync(request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken)
.ConfigureAwait(false);
var answerResponse = await AzureCommunicationServicesRestClient.AnswerCallAsync(request, cancellationToken).ConfigureAwait(false);

var result = new AnswerCallResult(GetCallConnection(answerResponse.Value.CallConnectionId), new CallConnectionProperties(answerResponse.Value));
result.SetEventProcessor(EventProcessor, answerResponse.Value.CallConnectionId, null);
Expand Down Expand Up @@ -220,12 +215,8 @@ public virtual Response<AnswerCallResult> AnswerCall(AnswerCallOptions options,
if (options == null) throw new ArgumentNullException(nameof(options));

AnswerCallRequestInternal request = CreateAnswerCallRequest(options);
var repeatabilityHeaders = new RepeatabilityHeaders();

var answerResponse = AzureCommunicationServicesRestClient.AnswerCall(request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken);
var answerResponse = AzureCommunicationServicesRestClient.AnswerCall(request, cancellationToken);

var result = new AnswerCallResult(GetCallConnection(answerResponse.Value.CallConnectionId), new CallConnectionProperties(answerResponse.Value));
result.SetEventProcessor(EventProcessor, answerResponse.Value.CallConnectionId, null);
Expand Down Expand Up @@ -294,18 +285,12 @@ public virtual async Task<Response> RedirectCallAsync(RedirectCallOptions option
throw new ArgumentNullException(nameof(options));

RedirectCallRequestInternal request = new RedirectCallRequestInternal(options.IncomingCallContext, CommunicationIdentifierSerializer.Serialize(options.CallInvite.Target));
var repeatabilityHeaders = new RepeatabilityHeaders();

request.CustomContext = new CustomContextInternal(
options.CallInvite.CustomContext.SipHeaders == null ? new ChangeTrackingDictionary<string, string>() : options.CallInvite.CustomContext.SipHeaders,
options.CallInvite.CustomContext.VoipHeaders == null ? new ChangeTrackingDictionary<string, string>() : options.CallInvite.CustomContext.VoipHeaders);

return await AzureCommunicationServicesRestClient.RedirectCallAsync(
request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken
).ConfigureAwait(false);
return await AzureCommunicationServicesRestClient.RedirectCallAsync(request, cancellationToken).ConfigureAwait(false);
}
catch (Exception ex)
{
Expand Down Expand Up @@ -343,17 +328,12 @@ public virtual Response RedirectCall(RedirectCallOptions options, CancellationTo
throw new ArgumentNullException(nameof(options));

RedirectCallRequestInternal request = new RedirectCallRequestInternal(options.IncomingCallContext, CommunicationIdentifierSerializer.Serialize(options.CallInvite.Target));
var repeatabilityHeaders = new RepeatabilityHeaders();

request.CustomContext = new CustomContextInternal(
options.CallInvite.CustomContext.SipHeaders == null ? new ChangeTrackingDictionary<string, string>() : options.CallInvite.CustomContext.SipHeaders,
options.CallInvite.CustomContext.VoipHeaders == null ? new ChangeTrackingDictionary<string, string>() : options.CallInvite.CustomContext.VoipHeaders);

return AzureCommunicationServicesRestClient.RedirectCall(
request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken);
return AzureCommunicationServicesRestClient.RedirectCall(request, cancellationToken);
}
catch (Exception ex)
{
Expand Down Expand Up @@ -390,14 +370,8 @@ public virtual async Task<Response> RejectCallAsync(RejectCallOptions options, C

RejectCallRequestInternal request = new RejectCallRequestInternal(options.IncomingCallContext);
request.CallRejectReason = options.CallRejectReason.ToString();
var repeatabilityHeaders = new RepeatabilityHeaders();

return await AzureCommunicationServicesRestClient.RejectCallAsync(
request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken
).ConfigureAwait(false);
return await AzureCommunicationServicesRestClient.RejectCallAsync(request, cancellationToken).ConfigureAwait(false);
}
catch (Exception ex)
{
Expand Down Expand Up @@ -434,14 +408,8 @@ public virtual Response RejectCall(RejectCallOptions options, CancellationToken

RejectCallRequestInternal request = new RejectCallRequestInternal(options.IncomingCallContext);
request.CallRejectReason = options.CallRejectReason.ToString();
var repeatabilityHeaders = new RepeatabilityHeaders();

return AzureCommunicationServicesRestClient.RejectCall(
request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken
);
return AzureCommunicationServicesRestClient.RejectCall(request, cancellationToken);
}
catch (Exception ex)
{
Expand Down Expand Up @@ -486,14 +454,8 @@ public virtual async Task<Response<CreateCallResult>> CreateCallAsync(CreateCall
throw new ArgumentNullException(nameof(options));

CreateCallRequestInternal request = CreateCallRequest(options);
var repeatabilityHeaders = new RepeatabilityHeaders();

var createCallResponse = await AzureCommunicationServicesRestClient.CreateCallAsync(
request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken
).ConfigureAwait(false);
var createCallResponse = await AzureCommunicationServicesRestClient.CreateCallAsync(request, cancellationToken).ConfigureAwait(false);

var result = new CreateCallResult(
GetCallConnection(createCallResponse.Value.CallConnectionId),
Expand Down Expand Up @@ -546,14 +508,8 @@ public virtual Response<CreateCallResult> CreateCall(CreateCallOptions options,
if (options == null) throw new ArgumentNullException(nameof(options));

CreateCallRequestInternal request = CreateCallRequest(options);
var repeatabilityHeaders = new RepeatabilityHeaders();

var createCallResponse = AzureCommunicationServicesRestClient.CreateCall(
request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken
);
var createCallResponse = AzureCommunicationServicesRestClient.CreateCall(request, cancellationToken);

var result = new CreateCallResult(
GetCallConnection(createCallResponse.Value.CallConnectionId),
Expand Down Expand Up @@ -591,14 +547,8 @@ public virtual async Task<Response<CreateCallResult>> CreateGroupCallAsync(Creat
}

CreateCallRequestInternal request = CreateCallRequest(options);
var repeatabilityHeaders = new RepeatabilityHeaders();

var createCallResponse = await AzureCommunicationServicesRestClient.CreateCallAsync(
request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken
).ConfigureAwait(false);
var createCallResponse = await AzureCommunicationServicesRestClient.CreateCallAsync(request, cancellationToken).ConfigureAwait(false);

var result = new CreateCallResult(
GetCallConnection(createCallResponse.Value.CallConnectionId),
Expand Down Expand Up @@ -636,14 +586,8 @@ public virtual Response<CreateCallResult> CreateGroupCall(CreateGroupCallOptions
}

CreateCallRequestInternal request = CreateCallRequest(options);
var repeatabilityHeaders = new RepeatabilityHeaders();

var createCallResponse = AzureCommunicationServicesRestClient.CreateCall(
request,
repeatabilityHeaders.RepeatabilityRequestId,
repeatabilityHeaders.RepeatabilityFirstSent,
cancellationToken
);

var createCallResponse = AzureCommunicationServicesRestClient.CreateCall(request, cancellationToken);

var result = new CreateCallResult(
GetCallConnection(createCallResponse.Value.CallConnectionId),
Expand Down
Loading