diff --git a/server/src/database.ts b/server/src/database.ts index c001388e79..3f1eb60a07 100644 --- a/server/src/database.ts +++ b/server/src/database.ts @@ -395,6 +395,26 @@ export const columns = { 'asset.height', 'asset.isEdited', ], + syncPartnerAsset: [ + 'asset.id', + 'asset.ownerId', + 'asset.originalFileName', + 'asset.thumbhash', + 'asset.checksum', + 'asset.fileCreatedAt', + 'asset.fileModifiedAt', + 'asset.localDateTime', + 'asset.type', + 'asset.deletedAt', + 'asset.visibility', + 'asset.duration', + 'asset.livePhotoVideoId', + 'asset.stackId', + 'asset.libraryId', + 'asset.width', + 'asset.height', + 'asset.isEdited', + ], syncAlbumUser: ['album_user.albumId as albumId', 'album_user.userId as userId', 'album_user.role'], syncStack: ['stack.id', 'stack.createdAt', 'stack.updatedAt', 'stack.primaryAssetId', 'stack.ownerId'], syncUser: ['id', 'name', 'email', 'avatarColor', 'deletedAt', 'updateId', 'profileImagePath', 'profileChangedAt'], diff --git a/server/src/repositories/sync.repository.ts b/server/src/repositories/sync.repository.ts index f9a7dbd076..c463f823aa 100644 --- a/server/src/repositories/sync.repository.ts +++ b/server/src/repositories/sync.repository.ts @@ -595,7 +595,7 @@ class PartnerAssetsSync extends BaseSync { @GenerateSql({ params: [dummyBackfillOptions, DummyValue.UUID], stream: true }) getBackfill(options: SyncBackfillOptions, partnerId: string) { return this.backfillQuery('asset', options) - .select(columns.syncAsset.filter((c) => c !== 'asset.isFavorite') as ReadonlyArray<(typeof columns.syncAsset)[number]>) + .select(columns.syncPartnerAsset) .select(sql`false`.as('isFavorite')) .select('asset.updateId') .where('ownerId', '=', partnerId) @@ -615,7 +615,7 @@ class PartnerAssetsSync extends BaseSync { @GenerateSql({ params: [dummyQueryOptions], stream: true }) getUpserts(options: SyncQueryOptions) { return this.upsertQuery('asset', options) - .select(columns.syncAsset.filter((c) => c !== 'asset.isFavorite') as ReadonlyArray<(typeof columns.syncAsset)[number]>) + .select(columns.syncPartnerAsset) .select(sql`false`.as('isFavorite')) .select('asset.updateId') .where('ownerId', 'in', (eb) =>