perf: reduce number of avatar requests

lib/Contracts/IAvatarService.php

@@ -27,4 +27,6 @@ public function getAvatar(string $email, string $uid): ?Avatar;
 	 * @return array|null image data
 	 */
 	public function getAvatarImage(string $email, string $uid);
+
+	public function getCachedAvatar(string $email, string $uid): Avatar|false|null;
 }

lib/Contracts/IMailSearch.php

@@ -39,6 +39,7 @@ public function findMessage(Account $account,
 	 * @param string|null $filter
 	 * @param int|null $cursor
 	 * @param int|null $limit
+	 * @param string|null $userId
 	 * @param string|null $view
 	 *
 	 * @return Message[]
@@ -52,6 +53,7 @@ public function findMessages(Account $account,
 		?string $filter,
 		?int $cursor,
 		?int $limit,
+		?string $userId,
 		?string $view): array;
 
 	/**

lib/Controller/MessagesController.php

@@ -156,6 +156,7 @@
 			$filter === '' ? null : $filter,
 			$cursor,
 			$limit,
+			$this->currentUserId,
 			$view
 		);
 		return new JSONResponse(

lib/Db/Message.php

@@ -12,6 +12,7 @@
 use Horde_Mail_Rfc822_Identification;
 use JsonSerializable;
 use OCA\Mail\AddressList;
+use OCA\Mail\Service\Avatar\Avatar;
 use OCP\AppFramework\Db\Entity;
 use ReturnTypeWillChange;
 use function in_array;
@@ -136,6 +137,12 @@ class Message extends Entity implements JsonSerializable {
 	/** @var Tag[] */
 	private $tags = [];
 
+	/** @var Avatar|null */
+	private $avatar;
+
+	/** @var bool */
+	private $fetchAvatarFromClient = false;
+
 	public function __construct() {
 		$this->from = new AddressList([]);
 		$this->to = new AddressList([]);
@@ -286,6 +293,24 @@ public function setFlag(string $flag, bool $value = true) {
 			);
 		}
 	}
+	/**
+	 * @param Avatar|null $avatar
+	 * @return void
+	 */
+	public function setAvatar(?Avatar $avatar): void {
+		$this->avatar = $avatar;
+	}
+
+	public function setFetchAvatarFromClient(bool $fetchAvatarFromClient): void {
+		$this->fetchAvatarFromClient = $fetchAvatarFromClient;
+	}
+
+	/**
+	 * @return ?Avatar
+	 */
+	public function getAvatar(): ?Avatar {
+		return $this->avatar;
+	}
 
 	#[\Override]
 	#[ReturnTypeWillChange]
@@ -332,6 +357,8 @@ static function (Tag $tag) {
 			'summary' => $this->getSummary(),
 			'encrypted' => ($this->isEncrypted() === true),
 			'mentionsMe' => $this->getMentionsMe(),
+			'avatar' => $this->avatar?->jsonSerialize(),
+			'fetchAvatarFromClient' => $this->fetchAvatarFromClient,
 		];
 	}
 }

lib/IMAP/PreviewEnhancer.php

@@ -15,6 +15,8 @@
 use OCA\Mail\Db\Message;
 use OCA\Mail\Db\MessageMapper as DbMapper;
 use OCA\Mail\IMAP\MessageMapper as ImapMapper;
+use OCA\Mail\Service\Avatar\Avatar;
+use OCA\Mail\Service\AvatarService;
 use Psr\Log\LoggerInterface;
 use function array_key_exists;
 use function array_map;
@@ -34,22 +36,27 @@ class PreviewEnhancer {
 	/** @var LoggerInterface */
 	private $logger;
 
+	/** @var AvatarService */
+	private $avatarService;
+
 	public function __construct(IMAPClientFactory $clientFactory,
 		ImapMapper $imapMapper,
 		DbMapper $dbMapper,
-		LoggerInterface $logger) {
+		LoggerInterface $logger,
+		AvatarService $avatarService) {
 		$this->clientFactory = $clientFactory;
 		$this->imapMapper = $imapMapper;
 		$this->mapper = $dbMapper;
 		$this->logger = $logger;
+		$this->avatarService = $avatarService;
 	}
 
 	/**
 	 * @param Message[] $messages
 	 *
 	 * @return Message[]
 	 */
-	public function process(Account $account, Mailbox $mailbox, array $messages): array {
+	public function process(Account $account, Mailbox $mailbox, array $messages, bool $preLoadAvatars = false, ?string $userId = null): array {
 		$needAnalyze = array_reduce($messages, static function (array $carry, Message $message) {
 			if ($message->getStructureAnalyzed()) {
 				// Nothing to do
@@ -59,6 +66,22 @@ public function process(Account $account, Mailbox $mailbox, array $messages): ar
 			return array_merge($carry, [$message->getUid()]);
 		}, []);
 
+		if ($preLoadAvatars) {
+			foreach ($messages as $message) {
+				$from = $message->getFrom()->first();
+				if ($message->getAvatar() === null && $from !== null && $from->getEmail() !== null && $userId !== null) {
+					$avatar = $this->avatarService->getCachedAvatar($from->getEmail(), $userId);
+					if ($avatar === null) {
+						$message->setFetchAvatarFromClient(true);
+					}
+					if ($avatar instanceof Avatar) {
+						$message->setAvatar($avatar);
+					}
+
+				}
+			}
+		}
+
 		if ($needAnalyze === []) {
 			// Nothing to enhance
 			return $messages;

lib/Service/AvatarService.php

@@ -86,6 +86,10 @@
 		}
 	}
 
+	public function getCachedAvatar(string $email, string $uid): Avatar|false|null {
+		return $this->cache->get($email, $uid);
+	}
+
 	/**
 	 * @param string $email
 	 * @param string $uid

lib/Service/Search/MailSearch.php

@@ -95,6 +95,7 @@ public function findMessages(Account $account,
 		?string $filter,
 		?int $cursor,
 		?int $limit,
+		?string $userId,
 		?string $view): array {
 		if ($mailbox->hasLocks($this->timeFactory->getTime())) {
 			throw MailboxLockedException::from($mailbox);
@@ -125,7 +126,9 @@ public function findMessages(Account $account,
 			$this->messageMapper->findByIds($account->getUserId(),
 				$this->getIdsLocally($account, $mailbox, $query, $sortOrder, $limit),
 				$sortOrder,
-			)
+			),
+			true,
+			$userId
 		);
 	}
 

src/components/Avatar.vue

@@ -17,6 +17,7 @@
 
 <script>
 import NcAvatar from '@nextcloud/vue/components/NcAvatar'
+import { generateUrl } from '@nextcloud/router'
 import { fetchAvatarUrlMemoized } from '../service/AvatarService.js'
 import logger from '../logger.js'
 
@@ -30,6 +31,14 @@ export default {
 			type: String,
 			required: true,
 		},
+		avatar: {
+			type: Object,
+			default: null,
+		},
+		fetchAvatar: {
+			type: Boolean,
+			default: false,
+		},
 		email: {
 			type: String,
 			required: true,
@@ -55,14 +64,21 @@ export default {
 		},
 	},
 	async mounted() {
-		if (this.email !== '') {
-			try {
-				this.avatarUrl = await fetchAvatarUrlMemoized(this.email)
-			} catch {
-				logger.debug('Could not fetch avatar', { email: this.email })
+		if (this.avatar) {
+			this.avatarUrl = this.avatar.isExternal
+				? generateUrl('/apps/mail/api/avatars/image/{email}', {
+					email: this.email,
+				})
+				: this.avatar.url
+		} else if (this.fetchAvatar) {
+			if (this.email !== '') {
+				try {
+					this.avatarUrl = await fetchAvatarUrlMemoized(this.email)
+				} catch {
+					logger.debug('Could not fetch avatar', { email: this.email })
+				}
 			}
 		}
-
 		this.loading = false
 	},
 }

src/components/Envelope.vue

@@ -36,7 +36,7 @@
 				:class="{ 'important-one-line': oneLineLayout, 'icon-important': !oneLineLayout }"
 				:data-starred="isImportant ? 'true' : 'false'"
 				@click.prevent="hasWriteAcl ? onToggleImportant() : false"
 				v-html="importantSvg" />
 			<JunkIcon v-if="data.flags.$junk"
 				:size="18"
 				class="app-content-list-item-star junk-icon-style"
@@ -53,7 +53,10 @@
 					<CheckIcon :size="40" class="check-icon" :class="{ 'app-content-list-item-avatar-selected': selected }" />
 				</template>
 				<template v-else>
-					<Avatar :display-name="addresses" :email="avatarEmail" />
+					<Avatar :display-name="addresses"
+						:email="avatarEmail"
+						:fetch-avatar="data.fetchAvatarFromClient"
+						:avatar="data.avatar" />
 				</template>
 			</div>
 		</template>
@@ -497,7 +500,7 @@
 
 		window.addEventListener('resize', this.onWindowResize)
 	},
 	computed: {
 		...mapStores(useMainStore),
 		...mapState(useMainStore, [
 			'isSnoozeDisabled',

src/components/OutboxMessageListItem.vue

@@ -10,7 +10,10 @@
 		:details="details"
 		@click="openModal">
 		<template #icon>
-			<Avatar :display-name="avatarDisplayName" :email="avatarEmail" />
+			<Avatar :display-name="avatarDisplayName"
+				:email="avatarEmail"
+				:fetch-avatar="data.fetchAvatarFromClient"
+				:avatar="message.avatar" />
 		</template>
 		<template #subname>
 			{{ subjectForSubtitle }}

src/components/ThreadEnvelope.vue

@@ -26,6 +26,8 @@
 					:display-name="envelope.from[0].label"
 					:disable-tooltip="true"
 					:size="40"
+					:fetch-avatar="envelope.fetchAvatarFromClient"
+					:avatar="envelope.avatar"
 					class="envelope__header__avatar-avatar" />
 				<div v-if="isImportant"
 					class="app-content-list-item-star icon-important"

tests/Integration/Db/MessageTest.php

@@ -11,6 +11,7 @@
 
 use ChristophWurst\Nextcloud\Testing\TestCase;
 use OCA\Mail\Db\Message;
+use OCA\Mail\Service\Avatar\Avatar;
 
 class MessageTest extends TestCase {
 	protected function setUp(): void {
@@ -109,4 +110,25 @@ public function testSetInReplyToEmpty(): void {
 		$this->assertEquals($expected, $message->getThreadRootId());
 		$this->assertNull($message->getInReplyTo());
 	}
+
+	public function testSetAvatar(): void {
+		$expected = new Avatar(
+			'http://example.com/avatar.png',
+			'image/png',
+			true
+		);
+		$message = new Message();
+
+		$message->setAvatar($expected);
+
+		$this->assertEquals($expected, $message->getAvatar());
+	}
+
+	public function testSetFetchAvatarFromClient(): void {
+		$message = new Message();
+
+		$message->setFetchAvatarFromClient(true);
+
+		$this->assertTrue($message->jsonSerialize()['fetchAvatarFromClient']);
+	}
 }

tests/Unit/IMAP/PreviewEnhancerTest.php

@@ -0,0 +1,93 @@
+<?php
+
+declare(strict_types=1);
+
+/**
+ * SPDX-FileCopyrightText: 2025 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace Unit\IMAP;
+
+use ChristophWurst\Nextcloud\Testing\TestCase;
+use OCA\Mail\Address;
+use OCA\Mail\AddressList;
+use OCA\Mail\Db\Message;
+use OCA\Mail\Db\MessageMapper as DbMapper;
+use OCA\Mail\IMAP\IMAPClientFactory;
+use OCA\Mail\IMAP\MessageMapper as ImapMapper;
+use OCA\Mail\IMAP\PreviewEnhancer;
+use OCA\Mail\Service\Avatar\Avatar;
+use OCA\Mail\Service\AvatarService;
+use PHPUnit\Framework\MockObject\MockObject;
+use Psr\Log\LoggerInterface;
+
+class PreviewEnhancerTest extends TestCase {
+
+
+	/** @var IMAPClientFactory|MockObject */
+	private $imapClientFactory;
+	/** @var ImapMapper|MockObject */
+	private $imapMapper;
+	/** @var DbMapper|MockObject */
+	private $dbMapper;
+	/** @var LoggerInterface|MockObject */
+	private $logger;
+	/** @var AvatarService|MockObject */
+	private $avatarService;
+	/** @var PreviewEnhancer */
+	private $previewEnhancer;
+
+	protected function setUp(): void {
+		parent::setUp();
+
+		$this->imapClientFactory = $this->createMock(IMAPClientFactory::class);
+		$this->imapMapper = $this->createMock(ImapMapper::class);
+		$this->dbMapper = $this->createMock(DbMapper::class);
+		$this->logger = $this->createMock(LoggerInterface::class);
+		$this->avatarService = $this->createMock(AvatarService::class);
+
+		$this->previewEnhancer = new previewEnhancer($this->imapClientFactory,
+			$this->imapMapper,
+			$this->dbMapper,
+			$this->logger,
+			$this->avatarService);
+	}
+
+	public function testAvatars(): void {
+
+		$message1 = new Message();
+		$message1->setId(1);
+		$message1->setStructureAnalyzed(true);
+		$message1->setFrom(new AddressList([Address::fromRaw('Alice', 'alice@example.com')]));
+		$message2 = new Message();
+		$message2->setId(2);
+		$message2->setStructureAnalyzed(true);
+		$message2->setFrom(new AddressList([Address::fromRaw('Bob', 'bob@example.com')]));
+		$messages = [$message1, $message2];
+		$message2Avatar = new Avatar('example.com', 'image/png', true);
+		$this->avatarService->expects($this->exactly(2))
+			->method('getCachedAvatar')
+			->withConsecutive(
+				['alice@example.com', 'testuser'],
+				['bob@example.com', 'testuser']
+			)
+			->willReturnOnConsecutiveCalls(
+				null,
+				$message2Avatar
+			);
+		$this->previewEnhancer->process(
+			$this->createMock(\OCA\Mail\Account::class),
+			$this->createMock(\OCA\Mail\Db\Mailbox::class),
+			$messages,
+			true,
+			'testuser'
+		);
+		$this->assertTrue($message1->jsonSerialize()['fetchAvatarFromClient']);
+		$this->assertFalse($message2->jsonSerialize()['fetchAvatarFromClient']);
+		$this->assertNull($message1->getAvatar());
+		$this->assertSame($message2Avatar, $message2->getAvatar());
+	}
+
+
+}