Commit 0763bf65: Merged PR 2: WIP: test pipeline...

main.bicep

+46

/infra/main.bicep

View

@description('Name of the eventhub namespace')

param eventHubNamespaceName string

@description('Name of the eventhub name')

param eventHubName string

@description('The service principal')

param principalId string

// Create an event hub namespace

resource eventHubNamespace 'Microsoft.EventHub/namespaces@2021-01-01-preview' = {

location: resourceGroup().location

sku: {

tier: 'Standard'

capacity: 1

}

properties: {

zoneRedundant: true

}

// Create an event hub inside the namespace

resource eventHub 'Microsoft.EventHub/namespaces/eventhubs@2021-01-01-preview' = {

parent: eventHubNamespace

properties: {

messageRetentionInDays: 7

partitionCount: 1

}

// give Azure Pipelines Service Principal permissions against the event hub

var roleDefinitionAzureEventHubsDataOwner = subscriptionResourceId('Microsoft.Authorization/roleDefinitions', 'f526a384-b230-433a-b45c-95f59c4a2dec')

resource integrationTestEventHubReceiverNamespaceRoleAssignment 'Microsoft.Authorization/roleAssignments@2018-01-01-preview' = {

scope: eventHubNamespace

properties: {

roleDefinitionId: roleDefinitionAzureEventHubsDataOwner

principalId: principalId

}

EventHubTest.cs

+111

/src/IntegrationTests/EventHubTest.cs

View

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading;

using System.Threading.Tasks;

using Azure.Identity;

using Azure.Messaging.EventHubs;

using Azure.Messaging.EventHubs.Consumer;

using Azure.Messaging.EventHubs.Producer;

using FluentAssertions;

using Microsoft.Extensions.Configuration;

using Newtonsoft.Json;

using Xunit;

using Xunit.Abstractions;

namespace IntegrationTests

{

public record EchoMessage(string Id, string Message, DateTime Timestamp);

public class EventHubTest

{

private readonly ITestOutputHelper _output;

public EventHubTest(ITestOutputHelper output)

{

_output = output;

}

[Fact]

public async Task Can_post_message_to_event_hub_and_read_it_back()

{

// ARRANGE

var configuration = new ConfigurationBuilder()

.AddEnvironmentVariables()

.Build();

// populated by variables specified in the Azure Pipeline

var eventhubNamespaceName = configuration["EVENTHUBNAMESPACENAME"];

eventhubNamespaceName.Should().NotBeNull();

var eventhubName = configuration["EVENTHUBNAME"];

eventhubName.Should().NotBeNull();

var tenantId = configuration["TENANTID"];

tenantId.Should().NotBeNull();

// populated as a consequence of the addSpnToEnvironment in the azure-pipelines.yml

var servicePrincipalId = configuration["SERVICEPRINCIPALID"];

servicePrincipalId.Should().NotBeNull();

var servicePrincipalKey = configuration["SERVICEPRINCIPALKEY"];

servicePrincipalKey.Should().NotBeNull();

var fullyQualifiedNamespace = $"{eventhubNamespaceName}.servicebus.windows.net";

var clientCredential = new ClientSecretCredential(tenantId, servicePrincipalId, servicePrincipalKey);

var eventHubClient = new EventHubProducerClient(

fullyQualifiedNamespace: fullyQualifiedNamespace,

eventHubName: eventhubName,

credential: clientCredential

);

var ourGuid = Guid.NewGuid().ToString();

var now = DateTime.UtcNow;

var sentEchoMessage = new EchoMessage(Id: ourGuid, Message: $"Test message", Timestamp: now);

var sentEventData = new EventData(

Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(sentEchoMessage))

);

// ACT

await eventHubClient.SendAsync(new List<EventData> { sentEventData }, CancellationToken.None);

var eventHubConsumerClient = new EventHubConsumerClient(

consumerGroup: EventHubConsumerClient.DefaultConsumerGroupName,

fullyQualifiedNamespace: fullyQualifiedNamespace,

eventHubName: eventhubName,

credential: clientCredential

);

List<PartitionEvent> partitionEvents = new();

await foreach (var partitionEvent in eventHubConsumerClient.ReadEventsAsync(new ReadEventOptions

{

MaximumWaitTime = TimeSpan.FromSeconds(10)

}))

{

if (partitionEvent.Data == null) break;

_output.WriteLine(Encoding.UTF8.GetString(partitionEvent.Data.EventBody.ToArray()));

partitionEvents.Add(partitionEvent);

}

// ASSERT

partitionEvents.Count.Should().BeGreaterOrEqualTo(1);

var firstOne = partitionEvents.FirstOrDefault(evnt =>

ExtractTypeFromEventBody<EchoMessage>(evnt, _output)?.Id == ourGuid

);

var receivedEchoMessage = ExtractTypeFromEventBody<EchoMessage>(firstOne, _output);

receivedEchoMessage.Should().BeEquivalentTo(sentEchoMessage, because: "the event body should be the same one posted to the message queue");

}

private static T ExtractTypeFromEventBody<T>(PartitionEvent evnt, ITestOutputHelper _output)

{

try

{

return JsonConvert.DeserializeObject<T>(Encoding.UTF8.GetString(evnt.Data.EventBody.ToArray()));

}

catch (JsonException)

{

_output.WriteLine("[" + Encoding.UTF8.GetString(evnt.Data.EventBody.ToArray()) + "] is probably not JSON");

return default(T);

}

IntegrationTest.csproj

+27

/src/IntegrationTests/IntegrationTest.csproj

View

<IsPackable>false</IsPackable>

</PropertyGroup>

<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

</PackageReference>

<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

</PackageReference>

</ItemGroup>

</Project>

.gitignore

+3

/.gitignore

View

bin

obj

azure-pipelines.yml

/azure-pipelines.yml

View

README.md

/README.md

View



	infra
	main.bicep +
	src/IntegrationTests
	EventHubTest.cs +
	IntegrationTest.csproj +
	.gitignore +
	azure-pipelines.yml +
	README.md