Skip to content

Commit 0b1a285

Browse files
committed
BlobLogListener public ctor
1 parent 664bb4d commit 0b1a285

File tree

2 files changed

+2
-18
lines changed

2 files changed

+2
-18
lines changed

sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Blobs/src/Listeners/BlobLogListener.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ internal class BlobLogListener
2929
private readonly StorageAnalyticsLogParser _parser;
3030
private readonly ILogger<BlobListener> _logger;
3131

32-
private BlobLogListener(BlobServiceClient blobClient, ILogger<BlobListener> logger)
32+
public BlobLogListener(BlobServiceClient blobClient, ILogger<BlobListener> logger)
3333
{
3434
_blobClient = blobClient;
3535

sdk/storage/Microsoft.Azure.WebJobs.Extensions.Storage.Blobs/tests/Listeners/BlobLogListenerTests.cs

Lines changed: 1 addition & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public async Task HasBlobWritesAsync_VariousCases(string logType1, int logType1C
7474
.Setup(c => c.GetBlobContainerClient("$logs"))
7575
.Returns(containerClientMock.Object);
7676

77-
var listener = CreateBlobLogListener(blobServiceClientMock.Object);
77+
var listener = new BlobLogListener(blobServiceClientMock.Object, NullLogger<BlobListener>.Instance);
7878

7979
// Act
8080
bool result = await listener.HasBlobWritesAsync(CancellationToken.None, hoursWindow: 1);
@@ -115,22 +115,6 @@ public void GetPathsForValidBlobWrites_Returns_ValidBlobWritesOnly()
115115
Assert.AreEqual(@"""0x8D199A96CB71468""/sample-blob.txt", singlePath.BlobName);
116116
}
117117

118-
private static BlobLogListener CreateBlobLogListener(BlobServiceClient serviceClient)
119-
{
120-
var logger = NullLogger<BlobListener>.Instance;
121-
var ctor = typeof(BlobLogListener)
122-
.GetConstructor(BindingFlags.Instance | BindingFlags.NonPublic,
123-
binder: null,
124-
types: new[] { typeof(BlobServiceClient), typeof(ILogger<BlobListener>) },
125-
modifiers: null);
126-
if (ctor == null)
127-
{
128-
throw new InvalidOperationException("BlobLogListener non-public constructor not found.");
129-
}
130-
131-
return (BlobLogListener)ctor.Invoke(new object[] { serviceClient, logger });
132-
}
133-
134118
private static class BlobItemFactory
135119
{
136120
private static readonly Type BlobItemType = typeof(BlobItem);

0 commit comments

Comments
 (0)