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

import { KeyParamsData } from '@standardnotes/responses'
import { promises } from 'fs'
import * as uuid from 'uuid'
import { Logger } from 'winston'
import { dirname } from 'path'

import { Item } from '../../Domain/Item/Item'
import { ItemBackupServiceInterface } from '../../Domain/Item/ItemBackupServiceInterface'
import { ItemProjection } from '../../Projection/ItemProjection'
import { ProjectorInterface } from '../../Projection/ProjectorInterface'

export class FSItemBackupService implements ItemBackupServiceInterface {
  constructor(
    private fileUploadPath: string,
    private itemProjector: ProjectorInterface<Item, ItemProjection>,
    private logger: Logger,
  ) {}

  async backup(_items: Item[], _authParams: KeyParamsData, _contentSizeLimit?: number): Promise<string[]> {
    throw new Error('Method not implemented.')
  }

  async dump(item: Item): Promise<string> {
    const contents = JSON.stringify({
      item: await this.itemProjector.projectCustom('dump', item),
    })

    const path = `${this.fileUploadPath}/dumps/${uuid.v4()}`

    this.logger.debug(`Dumping item ${item.uuid} to ${path}`)

    await promises.mkdir(dirname(path), { recursive: true })

    await promises.writeFile(path, contents)

    return path
  }
}