fix(syncing-server): fetching items in raw mode

packages/syncing-server/bin/revisions.ts

@@ -52,7 +52,7 @@ const fixRevisionsOwnership = async (
       )
     }
 
-    const items = await itemRepository.findAll({
+    const items = await itemRepository.findAllRaw<{ uuid: string; userUuid: string }>({
       createdBetween: [createdAfter, createdBefore],
       selectString: 'item.uuid as uuid, item.user_uuid as userUuid',
       contentType: [ContentType.Note, ContentType.File],

packages/syncing-server/src/Domain/Item/ItemRepositoryInterface.ts

@@ -6,6 +6,7 @@ import { ExtendedIntegrityPayload } from './ExtendedIntegrityPayload'
 export interface ItemRepositoryInterface {
   deleteByUserUuid(userUuid: string): Promise<void>
   findAll(query: ItemQuery): Promise<Item[]>
+  findAllRaw<T>(query: ItemQuery): Promise<T[]>
   streamAll(query: ItemQuery): Promise<ReadStream>
   countAll(query: ItemQuery): Promise<number>
   findContentSizeForComputingTransferLimit(

packages/syncing-server/src/Infra/MySQL/MySQLItemRepository.ts

@@ -103,6 +103,10 @@ export class MySQLItemRepository implements ItemRepositoryInterface {
     return this.createFindAllQueryBuilder(query).getMany()
   }
 
+  async findAllRaw<T>(query: ItemQuery): Promise<T[]> {
+    return this.createFindAllQueryBuilder(query).getRawMany<T>()
+  }
+
   async streamAll(query: ItemQuery): Promise<ReadStream> {
     return this.createFindAllQueryBuilder(query).stream()
   }
@@ -160,7 +164,7 @@ export class MySQLItemRepository implements ItemRepositoryInterface {
       })
     }
     if (query.createdBetween !== undefined) {
-      queryBuilder.andWhere('item.created_at BETWEEN :createdAfter AND :createdBefore', {
+      queryBuilder.andWhere('item.created_at >= :createdAfter AND item.created <= :createdBefore', {
         createdAfter: query.createdBetween[0].toISOString(),
         createdBefore: query.createdBetween[1].toISOString(),
       })