Adds UploadBlock and CommitFileBlock messages DynamicsValue/fake-xrm-…

…easy#157

src/FakeXrmEasy.Messages/FakeMessageExecutors/CommitFileBlocksUploadRequestExecutor.cs

@@ -0,0 +1,54 @@
+#if FAKE_XRM_EASY_9
+using System;
+using System.Linq;
+using FakeXrmEasy.Abstractions;
+using FakeXrmEasy.Abstractions.FakeMessageExecutors;
+using FakeXrmEasy.Core.FileStorage.Upload;
+using Microsoft.Crm.Sdk.Messages;
+using Microsoft.Xrm.Sdk;
+
+namespace FakeXrmEasy.FakeMessageExecutors
+{
+    /// <summary>
+    /// Implements the CommitFileBlocksUploadRequest https://learn.microsoft.com/en-us/dotnet/api/microsoft.crm.sdk.messages.commitfileblocksuploadrequest?view=dataverse-sdk-latest
+    /// </summary>
+    public class CommitFileBlocksUploadRequestExecutor: IFakeMessageExecutor
+    {
+        public bool CanExecute(OrganizationRequest request)
+        {
+            return request is CommitFileBlocksUploadRequest;
+        }
+
+        public OrganizationResponse Execute(OrganizationRequest request, IXrmFakedContext ctx)
+        {
+            var req = request as CommitFileBlocksUploadRequest;
+
+            var fileDb = (ctx as XrmFakedContext).FileDb;
+
+            var fileId = fileDb.CommitFileUploadSession(new CommitFileUploadSessionProperties()
+            {
+                FileName = req.FileName,
+                MimeType = req.MimeType,
+                BlockIdsListSequence = req.BlockList,
+                FileUploadSessionId = req.FileContinuationToken
+            });
+
+            var file = fileDb.GetFileById(fileId);
+
+            return new CommitFileBlocksUploadResponse()
+            {
+                Results = new ParameterCollection()
+                {
+                    { "FileId" , new Guid(fileId) },
+                    { "FileSizeInBytes" , (long) file.Content.Length }
+                }
+            };
+        }
+
+        public Type GetResponsibleRequestType()
+        {
+            return typeof(CommitFileBlocksUploadRequest);
+        }
+    }
+}
+#endif

src/FakeXrmEasy.Messages/FakeMessageExecutors/InitializeFileBlocksUploadRequestExecutor.cs

@@ -57,7 +57,7 @@ public OrganizationResponse Execute(OrganizationRequest request, IXrmFakedContex
         /// <returns></returns>
         public Type GetResponsibleRequestType()
         {
-            return typeof(InitializeFileBlocksUploadResponse);
+            return typeof(InitializeFileBlocksUploadRequest);
         }
     }
 }

src/FakeXrmEasy.Messages/FakeMessageExecutors/UploadBlockRequestExecutor.cs

@@ -0,0 +1,61 @@
+#if FAKE_XRM_EASY_9
+using System;
+using FakeXrmEasy.Abstractions;
+using FakeXrmEasy.Abstractions.FakeMessageExecutors;
+using FakeXrmEasy.Core.FileStorage.Upload;
+using Microsoft.Crm.Sdk.Messages;
+using Microsoft.Xrm.Sdk;
+
+namespace FakeXrmEasy.FakeMessageExecutors
+{
+    /// <summary>
+    /// Implements the UploadBlockRequest message https://learn.microsoft.com/en-us/dotnet/api/microsoft.crm.sdk.messages.uploadblockrequest?view=dataverse-sdk-latest
+    /// </summary>
+    public class UploadBlockRequestExecutor: IFakeMessageExecutor
+    {
+        /// <summary>
+        /// Returns true if the request to execute is an UploadBlockRequest
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        /// <exception cref="NotImplementedException"></exception>
+        public bool CanExecute(OrganizationRequest request)
+        {
+            return request is UploadBlockRequest;
+        }
+
+        /// <summary>
+        /// Executes the current request
+        /// </summary>
+        /// <param name="request"></param>
+        /// <param name="ctx"></param>
+        /// <returns></returns>
+        /// <exception cref="NotImplementedException"></exception>
+        public OrganizationResponse Execute(OrganizationRequest request, IXrmFakedContext ctx)
+        {
+            var uploadBlockRequest = request as UploadBlockRequest;
+            var fileDb = (ctx as XrmFakedContext).FileDb;
+
+            var fileUploadSession = fileDb.GetFileUploadSession(uploadBlockRequest.FileContinuationToken);
+            fileUploadSession.AddFileBlock(new UploadBlockProperties()
+            {
+                FileContinuationToken = uploadBlockRequest.FileContinuationToken,
+                BlockContents = uploadBlockRequest.BlockData,
+                BlockId = uploadBlockRequest.BlockId
+            });
+
+            return new UploadBlockResponse();
+        }
+
+        /// <summary>
+        /// Returns the type of UploadBlockRequest
+        /// </summary>
+        /// <returns></returns>
+        /// <exception cref="NotImplementedException"></exception>
+        public Type GetResponsibleRequestType()
+        {
+            return typeof(UploadBlockRequest);
+        }
+    }
+}
+#endif

tests/FakeXrmEasy.Messages.Tests/FakeMessageExecutors/AddMemberListRequestTests/AddMemberListRequestTests.cs

@@ -41,8 +41,6 @@ public void When_a_member_is_added_to_a_non_existing_list_exception_is_thrown()
         [Fact]
         public void When_a_request_is_called_with_an_empty_listid_parameter_exception_is_thrown()
         {
-
-
             AddListMembersListRequest addListMembersListRequest = new AddListMembersListRequest
             {
                 MemberIds = new[]

tests/FakeXrmEasy.Messages.Tests/FakeMessageExecutors/CommitFileBlocksUploadRequestTests/CommitFileBlocksUploadRequestTests.cs

@@ -0,0 +1,71 @@
+using System;
+using FakeXrmEasy.Core.FileStorage.Db;
+using Microsoft.Crm.Sdk.Messages;
+using Microsoft.Xrm.Sdk;
+using Xunit;
+
+namespace FakeXrmEasy.Messages.Tests.FakeMessageExecutors.CommitFileBlocksUploadRequestTests
+{
+    public class CommitFileBlocksUploadRequestTests: FakeXrmEasyTestsBase
+    {
+        private readonly InMemoryFileDb _fileDb;
+        private readonly Entity _entity;
+
+        private readonly InitializeFileBlocksUploadRequest _initFileUploadRequest;
+        private readonly CommitFileBlocksUploadRequest _commitFileBlocksUploadRequest;
+        private readonly UploadBlockRequest _uploadBlockRequest;
+
+        public CommitFileBlocksUploadRequestTests()
+        {
+            _fileDb = (_context as XrmFakedContext).FileDb;
+
+            _entity = new Entity("dv_test") { Id = Guid.NewGuid() };
+
+            _initFileUploadRequest = new InitializeFileBlocksUploadRequest()
+            {
+                FileName = "Test.pdf",
+                Target = _entity.ToEntityReference(),
+                FileAttributeName = "dv_file"
+            };
+
+            _uploadBlockRequest = new UploadBlockRequest()
+            {
+                BlockData = new byte[] { 1, 2, 3, 4 },
+                BlockId = new Guid().ToString(),
+            };
+
+            _commitFileBlocksUploadRequest = new CommitFileBlocksUploadRequest()
+            {
+                FileName = "Test.pdf",
+                BlockList = new[] { _uploadBlockRequest.BlockId },
+                MimeType = "application/pdf"
+            };
+        }
+
+        [Fact]
+        public void Should_commit_file_block_upload()
+        {
+            _context.Initialize(_entity);
+
+            var initFileUploadResponse = _service.Execute(_initFileUploadRequest) as InitializeFileBlocksUploadResponse;
+
+            _uploadBlockRequest.FileContinuationToken = initFileUploadResponse.FileContinuationToken;
+            _service.Execute(_uploadBlockRequest);
+
+            _commitFileBlocksUploadRequest.FileContinuationToken = initFileUploadResponse.FileContinuationToken;
+            var response = _service.Execute(_commitFileBlocksUploadRequest);
+            Assert.NotNull(response);
+            Assert.IsType<CommitFileBlocksUploadResponse>(response);
+
+            var commitResponse = response as CommitFileBlocksUploadResponse;
+            Assert.Equal(4L, commitResponse.FileSizeInBytes);
+            Assert.NotEqual(Guid.Empty, commitResponse.FileId);
+
+            var file = _fileDb.GetFileById(commitResponse.FileId.ToString());
+            Assert.NotNull(file);
+
+            Assert.Equal(_commitFileBlocksUploadRequest.MimeType, file.MimeType);
+            Assert.Equal(_uploadBlockRequest.BlockData, file.Content);
+        }
+    }
+}

tests/FakeXrmEasy.Messages.Tests/FakeMessageExecutors/InitializeFileBlocksUploadRequestTests/InitializeFileBlocksUploadRequestTests.cs

@@ -16,7 +16,7 @@ public class InitializeFileBlocksUploadRequestTests: FakeXrmEasyTestsBase
         private readonly Entity _entity;
         private readonly InitializeFileBlocksUploadRequest _request;
 
-        public InitializeFileBlocksUploadRequestTests()
+        public InitializeFileBlocksUploadRequestTests(): base()
         {
             _fileDb = (_context as XrmFakedContext).FileDb;
 

tests/FakeXrmEasy.Messages.Tests/FakeMessageExecutors/UploadBlockRequestTests/UploadBlockRequestTests.cs

@@ -0,0 +1,61 @@
+#if FAKE_XRM_EASY_9
+using System;
+using System.Linq;
+using FakeXrmEasy.Core.FileStorage.Db;
+using Microsoft.Crm.Sdk.Messages;
+using Microsoft.Xrm.Sdk;
+using Xunit;
+
+namespace FakeXrmEasy.Messages.Tests.FakeMessageExecutors.UploadBlockRequestTests
+{
+    public class UploadBlockRequestTests: FakeXrmEasyTestsBase
+    {
+        private readonly InMemoryFileDb _fileDb;
+        private readonly Entity _entity;
+        private readonly InitializeFileBlocksUploadRequest _request;
+
+        public UploadBlockRequestTests()
+        {
+            _fileDb = (_context as XrmFakedContext).FileDb;
+
+            _entity = new Entity("dv_test") { Id = Guid.NewGuid() };
+
+            _request = new InitializeFileBlocksUploadRequest()
+            {
+                FileName = "Test.pdf",
+                Target = _entity.ToEntityReference(),
+                FileAttributeName = "dv_file"
+            };
+        }
+
+        [Fact]
+        public void Should_call_upload_blob_request_with_correct_parameters()
+        {
+            _context.Initialize(_entity);
+
+            var initFileUploadResponse = _service.Execute(_request) as InitializeFileBlocksUploadResponse;
+
+            var request = new UploadBlockRequest()
+            {
+                FileContinuationToken = initFileUploadResponse.FileContinuationToken,
+                BlockData = new byte[] { 1, 2, 3, 4 },
+                BlockId = new Guid().ToString(),
+            };
+
+            var response = _service.Execute(request);
+            Assert.NotNull(response);
+            Assert.IsType<UploadBlockResponse>(response);
+
+            //Check the blob was added
+            var fileUploadSession = _fileDb.GetFileUploadSession(initFileUploadResponse.FileContinuationToken);
+            var fileBlocks = fileUploadSession.GetAllBlocks();
+
+            Assert.Single(fileBlocks);
+
+            var uploadedFileBlock = fileBlocks.FirstOrDefault();
+            Assert.Equal(request.BlockData, uploadedFileBlock.Content);
+            Assert.Equal(request.BlockId, uploadedFileBlock.BlockId);
+        }
+    }
+}
+#endif