Merge pull request #10 from scogliera/feature/add_dal

Propojení projektu s MongoDB

Controllers/TdaApiController.cs

@@ -1,4 +1,5 @@
 using Microsoft.AspNetCore.Mvc;
+using TeacherDigitalAgency.DAL;
 using TeacherDigitalAgency.Models;
 
 namespace TeacherDigitalAgency.Controllers;
@@ -8,10 +9,12 @@ namespace TeacherDigitalAgency.Controllers;
 public class TdaApiController: ControllerBase
 {
     private readonly ILogger<TdaApiController> _logger;
+    private readonly IMongoDal _mongoDal;
 
-    public TdaApiController(ILogger<TdaApiController> logger)
+    public TdaApiController(ILogger<TdaApiController> logger, IMongoDal mongoDal)
     {
-        _logger = logger;
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+        _mongoDal = mongoDal ?? throw new ArgumentNullException(nameof(mongoDal));
     }
 
     [HttpGet("/api")]

DAL/IMongoDal.cs

@@ -0,0 +1,12 @@
+using TeacherDigitalAgency.Models;
+
+namespace TeacherDigitalAgency.DAL;
+
+public interface IMongoDal
+{
+    public Lecturer? GetLecturer(Guid id);
+    public IEnumerable<Lecturer> GetAllLecturers();
+    public void SetLecturer(Lecturer lecturer);
+    public bool DeleteLecturer(Guid id);
+    public void AddLecturer(Lecturer lecturer);
+}

DAL/MongoDal.cs

@@ -0,0 +1,64 @@
+using MongoDB.Driver;
+using TeacherDigitalAgency.Models;
+
+namespace TeacherDigitalAgency.DAL;
+
+public class MongoDal: IMongoDal
+{
+    private readonly IMongoCollection<Lecturer> _lecturersCollection;
+
+    public MongoDal(IConfiguration configuration)
+    {
+        if (configuration == null)
+            throw new ArgumentNullException(nameof(configuration));
+
+        var connectionString = configuration.GetConnectionString("MongoDb") ?? throw new ArgumentNullException(nameof(configuration));
+
+        var settings = MongoClientSettings.FromConnectionString(connectionString);
+        settings.ServerApi = new ServerApi(ServerApiVersion.V1);
+
+        var client = new MongoClient(settings);
+        _lecturersCollection = client.GetDatabase("tda-db").GetCollection<Lecturer>("lecturers");
+    }
+
+    public Lecturer? GetLecturer(Guid id)
+    {
+        return _lecturersCollection.Find(lecturer => lecturer.Uuid == id).FirstOrDefault();
+    }
+
+    public IEnumerable<Lecturer> GetAllLecturers()
+    {
+        return _lecturersCollection.Find(_ => true).ToEnumerable();
+    }
+
+    public void SetLecturer(Lecturer lecturer)
+    {
+        var filter = Builders<Lecturer>.Filter.Eq(l => l.Uuid, lecturer.Uuid);
+        var update = Builders<Lecturer>.Update
+            .Set(l => l.TitleBefore, lecturer.TitleBefore)
+            .Set(l => l.FirstName, lecturer.FirstName)
+            .Set(l => l.MiddleName, lecturer.MiddleName)
+            .Set(l => l.LastName, lecturer.LastName)
+            .Set(l => l.TitleAfter, lecturer.TitleAfter)
+            .Set(l => l.PictureUrl, lecturer.PictureUrl)
+            .Set(l => l.Location, lecturer.Location)
+            .Set(l => l.Claim, lecturer.Claim)
+            .Set(l => l.Bio, lecturer.Bio)
+            .Set(l => l.Tags, lecturer.Tags)
+            .Set(l => l.PricePerHour, lecturer.PricePerHour)
+            .Set(l => l.ContactInfo, lecturer.ContactInfo);
+
+        _lecturersCollection.UpdateOne(filter, update);
+    }
+
+    public bool DeleteLecturer(Guid id)
+    {
+        var deleteResult = _lecturersCollection.DeleteOne(lecturer => lecturer.Uuid == id);
+        return deleteResult.DeletedCount > 0 && deleteResult.IsAcknowledged;
+    }
+
+    public void AddLecturer(Lecturer lecturer)
+    {
+        _lecturersCollection.InsertOne(lecturer);
+    }
+}

Models/Lecturer.cs

@@ -1,9 +1,11 @@
 using System.Text.Json.Serialization;
+using MongoDB.Bson;
 
 namespace TeacherDigitalAgency.Models;
 
 public class Lecturer
 {
+    [JsonIgnore] public ObjectId? _id { get; init; }
     [JsonPropertyName("uuid")] public Guid Uuid { get; init; } = Guid.NewGuid();
     [JsonPropertyName("title_before")] public string? TitleBefore { get; set; }
     [JsonPropertyName("first_name")] public required string FirstName { get; set; }

Program.cs

@@ -1,3 +1,5 @@
+using TeacherDigitalAgency.DAL;
+
 var builder = WebApplication.CreateBuilder(args);
 
 // Add services to the container
@@ -6,6 +8,7 @@
 builder.Services.AddControllers();
 builder.Services.AddAntDesign();
 builder.Services.AddSwaggerGen();
+builder.Services.AddSingleton<IMongoDal, MongoDal>();
 
 var app = builder.Build();
 

TeacherDigitalAgency.csproj

@@ -16,6 +16,7 @@
 
     <ItemGroup>
       <PackageReference Include="AntDesign" Version="0.16.3" />
+      <PackageReference Include="MongoDB.Driver" Version="2.23.1" />
       <PackageReference Include="Swashbuckle.AspNetCore.Swagger" Version="6.5.0" />
       <PackageReference Include="Swashbuckle.AspNetCore.SwaggerGen" Version="6.5.0" />
       <PackageReference Include="Swashbuckle.AspNetCore.SwaggerUI" Version="6.5.0" />

appsettings.json

@@ -5,5 +5,8 @@
       "Microsoft.AspNetCore": "Warning"
     }
   },
-  "AllowedHosts": "*"
+  "AllowedHosts": "*",
+  "ConnectionStrings": {
+    "MongoDb": ""
+  }
 }