Add content system

src/Web/Contents/Data/Content.cs

@@ -0,0 +1,13 @@
+namespace Hutopy.Web.Contents.Data;
+
+public class Content
+{
+    public Guid Id { get; init; }
+    public Guid CreatedBy { get; init; }
+    public DateTime CreatedAt { get; }
+
+    public string? Title { get; init; } = null!;
+    public string? Description { get; init; } = null!;
+    public string? Uri { get; init; } = null!;
+}
+    

src/Web/Contents/Data/ContentDbContext.cs

@@ -0,0 +1,19 @@
+using Microsoft.EntityFrameworkCore;
+
+namespace Hutopy.Web.Contents.Data;
+
+public class ContentDbContext(
+    DbContextOptions<ContentDbContext> options)
+    : DbContext(options)
+{
+    protected override void OnModelCreating(ModelBuilder modelBuilder)
+    {
+        modelBuilder
+            .Entity<Content>()
+            .Property(c => c.CreatedAt)
+            .ValueGeneratedOnAdd()
+            .HasDefaultValueSql("CURRENT_TIMESTAMP");
+    }
+
+    public DbSet<Content> Contents { get; set; }
+}

src/Web/Contents/Handlers/GetContents.cs

@@ -0,0 +1,30 @@
+using FastEndpoints;
+using Hutopy.Web.Contents.Data;
+using Microsoft.EntityFrameworkCore;
+
+namespace Hutopy.Web.Contents.Handlers;
+
+public class GetContents(
+    ContentDbContext context)
+    : EndpointWithoutRequest<Content>
+{
+    public override void Configure()
+    {
+        Tags("Contents");
+        Get("/api/contents/{ContentId:guid}");
+        AllowAnonymous();
+    }
+
+    public override async Task HandleAsync(
+        CancellationToken ct)
+    {
+        var contentId = Route<Guid>("ContentId");
+        
+        var comments = await context
+            .Contents
+            .Where(c => c.Id == contentId)
+            .ToListAsync(cancellationToken: ct);
+
+        await SendAsync(comments.First(), cancellation: ct);
+    }
+}

src/Web/Contents/Handlers/GetContentsByUser.cs

@@ -0,0 +1,30 @@
+using FastEndpoints;
+using Hutopy.Web.Messages.Data;
+using Microsoft.EntityFrameworkCore;
+
+namespace Hutopy.Web.Contents.Handlers;
+
+public class GetContentsByUser(
+    MessagingDbContext context)
+    : EndpointWithoutRequest<List<Message>>
+{
+    public override void Configure()
+    {
+        Tags("Contents");
+        Get("/api/contents/by-user/{UserId:guid}");
+        AllowAnonymous();
+    }
+
+    public override async Task HandleAsync(
+        CancellationToken ct)
+    {
+        var userId = Route<Guid>("UserId");
+
+        var posts = await context
+            .Messages
+            .Where(c => c.CreatedBy == userId)
+            .ToListAsync(cancellationToken: ct);
+
+        await SendAsync(posts, cancellation: ct);
+    }
+}

src/Web/Contents/Handlers/PostMessage.cs

@@ -0,0 +1,39 @@
+using FastEndpoints;
+using Hutopy.Web.Common;
+using Hutopy.Web.Contents.Data;
+
+namespace Hutopy.Web.Contents.Handlers;
+
+public record struct PostContentRequest(
+    string? Title,
+    string? Description,
+    string? Uri);
+
+public class PostMessage(
+    ContentDbContext context)
+    : Endpoint<PostContentRequest>
+{
+    public override void Configure()
+    {
+        // TODO: Find how to specify the name we see in Swagger
+        Tags("Contents");
+        Post("/api/contents");
+    }
+
+    public override async Task HandleAsync(
+        PostContentRequest req,
+        CancellationToken ct)
+    {
+        await context.Contents.AddAsync(
+            new Content
+            {
+                CreatedBy = User.GetUserId(), 
+                Title = req.Title, 
+                Description = req.Description, 
+                Uri = req.Uri
+            },
+            ct);
+
+        await context.SaveChangesAsync(ct);
+    }
+}

src/Web/Contents/Migrations/20240702034957_Initial.Designer.cs

@@ -0,0 +1,58 @@
+// <auto-generated />
+using System;
+using Hutopy.Web.Contents.Data;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Metadata;
+using Microsoft.EntityFrameworkCore.Migrations;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+
+#nullable disable
+
+namespace Hutopy.Web.Contents.Migrations
+{
+    [DbContext(typeof(ContentDbContext))]
+    [Migration("20240702034957_Initial")]
+    partial class Initial
+    {
+        /// <inheritdoc />
+        protected override void BuildTargetModel(ModelBuilder modelBuilder)
+        {
+#pragma warning disable 612, 618
+            modelBuilder
+                .HasAnnotation("ProductVersion", "8.0.3")
+                .HasAnnotation("Relational:MaxIdentifierLength", 128);
+
+            SqlServerModelBuilderExtensions.UseIdentityColumns(modelBuilder);
+
+            modelBuilder.Entity("Hutopy.Web.Contents.Data.Content", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("uniqueidentifier");
+
+                    b.Property<DateTime>("CreatedAt")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("datetime2")
+                        .HasDefaultValueSql("CURRENT_TIMESTAMP");
+
+                    b.Property<Guid>("CreatedBy")
+                        .HasColumnType("uniqueidentifier");
+
+                    b.Property<string>("Description")
+                        .HasColumnType("nvarchar(max)");
+
+                    b.Property<string>("Title")
+                        .HasColumnType("nvarchar(max)");
+
+                    b.Property<string>("Uri")
+                        .HasColumnType("nvarchar(max)");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Contents");
+                });
+#pragma warning restore 612, 618
+        }
+    }
+}

src/Web/Contents/Migrations/20240702034957_Initial.cs

@@ -0,0 +1,38 @@
+using System;
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace Hutopy.Web.Contents.Migrations
+{
+    /// <inheritdoc />
+    public partial class Initial : Migration
+    {
+        /// <inheritdoc />
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.CreateTable(
+                name: "Contents",
+                columns: table => new
+                {
+                    Id = table.Column<Guid>(type: "uniqueidentifier", nullable: false),
+                    CreatedBy = table.Column<Guid>(type: "uniqueidentifier", nullable: false),
+                    CreatedAt = table.Column<DateTime>(type: "datetime2", nullable: false, defaultValueSql: "CURRENT_TIMESTAMP"),
+                    Title = table.Column<string>(type: "nvarchar(max)", nullable: true),
+                    Description = table.Column<string>(type: "nvarchar(max)", nullable: true),
+                    Uri = table.Column<string>(type: "nvarchar(max)", nullable: true)
+                },
+                constraints: table =>
+                {
+                    table.PrimaryKey("PK_Contents", x => x.Id);
+                });
+        }
+
+        /// <inheritdoc />
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropTable(
+                name: "Contents");
+        }
+    }
+}

src/Web/Contents/Migrations/ContentDbContextModelSnapshot.cs

@@ -0,0 +1,55 @@
+// <auto-generated />
+using System;
+using Hutopy.Web.Contents.Data;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Infrastructure;
+using Microsoft.EntityFrameworkCore.Metadata;
+using Microsoft.EntityFrameworkCore.Storage.ValueConversion;
+
+#nullable disable
+
+namespace Hutopy.Web.Contents.Migrations
+{
+    [DbContext(typeof(ContentDbContext))]
+    partial class ContentDbContextModelSnapshot : ModelSnapshot
+    {
+        protected override void BuildModel(ModelBuilder modelBuilder)
+        {
+#pragma warning disable 612, 618
+            modelBuilder
+                .HasAnnotation("ProductVersion", "8.0.3")
+                .HasAnnotation("Relational:MaxIdentifierLength", 128);
+
+            SqlServerModelBuilderExtensions.UseIdentityColumns(modelBuilder);
+
+            modelBuilder.Entity("Hutopy.Web.Contents.Data.Content", b =>
+                {
+                    b.Property<Guid>("Id")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("uniqueidentifier");
+
+                    b.Property<DateTime>("CreatedAt")
+                        .ValueGeneratedOnAdd()
+                        .HasColumnType("datetime2")
+                        .HasDefaultValueSql("CURRENT_TIMESTAMP");
+
+                    b.Property<Guid>("CreatedBy")
+                        .HasColumnType("uniqueidentifier");
+
+                    b.Property<string>("Description")
+                        .HasColumnType("nvarchar(max)");
+
+                    b.Property<string>("Title")
+                        .HasColumnType("nvarchar(max)");
+
+                    b.Property<string>("Uri")
+                        .HasColumnType("nvarchar(max)");
+
+                    b.HasKey("Id");
+
+                    b.ToTable("Contents");
+                });
+#pragma warning restore 612, 618
+        }
+    }
+}

src/Web/Program.cs

@@ -4,6 +4,7 @@ using Hutopy.Application;
 using Hutopy.Infrastructure;
 using Hutopy.Infrastructure.Data;
 using Hutopy.Web;
+using Hutopy.Web.Contents.Data;
 using Hutopy.Web.Messages.Data;
 using Microsoft.AspNetCore.HttpOverrides;
 using Microsoft.EntityFrameworkCore;
@@ -83,6 +84,11 @@ builder.Services.AddDbContext<MessagingDbContext>((_, options) =>
     options.UseSqlServer(builder.Configuration.GetConnectionString("CommentStore"));
 });
 
+builder.Services.AddDbContext<ContentDbContext>((_, options) =>
+{
+    options.UseSqlServer(builder.Configuration.GetConnectionString("ContentStore"));
+});
+
 var app = builder.Build();
 
 app.UseForwardedHeaders(

src/Web/Web.csproj

@@ -30,8 +30,4 @@
     <PackageReference Include="FluentValidation.AspNetCore" />
   </ItemGroup>
 
-  <ItemGroup>
-    <Folder Include="Messages\Migrations\" />
-  </ItemGroup>
-
 </Project>

src/Web/appsettings.Development.json

@@ -9,7 +9,8 @@
   },
   "ConnectionStrings": {
     "DefaultConnection": "Server=localhost,1433;Initial Catalog=Hutopy;User Id=sa;Password=P@ssword123!;MultipleActiveResultSets=true;TrustServerCertificate=True;MultiSubnetFailover=True",
-    "CommentStore": "Server=localhost,1433;Initial Catalog=Hutopy;User Id=sa;Password=P@ssword123!;MultipleActiveResultSets=true;TrustServerCertificate=True;MultiSubnetFailover=True"
+    "CommentStore": "Server=localhost,1433;Initial Catalog=Hutopy;User Id=sa;Password=P@ssword123!;MultipleActiveResultSets=true;TrustServerCertificate=True;MultiSubnetFailover=True",
+    "ContentStore": "Server=localhost,1433;Initial Catalog=Hutopy;User Id=sa;Password=P@ssword123!;MultipleActiveResultSets=true;TrustServerCertificate=True;MultiSubnetFailover=True"
   },
   "Authentication": {
     "Jwt": {