chore(release): publish new version

- @standardnotes/syncing-server@1.26.9

packages/syncing-server/CHANGELOG.md

@@ -3,6 +3,12 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.26.9](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.26.8...@standardnotes/syncing-server@1.26.9) (2022-12-15)
+
+### Bug Fixes
+
+* **syncing-server:** fetching items in raw mode ([f27aa21](https://github.com/standardnotes/syncing-server-js/commit/f27aa21eb52a73b748e3a555bf201c834fd34aad))
+
 ## [1.26.8](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.26.7...@standardnotes/syncing-server@1.26.8) (2022-12-15)
 
 ### Bug Fixes

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/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/syncing-server",
-  "version": "1.26.8",
+  "version": "1.26.9",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

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(),
       })