mylesmarkevich/standardnotes-server
1
0
Fork 0
mirror of https://github.com/standardnotes/server synced 2026-08-28 11:57:18 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix(syncing-server): revisions procedure properties

Browse Source
This commit is contained in:
Karol Sójko
2022-12-13 07:01:06 +01:00
parent 40d0e4631f
commit cd101b96ea
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/syncing-server/bin/revisions.ts
+4 -2
View File
@@ -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,
}),
)