diff --git a/server/src/services/asset-media.service.ts b/server/src/services/asset-media.service.ts index 077bff3db2..818bd5eb91 100644 --- a/server/src/services/asset-media.service.ts +++ b/server/src/services/asset-media.service.ts @@ -351,9 +351,12 @@ export class AssetMediaService extends BaseService { } await this.albumRepository.addAssetIds(album.id, [assetId]); - for (const { user } of album.albumUsers) { - await this.eventRepository.emit('AlbumUpdate', { id: album.id, recipientId: user.id }); - } + const userIds = album.albumUsers.map(({ user }) => user.id); + await this.eventRepository.emit('AlbumUpdate', { + id: album.id, + userIds, + recipientIds: userIds, + }); } private requireQuota(auth: AuthDto, size: number) { diff --git a/server/test/medium/specs/services/asset-media.service.spec.ts b/server/test/medium/specs/services/asset-media.service.spec.ts index 2d3546d9b0..52ec8e12dc 100644 --- a/server/test/medium/specs/services/asset-media.service.spec.ts +++ b/server/test/medium/specs/services/asset-media.service.spec.ts @@ -216,7 +216,8 @@ describe(AssetService.name, () => { expect(ctx.getMock(EventRepository).emit).toHaveBeenCalledWith('AlbumUpdate', { id: album.id, - recipientId: user.id, + userIds: [user.id], + recipientIds: [user.id], }); });