chore(release): publish new version

- @standardnotes/revisions-server@1.6.0

packages/api-gateway/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.39.4](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.39.3...@standardnotes/api-gateway@1.39.4) (2022-11-25)
+
+### Bug Fixes
+
+* **api-gateway:** make revisions and workspace server urls optional ([8907879](https://github.com/standardnotes/api-gateway/commit/8907879a194d2d8328fbd3ca8ec9d0b608c2da50))
+
 ## [1.39.3](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.39.2...@standardnotes/api-gateway@1.39.3) (2022-11-25)
 
 **Note:** Version bump only for package @standardnotes/api-gateway

packages/api-gateway/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/api-gateway",
-  "version": "1.39.3",
+  "version": "1.39.4",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

packages/api-gateway/src/Bootstrap/Container.ts

@@ -54,11 +54,11 @@ export class ContainerConfigLoader {
     // env vars
     container.bind(TYPES.SYNCING_SERVER_JS_URL).toConstantValue(env.get('SYNCING_SERVER_JS_URL'))
     container.bind(TYPES.AUTH_SERVER_URL).toConstantValue(env.get('AUTH_SERVER_URL'))
-    container.bind(TYPES.REVISIONS_SERVER_URL).toConstantValue(env.get('REVISIONS_SERVER_URL'))
+    container.bind(TYPES.REVISIONS_SERVER_URL).toConstantValue(env.get('REVISIONS_SERVER_URL', true))
     container.bind(TYPES.PAYMENTS_SERVER_URL).toConstantValue(env.get('PAYMENTS_SERVER_URL', true))
     container.bind(TYPES.FILES_SERVER_URL).toConstantValue(env.get('FILES_SERVER_URL', true))
     container.bind(TYPES.AUTH_JWT_SECRET).toConstantValue(env.get('AUTH_JWT_SECRET'))
-    container.bind(TYPES.WORKSPACE_SERVER_URL).toConstantValue(env.get('WORKSPACE_SERVER_URL'))
+    container.bind(TYPES.WORKSPACE_SERVER_URL).toConstantValue(env.get('WORKSPACE_SERVER_URL', true))
     container.bind(TYPES.WEB_SOCKET_SERVER_URL).toConstantValue(env.get('WEB_SOCKET_SERVER_URL', true))
     container
       .bind(TYPES.HTTP_CALL_TIMEOUT)

packages/api-gateway/src/Service/Http/HttpService.ts

@@ -39,6 +39,11 @@ export class HttpService implements HttpServiceInterface {
     endpoint: string,
     payload?: Record<string, unknown> | string,
   ): Promise<void> {
+    if (!this.revisionsServerUrl) {
+      response.status(400).send({ message: 'Revisions Server not configured' })
+
+      return
+    }
     await this.callServer(this.revisionsServerUrl, request, response, endpoint, payload)
   }
 
@@ -66,6 +71,12 @@ export class HttpService implements HttpServiceInterface {
     endpoint: string,
     payload?: Record<string, unknown> | string,
   ): Promise<void> {
+    if (!this.workspaceServerUrl) {
+      response.status(400).send({ message: 'Workspace Server not configured' })
+
+      return
+    }
+
     await this.callServer(this.workspaceServerUrl, request, response, endpoint, payload)
   }
 

packages/auth/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.60.13](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.60.12...@standardnotes/auth-server@1.60.13) (2022-11-25)
+
+### Bug Fixes
+
+* **auth:** bring back streaming all users in an email campaign send out ([8407c3b](https://github.com/standardnotes/server/commit/8407c3b64910c87591a97b856f5b0c0aebc98e51))
+
+## [1.60.12](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.60.11...@standardnotes/auth-server@1.60.12) (2022-11-25)
+
+### Bug Fixes
+
+* **auth:** tmp test email campaign black friday 2022 reminder on team only ([25a6796](https://github.com/standardnotes/server/commit/25a6796e636bc30de99001bd16a2a1084b608b6a))
+
 ## [1.60.11](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.60.10...@standardnotes/auth-server@1.60.11) (2022-11-25)
 
 **Note:** Version bump only for package @standardnotes/auth-server

packages/auth/jest.config.js

@@ -7,6 +7,6 @@ module.exports = {
   transform: {
     ...tsjPreset.transform,
   },
-  coveragePathIgnorePatterns: ['/Bootstrap/', '/InversifyExpressUtils/', 'HealthCheckController'],
+  coveragePathIgnorePatterns: ['/Bootstrap/', '/InversifyExpressUtils/', 'HealthCheckController', '/Infra/'],
   setupFilesAfterEnv: ['./test-setup.ts'],
 }

packages/auth/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/auth-server",
-  "version": "1.60.11",
+  "version": "1.60.13",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

packages/auth/src/Domain/User/UserRepositoryInterface.ts

@@ -3,6 +3,7 @@ import { User } from './User'
 
 export interface UserRepositoryInterface {
   streamAll(): Promise<ReadStream>
+  streamTeam(memberEmail?: string): Promise<ReadStream>
   findOneByUuid(uuid: string): Promise<User | null>
   findOneByEmail(email: string): Promise<User | null>
   save(user: User): Promise<User>

packages/auth/src/Infra/MySQL/MySQLUserRepository.ts

@@ -25,6 +25,17 @@ export class MySQLUserRepository implements UserRepositoryInterface {
     return this.ormRepository.createQueryBuilder('user').stream()
   }
 
+  async streamTeam(memberEmail?: string): Promise<ReadStream> {
+    const queryBuilder = this.ormRepository.createQueryBuilder()
+    if (memberEmail !== undefined) {
+      queryBuilder.where('email = :email', { email: memberEmail })
+    } else {
+      queryBuilder.where('email LIKE :email', { email: '%@standardnotes.com' })
+    }
+
+    return queryBuilder.stream()
+  }
+
   async findOneByUuid(uuid: string): Promise<User | null> {
     return this.ormRepository
       .createQueryBuilder('user')

packages/revisions/CHANGELOG.md

@@ -3,6 +3,18 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+# [1.6.0](https://github.com/standardnotes/server/compare/@standardnotes/revisions-server@1.5.0...@standardnotes/revisions-server@1.6.0) (2022-11-28)
+
+### Features
+
+* **revisions:** add deleting revisions ([ac8a69f](https://github.com/standardnotes/server/commit/ac8a69f8d428e3cf8e4df5269db3cb31d9b118d5))
+
+# [1.5.0](https://github.com/standardnotes/server/compare/@standardnotes/revisions-server@1.4.8...@standardnotes/revisions-server@1.5.0) (2022-11-28)
+
+### Features
+
+* **revisions:** add fetching single revision ([284561d](https://github.com/standardnotes/server/commit/284561d093eaa6d73af888142583ec705ba18f79))
+
 ## [1.4.8](https://github.com/standardnotes/server/compare/@standardnotes/revisions-server@1.4.7...@standardnotes/revisions-server@1.4.8) (2022-11-25)
 
 **Note:** Version bump only for package @standardnotes/revisions-server

packages/revisions/package.json

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

packages/revisions/src/Bootstrap/Container.ts

@@ -36,6 +36,8 @@ import { ItemDumpedEventHandler } from '../Domain/Handler/ItemDumpedEventHandler
 import { DumpRepositoryInterface } from '../Domain/Dump/DumpRepositoryInterface'
 import { S3DumpRepository } from '../Infra/S3/S3ItemDumpRepository'
 import { FSDumpRepository } from '../Infra/FS/FSDumpRepository'
+import { GetRevision } from '../Domain/UseCase/GetRevision/GetRevision'
+import { DeleteRevision } from '../Domain/UseCase/DeleteRevision/DeleteRevision'
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const newrelicFormatter = require('@newrelic/winston-enricher')
@@ -152,11 +154,24 @@ export class ContainerConfigLoader {
     container
       .bind<GetRevisionsMetada>(TYPES.GetRevisionsMetada)
       .toConstantValue(new GetRevisionsMetada(container.get(TYPES.RevisionRepository)))
+    container
+      .bind<GetRevision>(TYPES.GetRevision)
+      .toConstantValue(new GetRevision(container.get(TYPES.RevisionRepository)))
+    container
+      .bind<DeleteRevision>(TYPES.DeleteRevision)
+      .toConstantValue(new DeleteRevision(container.get(TYPES.RevisionRepository)))
 
     // Controller
     container
       .bind<RevisionsController>(TYPES.RevisionsController)
-      .toConstantValue(new RevisionsController(container.get(TYPES.GetRevisionsMetada), container.get(TYPES.Logger)))
+      .toConstantValue(
+        new RevisionsController(
+          container.get(TYPES.GetRevisionsMetada),
+          container.get(TYPES.GetRevision),
+          container.get(TYPES.DeleteRevision),
+          container.get(TYPES.Logger),
+        ),
+      )
 
     // Handlers
     container

packages/revisions/src/Bootstrap/Types.ts

@@ -25,6 +25,8 @@ const TYPES = {
   VERSION: Symbol.for('VERSION'),
   // use cases
   GetRevisionsMetada: Symbol.for('GetRevisionsMetada'),
+  GetRevision: Symbol.for('GetRevision'),
+  DeleteRevision: Symbol.for('DeleteRevision'),
   // Controller
   RevisionsController: Symbol.for('RevisionsController'),
   // Handlers

packages/revisions/src/Controller/RevisionsController.spec.ts

@@ -1,20 +1,30 @@
 import { Result } from '@standardnotes/domain-core'
 import { Logger } from 'winston'
 
+import { DeleteRevision } from '../Domain/UseCase/DeleteRevision/DeleteRevision'
+import { GetRevision } from '../Domain/UseCase/GetRevision/GetRevision'
 import { GetRevisionsMetada } from '../Domain/UseCase/GetRevisionsMetada/GetRevisionsMetada'
 
 import { RevisionsController } from './RevisionsController'
 
 describe('RevisionsController', () => {
   let getRevisionsMetadata: GetRevisionsMetada
+  let getRevision: GetRevision
+  let deleteRevision: DeleteRevision
   let logger: Logger
 
-  const createController = () => new RevisionsController(getRevisionsMetadata, logger)
+  const createController = () => new RevisionsController(getRevisionsMetadata, getRevision, deleteRevision, logger)
 
   beforeEach(() => {
     getRevisionsMetadata = {} as jest.Mocked<GetRevisionsMetada>
     getRevisionsMetadata.execute = jest.fn().mockReturnValue(Result.ok())
 
+    getRevision = {} as jest.Mocked<GetRevision>
+    getRevision.execute = jest.fn().mockReturnValue(Result.ok())
+
+    deleteRevision = {} as jest.Mocked<DeleteRevision>
+    deleteRevision.execute = jest.fn().mockReturnValue(Result.ok())
+
     logger = {} as jest.Mocked<Logger>
     logger.warn = jest.fn()
   })
@@ -31,4 +41,30 @@ describe('RevisionsController', () => {
 
     expect(response.status).toEqual(400)
   })
+
+  it('should get revision', async () => {
+    const response = await createController().getRevision({ revisionUuid: '1-2-3', userUuid: '1-2-3' })
+
+    expect(response.status).toEqual(200)
+  })
+
+  it('should indicate failure to get revision', async () => {
+    getRevision.execute = jest.fn().mockReturnValue(Result.fail('Oops'))
+    const response = await createController().getRevision({ revisionUuid: '1-2-3', userUuid: '1-2-3' })
+
+    expect(response.status).toEqual(400)
+  })
+
+  it('should delete revision', async () => {
+    const response = await createController().deleteRevision({ revisionUuid: '1-2-3', userUuid: '1-2-3' })
+
+    expect(response.status).toEqual(200)
+  })
+
+  it('should indicate failure to delete revision', async () => {
+    deleteRevision.execute = jest.fn().mockReturnValue(Result.fail('Oops'))
+    const response = await createController().deleteRevision({ revisionUuid: '1-2-3', userUuid: '1-2-3' })
+
+    expect(response.status).toEqual(400)
+  })
 })

packages/revisions/src/Controller/RevisionsController.ts

@@ -3,9 +3,18 @@ import { HttpResponse, HttpStatusCode } from '@standardnotes/api'
 
 import { GetRevisionsMetada } from '../Domain/UseCase/GetRevisionsMetada/GetRevisionsMetada'
 import { GetRevisionsMetadataRequestParams } from '../Infra/Http/GetRevisionsMetadataRequestParams'
+import { GetRevisionRequestParams } from '../Infra/Http/GetRevisionRequestParams'
+import { GetRevision } from '../Domain/UseCase/GetRevision/GetRevision'
+import { DeleteRevision } from '../Domain/UseCase/DeleteRevision/DeleteRevision'
+import { DeleteRevisionRequestParams } from '../Infra/Http/DeleteRevisionRequestParams'
 
 export class RevisionsController {
-  constructor(private getRevisionsMetadata: GetRevisionsMetada, private logger: Logger) {}
+  constructor(
+    private getRevisionsMetadata: GetRevisionsMetada,
+    private doGetRevision: GetRevision,
+    private doDeleteRevision: DeleteRevision,
+    private logger: Logger,
+  ) {}
 
   async getRevisions(params: GetRevisionsMetadataRequestParams): Promise<HttpResponse> {
     const revisionMetadataOrError = await this.getRevisionsMetadata.execute({
@@ -31,4 +40,54 @@ export class RevisionsController {
       data: { revisions: revisionMetadataOrError.getValue() },
     }
   }
+
+  async getRevision(params: GetRevisionRequestParams): Promise<HttpResponse> {
+    const revisionOrError = await this.doGetRevision.execute({
+      revisionUuid: params.revisionUuid,
+      userUuid: params.userUuid,
+    })
+
+    if (revisionOrError.isFailed()) {
+      this.logger.warn(revisionOrError.getError())
+
+      return {
+        status: HttpStatusCode.BadRequest,
+        data: {
+          error: {
+            message: 'Could not retrieve revision.',
+          },
+        },
+      }
+    }
+
+    return {
+      status: HttpStatusCode.Success,
+      data: { revision: revisionOrError.getValue() },
+    }
+  }
+
+  async deleteRevision(params: DeleteRevisionRequestParams): Promise<HttpResponse> {
+    const revisionOrError = await this.doDeleteRevision.execute({
+      revisionUuid: params.revisionUuid,
+      userUuid: params.userUuid,
+    })
+
+    if (revisionOrError.isFailed()) {
+      this.logger.warn(revisionOrError.getError())
+
+      return {
+        status: HttpStatusCode.BadRequest,
+        data: {
+          error: {
+            message: 'Could not delete revision.',
+          },
+        },
+      }
+    }
+
+    return {
+      status: HttpStatusCode.Success,
+      data: { message: revisionOrError.getValue() },
+    }
+  }
 }

packages/revisions/src/Domain/Revision/RevisionRepositoryInterface.ts

@@ -4,6 +4,8 @@ import { Revision } from './Revision'
 import { RevisionMetadata } from './RevisionMetadata'
 
 export interface RevisionRepositoryInterface {
+  removeOneByUuid(revisionUuid: Uuid, userUuid: Uuid): Promise<void>
+  findOneByUuid(revisionUuid: Uuid, userUuid: Uuid): Promise<Revision | null>
   findMetadataByItemId(itemUuid: Uuid, userUuid: Uuid): Promise<Array<RevisionMetadata>>
   save(revision: Revision): Promise<Revision>
 }

packages/revisions/src/Domain/UseCase/DeleteRevision/DeleteRevision.spec.ts

@@ -0,0 +1,41 @@
+import { RevisionRepositoryInterface } from '../../Revision/RevisionRepositoryInterface'
+import { DeleteRevision } from './DeleteRevision'
+
+describe('DeleteRevision', () => {
+  let revisionRepository: RevisionRepositoryInterface
+
+  const createUseCase = () => new DeleteRevision(revisionRepository)
+
+  beforeEach(() => {
+    revisionRepository = {} as jest.Mocked<RevisionRepositoryInterface>
+    revisionRepository.removeOneByUuid = jest.fn()
+  })
+
+  it('should delete revision', async () => {
+    const result = await createUseCase().execute({
+      revisionUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+      userUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+    })
+
+    expect(result.isFailed()).toBeFalsy()
+    expect(result.getValue()).toEqual('Revision removed')
+  })
+
+  it('should not delete revision for an invalid item uuid', async () => {
+    const result = await createUseCase().execute({
+      revisionUuid: '1-2-3',
+      userUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+    })
+
+    expect(result.isFailed()).toBeTruthy()
+  })
+
+  it('should not delete revision for a an invalid user uuid', async () => {
+    const result = await createUseCase().execute({
+      userUuid: '1-2-3',
+      revisionUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+    })
+
+    expect(result.isFailed()).toBeTruthy()
+  })
+})

packages/revisions/src/Domain/UseCase/DeleteRevision/DeleteRevision.ts

@@ -0,0 +1,26 @@
+import { Result, UseCaseInterface, Uuid } from '@standardnotes/domain-core'
+
+import { RevisionRepositoryInterface } from '../../Revision/RevisionRepositoryInterface'
+import { DeleteRevisionDTO } from './DeleteRevisionDTO'
+
+export class DeleteRevision implements UseCaseInterface<string> {
+  constructor(private revisionRepository: RevisionRepositoryInterface) {}
+
+  async execute(dto: DeleteRevisionDTO): Promise<Result<string>> {
+    const revisionUuidOrError = Uuid.create(dto.revisionUuid)
+    if (revisionUuidOrError.isFailed()) {
+      return Result.fail<string>(`Could not delete revision: ${revisionUuidOrError.getError()}`)
+    }
+    const revisionUuid = revisionUuidOrError.getValue()
+
+    const userUuidOrError = Uuid.create(dto.userUuid)
+    if (userUuidOrError.isFailed()) {
+      return Result.fail<string>(`Could not delete revision: ${userUuidOrError.getError()}`)
+    }
+    const userUuid = userUuidOrError.getValue()
+
+    await this.revisionRepository.removeOneByUuid(revisionUuid, userUuid)
+
+    return Result.ok<string>('Revision removed')
+  }
+}

packages/revisions/src/Domain/UseCase/DeleteRevision/DeleteRevisionDTO.ts

@@ -0,0 +1,4 @@
+export interface DeleteRevisionDTO {
+  userUuid: string
+  revisionUuid: string
+}

packages/revisions/src/Domain/UseCase/GetRevision/GetRevision.spec.ts

@@ -0,0 +1,53 @@
+import { Revision } from '../../Revision/Revision'
+import { RevisionRepositoryInterface } from '../../Revision/RevisionRepositoryInterface'
+import { GetRevision } from './GetRevision'
+
+describe('GetRevision', () => {
+  let revisionRepository: RevisionRepositoryInterface
+
+  const createUseCase = () => new GetRevision(revisionRepository)
+
+  beforeEach(() => {
+    revisionRepository = {} as jest.Mocked<RevisionRepositoryInterface>
+    revisionRepository.findOneByUuid = jest.fn().mockReturnValue({} as jest.Mocked<Revision>)
+  })
+
+  it('should return revision for a given item', async () => {
+    const result = await createUseCase().execute({
+      revisionUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+      userUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+    })
+
+    expect(result.isFailed()).toBeFalsy()
+    expect(result.getValue()).not.toBeNull()
+  })
+
+  it('should not return revision for a given item if not found', async () => {
+    revisionRepository.findOneByUuid = jest.fn().mockReturnValue(null)
+
+    const result = await createUseCase().execute({
+      revisionUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+      userUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+    })
+
+    expect(result.isFailed()).toBeTruthy()
+  })
+
+  it('should not return revision for a an invalid item uuid', async () => {
+    const result = await createUseCase().execute({
+      revisionUuid: '1-2-3',
+      userUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+    })
+
+    expect(result.isFailed()).toBeTruthy()
+  })
+
+  it('should not return revision for a an invalid user uuid', async () => {
+    const result = await createUseCase().execute({
+      userUuid: '1-2-3',
+      revisionUuid: '84c0f8e8-544a-4c7e-9adf-26209303bc1d',
+    })
+
+    expect(result.isFailed()).toBeTruthy()
+  })
+})

packages/revisions/src/Domain/UseCase/GetRevision/GetRevision.ts

@@ -0,0 +1,31 @@
+import { Result, UseCaseInterface, Uuid } from '@standardnotes/domain-core'
+
+import { Revision } from '../../Revision/Revision'
+import { RevisionRepositoryInterface } from '../../Revision/RevisionRepositoryInterface'
+import { GetRevisionDTO } from './GetRevisionDTO'
+
+export class GetRevision implements UseCaseInterface<Revision> {
+  constructor(private revisionRepository: RevisionRepositoryInterface) {}
+
+  async execute(dto: GetRevisionDTO): Promise<Result<Revision>> {
+    const revisionUuidOrError = Uuid.create(dto.revisionUuid)
+    if (revisionUuidOrError.isFailed()) {
+      return Result.fail<Revision>(`Could not get revision: ${revisionUuidOrError.getError()}`)
+    }
+    const revisionUuid = revisionUuidOrError.getValue()
+
+    const userUuidOrError = Uuid.create(dto.userUuid)
+    if (userUuidOrError.isFailed()) {
+      return Result.fail<Revision>(`Could not get revision: ${userUuidOrError.getError()}`)
+    }
+    const userUuid = userUuidOrError.getValue()
+
+    const revision = await this.revisionRepository.findOneByUuid(revisionUuid, userUuid)
+
+    if (revision === null) {
+      return Result.fail<Revision>(`Could not find revision with uuid: ${revisionUuid.value}`)
+    }
+
+    return Result.ok<Revision>(revision)
+  }
+}

packages/revisions/src/Domain/UseCase/GetRevision/GetRevisionDTO.ts

@@ -0,0 +1,4 @@
+export interface GetRevisionDTO {
+  userUuid: string
+  revisionUuid: string
+}

packages/revisions/src/Infra/Http/DeleteRevisionRequestParams.ts

@@ -0,0 +1,4 @@
+export interface DeleteRevisionRequestParams {
+  revisionUuid: string
+  userUuid: string
+}

packages/revisions/src/Infra/Http/GetRevisionRequestParams.ts

@@ -0,0 +1,4 @@
+export interface GetRevisionRequestParams {
+  revisionUuid: string
+  userUuid: string
+}

packages/revisions/src/Infra/InversifyExpress/InversifyExpressRevisionsController.ts

@@ -1,5 +1,5 @@
 import { Request, Response } from 'express'
-import { BaseHttpController, controller, httpGet, results } from 'inversify-express-utils'
+import { BaseHttpController, controller, httpDelete, httpGet, results } from 'inversify-express-utils'
 import { inject } from 'inversify'
 
 import TYPES from '../../Bootstrap/Types'
@@ -20,4 +20,24 @@ export class InversifyExpressRevisionsController extends BaseHttpController {
 
     return this.json(result.data, result.status)
   }
+
+  @httpGet('/:uuid')
+  public async getRevision(req: Request, response: Response): Promise<results.JsonResult> {
+    const result = await this.revisionsController.getRevision({
+      revisionUuid: req.params.uuid,
+      userUuid: response.locals.user.uuid,
+    })
+
+    return this.json(result.data, result.status)
+  }
+
+  @httpDelete('/:uuid')
+  public async deleteRevision(req: Request, response: Response): Promise<results.JsonResult> {
+    const result = await this.revisionsController.deleteRevision({
+      revisionUuid: req.params.uuid,
+      userUuid: response.locals.user.uuid,
+    })
+
+    return this.json(result.data, result.status)
+  }
 }

packages/revisions/src/Infra/MySQL/MySQLRevisionRepository.ts

@@ -13,6 +13,29 @@ export class MySQLRevisionRepository implements RevisionRepositoryInterface {
     private revisionMapper: MapperInterface<Revision, TypeORMRevision>,
   ) {}
 
+  async removeOneByUuid(revisionUuid: Uuid, userUuid: Uuid): Promise<void> {
+    await this.ormRepository
+      .createQueryBuilder()
+      .delete()
+      .from('revisions')
+      .where('uuid = :revisionUuid AND user_uuid = :userUuid', { userUuid, revisionUuid })
+      .execute()
+  }
+
+  async findOneByUuid(revisionUuid: Uuid, userUuid: Uuid): Promise<Revision | null> {
+    const typeormRevision = await this.ormRepository
+      .createQueryBuilder()
+      .where('uuid = :revisionUuid', { revisionUuid })
+      .andWhere('user_uuid = :userUuid', { userUuid })
+      .getOne()
+
+    if (typeormRevision === null) {
+      return null
+    }
+
+    return this.revisionMapper.toDomain(typeormRevision)
+  }
+
   async save(revision: Revision): Promise<Revision> {
     const typeormRevision = this.revisionMapper.toProjection(revision)