55 lines
1.9 KiB
C#
55 lines
1.9 KiB
C#
using System.Text;
|
|
using AutoMapper;
|
|
using MediatR;
|
|
using mws.backend.dotnet.application.Common;
|
|
using mws.backend.dotnet.application.Permissions;
|
|
using mws.backend.dotnet.domain.Documents;
|
|
|
|
namespace mws.backend.dotnet.application.Documents;
|
|
|
|
public record UpdateDocumentCommand(Guid UserId, Guid DocumentId, UpdateDocumentRequest Request) : IRequest<DocumentDto>;
|
|
|
|
public class UpdateDocumentHandler(IUnitOfWork uow, IMapper mapper, IDocumentContentStore contentStore)
|
|
: IRequestHandler<UpdateDocumentCommand, DocumentDto>
|
|
{
|
|
public async Task<DocumentDto> Handle(UpdateDocumentCommand command, CancellationToken ct)
|
|
{
|
|
var doc = await DocumentAccess.GetDocumentForUserAsync(uow, command.UserId, command.DocumentId, ct);
|
|
await DocumentAccess.EnsureDocumentPermissionAsync(uow, command.UserId, doc.ProjectId, PermissionAction.Edit, ct);
|
|
|
|
var request = command.Request;
|
|
if (string.IsNullOrWhiteSpace(request.Title))
|
|
{
|
|
throw new BadRequestException("Title is required");
|
|
}
|
|
|
|
doc.Title = request.Title.Trim();
|
|
doc.UpdatedAt = DateTime.UtcNow;
|
|
doc.UpdatedBy = command.UserId;
|
|
|
|
await uow.SaveChangesAsync(ct);
|
|
|
|
if (doc.Type == DocumentType.Document)
|
|
{
|
|
await contentStore.EnsureBucketAsync(doc.ProjectId, ct);
|
|
var bytes = Encoding.UTF8.GetBytes(request.Content ?? "");
|
|
using (var ms = new MemoryStream(bytes))
|
|
{
|
|
await contentStore.UploadAsync(doc.ProjectId, doc.Id, "text/html; charset=utf-8", ms, ct);
|
|
}
|
|
|
|
doc.ContentSize = bytes.Length;
|
|
doc.UpdatedContentAt = DateTime.UtcNow;
|
|
doc.ContentHash = null;
|
|
await uow.SaveChangesAsync(ct);
|
|
}
|
|
|
|
var dto = mapper.Map<DocumentDto>(doc);
|
|
if (doc.Type == DocumentType.Document)
|
|
{
|
|
dto.Content = request.Content;
|
|
}
|
|
return dto;
|
|
}
|
|
}
|