feat: use task processing to send emails

lib/public/Json/JsonDeserializable.php

@@ -0,0 +1,16 @@
+<?php
+
+declare(strict_types=1);
+
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace OCP\Json;
+
+interface JsonDeserializable {
+
+    public function jsonDeserialize(array $data): void;
+
+}

lib/public/Mail/Provider/Address.php

@@ -8,6 +8,9 @@
  */
 namespace OCP\Mail\Provider;
 
+use JsonSerializable;
+use OCP\Json\JsonDeserializable;
+
 /**
  * Mail Address Object
  *
@@ -16,7 +19,7 @@
  * @since 30.0.0
  *
  */
-class Address implements \OCP\Mail\Provider\IAddress {
+class Address implements IAddress, JsonSerializable, JsonDeserializable {
 
 	/**
 	 * initialize the mail address object
@@ -32,6 +35,32 @@ public function __construct(
 	) {
 	}
 
+	/**
+	 * export this objects data as an array
+	 *
+	 * @since 33.0.0
+	 *
+	 * @return array representation of this object as an array
+	 */
+	public function jsonSerialize(): array {
+		return [
+			'address' => $this->address,
+			'label' => $this->label,
+		];
+	}
+
+	/**
+	 * import this objects data from an array
+	 *
+	 * @since 33.0.0
+	 *
+	 * @param array array representation of this object
+	 */
+	public function jsonDeserialize(array $data): void {
+		$this->address = $data['address'] ?? null;
+		$this->label = $data['label'] ?? null;
+	}
+
 	/**
 	 * sets the mail address
 	 *

lib/public/Mail/Provider/Attachment.php

@@ -8,6 +8,9 @@
  */
 namespace OCP\Mail\Provider;
 
+use JsonSerializable;
+use OCP\Json\JsonDeserializable;
+
 /**
  * Mail Attachment Object
  *
@@ -16,7 +19,7 @@
  * @since 30.0.0
  *
  */
-class Attachment implements \OCP\Mail\Provider\IAttachment {
+class Attachment implements IAttachment, JsonSerializable, JsonDeserializable {
 
 	/**
 	 * initialize the mail attachment object
@@ -36,6 +39,36 @@ public function __construct(
 	) {
 	}
 
+	/**
+	 * export this objects data as an array
+	 *
+	 * @since 33.0.0
+	 *
+	 * @return array representation of this object as an array
+	 */
+	public function jsonSerialize(): array {
+		return [
+			'contents' => base64_encode($this->contents ?? ''),
+			'name' => $this->name,
+			'type' => $this->type,
+			'embedded' => $this->embedded,
+		];
+	}
+
+	/**
+	 * import this objects data from an array
+	 *
+	 * @since 33.0.0
+	 *
+	 * @param array array representation of this object
+	 */
+	public function jsonDeserialize(array $data): void {
+		$this->contents = base64_decode($data['contents'] ?? '');
+		$this->name = $data['name'] ?? null;
+		$this->type = $data['type'] ?? null;
+		$this->embedded = $data['embedded'] ?? false;
+	}
+
 	/**
 	 * sets the attachment file name
 	 *

lib/public/Mail/Provider/Message.php

@@ -8,6 +8,9 @@
  */
 namespace OCP\Mail\Provider;
 
+use JsonSerializable;
+use OCP\Json\JsonDeserializable;
+
 /**
  * Mail Message Object
  *
@@ -16,7 +19,7 @@
  * @since 30.0.0
  *
  */
-class Message implements \OCP\Mail\Provider\IMessage {
+class Message implements IMessage, JsonSerializable, JsonDeserializable {
 
 	/**
 	 * initialize the mail message object
@@ -30,6 +33,64 @@ public function __construct(
 	) {
 	}
 
+	/**
+	 * export this objects data as an array
+	 *
+	 * @since 33.0.0
+	 *
+	 * @return array representation of this object as an array
+	 */
+	public function jsonSerialize(): array {
+		$data = $this->data;
+		$data['bodyHtml'] = base64_encode($this->data['bodyHtml'] ?? '');
+		$data['bodyPlain'] = base64_encode($this->data['bodyPlain'] ?? '');
+		$data['subject'] = base64_encode($this->data['subject'] ?? '');
+		return $data;
+	}
+
+	/**
+	 * import this objects data from an array
+	 *
+	 * @since 33.0.0
+	 *
+	 * @param array array representation of this object
+	 */
+	public function jsonDeserialize(array $data): void {
+		$this->data = $data;
+		// decode encoded fields
+		$this->data['bodyHtml'] = base64_decode($data['bodyHtml'] ?? '');
+		$this->data['bodyPlain'] = base64_decode($data['bodyPlain'] ?? '');
+		$this->data['subject'] = base64_decode($data['subject'] ?? '');
+		//  convert object fields
+		foreach (['from', 'replyTo'] as $field) {
+			if (isset($data[$field]) && is_array($data[$field])) {
+				$address = new Address();
+				$address->jsonDeserialize($data[$field]);
+				$this->data[$field] = $address;
+			} else {
+				$this->data[$field] = null;
+			}
+		}
+		foreach (['to', 'cc', 'bcc', 'attachments'] as $field) {
+			$this->data[$field] = [];
+			if (isset($data[$field]) && is_array($data[$field])) {
+				foreach ($data[$field] as $item) {
+					if (is_array($item)) {
+						if ($field === 'attachments') {
+							$attachment = new Attachment(null, null, null);
+							$attachment->jsonDeserialize($item);
+							$this->data[$field][] = $attachment;
+						} else {
+							$address = new Address();
+							$address->jsonDeserialize($item);
+							$this->data[$field][] = $address;
+						}
+					}
+				}
+			}
+		}
+	}
+
 	/**
 	 * arbitrary unique text string identifying this message
 	 *

lib/public/TaskProcessing/EShapeType.php

@@ -30,6 +30,8 @@ enum EShapeType: int {
 	case ListOfAudios = 13;
 	case ListOfVideos = 14;
 	case ListOfFiles = 15;
+	Case Array = 20;
+	Case Object = 21;
 
 	/**
 	 * @param mixed $value
@@ -106,6 +108,12 @@ public function validateInput(mixed $value): void {
 		if ($this === EShapeType::ListOfFiles && (!is_array($value) || count(array_filter($value, fn ($item) => !is_numeric($item))) > 0)) {
 			throw new ValidationException('Non-audio list item provided for ListOfFiles slot');
 		}
+		if ($this === EShapeType::Array && !is_array($value)) {
+			throw new ValidationException('Non-array item provided for Array slot');
+		}
+		if ($this === EShapeType::Object && !is_object($value)) {
+			throw new ValidationException('Non-object item provided for Object slot');
+		}
 	}
 
 	/**