feat(syncing-server): add revisions ownership fix procedure

This commit is contained in:
Karol Sójko
2022-11-30 18:13:43 +01:00
parent 02639cddb2
commit 6cd68ddd6a
7 changed files with 117 additions and 0 deletions
@@ -130,8 +130,12 @@ export class MySQLItemRepository implements ItemRepositoryInterface {
private createFindAllQueryBuilder(query: ItemQuery): SelectQueryBuilder<Item> {
const queryBuilder = this.ormRepository.createQueryBuilder('item')
queryBuilder.orderBy(`item.${query.sortBy}`, query.sortOrder)
if (query.selectFields !== undefined) {
queryBuilder.select(query.selectFields.map((field) => `item.${field}`))
}
if (query.userUuid !== undefined) {
queryBuilder.where('item.user_uuid = :userUuid', { userUuid: query.userUuid })
}
@@ -149,6 +153,9 @@ export class MySQLItemRepository implements ItemRepositoryInterface {
lastSyncTime: query.lastSyncTime,
})
}
if (query.createdBefore !== undefined) {
queryBuilder.andWhere('item.created_at < :createdAt', { createdAt: query.createdBefore.toISOString() })
}
if (query.offset !== undefined) {
queryBuilder.skip(query.offset)
}