From cd101b96eae8969a4dd2387deb1d4e8679ead216 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Karol=20S=C3=B3jko?= Date: Tue, 13 Dec 2022 07:01:06 +0100 Subject: [PATCH] fix(syncing-server): revisions procedure properties --- packages/syncing-server/bin/revisions.ts | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/packages/syncing-server/bin/revisions.ts b/packages/syncing-server/bin/revisions.ts index b7cc1bb24..f881ffd3e 100644 --- a/packages/syncing-server/bin/revisions.ts +++ b/packages/syncing-server/bin/revisions.ts @@ -11,6 +11,7 @@ import { DomainEventFactoryInterface } from '../src/Domain/Event/DomainEventFact import { DomainEventPublisherInterface } from '@standardnotes/domain-events' import { ItemRepositoryInterface } from '../src/Domain/Item/ItemRepositoryInterface' import { Stream } from 'stream' +import { ContentType } from '@standardnotes/common' const fixRevisionsOwnership = async ( itemRepository: ItemRepositoryInterface, @@ -21,6 +22,7 @@ const fixRevisionsOwnership = async ( const stream = await itemRepository.streamAll({ createdBefore: new Date('2022-11-23'), selectFields: ['user_uuid', 'uuid'], + contentType: ContentType.File, }) return new Promise((resolve, reject) => { @@ -30,7 +32,7 @@ const fixRevisionsOwnership = async ( objectMode: true, transform: async (rawItemData, _encoding, callback) => { try { - if (!rawItemData.item_user_uuid || !rawItemData.item_uuid) { + if (!rawItemData.user_uuid || !rawItemData.item_uuid) { logger.error('Could not process item %O', rawItemData) return callback() @@ -38,7 +40,7 @@ const fixRevisionsOwnership = async ( await domainEventPublisher.publish( domainEventFactory.createRevisionsOwnershipUpdateRequestedEvent({ - userUuid: rawItemData.item_user_uuid, + userUuid: rawItemData.user_uuid, itemUuid: rawItemData.item_uuid, }), )