Add zipkin and dashboard

.gitignore

@@ -428,3 +428,6 @@ CoverageReport/
 
 # Rider SonarLint plugin
 **/.idea/sonarlint/
+
+# Docker container volumes
+**/docker-volumes/

src/backend/Backend.sln

@@ -9,6 +9,7 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "WebApi.Tests", "..\..\tests
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{9EBA80A2-4F3D-4EBC-AC53-3D4DE1719443}"
 	ProjectSection(SolutionItems) = preProject
+		..\..\.gitignore = ..\..\.gitignore
 		..\..\README.md = ..\..\README.md
 	EndProjectSection
 EndProject

src/backend/Makefile

@@ -1,11 +1,11 @@
 .PHONY: run
 run:
-	mkdir -p log
-	chmod 777 log
-	mkdir -p rabbitmq/data
-	chmod 777 rabbitmq/data
-	mkdir -p rabbitmq/log
-	chmod 777 rabbitmq/log
+	mkdir -p docker-volumes/log && chmod 777 docker-volumes/log
+	mkdir -p docker-volumes/rabbitmq/data && chmod 777 docker-volumes/rabbitmq/data
+	mkdir -p docker-volumes/rabbitmq/log && chmod 777 docker-volumes/rabbitmq/log
+	mkdir -p docker-volumes/mssql/data && chmod 777 docker-volumes/mssql/data
+	mkdir -p docker-volumes/mssql/log && chmod 777 docker-volumes/mssql/log
+	mkdir -p docker-volumes/mssql/secrets && chmod 777 docker-volumes/mssql/secrets
 	docker compose up -d --build
 
 .PHONY: clean
@@ -15,7 +15,7 @@ clean:
 
 .PHONY: wait
 wait:
-	until [ -f "./log/traces.log" ] && [ -f "./log/metrics.log" ] && [ -f "./log/logs.log" ]; do sleep 5; done
+	until [ -f "./docker-volumes/log/traces.log" ] && [ -f "./docker-volumes/log/metrics.log" ] && [ -f "./docker-volumes/log/logs.log" ]; do sleep 5; done
 
 .PHONY: test
 test: run wait clean

src/backend/WebApi/BloggingContext.cs

@@ -0,0 +1,67 @@
+using Microsoft.EntityFrameworkCore;
+
+namespace WebApi;
+
+/// <summary>
+///     TODO
+/// </summary>
+public class BloggingContext(DbContextOptions<BloggingContext> options) : DbContext(options)
+{
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public DbSet<Blog> Blogs { get; set; }
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public DbSet<Post> Posts { get; set; }
+}
+
+/// <summary>
+///     TODO
+/// </summary>
+public class Blog
+{
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public int BlogId { get; set; }
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public string Url { get; set; } = string.Empty;
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public List<Post> Posts { get; } = new();
+}
+
+/// <summary>
+///     TODO
+/// </summary>
+public class Post
+{
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public int PostId { get; set; }
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public string Title { get; set; } = string.Empty;
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public string Content { get; set; } = string.Empty;
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public int BlogId { get; set; }
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public Blog? Blog { get; set; }
+}

src/backend/WebApi/Controllers/BloggingController.cs

@@ -0,0 +1,60 @@
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.EntityFrameworkCore;
+
+namespace WebApi.Controllers;
+
+/// <summary>
+///     Blogging controller
+/// </summary>
+[ApiController]
+[Route("[controller]")]
+public class BloggingController(ILogger<BloggingController> logger, BloggingContext bloggingContext) : ControllerBase
+{
+    /// <summary>
+    ///     Get blogs
+    /// </summary>
+    /// <returns></returns>
+    [HttpGet("Blog", Name = "GetBlogs")]
+    public async Task<ActionResult<IEnumerable<Blog>>> GetBlogs(CancellationToken cancellationToken)
+    {
+        logger.LogInformation("GetBlogs was called");
+        return await bloggingContext.Blogs.ToListAsync(cancellationToken);
+    }
+
+    /// <summary>
+    ///     Create blog
+    /// </summary>
+    /// <returns></returns>
+    [HttpPost("Blog", Name = "PostBlog")]
+    public async Task<ActionResult<Blog>> PostBlog(Blog blog, CancellationToken cancellationToken)
+    {
+        logger.LogInformation("PostBlog was called");
+        var blogEntry = bloggingContext.Blogs.Add(blog);
+        await bloggingContext.SaveChangesAsync(cancellationToken);
+        return blogEntry.Entity;
+    }
+
+    /// <summary>
+    ///     Get posts
+    /// </summary>
+    /// <returns></returns>
+    [HttpGet("Post", Name = "GetPosts")]
+    public async Task<ActionResult<IEnumerable<Post>>> GetPosts(CancellationToken cancellationToken)
+    {
+        logger.LogInformation("GetPosts was called");
+        return await bloggingContext.Posts.ToListAsync(cancellationToken);
+    }
+
+    /// <summary>
+    ///     Create post
+    /// </summary>
+    /// <returns></returns>
+    [HttpPost("Post", Name = "PostPost")]
+    public async Task<ActionResult<Post>> PostPost(Post post, CancellationToken cancellationToken)
+    {
+        logger.LogInformation("PostPost was called");
+        var postEntry = bloggingContext.Posts.Add(post);
+        await bloggingContext.SaveChangesAsync(cancellationToken);
+        return postEntry.Entity;
+    }
+}

src/backend/WebApi/Controllers/SendMessageController.cs

@@ -0,0 +1,36 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+using Microsoft.AspNetCore.Mvc;
+using Utils.Messaging;
+
+namespace WebApi.Controllers;
+
+/// <summary>
+///     TODO
+/// </summary>
+[ApiController]
+[Route("[controller]")]
+public class SendMessageController : ControllerBase
+{
+    private readonly ILogger<SendMessageController> logger;
+    private readonly MessageSender messageSender;
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    /// <param name="logger"></param>
+    /// <param name="messageSender"></param>
+    public SendMessageController(ILogger<SendMessageController> logger, MessageSender messageSender)
+    {
+        this.logger = logger;
+        this.messageSender = messageSender;
+    }
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    /// <returns></returns>
+    [HttpGet]
+    public string Get() => messageSender.SendMessage();
+}

src/backend/WebApi/Messaging/MessageReceiver.cs

@@ -0,0 +1,104 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+using System.Diagnostics;
+using System.Text;
+using OpenTelemetry;
+using OpenTelemetry.Context.Propagation;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+
+namespace Utils.Messaging;
+
+/// <summary>
+///     TODO
+/// </summary>
+public class MessageReceiver : IDisposable
+{
+    private static readonly ActivitySource ActivitySource = new(nameof(MessageReceiver));
+    private static readonly TextMapPropagator Propagator = Propagators.DefaultTextMapPropagator;
+
+    private readonly ILogger<MessageReceiver> logger;
+    private readonly IConnection connection;
+    private readonly IModel channel;
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public MessageReceiver(ILogger<MessageReceiver> logger)
+    {
+        this.logger = logger;
+        connection = RabbitMqHelper.CreateConnection();
+        channel = RabbitMqHelper.CreateModelAndDeclareTestQueue(connection);
+    }
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public void Dispose()
+    {
+        channel.Dispose();
+        connection.Dispose();
+    }
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public void StartConsumer()
+    {
+        RabbitMqHelper.StartConsumer(channel, ReceiveMessage);
+    }
+
+    /// <summary>
+    ///     TODO
+    /// </summary>
+    public void ReceiveMessage(BasicDeliverEventArgs ea)
+    {
+        // Extract the PropagationContext of the upstream parent from the message headers.
+        var parentContext = Propagator.Extract(default, ea.BasicProperties, ExtractTraceContextFromBasicProperties);
+        Baggage.Current = parentContext.Baggage;
+
+        // Start an activity with a name following the semantic convention of the OpenTelemetry messaging specification.
+        // https://github.com/open-telemetry/semantic-conventions/blob/main/docs/messaging/messaging-spans.md#span-name
+        var activityName = $"{ea.RoutingKey} receive";
+
+        using var activity = ActivitySource.StartActivity(activityName, ActivityKind.Consumer, parentContext.ActivityContext);
+        try
+        {
+            var message = Encoding.UTF8.GetString(ea.Body.Span.ToArray());
+
+            logger.LogInformation($"Message received: [{message}]");
+
+            activity?.SetTag("message", message);
+
+            // The OpenTelemetry messaging specification defines a number of attributes. These attributes are added here.
+            if (activity != null)
+                RabbitMqHelper.AddMessagingTags(activity);
+
+            // Simulate some work
+            Thread.Sleep(1000);
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, "Message processing failed.");
+        }
+    }
+
+    private IEnumerable<string> ExtractTraceContextFromBasicProperties(IBasicProperties props, string key)
+    {
+        try
+        {
+            if (props.Headers.TryGetValue(key, out var value) && value is byte[] bytes)
+                return
+                [
+                    Encoding.UTF8.GetString(bytes)
+                ];
+        }
+        catch (Exception ex)
+        {
+            logger.LogError(ex, "Failed to extract trace context.");
+        }
+
+        return [];
+    }
+}