-
-
Notifications
You must be signed in to change notification settings - Fork 207
/
HttpTransport.cs
46 lines (41 loc) · 1.69 KB
/
HttpTransport.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
using Sentry.Extensibility;
using Sentry.Http;
using Sentry.Infrastructure;
using Sentry.Protocol.Envelopes;
namespace Sentry.Internal.Http;
internal class HttpTransport : HttpTransportBase, ITransport
{
private readonly HttpClient _httpClient;
public HttpTransport(SentryOptions options, HttpClient httpClient)
: base(options)
{
_httpClient = httpClient;
}
internal HttpTransport(SentryOptions options, HttpClient httpClient,
Func<string, string?>? getEnvironmentVariable = default,
ISystemClock? clock = default)
: base(options, getEnvironmentVariable, clock)
{
_httpClient = httpClient;
}
/// <summary>
/// Sends an envelope over this transport.
/// </summary>
/// <param name="envelope">The envelope to send.</param>
/// <param name="cancellationToken">A cancellation token.</param>
/// <remarks>
/// This method implements the overarching workflow, but all features are implemented in the base class
/// such that they can be shared with higher-level SDKs (such as Unity) that may implement their own method
/// for performing HTTP transport.
/// </remarks>
public virtual async Task SendEnvelopeAsync(Envelope envelope, CancellationToken cancellationToken = default)
{
using var processedEnvelope = ProcessEnvelope(envelope);
if (processedEnvelope.Items.Count > 0)
{
using var request = CreateRequest(processedEnvelope);
using var response = await _httpClient.SendAsync(request, cancellationToken).ConfigureAwait(false);
await HandleResponseAsync(response, processedEnvelope, cancellationToken).ConfigureAwait(false);
}
}
}