Merge pull request #234 from delegateas/75_Implement_SendEmailRequest

Implemented SendEmailRequestHandler

src/XrmMockupShared/Core.cs

@@ -211,6 +211,7 @@ private void InitializeDB()
  new CloseIncidentRequestHandler(this, db, metadata, security),
  new AddMembersTeamRequestHandler(this, db, metadata, security),
  new RemoveMembersTeamRequestHandler(this, db, metadata, security),
+ new SendEmailRequestHandler(this, db, metadata, security),
 #if !(XRM_MOCKUP_2011 || XRM_MOCKUP_2013)
  new IsValidStateTransitionRequestHandler(this, db, metadata, security),
  new CalculateRollupFieldRequestHandler(this, db, metadata, security),

src/XrmMockupShared/Database/DbAttributeTypeMap.cs

@@ -1,7 +1,7 @@
-using Microsoft.Xrm.Sdk.Metadata;
+using Microsoft.Xrm.Sdk;
+using Microsoft.Xrm.Sdk.Metadata;
 using System;
 using System.Collections.Generic;
-using System.Text;
 
 namespace DG.Tools.XrmMockup.Database
 {
@@ -27,7 +27,7 @@ internal static class DbAttributeTypeHelper
  { AttributeTypeCode.Money, typeof(decimal) },
  { AttributeTypeCode.Owner, typeof(DbRow) },
  { AttributeTypeCode.Customer, typeof(DbRow) },
- { AttributeTypeCode.PartyList, typeof(DbRow[]) },
+ { AttributeTypeCode.PartyList, typeof(EntityCollection) },
  { AttributeTypeCode.String, typeof(string) },
  { AttributeTypeCode.Uniqueidentifier, typeof(Guid) },
  { AttributeTypeCode.Virtual, typeof(DbRow[]) }
@@ -37,7 +37,7 @@ public static bool IsValidType(AttributeMetadata attrMetadata, object value) {
  if (value == null) return true;
  _metadataTypeMap.TryGetValue(attrMetadata.AttributeType.Value, out Type expectedType);
  if (expectedType == null) {
- throw new NotImplementedException($"Attribute of type '{attrMetadata.AttributeType.Value}' is not implemeted in XrmMockup yet.");
+ throw new NotImplementedException($"Attribute of type '{attrMetadata.AttributeType.Value}' is not implemented in XrmMockup yet.");
  }
  if (expectedType.Name == "DbRow[]" && attrMetadata.AttributeType.Value == AttributeTypeCode.Virtual)
  return true;

src/XrmMockupShared/Requests/SendEmailRequestHandler.cs

@@ -0,0 +1,140 @@
+using DG.Tools.XrmMockup.Database;
+using Microsoft.Crm.Sdk.Messages;
+using Microsoft.Xrm.Sdk;
+using System;
+using System.ServiceModel;
+
+namespace DG.Tools.XrmMockup
+{
+ internal class SendEmailRequestHandler : RequestHandler
+ {
+ const int EMAIL_STATE_COMPLETED = 1;
+ const int EMAIL_STATUS_DRAFT = 1;
+ const int EMAIL_STATUS_PENDING_SEND = 6;
+ const int EMAIL_STATUS_SENT = 3;
+
+ public SendEmailRequestHandler(Core core, XrmDb db, MetadataSkeleton metadata, Security security) : base(core, db, metadata, security, "SendEmail") { }
+
+ internal override void CheckSecurity(OrganizationRequest orgRequest, EntityReference userRef)
+ {
+ var request = MakeRequest<SendEmailRequest>(orgRequest);
+ if (request.EmailId == Guid.Empty)
+ {
+ throw new FaultException("Required field 'EmailId' is missing");
+ }
+
+ var emailRef = new EntityReference("email", request.EmailId);
+
+ if (!security.HasPermission(emailRef, AccessRights.ReadAccess, userRef))
+ {
+ throw new FaultException($"Principal user (Id={userRef.Id}) is missing Read privilege for email (Id={emailRef.Id})");
+ }
+
+ if (!security.HasPermission(emailRef, AccessRights.WriteAccess, userRef))
+ {
+ throw new FaultException($"Principal user (Id={userRef.Id}) is missing Write privilege for email (Id={emailRef.Id})");
+ }
+
+ var email = db.GetEntityOrNull(emailRef) ?? throw new FaultException($"email with Id = {request.EmailId} does not exist");
+
+ if (email.Contains("regardingobjectid"))
+ {
+ var regardingObject = email.GetAttributeValue<EntityReference>("regardingobjectid");
+
+ if (!security.HasPermission(regardingObject, AccessRights.ReadAccess, userRef))
+ {
+ throw new FaultException($"Principal user (Id={userRef.Id}) is missing Read privilege for {regardingObject.LogicalName} (Id={regardingObject.Id})");
+ }
+ }
+
+ // Remaining security checks have been omitted to reduce complexity
+ }
+
+ internal override OrganizationResponse Execute(OrganizationRequest orgRequest, EntityReference userRef)
+ {
+ var request = MakeRequest<SendEmailRequest>(orgRequest);
+
+ var email = db.GetEntity(new EntityReference("email", request.EmailId));
+
+ if (email.GetAttributeValue<OptionSetValue>("statuscode").Value != EMAIL_STATUS_DRAFT)
+ {
+ throw new FaultException("Email must be in Draft status to send");
+ }
+
+ if (email.GetAttributeValue<bool>("directioncode") is false)
+ {
+ throw new FaultException("Cannot send incoming email messages");
+ }
+
+ if (email.Contains("from"))
+ {
+ var from = email.GetAttributeValue<EntityCollection>("from");
+ if (from.Entities.Count != 1)
+ {
+ throw new FaultException("The email must have one and only one sender");
+ }
+
+ var activityParty = from.Entities[0];
+ if (activityParty.Contains("partyid"))
+ {
+ var partyRef = activityParty.GetAttributeValue<EntityReference>("partyid");
+ if (db.GetEntityOrNull(partyRef) is null)
+ {
+ throw new FaultException($"{partyRef.LogicalName} with Id = {partyRef.Id} does not exist");
+ }
+ }
+ else
+ {
+ throw new FaultException("Sender cannot be unresolved");
+ }
+ }
+ else
+ {
+ throw new FaultException("The email must have a sender");
+ }
+
+ if (email.Contains("to"))
+ {
+ var to = email.GetAttributeValue<EntityCollection>("to");
+ if (to.Entities.Count is 0)
+ {
+ throw new FaultException("The email must have at least one recipient before it can be sent");
+ }
+
+ foreach (Entity activityParty in to.Entities)
+ {
+ if (activityParty.Contains("partyid"))
+ {
+ var partyRef = activityParty.GetAttributeValue<EntityReference>("partyid");
+ if (db.GetEntityOrNull(partyRef) is null)
+ {
+ throw new FaultException($"{partyRef.LogicalName} with Id = {partyRef.Id} does not exist");
+ }
+ }
+ else if (!activityParty.Contains("addressused"))
+ {
+ throw new FaultException("Invalid ActivityParty");
+ }
+ }
+ }
+ else
+ {
+ throw new FaultException("The email must have at least one recipient before it can be sent");
+ }
+
+
+ email["statecode"] = new OptionSetValue(EMAIL_STATE_COMPLETED);
+ email["statuscode"] = new OptionSetValue(request.IssueSend ? EMAIL_STATUS_PENDING_SEND : EMAIL_STATUS_SENT);
+
+ db.Update(email);
+
+ return new SendEmailResponse
+ {
+ Results = new ParameterCollection
+ {
+ { "Subject", email.Contains("subject") ? email.GetAttributeValue<string>("subject") : null }
+ }
+ };
+ }
+ }
+}

src/XrmMockupShared/XrmMockupShared.projitems

@@ -14,6 +14,7 @@
  <Compile Include="$(MSBuildThisFileDirectory)Database\DbTable.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)MockupServiceAsync2.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)MockupServiceAsync.cs" />
+ <Compile Include="$(MSBuildThisFileDirectory)Requests\SendEmailRequestHandler.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)Serialization\DbDTO.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)Serialization\OptionSetCollectionDTO.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)Serialization\EntityReferenceDTO.cs" />

tests/SharedTests/SharedTests.projitems

@@ -20,6 +20,7 @@
  <Compile Include="$(MSBuildThisFileDirectory)TestCWAAccountOptional.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)TestDefaultBusinessUnitTeamsMembers.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)TestPriorityAttribute.cs" />
+ <Compile Include="$(MSBuildThisFileDirectory)TestSendEmail.cs" />
  <Compile Include="..\SharedTests\TestZipSnapshot.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)TestTableReset.cs" />
  <Compile Include="$(MSBuildThisFileDirectory)TestPrivileges\TestPrivilegesAppendToOnUpdate.cs" />