chore(release): publish new version

- @standardnotes/revisions-server@1.3.0

packages/revisions/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.3.0](https://github.com/standardnotes/server/compare/@standardnotes/revisions-server@1.2.2...@standardnotes/revisions-server@1.3.0) (2022-11-22)
+
+### Features
+
+* **revisions:** add filesystem dump repository ([14ab1ca](https://github.com/standardnotes/server/commit/14ab1cae6981b7c12e797dd316da1b3bdb37c75f))
+
 ## [1.2.2](https://github.com/standardnotes/server/compare/@standardnotes/revisions-server@1.2.1...@standardnotes/revisions-server@1.2.2) (2022-11-22)
 
 **Note:** Version bump only for package @standardnotes/revisions-server

packages/revisions/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/revisions-server",
-  "version": "1.2.2",
+  "version": "1.3.0",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

packages/revisions/src/Bootstrap/Container.ts

@@ -35,6 +35,7 @@ import { RevisionPersistenceMapper } from '../Mapping/RevisionPersistenceMapper'
 import { ItemDumpedEventHandler } from '../Domain/Handler/ItemDumpedEventHandler'
 import { DumpRepositoryInterface } from '../Domain/Dump/DumpRepositoryInterface'
 import { S3DumpRepository } from '../Infra/S3/S3ItemDumpRepository'
+import { FSDumpRepository } from '../Infra/FS/FSDumpRepository'
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const newrelicFormatter = require('@newrelic/winston-enricher')
@@ -126,15 +127,21 @@ export class ContainerConfigLoader {
           container.get(TYPES.RevisionPersistenceMapper),
         ),
       )
-    container
-      .bind<DumpRepositoryInterface>(TYPES.DumpRepository)
-      .toConstantValue(
-        new S3DumpRepository(
-          container.get(TYPES.S3_BACKUP_BUCKET_NAME),
-          container.get(TYPES.S3),
-          container.get(TYPES.RevisionItemStringMapper),
-        ),
-      )
+    if (env.get('S3_AWS_REGION', true)) {
+      container
+        .bind<DumpRepositoryInterface>(TYPES.DumpRepository)
+        .toConstantValue(
+          new S3DumpRepository(
+            container.get(TYPES.S3_BACKUP_BUCKET_NAME),
+            container.get(TYPES.S3),
+            container.get(TYPES.RevisionItemStringMapper),
+          ),
+        )
+    } else {
+      container
+        .bind<DumpRepositoryInterface>(TYPES.DumpRepository)
+        .toConstantValue(new FSDumpRepository(container.get(TYPES.RevisionItemStringMapper)))
+    }
 
     // use cases
     container

packages/revisions/src/Infra/FS/FSDumpRepository.ts

@@ -0,0 +1,21 @@
+import { MapperInterface } from '@standardnotes/domain-core'
+import { promises } from 'fs'
+
+import { DumpRepositoryInterface } from '../../Domain/Dump/DumpRepositoryInterface'
+import { Revision } from '../../Domain/Revision/Revision'
+
+export class FSDumpRepository implements DumpRepositoryInterface {
+  constructor(private revisionStringItemMapper: MapperInterface<Revision, string>) {}
+
+  async getRevisionFromDumpPath(path: string): Promise<Revision | null> {
+    const contents = (await promises.readFile(path)).toString()
+
+    const revision = this.revisionStringItemMapper.toDomain(contents)
+
+    return revision
+  }
+
+  async removeDump(path: string): Promise<void> {
+    await promises.rm(path)
+  }
+}

packages/syncing-server/.env.sample

@@ -42,3 +42,6 @@ NEW_RELIC_NO_CONFIG_FILE=true
 NEW_RELIC_DISTRIBUTED_TRACING_ENABLED=false
 NEW_RELIC_LOG_ENABLED=false
 NEW_RELIC_LOG_LEVEL=info
+
+# (Optional) Revision Dumps
+FILE_UPLOAD_PATH=

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.17.0](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.16.1...@standardnotes/syncing-server@1.17.0) (2022-11-22)
+
+### Features
+
+* **syncing-server:** add dumping backup items to filesystem ([97b367d](https://github.com/standardnotes/syncing-server-js/commit/97b367d4eee1e8bc2fcfd4a477e6fb1d19507c14))
+
 ## [1.16.1](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.16.0...@standardnotes/syncing-server@1.16.1) (2022-11-22)
 
 **Note:** Version bump only for package @standardnotes/syncing-server

packages/syncing-server/package.json

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

packages/syncing-server/src/Bootstrap/Container.ts

@@ -85,6 +85,7 @@ import { MapperInterface } from '@standardnotes/domain-core'
 import { RevisionMetadata } from '../Domain/Revision/RevisionMetadata'
 import { SimpleRevisionProjection } from '../Projection/SimpleRevisionProjection'
 import { ItemRevisionCreationRequestedEventHandler } from '../Domain/Handler/ItemRevisionCreationRequestedEventHandler'
+import { FSItemBackupService } from '../Infra/FS/FSItemBackupService'
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const newrelicFormatter = require('@newrelic/winston-enricher')
@@ -92,6 +93,7 @@ const newrelicFormatter = require('@newrelic/winston-enricher')
 export class ContainerConfigLoader {
   private readonly DEFAULT_CONTENT_SIZE_TRANSFER_LIMIT = 10_000_000
   private readonly DEFAULT_MAX_ITEMS_LIMIT = 300
+  private readonly DEFAULT_FILE_UPLOAD_PATH = `${__dirname}/../../uploads`
 
   async load(): Promise<Container> {
     const env: Env = new Env()
@@ -203,6 +205,11 @@ export class ContainerConfigLoader {
       .toConstantValue(
         env.get('MAX_ITEMS_LIMIT', true) ? +env.get('MAX_ITEMS_LIMIT', true) : this.DEFAULT_MAX_ITEMS_LIMIT,
       )
+    container
+      .bind(TYPES.FILE_UPLOAD_PATH)
+      .toConstantValue(
+        env.get('FILE_UPLOAD_PATH', true) ? env.get('FILE_UPLOAD_PATH', true) : this.DEFAULT_FILE_UPLOAD_PATH,
+      )
 
     // use cases
     container.bind<SyncItems>(TYPES.SyncItems).to(SyncItems)
@@ -252,7 +259,11 @@ export class ContainerConfigLoader {
       .to(SyncResponseFactoryResolver)
     container.bind<AuthHttpServiceInterface>(TYPES.AuthHttpService).to(AuthHttpService)
     container.bind<ExtensionsHttpServiceInterface>(TYPES.ExtensionsHttpService).to(ExtensionsHttpService)
-    container.bind<ItemBackupServiceInterface>(TYPES.ItemBackupService).to(S3ItemBackupService)
+    if (env.get('S3_AWS_REGION', true)) {
+      container.bind<ItemBackupServiceInterface>(TYPES.ItemBackupService).to(S3ItemBackupService)
+    } else {
+      container.bind<ItemBackupServiceInterface>(TYPES.ItemBackupService).to(FSItemBackupService)
+    }
     container.bind<RevisionServiceInterface>(TYPES.RevisionService).to(RevisionService)
 
     if (env.get('SNS_TOPIC_ARN', true)) {

packages/syncing-server/src/Bootstrap/Types.ts

@@ -37,6 +37,7 @@ const TYPES = {
   VERSION: Symbol.for('VERSION'),
   CONTENT_SIZE_TRANSFER_LIMIT: Symbol.for('CONTENT_SIZE_TRANSFER_LIMIT'),
   MAX_ITEMS_LIMIT: Symbol.for('MAX_ITEMS_LIMIT'),
+  FILE_UPLOAD_PATH: Symbol.for('FILE_UPLOAD_PATH'),
   // use cases
   SyncItems: Symbol.for('SyncItems'),
   CheckIntegrity: Symbol.for('CheckIntegrity'),

packages/syncing-server/src/Infra/FS/FSItemBackupService.ts

@@ -0,0 +1,34 @@
+import { KeyParamsData } from '@standardnotes/responses'
+import { promises } from 'fs'
+import * as uuid from 'uuid'
+import { inject, injectable } from 'inversify'
+
+import TYPES from '../../Bootstrap/Types'
+import { Item } from '../../Domain/Item/Item'
+import { ItemBackupServiceInterface } from '../../Domain/Item/ItemBackupServiceInterface'
+import { ItemProjection } from '../../Projection/ItemProjection'
+import { ProjectorInterface } from '../../Projection/ProjectorInterface'
+
+@injectable()
+export class FSItemBackupService implements ItemBackupServiceInterface {
+  constructor(
+    @inject(TYPES.FILE_UPLOAD_PATH) private fileUploadPath: string,
+    @inject(TYPES.ItemProjector) private itemProjector: ProjectorInterface<Item, ItemProjection>,
+  ) {}
+
+  async backup(_items: Item[], _authParams: KeyParamsData): Promise<string> {
+    throw new Error('Method not implemented.')
+  }
+
+  async dump(item: Item): Promise<string> {
+    const contents = JSON.stringify({
+      item: await this.itemProjector.projectFull(item),
+    })
+
+    const path = `${this.fileUploadPath}/dumps/${uuid.v4()}`
+
+    await promises.writeFile(path, contents)
+
+    return path
+  }
+}