ews: calendar items - process attendees

Author: gromandreas

exch/ews/context.cpp

@@ -1997,6 +1997,59 @@ void EWSContext::toContent(const std::string& dir, tCalendarItem& item, sShape&
 		shape.write(NtGlobalObjectId, TAGGED_PROPVAL{PT_BINARY, goid});
 		shape.write(NtCleanGlobalObjectId, TAGGED_PROPVAL{PT_BINARY, goid});
 	}
+
+	size_t recipients = (item.RequiredAttendees ? item.RequiredAttendees->size() : 0) +
+	                    (item.OptionalAttendees ? item.OptionalAttendees->size() : 0) +
+	                    (item.Resources ? item.Resources->size() : 0);
+	if (recipients) {
+		if (!content->children.prcpts && !(content->children.prcpts = tarray_set_init()))
+			throw EWSError::NotEnoughMemory(E3288);
+		TARRAY_SET* rcpts = content->children.prcpts;
+		if (item.RequiredAttendees)
+			for (const auto &att : *item.RequiredAttendees)
+				att.Mailbox.mkRecipient(rcpts->emplace(), MAPI_TO);
+		if (item.OptionalAttendees)
+			for (const auto &att : *item.OptionalAttendees)
+				att.Mailbox.mkRecipient(rcpts->emplace(), MAPI_CC);
+		if (item.Resources)
+			for (const auto &att : *item.Resources)
+				att.Mailbox.mkRecipient(rcpts->emplace(), MAPI_TO);
+		std::string dispName;
+		if (!mysql_adaptor_get_user_displayname(m_auth_info.username, dispName))
+			throw DispatchError(E3302);
+		auto displayName = deconst(dispName.c_str());
+		shape.write(TAGGED_PROPVAL{PR_SENT_REPRESENTING_NAME, displayName});
+		shape.write(TAGGED_PROPVAL{PR_SENDER_NAME, displayName});
+		auto username = deconst(m_auth_info.username);
+		shape.write(TAGGED_PROPVAL{PR_SENT_REPRESENTING_SMTP_ADDRESS, username});
+		shape.write(TAGGED_PROPVAL{PR_SENDER_SMTP_ADDRESS, username});
+		auto addrType = deconst("SMTP");
+		shape.write(TAGGED_PROPVAL{PR_SENT_REPRESENTING_ADDRTYPE, addrType});
+		shape.write(TAGGED_PROPVAL{PR_SENDER_ADDRTYPE, addrType});
+		auto uint0 = construct<uint32_t>(0);
+		auto uint1 = construct<uint32_t>(1);
+		auto uint5 = construct<uint32_t>(5);
+		shape.write(NtMeetingType, TAGGED_PROPVAL{PT_LONG, uint1});
+		shape.write(NtPrivate, TAGGED_PROPVAL{PT_BOOLEAN, uint0});
+		shape.write(NtAppointmentStateFlags, TAGGED_PROPVAL{PT_LONG, uint1});
+		shape.write(NtResponseStatus, TAGGED_PROPVAL{PT_LONG, uint5});
+		std::string essdn;
+		if (cvt_username_to_essdn(m_auth_info.username, m_plugin.x500_org_name.c_str(),
+		    mysql_adaptor_get_user_ids, mysql_adaptor_get_domain_ids, essdn) != ecSuccess)
+			throw DispatchError(E3085);
+		shape.write(TAGGED_PROPVAL{PR_SENT_REPRESENTING_EMAIL_ADDRESS, strcpy(alloc<char>(essdn.size() + 1), essdn.c_str())});
+		shape.write(TAGGED_PROPVAL{PR_SENDER_EMAIL_ADDRESS, strcpy(alloc<char>(essdn.size() + 1), essdn.c_str())});
+		EMSAB_ENTRYID abEid{0, DT_MAILUSER, essdn.data()};
+		EXT_PUSH ext_push;
+		static constexpr size_t ABEIDBUFFSIZE = 1280;
+		uint8_t* abEidBuff = alloc<uint8_t>(ABEIDBUFFSIZE);
+		if (!ext_push.init(abEidBuff, ABEIDBUFFSIZE, EXT_FLAG_UTF16) ||
+		    ext_push.p_abk_eid(abEid) != pack_result::ok)
+			throw DispatchError(E3085);
+		BINARY* abEidContainer = construct<BINARY>(BINARY{ext_push.m_offset, {abEidBuff}});
+		shape.write(TAGGED_PROPVAL{PR_SENT_REPRESENTING_ENTRYID, abEidContainer});
+		shape.write(TAGGED_PROPVAL{PR_SENDER_ENTRYID, abEidContainer});
+	}
 }
 
 /**

exch/ews/exceptions.hpp

@@ -429,6 +429,8 @@ inline std::string E3297(const char* uid) {return fmt::format("E-3297: Failed to
 E(3298, "Failed to allocate memory for goid data");
 E(3299, "Failed to generate goid data");
 E(3300, "Failed to get offset from the timezone definition");
+E(3301, "Failed to copy message to sent items");
+E(3302, "Failed to get the display name");
 
 #undef E
 }

exch/ews/requests.cpp

@@ -243,19 +243,56 @@ void process(mCreateItemRequest&& request, XMLElement* response, const EWSContex
 		request.MessageDisposition = Enum::SaveOnly;
 	if (!request.SendMeetingInvitations)
 		request.SendMeetingInvitations = Enum::SendToNone;
-	bool sendMessages = request.MessageDisposition == Enum::SendOnly || request.MessageDisposition == Enum::SendAndSaveCopy;
+	bool sendMessages = request.MessageDisposition == Enum::SendOnly
+		|| request.MessageDisposition == Enum::SendAndSaveCopy
+		|| request.SendMeetingInvitations == Enum::SendOnlyToAll
+		|| request.SendMeetingInvitations == Enum::SendToAllAndSaveCopy;
 
 	data.ResponseMessages.reserve(request.Items.size());
+	auto proptrue = 1;
 	for (sItem &item : request.Items) try {
 		if (!hasAccess)
 			throw EWSError::AccessDenied(E3130);
 
 		mCreateItemResponseMessage msg;
 		bool persist = !(std::holds_alternative<tMessage>(item) && request.MessageDisposition == Enum::SendOnly);
-		bool send = std::holds_alternative<tMessage>(item) &&	sendMessages;
+		bool send = std::holds_alternative<tMessage>(item) && sendMessages;
 		auto content = ctx.toContent(dir, *targetFolder, item, persist);
 		if (persist)
 			msg.Items.emplace_back(ctx.create(dir, *targetFolder, *content));
+		if (std::holds_alternative<tCalendarItem>(item) && sendMessages &&
+		    request.SendMeetingInvitations == Enum::SendToAllAndSaveCopy) {
+			sFolderSpec sentitems = ctx.resolveFolder(tDistinguishedFolderId(Enum::sentitems));
+			uint64_t newMid;
+			if (!ctx.plugin().exmdb.allocate_message_id(dir.c_str(),
+				sentitems.folderId, &newMid))
+				throw EWSError::InternalServerError(E3132);
+			BOOL result;
+			uint64_t messageId = *(*content).proplist.get<uint64_t>(PidTagMid);
+			if (!ctx.plugin().exmdb.movecopy_message(dir.c_str(), CP_ACP,
+				messageId, sentitems.folderId, newMid, false, &result)
+				|| !result)
+				throw EWSError::InternalServerError(E3301);
+			const char* username = ctx.effectiveUser(sentitems);
+			auto now = EWSContext::construct<uint64_t>(rop_util_current_nttime());
+			TAGGED_PROPVAL props[] = {
+				{PR_MESSAGE_CLASS, deconst("IPM.Schedule.Meeting.Request")},
+				{PR_RESPONSE_REQUESTED, &proptrue},
+				{PR_CLIENT_SUBMIT_TIME, now},
+				{PR_MESSAGE_DELIVERY_TIME, now},
+			};
+			TPROPVAL_ARRAY proplist{std::size(props), props};
+			PROBLEM_ARRAY problems;
+			if (!ctx.plugin().exmdb.set_message_properties(dir.c_str(),
+				username, CP_ACP, newMid, &proplist, &problems))
+				throw EWSError::ItemSave(E3092);
+			MESSAGE_CONTENT *sendcontent = nullptr;
+			if (!ctx.plugin().exmdb.read_message(dir.c_str(),
+				username, CP_ACP, newMid, &sendcontent)
+				|| sendcontent == nullptr)
+				throw EWSError::ItemNotFound(E3143);
+			ctx.send(dir, messageId, *sendcontent);
+		}
 		if (send)
 			ctx.send(dir, 0, *content);
 		msg.success();