Media files

Controllers/VideoTourController.cs

@@ -1,7 +1,9 @@
 using Microsoft.AspNetCore.Mvc;
 using SimpleWebAppReact.Entities;
 using Microsoft.Extensions.Logging;
+using MongoDB.Bson;
 using MongoDB.Driver;
+using MongoDB.Driver.GridFS;
 using SimpleWebAppReact.Services;
 
 namespace SimpleWebAppReact.Controllers
@@ -15,11 +17,13 @@
     {
         private readonly ILogger<VideoTourController> _logger;
         private readonly IMongoCollection<VideoTour>? _videoTours;
+        private readonly IGridFSBucket _videosBucket;
 
         public VideoTourController(ILogger<VideoTourController> logger, MongoDbService mongoDbService)
         {
             _logger = logger;
             _videoTours = mongoDbService.Database?.GetCollection<VideoTour>("videoTour");
+            _videosBucket = new GridFSBucket(mongoDbService.Database);
         }
 
         /// <summary>
@@ -40,7 +44,7 @@
         /// <param name="id"></param>
         /// <returns></returns>
         [HttpGet("{id}")]
         public async Task<ActionResult<VideoTour?>> GetById(string id)
         {
             if (!ModelState.IsValid) {
                 return BadRequest(ModelState);
@@ -52,15 +56,42 @@
             return videoTour is not null ? Ok(videoTour) : NotFound();
         }
 
+        [HttpGet("{id}/file")]
+        public async Task<ActionResult> GetFileById(string id)
+        {
+            var filter = Builders<VideoTour>.Filter.Eq(x => x.Id, id);
+            var videoTour = (await _videoTours.FindAsync(filter)).FirstOrDefault();
+
+            if (videoTour is null)
+            {
+                return NotFound();
+            }
+
+            var videoId = ObjectId.Parse(videoTour.FileId);
+            await using var downloadStream = await _videosBucket.OpenDownloadStreamAsync(videoId);
+            return File(downloadStream, "video/mp4");
+        }
+
         /// <summary>
         /// adds videoTour entry to table
         /// </summary>
         /// <param name="videoTour"></param>
         /// <returns></returns>
         [HttpPost]
-        public async Task<ActionResult> Post(VideoTour videoTour)
+        public async Task<ActionResult> Post([FromQuery] VideoTour videoTour, IFormFile file)
         {
+            if (file.ContentType != "video/mp4")
+            {
+                return BadRequest("File must be an mp4");
+            }
+
+            var fileStream = file.OpenReadStream();
+            var objectId = await _videosBucket.UploadFromStreamAsync(videoTour.Id, fileStream);
+            fileStream.Close();
+
+            videoTour.FileId = objectId.ToString();
+
             await _videoTours.InsertOneAsync(videoTour);
             return CreatedAtAction(nameof(GetById), new { id = videoTour.Id }, videoTour);
         }
 
@@ -73,7 +104,7 @@
         public async Task<ActionResult> Update(VideoTour videoTour)
         {
             var filter = Builders<VideoTour>.Filter.Eq(x => x.Id, videoTour.Id);
             await _videoTours.ReplaceOneAsync(filter, videoTour);
             return Ok();
         }
 
@@ -86,7 +117,18 @@
         public async Task<ActionResult> Delete(string id)
         {
             var filter = Builders<VideoTour>.Filter.Eq(x => x.Id, id);
+            var videoTour = (await _videoTours.FindAsync(filter)).FirstOrDefault();
+
+            if (videoTour is null)
+            {
+                return NotFound();
+            }
+
             await _videoTours.DeleteOneAsync(filter);
+
+            var objectId = ObjectId.Parse(videoTour.FileId);
+            await _videosBucket.DeleteAsync(objectId);
+
             return Ok();
         }
     }

Entities/VideoTour.cs

@@ -13,8 +13,8 @@ public class VideoTour
     [BsonElement("title"), BsonRepresentation(BsonType.String)]
     public string? Title { get; set; }
 
-    [BsonElement("url"), BsonRepresentation(BsonType.String)]
-    public string? Url { get; set; }
+    [BsonElement("fileId"), BsonRepresentation(BsonType.String)]
+    public string? FileId { get; set; }
 
     [BsonElement("length"), BsonRepresentation(BsonType.Double)]
     public Double? Length { get; set; }

SimpleWebAppReact.csproj

@@ -15,6 +15,7 @@
     <PackageReference Include="Microsoft.AspNetCore.Cors" Version="2.2.0" />
     <PackageReference Include="Microsoft.AspNetCore.Mvc.Testing" Version="6.0.33" />
     <PackageReference Include="MongoDB.Driver" Version="2.28.0" />
+    <PackageReference Include="MongoDB.Driver.GridFS" Version="2.28.0" />
     <PackageReference Include="Moq" Version="4.20.70" />
     <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />