chore(release): publish new version

- @standardnotes/analytics@2.7.2

.pnp.cjs

@@ -2551,6 +2551,7 @@ const RAW_RUNTIME_STATE =
           ["@types/jest", "npm:29.1.1"],\
           ["@types/newrelic", "npm:7.0.3"],\
           ["@types/node", "npm:18.0.3"],\
+          ["@types/uuid", "npm:8.3.4"],\
           ["@typescript-eslint/eslint-plugin", "virtual:c66bf20e88479ada0172094776519a9f51acc4731d22079b60a295bcec7ea42d5545cbce58a77a50d932bf953298799135e99707486e343da6d99ba1d167bdbd#npm:5.30.5"],\
           ["aws-sdk", "npm:2.1234.0"],\
           ["dayjs", "npm:1.11.6"],\
@@ -2563,9 +2564,11 @@ const RAW_RUNTIME_STATE =
           ["mysql2", "npm:2.3.3"],\
           ["newrelic", "npm:9.0.0"],\
           ["reflect-metadata", "npm:0.1.13"],\
+          ["shallow-equal-object", "npm:1.1.1"],\
           ["ts-jest", "virtual:fd909b174d079e30b336c4ce72c38a88c1e447767b1a8dd7655e07719a1e31b97807f0931368724fc78897ff15e6a6d00b83316c0f76d11f85111f342e08bb79#npm:29.0.3"],\
           ["typeorm", "virtual:c66bf20e88479ada0172094776519a9f51acc4731d22079b60a295bcec7ea42d5545cbce58a77a50d932bf953298799135e99707486e343da6d99ba1d167bdbd#npm:0.3.10"],\
           ["typescript", "patch:typescript@npm%3A4.8.4#optional!builtin<compat/typescript>::version=4.8.4&hash=701156"],\
+          ["uuid", "npm:9.0.0"],\
           ["winston", "npm:3.8.2"]\
         ],\
         "linkType": "SOFT"\
@@ -12213,6 +12216,15 @@ const RAW_RUNTIME_STATE =
         "linkType": "HARD"\
       }]\
     ]],\
+    ["shallow-equal-object", [\
+      ["npm:1.1.1", {\
+        "packageLocation": "./.yarn/cache/shallow-equal-object-npm-1.1.1-a41b289b2e-9e5e0cd10b.zip/node_modules/shallow-equal-object/",\
+        "packageDependencies": [\
+          ["shallow-equal-object", "npm:1.1.1"]\
+        ],\
+        "linkType": "HARD"\
+      }]\
+    ]],\
     ["shebang-command", [\
       ["npm:2.0.0", {\
         "packageLocation": "./.yarn/cache/shebang-command-npm-2.0.0-eb2b01921d-5907a8d5fa.zip/node_modules/shebang-command/",\

packages/analytics/CHANGELOG.md

@@ -3,6 +3,61 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [2.7.2](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.7.1...@standardnotes/analytics@2.7.2) (2022-11-09)
+
+### Bug Fixes
+
+* **analytics:** mrr column types ([90aef90](https://github.com/standardnotes/server/commit/90aef905af05b8c1c86c7bd383df6b2b502f7c91))
+
+## [2.7.1](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.7.0...@standardnotes/analytics@2.7.1) (2022-11-09)
+
+### Bug Fixes
+
+* **analytics:** add missing created at column ([89502be](https://github.com/standardnotes/server/commit/89502bed638b17301e42e0d5916635b0a59f585d))
+
+# [2.7.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.6.0...@standardnotes/analytics@2.7.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription canceled ([52a257a](https://github.com/standardnotes/server/commit/52a257abb16034134a50474fbbb2493a00c58b99))
+
+# [2.6.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.5.0...@standardnotes/analytics@2.6.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription refunded ([0f65c05](https://github.com/standardnotes/server/commit/0f65c051abcff805e920f91d338e5fadda7905a9))
+
+# [2.5.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.4.0...@standardnotes/analytics@2.5.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription expired ([5c3db2c](https://github.com/standardnotes/server/commit/5c3db2cb29a929e44b63eb8226ce4ad1d14f8a99))
+
+# [2.4.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.3.1...@standardnotes/analytics@2.4.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription renewed ([cdb7fcf](https://github.com/standardnotes/server/commit/cdb7fcf8311fecfabe3ef9eb656cd6ec57b87de0))
+
+## [2.3.1](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.3.0...@standardnotes/analytics@2.3.1) (2022-11-09)
+
+### Bug Fixes
+
+* **analytics:** missing injectable annotation ([9d3ef24](https://github.com/standardnotes/server/commit/9d3ef24ba94ad28976a211d40f94f1bce8d0d305))
+
+# [2.3.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.2.0...@standardnotes/analytics@2.3.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription purchased ([5ea9941](https://github.com/standardnotes/server/commit/5ea9941519ffb3027527130ec869da14abc5e994))
+
+# [2.2.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.1.0...@standardnotes/analytics@2.2.0) (2022-11-08)
+
+### Features
+
+* **analytics:** add persistence for revenue modifications ([4928685](https://github.com/standardnotes/server/commit/49286851989f557d3b391b6b535a9aa307fbef50))
+* **analytics:** create new ddd architecture for persisting revenue modifications ([0103233](https://github.com/standardnotes/server/commit/0103233d4a1e222e7c9b059475c1cdc3b2617455))
+
 # [2.1.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@1.52.0...@standardnotes/analytics@2.1.0) (2022-11-07)
 
 ### Features

packages/analytics/jest.config.js

@@ -7,4 +7,5 @@ module.exports = {
   transform: {
     ...tsjPreset.transform,
   },
+  coveragePathIgnorePatterns: ['/Infra/'],
 }

packages/analytics/migrations/1667912580964-add_revenue_modifications.ts

@@ -0,0 +1,17 @@
+import { MigrationInterface, QueryRunner } from 'typeorm'
+
+export class addRevenueModifications1667912580964 implements MigrationInterface {
+  name = 'addRevenueModifications1667912580964'
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      'CREATE TABLE `revenue_modifications` (`uuid` varchar(36) NOT NULL, `subscription_id` int NOT NULL, `user_email` varchar(255) NOT NULL, `user_uuid` varchar(36) NOT NULL, `event_type` varchar(255) NOT NULL, `subscription_plan` varchar(255) NOT NULL, `billing_frequency` int NOT NULL, `new_customer` tinyint NOT NULL, `previous_mrr` int NOT NULL, `new_mrr` int NOT NULL, INDEX `email` (`user_email`), INDEX `user_uuid` (`user_uuid`), PRIMARY KEY (`uuid`)) ENGINE=InnoDB',
+    )
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query('DROP INDEX `user_uuid` ON `revenue_modifications`')
+    await queryRunner.query('DROP INDEX `email` ON `revenue_modifications`')
+    await queryRunner.query('DROP TABLE `revenue_modifications`')
+  }
+}

packages/analytics/migrations/1667994036734-add_missing_created_at.ts

@@ -0,0 +1,13 @@
+import { MigrationInterface, QueryRunner } from 'typeorm'
+
+export class addMissingCreatedAt1667994036734 implements MigrationInterface {
+  name = 'addMissingCreatedAt1667994036734'
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query('ALTER TABLE `revenue_modifications` ADD `created_at` bigint NOT NULL')
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query('ALTER TABLE `revenue_modifications` DROP COLUMN `created_at`')
+  }
+}

packages/analytics/migrations/1667995681714-fix_mrr_floating_columns.ts

@@ -0,0 +1,19 @@
+import { MigrationInterface, QueryRunner } from 'typeorm'
+
+export class fixMrrFloatingColumns1667995681714 implements MigrationInterface {
+  name = 'fixMrrFloatingColumns1667995681714'
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query('ALTER TABLE `revenue_modifications` DROP COLUMN `previous_mrr`')
+    await queryRunner.query('ALTER TABLE `revenue_modifications` ADD `previous_mrr` float NOT NULL')
+    await queryRunner.query('ALTER TABLE `revenue_modifications` DROP COLUMN `new_mrr`')
+    await queryRunner.query('ALTER TABLE `revenue_modifications` ADD `new_mrr` float NOT NULL')
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query('ALTER TABLE `revenue_modifications` DROP COLUMN `new_mrr`')
+    await queryRunner.query('ALTER TABLE `revenue_modifications` ADD `new_mrr` int NOT NULL')
+    await queryRunner.query('ALTER TABLE `revenue_modifications` DROP COLUMN `previous_mrr`')
+    await queryRunner.query('ALTER TABLE `revenue_modifications` ADD `previous_mrr` int NOT NULL')
+  }
+}

packages/analytics/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/analytics",
-  "version": "2.1.0",
+  "version": "2.7.2",
   "engines": {
     "node": ">=14.0.0 <17.0.0"
   },
@@ -29,6 +29,7 @@
     "@types/jest": "^29.1.1",
     "@types/newrelic": "^7.0.3",
     "@types/node": "^18.0.0",
+    "@types/uuid": "^8.3.0",
     "@typescript-eslint/eslint-plugin": "^5.30.0",
     "eslint": "^8.14.0",
     "eslint-plugin-prettier": "^4.2.1",
@@ -51,7 +52,9 @@
     "mysql2": "^2.3.3",
     "newrelic": "^9.0.0",
     "reflect-metadata": "^0.1.13",
+    "shallow-equal-object": "^1.1.1",
     "typeorm": "^0.3.6",
+    "uuid": "^9.0.0",
     "winston": "^3.8.1"
   }
 }

packages/analytics/src/Bootstrap/Container.ts

@@ -44,6 +44,13 @@ import { SubscriptionPurchasedEventHandler } from '../Domain/Handler/Subscriptio
 import { SubscriptionExpiredEventHandler } from '../Domain/Handler/SubscriptionExpiredEventHandler'
 import { SubscriptionReactivatedEventHandler } from '../Domain/Handler/SubscriptionReactivatedEventHandler'
 import { RefundProcessedEventHandler } from '../Domain/Handler/RefundProcessedEventHandler'
+import { RevenueModificationRepositoryInterface } from '../Domain/Revenue/RevenueModificationRepositoryInterface'
+import { MySQLRevenueModificationRepository } from '../Infra/MySQL/MySQLRevenueModificationRepository'
+import { TypeORMRevenueModification } from '../Infra/TypeORM/TypeORMRevenueModification'
+import { MapInterface } from '../Domain/Map/MapInterface'
+import { RevenueModification } from '../Domain/Revenue/RevenueModification'
+import { RevenueModificationMap } from '../Domain/Map/RevenueModificationMap'
+import { SaveRevenueModification } from '../Domain/UseCase/SaveRevenueModification/SaveRevenueModification'
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const newrelicFormatter = require('@newrelic/winston-enricher')
@@ -116,14 +123,21 @@ export class ContainerConfigLoader {
     container
       .bind<AnalyticsEntityRepositoryInterface>(TYPES.AnalyticsEntityRepository)
       .to(MySQLAnalyticsEntityRepository)
+    container
+      .bind<RevenueModificationRepositoryInterface>(TYPES.RevenueModificationRepository)
+      .to(MySQLRevenueModificationRepository)
 
     // ORM
     container
       .bind<Repository<AnalyticsEntity>>(TYPES.ORMAnalyticsEntityRepository)
       .toConstantValue(AppDataSource.getRepository(AnalyticsEntity))
+    container
+      .bind<Repository<TypeORMRevenueModification>>(TYPES.ORMRevenueModificationRepository)
+      .toConstantValue(AppDataSource.getRepository(TypeORMRevenueModification))
 
     // Use Case
     container.bind<GetUserAnalyticsId>(TYPES.GetUserAnalyticsId).to(GetUserAnalyticsId)
+    container.bind<SaveRevenueModification>(TYPES.SaveRevenueModification).to(SaveRevenueModification)
 
     // Hanlders
     container.bind<UserRegisteredEventHandler>(TYPES.UserRegisteredEventHandler).to(UserRegisteredEventHandler)
@@ -152,6 +166,11 @@ export class ContainerConfigLoader {
       .to(SubscriptionReactivatedEventHandler)
     container.bind<RefundProcessedEventHandler>(TYPES.RefundProcessedEventHandler).to(RefundProcessedEventHandler)
 
+    // Maps
+    container
+      .bind<MapInterface<RevenueModification, TypeORMRevenueModification>>(TYPES.RevenueModificationMap)
+      .to(RevenueModificationMap)
+
     // Services
     container.bind<DomainEventFactory>(TYPES.DomainEventFactory).to(DomainEventFactory)
     container.bind<PeriodKeyGeneratorInterface>(TYPES.PeriodKeyGenerator).toConstantValue(new PeriodKeyGenerator())

packages/analytics/src/Bootstrap/DataSource.ts

@@ -1,6 +1,7 @@
 import { DataSource, LoggerOptions } from 'typeorm'
 
 import { AnalyticsEntity } from '../Domain/Entity/AnalyticsEntity'
+import { TypeORMRevenueModification } from '../Infra/TypeORM/TypeORMRevenueModification'
 
 import { Env } from './Env'
 
@@ -36,7 +37,7 @@ export const AppDataSource = new DataSource({
     ],
     removeNodeErrorCount: 10,
   },
-  entities: [AnalyticsEntity],
+  entities: [AnalyticsEntity, TypeORMRevenueModification],
   migrations: [env.get('DB_MIGRATIONS_PATH', true) ?? 'dist/migrations/*.js'],
   migrationsRun: true,
   logging: <LoggerOptions>env.get('DB_DEBUG_LEVEL'),

packages/analytics/src/Bootstrap/Types.ts

@@ -13,10 +13,13 @@ const TYPES = {
   NEW_RELIC_ENABLED: Symbol.for('NEW_RELIC_ENABLED'),
   // Repositories
   AnalyticsEntityRepository: Symbol.for('AnalyticsEntityRepository'),
+  RevenueModificationRepository: Symbol.for('RevenueModificationRepository'),
   // ORM
   ORMAnalyticsEntityRepository: Symbol.for('ORMAnalyticsEntityRepository'),
+  ORMRevenueModificationRepository: Symbol.for('ORMRevenueModificationRepository'),
   // Use Case
   GetUserAnalyticsId: Symbol.for('GetUserAnalyticsId'),
+  SaveRevenueModification: Symbol.for('SaveRevenueModification'),
   // Handlers
   UserRegisteredEventHandler: Symbol.for('UserRegisteredEventHandler'),
   AccountDeletionRequestedEventHandler: Symbol.for('AccountDeletionRequestedEventHandler'),
@@ -29,6 +32,8 @@ const TYPES = {
   SubscriptionExpiredEventHandler: Symbol.for('SubscriptionExpiredEventHandler'),
   SubscriptionReactivatedEventHandler: Symbol.for('SubscriptionReactivatedEventHandler'),
   RefundProcessedEventHandler: Symbol.for('RefundProcessedEventHandler'),
+  // Maps
+  RevenueModificationMap: Symbol.for('RevenueModificationMap'),
   // Services
   DomainEventPublisher: Symbol.for('DomainEventPublisher'),
   DomainEventSubscriberFactory: Symbol.for('DomainEventSubscriberFactory'),

packages/analytics/src/Domain/Common/Email.spec.ts

@@ -0,0 +1,16 @@
+import { Email } from './Email'
+
+describe('Email', () => {
+  it('should create a value object', () => {
+    const valueOrError = Email.create('test@test.te')
+
+    expect(valueOrError.isFailed()).toBeFalsy()
+    expect(valueOrError.getValue().value).toEqual('test@test.te')
+  })
+
+  it('should not create an invalid value object', () => {
+    const valueOrError = Email.create('')
+
+    expect(valueOrError.isFailed()).toBeTruthy()
+  })
+})

packages/analytics/src/Domain/Common/Email.ts

@@ -0,0 +1,21 @@
+import { ValueObject } from '../Core/ValueObject'
+import { Result } from '../Core/Result'
+import { EmailProps } from './EmailProps'
+
+export class Email extends ValueObject<EmailProps> {
+  get value(): string {
+    return this.props.value
+  }
+
+  private constructor(props: EmailProps) {
+    super(props)
+  }
+
+  static create(email: string): Result<Email> {
+    if (!!email === false || email.length === 0) {
+      return Result.fail<Email>('Email cannot be empty')
+    } else {
+      return Result.ok<Email>(new Email({ value: email }))
+    }
+  }
+}

packages/analytics/src/Domain/Common/EmailProps.ts

@@ -0,0 +1,3 @@
+export interface EmailProps {
+  value: string
+}

packages/analytics/src/Domain/Common/Uuid.spec.ts

@@ -0,0 +1,16 @@
+import { Uuid } from './Uuid'
+
+describe('Uuid', () => {
+  it('should create a value object', () => {
+    const valueOrError = Uuid.create('1-2-3')
+
+    expect(valueOrError.isFailed()).toBeFalsy()
+    expect(valueOrError.getValue().value).toEqual('1-2-3')
+  })
+
+  it('should not create an invalid value object', () => {
+    const valueOrError = Uuid.create('')
+
+    expect(valueOrError.isFailed()).toBeTruthy()
+  })
+})

packages/analytics/src/Domain/Common/Uuid.ts

@@ -0,0 +1,21 @@
+import { ValueObject } from '../Core/ValueObject'
+import { Result } from '../Core/Result'
+import { UuidProps } from './UuidProps'
+
+export class Uuid extends ValueObject<UuidProps> {
+  get value(): string {
+    return this.props.value
+  }
+
+  private constructor(props: UuidProps) {
+    super(props)
+  }
+
+  static create(uuid: string): Result<Uuid> {
+    if (!!uuid === false || uuid.length === 0) {
+      return Result.fail<Uuid>('Uuid cannot be empty')
+    } else {
+      return Result.ok<Uuid>(new Uuid({ value: uuid }))
+    }
+  }
+}

packages/analytics/src/Domain/Common/UuidProps.ts

@@ -0,0 +1,3 @@
+export interface UuidProps {
+  value: string
+}

packages/analytics/src/Domain/Core/Aggregate.ts

@@ -0,0 +1,10 @@
+/* istanbul ignore file */
+
+import { Entity } from './Entity'
+import { UniqueEntityId } from './UniqueEntityId'
+
+export abstract class Aggregate<T> extends Entity<T> {
+  get id(): UniqueEntityId {
+    return this._id
+  }
+}

packages/analytics/src/Domain/Core/Entity.ts

@@ -0,0 +1,27 @@
+/* istanbul ignore file */
+
+import { UniqueEntityId } from './UniqueEntityId'
+
+export abstract class Entity<T> {
+  protected readonly _id: UniqueEntityId
+
+  constructor(public readonly props: T, id?: UniqueEntityId) {
+    this._id = id ? id : new UniqueEntityId()
+  }
+
+  public equals(object?: Entity<T>): boolean {
+    if (object == null || object == undefined) {
+      return false
+    }
+
+    if (this === object) {
+      return true
+    }
+
+    if (!(object instanceof Entity)) {
+      return false
+    }
+
+    return this._id.equals(object._id)
+  }
+}

packages/analytics/src/Domain/Core/Id.ts

@@ -0,0 +1,24 @@
+/* istanbul ignore file */
+
+export class Id<T> {
+  constructor(private value: T) {}
+
+  equals(id?: Id<T>): boolean {
+    if (id === null || id === undefined) {
+      return false
+    }
+    if (!(id instanceof this.constructor)) {
+      return false
+    }
+
+    return id.toValue() === this.value
+  }
+
+  toString() {
+    return String(this.value)
+  }
+
+  toValue(): T {
+    return this.value
+  }
+}

packages/analytics/src/Domain/Core/Result.ts

@@ -0,0 +1,35 @@
+/* istanbul ignore file */
+
+export class Result<T> {
+  constructor(private isSuccess: boolean, private error?: T | string, private value?: T) {
+    Object.freeze(this)
+  }
+
+  isFailed(): boolean {
+    return !this.isSuccess
+  }
+
+  getValue(): T {
+    if (!this.isSuccess) {
+      throw new Error('Cannot get value of an unsuccessfull result')
+    }
+
+    return this.value as T
+  }
+
+  getError(): T | string {
+    if (this.isSuccess || this.error === undefined) {
+      throw new Error('Cannot get an error of a successfull result')
+    }
+
+    return this.error
+  }
+
+  static ok<U>(value?: U): Result<U> {
+    return new Result<U>(true, undefined, value)
+  }
+
+  static fail<U>(error: U | string): Result<U> {
+    return new Result<U>(false, error)
+  }
+}

packages/analytics/src/Domain/Core/UniqueEntityId.ts

@@ -0,0 +1,10 @@
+/* istanbul ignore file */
+
+import { v4 as uuid } from 'uuid'
+import { Id } from './Id'
+
+export class UniqueEntityId extends Id<string | number> {
+  constructor(id?: string | number) {
+    super(id ? id : uuid())
+  }
+}

packages/analytics/src/Domain/Core/ValueObject.ts

@@ -0,0 +1,24 @@
+/* istanbul ignore file */
+
+import { shallowEqual } from 'shallow-equal-object'
+
+import { ValueObjectProps } from './ValueObjectProps'
+
+export abstract class ValueObject<T extends ValueObjectProps> {
+  public readonly props: T
+
+  constructor(props: T) {
+    this.props = Object.freeze(props)
+  }
+
+  equals(valueObject?: ValueObject<T>): boolean {
+    if (valueObject === null || valueObject === undefined) {
+      return false
+    }
+    if (valueObject.props === undefined) {
+      return false
+    }
+
+    return shallowEqual(this.props, valueObject.props)
+  }
+}

packages/analytics/src/Domain/Core/ValueObjectProps.ts

@@ -0,0 +1,4 @@
+export interface ValueObjectProps {
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  [index: string]: any
+}

packages/analytics/src/Domain/Handler/SubscriptionCancelledEventHandler.spec.ts

@@ -9,14 +9,19 @@ import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
 import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { Period } from '../Time/Period'
+import { Result } from '../Core/Result'
+import { RevenueModification } from '../Revenue/RevenueModification'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
 
 describe('SubscriptionCancelledEventHandler', () => {
   let event: SubscriptionCancelledEvent
   let getUserAnalyticsId: GetUserAnalyticsId
   let analyticsStore: AnalyticsStoreInterface
   let statisticsStore: StatisticsStoreInterface
+  let saveRevenueModification: SaveRevenueModification
 
-  const createHandler = () => new SubscriptionCancelledEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore)
+  const createHandler = () =>
+    new SubscriptionCancelledEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore, saveRevenueModification)
 
   beforeEach(() => {
     getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
@@ -30,6 +35,7 @@ describe('SubscriptionCancelledEventHandler', () => {
 
     event = {} as jest.Mocked<SubscriptionCancelledEvent>
     event.createdAt = new Date(1)
+    event.type = 'SUBSCRIPTION_CANCELLED'
     event.payload = {
       subscriptionId: 1,
       userEmail: 'test@test.com',
@@ -41,7 +47,13 @@ describe('SubscriptionCancelledEventHandler', () => {
       timestamp: 1,
       offline: false,
       replaced: false,
+      userExistingSubscriptionsCount: 1,
+      billingFrequency: 1,
+      payAmount: 12.99,
     }
+
+    saveRevenueModification = {} as jest.Mocked<SaveRevenueModification>
+    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.ok<RevenueModification>())
   })
 
   it('should track subscription cancelled statistics', async () => {
@@ -55,6 +67,7 @@ describe('SubscriptionCancelledEventHandler', () => {
       Period.ThisWeek,
       Period.ThisMonth,
     ])
+    expect(saveRevenueModification.execute).toHaveBeenCalled()
   })
 
   it('should not track statistics for subscriptions that are in a legacy 5 year plan', async () => {
@@ -65,5 +78,6 @@ describe('SubscriptionCancelledEventHandler', () => {
     await createHandler().handle(event)
 
     expect(statisticsStore.incrementMeasure).not.toHaveBeenCalled()
+    expect(saveRevenueModification.execute).toHaveBeenCalled()
   })
 })

packages/analytics/src/Domain/Handler/SubscriptionCancelledEventHandler.ts

@@ -4,10 +4,14 @@ import { inject, injectable } from 'inversify'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
+import { Email } from '../Common/Email'
 import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
+import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
+import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
 import { Period } from '../Time/Period'
 import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
 
 @injectable()
 export class SubscriptionCancelledEventHandler implements DomainEventHandlerInterface {
@@ -15,10 +19,11 @@ export class SubscriptionCancelledEventHandler implements DomainEventHandlerInte
     @inject(TYPES.GetUserAnalyticsId) private getUserAnalyticsId: GetUserAnalyticsId,
     @inject(TYPES.AnalyticsStore) private analyticsStore: AnalyticsStoreInterface,
     @inject(TYPES.StatisticsStore) private statisticsStore: StatisticsStoreInterface,
+    @inject(TYPES.SaveRevenueModification) private saveRevenueModification: SaveRevenueModification,
   ) {}
 
   async handle(event: SubscriptionCancelledEvent): Promise<void> {
-    const { analyticsId } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
+    const { analyticsId, userUuid } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
     await this.analyticsStore.markActivity([AnalyticsActivity.SubscriptionCancelled], analyticsId, [
       Period.Today,
       Period.ThisWeek,
@@ -26,6 +31,17 @@ export class SubscriptionCancelledEventHandler implements DomainEventHandlerInte
     ])
 
     await this.trackSubscriptionStatistics(event)
+
+    await this.saveRevenueModification.execute({
+      billingFrequency: event.payload.billingFrequency,
+      eventType: SubscriptionEventType.create(event.type).getValue(),
+      newSubscriber: event.payload.userExistingSubscriptionsCount === 1,
+      payedAmount: event.payload.payAmount,
+      planName: SubscriptionPlanName.create(event.payload.subscriptionName).getValue(),
+      subscriptionId: event.payload.subscriptionId,
+      userEmail: Email.create(event.payload.userEmail).getValue(),
+      userUuid,
+    })
   }
 
   private async trackSubscriptionStatistics(event: SubscriptionCancelledEvent) {

packages/analytics/src/Domain/Handler/SubscriptionExpiredEventHandler.spec.ts

@@ -7,18 +7,24 @@ import { SubscriptionExpiredEventHandler } from './SubscriptionExpiredEventHandl
 import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
+import { Result } from '../Core/Result'
+import { RevenueModification } from '../Revenue/RevenueModification'
 
 describe('SubscriptionExpiredEventHandler', () => {
   let event: SubscriptionExpiredEvent
   let getUserAnalyticsId: GetUserAnalyticsId
   let analyticsStore: AnalyticsStoreInterface
   let statisticsStore: StatisticsStoreInterface
+  let saveRevenueModification: SaveRevenueModification
 
-  const createHandler = () => new SubscriptionExpiredEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore)
+  const createHandler = () =>
+    new SubscriptionExpiredEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore, saveRevenueModification)
 
   beforeEach(() => {
     event = {} as jest.Mocked<SubscriptionExpiredEvent>
     event.createdAt = new Date(1)
+    event.type = 'SUBSCRIPTION_EXPIRED'
     event.payload = {
       subscriptionId: 1,
       userEmail: 'test@test.com',
@@ -26,6 +32,9 @@ describe('SubscriptionExpiredEventHandler', () => {
       timestamp: 1,
       offline: false,
       totalActiveSubscriptionsCount: 123,
+      userExistingSubscriptionsCount: 2,
+      billingFrequency: 1,
+      payAmount: 12.99,
     }
 
     getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
@@ -36,6 +45,9 @@ describe('SubscriptionExpiredEventHandler', () => {
 
     statisticsStore = {} as jest.Mocked<StatisticsStoreInterface>
     statisticsStore.setMeasure = jest.fn()
+
+    saveRevenueModification = {} as jest.Mocked<SaveRevenueModification>
+    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.ok<RevenueModification>())
   })
 
   it('should update analytics and statistics', async () => {
@@ -43,5 +55,6 @@ describe('SubscriptionExpiredEventHandler', () => {
 
     expect(analyticsStore.markActivity).toHaveBeenCalled()
     expect(statisticsStore.setMeasure).toHaveBeenCalled()
+    expect(saveRevenueModification.execute).toHaveBeenCalled()
   })
 })

packages/analytics/src/Domain/Handler/SubscriptionExpiredEventHandler.ts

@@ -4,10 +4,14 @@ import { inject, injectable } from 'inversify'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
+import { Email } from '../Common/Email'
 import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
+import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
+import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
 import { Period } from '../Time/Period'
 import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
 
 @injectable()
 export class SubscriptionExpiredEventHandler implements DomainEventHandlerInterface {
@@ -15,10 +19,11 @@ export class SubscriptionExpiredEventHandler implements DomainEventHandlerInterf
     @inject(TYPES.GetUserAnalyticsId) private getUserAnalyticsId: GetUserAnalyticsId,
     @inject(TYPES.AnalyticsStore) private analyticsStore: AnalyticsStoreInterface,
     @inject(TYPES.StatisticsStore) private statisticsStore: StatisticsStoreInterface,
+    @inject(TYPES.SaveRevenueModification) private saveRevenueModification: SaveRevenueModification,
   ) {}
 
   async handle(event: SubscriptionExpiredEvent): Promise<void> {
-    const { analyticsId } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
+    const { analyticsId, userUuid } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
     await this.analyticsStore.markActivity(
       [AnalyticsActivity.SubscriptionExpired, AnalyticsActivity.ExistingCustomersChurn],
       analyticsId,
@@ -30,5 +35,16 @@ export class SubscriptionExpiredEventHandler implements DomainEventHandlerInterf
       event.payload.totalActiveSubscriptionsCount,
       [Period.Today, Period.ThisWeek, Period.ThisMonth, Period.ThisYear],
     )
+
+    await this.saveRevenueModification.execute({
+      billingFrequency: event.payload.billingFrequency,
+      eventType: SubscriptionEventType.create(event.type).getValue(),
+      newSubscriber: event.payload.userExistingSubscriptionsCount === 1,
+      payedAmount: event.payload.payAmount,
+      planName: SubscriptionPlanName.create(event.payload.subscriptionName).getValue(),
+      subscriptionId: event.payload.subscriptionId,
+      userEmail: Email.create(event.payload.userEmail).getValue(),
+      userUuid,
+    })
   }
 }

packages/analytics/src/Domain/Handler/SubscriptionPurchasedEventHandler.spec.ts

@@ -8,6 +8,9 @@ import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyti
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { Period } from '../Time/Period'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
+import { Result } from '../Core/Result'
+import { RevenueModification } from '../Revenue/RevenueModification'
 
 describe('SubscriptionPurchasedEventHandler', () => {
   let event: SubscriptionPurchasedEvent
@@ -15,8 +18,10 @@ describe('SubscriptionPurchasedEventHandler', () => {
   let getUserAnalyticsId: GetUserAnalyticsId
   let analyticsStore: AnalyticsStoreInterface
   let statisticsStore: StatisticsStoreInterface
+  let saveRevenueModification: SaveRevenueModification
 
-  const createHandler = () => new SubscriptionPurchasedEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore)
+  const createHandler = () =>
+    new SubscriptionPurchasedEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore, saveRevenueModification)
 
   beforeEach(() => {
     statisticsStore = {} as jest.Mocked<StatisticsStoreInterface>
@@ -25,6 +30,7 @@ describe('SubscriptionPurchasedEventHandler', () => {
 
     event = {} as jest.Mocked<SubscriptionPurchasedEvent>
     event.createdAt = new Date(1)
+    event.type = 'SUBSCRIPTION_PURCHASED'
     event.payload = {
       subscriptionId: 1,
       userEmail: 'test@test.com',
@@ -37,6 +43,8 @@ describe('SubscriptionPurchasedEventHandler', () => {
       newSubscriber: true,
       totalActiveSubscriptionsCount: 123,
       userRegisteredAt: 23,
+      billingFrequency: 12,
+      payAmount: 29.99,
     }
 
     getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
@@ -45,12 +53,16 @@ describe('SubscriptionPurchasedEventHandler', () => {
     analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
     analyticsStore.markActivity = jest.fn()
     analyticsStore.unmarkActivity = jest.fn()
+
+    saveRevenueModification = {} as jest.Mocked<SaveRevenueModification>
+    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.ok<RevenueModification>())
   })
 
   it('should mark subscription creation statistics', async () => {
     await createHandler().handle(event)
 
     expect(statisticsStore.incrementMeasure).toHaveBeenCalled()
+    expect(saveRevenueModification.execute).toHaveBeenCalled()
   })
 
   it("should not measure registration to subscription time if this is not user's first subscription", async () => {

packages/analytics/src/Domain/Handler/SubscriptionPurchasedEventHandler.ts

@@ -4,10 +4,14 @@ import { inject, injectable } from 'inversify'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
+import { Email } from '../Common/Email'
 import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
+import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
+import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
 import { Period } from '../Time/Period'
 import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
 
 @injectable()
 export class SubscriptionPurchasedEventHandler implements DomainEventHandlerInterface {
@@ -15,10 +19,11 @@ export class SubscriptionPurchasedEventHandler implements DomainEventHandlerInte
     @inject(TYPES.GetUserAnalyticsId) private getUserAnalyticsId: GetUserAnalyticsId,
     @inject(TYPES.AnalyticsStore) private analyticsStore: AnalyticsStoreInterface,
     @inject(TYPES.StatisticsStore) private statisticsStore: StatisticsStoreInterface,
+    @inject(TYPES.SaveRevenueModification) private saveRevenueModification: SaveRevenueModification,
   ) {}
 
   async handle(event: SubscriptionPurchasedEvent): Promise<void> {
-    const { analyticsId } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
+    const { analyticsId, userUuid } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
     await this.analyticsStore.markActivity([AnalyticsActivity.SubscriptionPurchased], analyticsId, [
       Period.Today,
       Period.ThisWeek,
@@ -54,5 +59,16 @@ export class SubscriptionPurchasedEventHandler implements DomainEventHandlerInte
         [Period.Today, Period.ThisWeek, Period.ThisMonth, Period.ThisYear],
       )
     }
+
+    await this.saveRevenueModification.execute({
+      billingFrequency: event.payload.billingFrequency,
+      eventType: SubscriptionEventType.create(event.type).getValue(),
+      newSubscriber: event.payload.newSubscriber,
+      payedAmount: event.payload.payAmount,
+      planName: SubscriptionPlanName.create(event.payload.subscriptionName).getValue(),
+      subscriptionId: event.payload.subscriptionId,
+      userEmail: Email.create(event.payload.userEmail).getValue(),
+      userUuid,
+    })
   }
 }

packages/analytics/src/Domain/Handler/SubscriptionRefundedEventHandler.spec.ts

@@ -10,18 +10,24 @@ import { SubscriptionRefundedEventHandler } from './SubscriptionRefundedEventHan
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { Period } from '../Time/Period'
+import { Result } from '../Core/Result'
+import { RevenueModification } from '../Revenue/RevenueModification'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
 
 describe('SubscriptionRefundedEventHandler', () => {
   let event: SubscriptionRefundedEvent
   let getUserAnalyticsId: GetUserAnalyticsId
   let analyticsStore: AnalyticsStoreInterface
   let statisticsStore: StatisticsStoreInterface
+  let saveRevenueModification: SaveRevenueModification
 
-  const createHandler = () => new SubscriptionRefundedEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore)
+  const createHandler = () =>
+    new SubscriptionRefundedEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore, saveRevenueModification)
 
   beforeEach(() => {
     event = {} as jest.Mocked<SubscriptionRefundedEvent>
     event.createdAt = new Date(1)
+    event.type = 'SUBSCRIPTION_REFUNDED'
     event.payload = {
       subscriptionId: 1,
       userEmail: 'test@test.com',
@@ -30,6 +36,8 @@ describe('SubscriptionRefundedEventHandler', () => {
       offline: false,
       userExistingSubscriptionsCount: 3,
       totalActiveSubscriptionsCount: 1,
+      billingFrequency: 1,
+      payAmount: 12.99,
     }
 
     getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
@@ -41,6 +49,9 @@ describe('SubscriptionRefundedEventHandler', () => {
 
     statisticsStore = {} as jest.Mocked<StatisticsStoreInterface>
     statisticsStore.setMeasure = jest.fn()
+
+    saveRevenueModification = {} as jest.Mocked<SaveRevenueModification>
+    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.ok<RevenueModification>())
   })
 
   it('should mark churn for new customer', async () => {
@@ -56,6 +67,8 @@ describe('SubscriptionRefundedEventHandler', () => {
     expect(analyticsStore.markActivity).toHaveBeenCalledWith([AnalyticsActivity.NewCustomersChurn], 3, [
       Period.ThisMonth,
     ])
+
+    expect(saveRevenueModification.execute).toHaveBeenCalled()
   })
 
   it('should mark churn for existing customer', async () => {

packages/analytics/src/Domain/Handler/SubscriptionRefundedEventHandler.ts

@@ -4,10 +4,14 @@ import { inject, injectable } from 'inversify'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
+import { Email } from '../Common/Email'
 import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
+import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
+import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
 import { Period } from '../Time/Period'
 import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
 
 @injectable()
 export class SubscriptionRefundedEventHandler implements DomainEventHandlerInterface {
@@ -15,10 +19,11 @@ export class SubscriptionRefundedEventHandler implements DomainEventHandlerInter
     @inject(TYPES.GetUserAnalyticsId) private getUserAnalyticsId: GetUserAnalyticsId,
     @inject(TYPES.AnalyticsStore) private analyticsStore: AnalyticsStoreInterface,
     @inject(TYPES.StatisticsStore) private statisticsStore: StatisticsStoreInterface,
+    @inject(TYPES.SaveRevenueModification) private saveRevenueModification: SaveRevenueModification,
   ) {}
 
   async handle(event: SubscriptionRefundedEvent): Promise<void> {
-    const { analyticsId } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
+    const { analyticsId, userUuid } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
     await this.analyticsStore.markActivity([AnalyticsActivity.SubscriptionRefunded], analyticsId, [
       Period.Today,
       Period.ThisWeek,
@@ -26,6 +31,17 @@ export class SubscriptionRefundedEventHandler implements DomainEventHandlerInter
     ])
 
     await this.markChurnActivity(analyticsId, event)
+
+    await this.saveRevenueModification.execute({
+      billingFrequency: event.payload.billingFrequency,
+      eventType: SubscriptionEventType.create(event.type).getValue(),
+      newSubscriber: event.payload.userExistingSubscriptionsCount === 1,
+      payedAmount: event.payload.payAmount,
+      planName: SubscriptionPlanName.create(event.payload.subscriptionName).getValue(),
+      subscriptionId: event.payload.subscriptionId,
+      userEmail: Email.create(event.payload.userEmail).getValue(),
+      userUuid,
+    })
   }
 
   private async markChurnActivity(analyticsId: number, event: SubscriptionRefundedEvent): Promise<void> {

packages/analytics/src/Domain/Handler/SubscriptionRenewedEventHandler.spec.ts

@@ -6,17 +6,23 @@ import { SubscriptionRenewedEvent } from '@standardnotes/domain-events'
 import { SubscriptionRenewedEventHandler } from './SubscriptionRenewedEventHandler'
 import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
+import { RevenueModification } from '../Revenue/RevenueModification'
+import { Result } from '../Core/Result'
 
 describe('SubscriptionRenewedEventHandler', () => {
   let event: SubscriptionRenewedEvent
   let getUserAnalyticsId: GetUserAnalyticsId
   let analyticsStore: AnalyticsStoreInterface
+  let saveRevenueModification: SaveRevenueModification
 
-  const createHandler = () => new SubscriptionRenewedEventHandler(getUserAnalyticsId, analyticsStore)
+  const createHandler = () =>
+    new SubscriptionRenewedEventHandler(getUserAnalyticsId, analyticsStore, saveRevenueModification)
 
   beforeEach(() => {
     event = {} as jest.Mocked<SubscriptionRenewedEvent>
     event.createdAt = new Date(1)
+    event.type = 'SUBSCRIPTION_RENEWED'
     event.payload = {
       subscriptionId: 1,
       userEmail: 'test@test.com',
@@ -24,6 +30,8 @@ describe('SubscriptionRenewedEventHandler', () => {
       subscriptionExpiresAt: 2,
       timestamp: 1,
       offline: false,
+      billingFrequency: 1,
+      payAmount: 12.99,
     }
 
     getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
@@ -32,6 +40,9 @@ describe('SubscriptionRenewedEventHandler', () => {
     analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
     analyticsStore.markActivity = jest.fn()
     analyticsStore.unmarkActivity = jest.fn()
+
+    saveRevenueModification = {} as jest.Mocked<SaveRevenueModification>
+    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.ok<RevenueModification>())
   })
 
   it('should track subscription renewed statistics', async () => {
@@ -39,5 +50,6 @@ describe('SubscriptionRenewedEventHandler', () => {
 
     expect(analyticsStore.markActivity).toHaveBeenCalled()
     expect(analyticsStore.unmarkActivity).toHaveBeenCalled()
+    expect(saveRevenueModification.execute).toHaveBeenCalled()
   })
 })

packages/analytics/src/Domain/Handler/SubscriptionRenewedEventHandler.ts

@@ -6,16 +6,21 @@ import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyti
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
 import { Period } from '../Time/Period'
+import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
+import { Email } from '../Common/Email'
+import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
+import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
 
 @injectable()
 export class SubscriptionRenewedEventHandler implements DomainEventHandlerInterface {
   constructor(
     @inject(TYPES.GetUserAnalyticsId) private getUserAnalyticsId: GetUserAnalyticsId,
     @inject(TYPES.AnalyticsStore) private analyticsStore: AnalyticsStoreInterface,
+    @inject(TYPES.SaveRevenueModification) private saveRevenueModification: SaveRevenueModification,
   ) {}
 
   async handle(event: SubscriptionRenewedEvent): Promise<void> {
-    const { analyticsId } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
+    const { analyticsId, userUuid } = await this.getUserAnalyticsId.execute({ userEmail: event.payload.userEmail })
     await this.analyticsStore.markActivity([AnalyticsActivity.SubscriptionRenewed], analyticsId, [
       Period.Today,
       Period.ThisWeek,
@@ -26,5 +31,16 @@ export class SubscriptionRenewedEventHandler implements DomainEventHandlerInterf
       analyticsId,
       [Period.Today, Period.ThisWeek, Period.ThisMonth],
     )
+
+    await this.saveRevenueModification.execute({
+      billingFrequency: event.payload.billingFrequency,
+      eventType: SubscriptionEventType.create(event.type).getValue(),
+      newSubscriber: false,
+      payedAmount: event.payload.payAmount,
+      planName: SubscriptionPlanName.create(event.payload.subscriptionName).getValue(),
+      subscriptionId: event.payload.subscriptionId,
+      userEmail: Email.create(event.payload.userEmail).getValue(),
+      userUuid,
+    })
   }
 }

packages/analytics/src/Domain/Map/MapInterface.ts

@@ -0,0 +1,4 @@
+export interface MapInterface<T, U> {
+  toDomain(persistence: U): T
+  toPersistence(domain: T): U
+}

packages/analytics/src/Domain/Map/RevenueModificationMap.ts

@@ -0,0 +1,63 @@
+import { injectable } from 'inversify'
+
+import { TypeORMRevenueModification } from '../../Infra/TypeORM/TypeORMRevenueModification'
+import { UniqueEntityId } from '../Core/UniqueEntityId'
+import { MonthlyRevenue } from '../Revenue/MonthlyRevenue'
+import { RevenueModification } from '../Revenue/RevenueModification'
+import { Subscription } from '../Subscription/Subscription'
+import { User } from '../User/User'
+import { MapInterface } from './MapInterface'
+import { Email } from '../Common/Email'
+import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
+import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
+
+@injectable()
+export class RevenueModificationMap implements MapInterface<RevenueModification, TypeORMRevenueModification> {
+  toDomain(persistence: TypeORMRevenueModification): RevenueModification {
+    const user = User.create(
+      {
+        email: Email.create(persistence.userEmail).getValue(),
+      },
+      new UniqueEntityId(persistence.userUuid),
+    )
+    const subscription = Subscription.create(
+      {
+        billingFrequency: persistence.billingFrequency,
+        isFirstSubscriptionForUser: persistence.isNewCustomer,
+        payedAmount: persistence.billingFrequency * persistence.newMonthlyRevenue,
+        planName: SubscriptionPlanName.create(persistence.subscriptionPlan).getValue(),
+      },
+      new UniqueEntityId(persistence.subscriptionId),
+    )
+    const previousMonthlyRevenueOrError = MonthlyRevenue.create(persistence.previousMonthlyRevenue)
+
+    return RevenueModification.create(
+      {
+        user,
+        subscription,
+        eventType: SubscriptionEventType.create(persistence.eventType).getValue(),
+        previousMonthlyRevenue: previousMonthlyRevenueOrError.getValue(),
+        createdAt: persistence.createdAt,
+      },
+      new UniqueEntityId(persistence.uuid),
+    )
+  }
+
+  toPersistence(domain: RevenueModification): TypeORMRevenueModification {
+    const { subscription, user } = domain.props
+    const persistence = new TypeORMRevenueModification()
+    persistence.uuid = domain.id.toString()
+    persistence.billingFrequency = subscription.props.billingFrequency
+    persistence.eventType = domain.props.eventType.value
+    persistence.isNewCustomer = subscription.props.isFirstSubscriptionForUser
+    persistence.newMonthlyRevenue = domain.newMonthlyRevenue.value
+    persistence.previousMonthlyRevenue = domain.props.previousMonthlyRevenue.value
+    persistence.subscriptionId = subscription.id.toValue() as number
+    persistence.subscriptionPlan = subscription.props.planName.value
+    persistence.userEmail = user.props.email.value
+    persistence.userUuid = user.id.toString()
+    persistence.createdAt = domain.props.createdAt
+
+    return persistence
+  }
+}

packages/analytics/src/Domain/Revenue/MonthlyRevenue.spec.ts

@@ -0,0 +1,16 @@
+import { MonthlyRevenue } from './MonthlyRevenue'
+
+describe('MonthlyRevenue', () => {
+  it('should create a value object', () => {
+    const valueOrError = MonthlyRevenue.create(123)
+
+    expect(valueOrError.isFailed()).toBeFalsy()
+    expect(valueOrError.getValue().value).toEqual(123)
+  })
+
+  it('should not create an invalid value object', () => {
+    const valueOrError = MonthlyRevenue.create(-3)
+
+    expect(valueOrError.isFailed()).toBeTruthy()
+  })
+})

packages/analytics/src/Domain/Revenue/MonthlyRevenue.ts

@@ -0,0 +1,21 @@
+import { ValueObject } from '../Core/ValueObject'
+import { Result } from '../Core/Result'
+import { MonthlyRevenueProps } from './MonthlyRevenueProps'
+
+export class MonthlyRevenue extends ValueObject<MonthlyRevenueProps> {
+  get value(): number {
+    return this.props.value
+  }
+
+  private constructor(props: MonthlyRevenueProps) {
+    super(props)
+  }
+
+  static create(revenue: number): Result<MonthlyRevenue> {
+    if (isNaN(revenue) || revenue < 0) {
+      return Result.fail<MonthlyRevenue>('Monthly revenue must be a non-negative number')
+    } else {
+      return Result.ok<MonthlyRevenue>(new MonthlyRevenue({ value: revenue }))
+    }
+  }
+}

packages/analytics/src/Domain/Revenue/MonthlyRevenueProps.ts

@@ -0,0 +1,3 @@
+export interface MonthlyRevenueProps {
+  value: number
+}

packages/analytics/src/Domain/Revenue/RevenueModification.spec.ts

@@ -0,0 +1,63 @@
+import { Email } from '../Common/Email'
+import { Subscription } from '../Subscription/Subscription'
+import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
+import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
+import { User } from '../User/User'
+import { MonthlyRevenue } from './MonthlyRevenue'
+import { RevenueModification } from './RevenueModification'
+
+describe('RevenueModification', () => {
+  let user: User
+  let subscription: Subscription
+
+  beforeEach(() => {
+    subscription = Subscription.create({
+      billingFrequency: 12,
+      isFirstSubscriptionForUser: true,
+      payedAmount: 123,
+      planName: SubscriptionPlanName.create('PRO_PLAN').getValue(),
+    })
+    user = User.create({
+      email: Email.create('test@test.te').getValue(),
+    })
+  })
+
+  it('should create an aggregate for purchased subscription', () => {
+    const revenueModification = RevenueModification.create({
+      createdAt: 2,
+      eventType: SubscriptionEventType.create('SUBSCRIPTION_PURCHASED').getValue(),
+      previousMonthlyRevenue: MonthlyRevenue.create(123).getValue(),
+      subscription,
+      user,
+    })
+
+    expect(revenueModification.id.toString()).toHaveLength(36)
+    expect(revenueModification.newMonthlyRevenue.value).toEqual(123 / 12)
+  })
+
+  it('should create an aggregate for subscription expired', () => {
+    const revenueModification = RevenueModification.create({
+      createdAt: 1,
+      eventType: SubscriptionEventType.create('SUBSCRIPTION_EXPIRED').getValue(),
+      previousMonthlyRevenue: MonthlyRevenue.create(123).getValue(),
+      subscription,
+      user,
+    })
+
+    expect(revenueModification.id.toString()).toHaveLength(36)
+    expect(revenueModification.newMonthlyRevenue.value).toEqual(0)
+  })
+
+  it('should create an aggregate for subscription cancelled', () => {
+    const revenueModification = RevenueModification.create({
+      createdAt: 2,
+      eventType: SubscriptionEventType.create('SUBSCRIPTION_CANCELLED').getValue(),
+      previousMonthlyRevenue: MonthlyRevenue.create(123).getValue(),
+      subscription,
+      user,
+    })
+
+    expect(revenueModification.id.toString()).toHaveLength(36)
+    expect(revenueModification.newMonthlyRevenue.value).toEqual(123)
+  })
+})

packages/analytics/src/Domain/Revenue/RevenueModification.ts

@@ -0,0 +1,38 @@
+import { Aggregate } from '../Core/Aggregate'
+import { UniqueEntityId } from '../Core/UniqueEntityId'
+import { MonthlyRevenue } from './MonthlyRevenue'
+import { RevenueModificationProps } from './RevenueModificationProps'
+
+export class RevenueModification extends Aggregate<RevenueModificationProps> {
+  private constructor(props: RevenueModificationProps, id?: UniqueEntityId) {
+    super(props, id)
+  }
+
+  static create(props: RevenueModificationProps, id?: UniqueEntityId): RevenueModification {
+    return new RevenueModification(props, id)
+  }
+
+  get newMonthlyRevenue(): MonthlyRevenue {
+    const { subscription } = this.props
+
+    let revenue = 0
+    switch (this.props.eventType.value) {
+      case 'SUBSCRIPTION_PURCHASED':
+      case 'SUBSCRIPTION_RENEWED':
+      case 'SUBSCRIPTION_DATA_MIGRATED':
+        revenue = subscription.props.payedAmount / subscription.props.billingFrequency
+        break
+      case 'SUBSCRIPTION_EXPIRED':
+      case 'SUBSCRIPTION_REFUNDED':
+        revenue = 0
+        break
+      case 'SUBSCRIPTION_CANCELLED':
+        revenue = this.props.previousMonthlyRevenue.value
+        break
+    }
+
+    const monthlyRevenueOrError = MonthlyRevenue.create(revenue)
+
+    return monthlyRevenueOrError.getValue()
+  }
+}

packages/analytics/src/Domain/Revenue/RevenueModificationProps.ts

@@ -0,0 +1,12 @@
+import { MonthlyRevenue } from './MonthlyRevenue'
+import { Subscription } from '../Subscription/Subscription'
+import { User } from '../User/User'
+import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
+
+export interface RevenueModificationProps {
+  user: User
+  subscription: Subscription
+  eventType: SubscriptionEventType
+  previousMonthlyRevenue: MonthlyRevenue
+  createdAt: number
+}

packages/analytics/src/Domain/Revenue/RevenueModificationRepositoryInterface.ts

@@ -0,0 +1,7 @@
+import { Uuid } from '../Common/Uuid'
+import { RevenueModification } from './RevenueModification'
+
+export interface RevenueModificationRepositoryInterface {
+  findLastByUserUuid(userUuid: Uuid): Promise<RevenueModification | null>
+  save(revenueModification: RevenueModification): Promise<RevenueModification>
+}

packages/analytics/src/Domain/Subscription/Subscription.spec.ts

@@ -0,0 +1,15 @@
+import { Subscription } from './Subscription'
+import { SubscriptionPlanName } from './SubscriptionPlanName'
+
+describe('Subscription', () => {
+  it('should create an entity', () => {
+    const subscription = Subscription.create({
+      billingFrequency: 1,
+      isFirstSubscriptionForUser: true,
+      payedAmount: 12.99,
+      planName: SubscriptionPlanName.create('PRO_PLAN').getValue(),
+    })
+
+    expect(subscription.id.toString()).toHaveLength(36)
+  })
+})

packages/analytics/src/Domain/Subscription/Subscription.ts

@@ -0,0 +1,17 @@
+import { Entity } from '../Core/Entity'
+import { UniqueEntityId } from '../Core/UniqueEntityId'
+import { SubscriptionProps } from './SubscriptionProps'
+
+export class Subscription extends Entity<SubscriptionProps> {
+  get id(): UniqueEntityId {
+    return this._id
+  }
+
+  private constructor(props: SubscriptionProps, id?: UniqueEntityId) {
+    super(props, id)
+  }
+
+  static create(props: SubscriptionProps, id?: UniqueEntityId): Subscription {
+    return new Subscription(props, id)
+  }
+}

packages/analytics/src/Domain/Subscription/SubscriptionEventType.spec.ts

@@ -0,0 +1,16 @@
+import { SubscriptionEventType } from './SubscriptionEventType'
+
+describe('SubscriptionEventType', () => {
+  it('should create a value object', () => {
+    const valueOrError = SubscriptionEventType.create('SUBSCRIPTION_PURCHASED')
+
+    expect(valueOrError.isFailed()).toBeFalsy()
+    expect(valueOrError.getValue().value).toEqual('SUBSCRIPTION_PURCHASED')
+  })
+
+  it('should not create an invalid value object', () => {
+    const valueOrError = SubscriptionEventType.create('SUBSCRIPTION_REACTIVATED')
+
+    expect(valueOrError.isFailed()).toBeTruthy()
+  })
+})

packages/analytics/src/Domain/Subscription/SubscriptionEventType.ts

@@ -0,0 +1,30 @@
+import { ValueObject } from '../Core/ValueObject'
+import { Result } from '../Core/Result'
+import { SubscriptionEventTypeProps } from './SubscriptionEventTypeProps'
+
+export class SubscriptionEventType extends ValueObject<SubscriptionEventTypeProps> {
+  get value(): string {
+    return this.props.value
+  }
+
+  private constructor(props: SubscriptionEventTypeProps) {
+    super(props)
+  }
+
+  static create(subscriptionEventType: string): Result<SubscriptionEventType> {
+    if (
+      ![
+        'SUBSCRIPTION_PURCHASED',
+        'SUBSCRIPTION_RENEWED',
+        'SUBSCRIPTION_EXPIRED',
+        'SUBSCRIPTION_REFUNDED',
+        'SUBSCRIPTION_CANCELLED',
+        'SUBSCRIPTION_DATA_MIGRATED',
+      ].includes(subscriptionEventType)
+    ) {
+      return Result.fail<SubscriptionEventType>(`Invalid subscription event type ${subscriptionEventType}`)
+    } else {
+      return Result.ok<SubscriptionEventType>(new SubscriptionEventType({ value: subscriptionEventType }))
+    }
+  }
+}

packages/analytics/src/Domain/Subscription/SubscriptionEventTypeProps.ts

@@ -0,0 +1,3 @@
+export interface SubscriptionEventTypeProps {
+  value: string
+}

packages/analytics/src/Domain/Subscription/SubscriptionPlanName.spec.ts

@@ -0,0 +1,16 @@
+import { SubscriptionPlanName } from './SubscriptionPlanName'
+
+describe('SubscriptionPlanName', () => {
+  it('should create a value object', () => {
+    const valueOrError = SubscriptionPlanName.create('PRO_PLAN')
+
+    expect(valueOrError.isFailed()).toBeFalsy()
+    expect(valueOrError.getValue().value).toEqual('PRO_PLAN')
+  })
+
+  it('should not create an invalid value object', () => {
+    const valueOrError = SubscriptionPlanName.create('TEST')
+
+    expect(valueOrError.isFailed()).toBeTruthy()
+  })
+})

packages/analytics/src/Domain/Subscription/SubscriptionPlanName.ts

@@ -0,0 +1,21 @@
+import { ValueObject } from '../Core/ValueObject'
+import { Result } from '../Core/Result'
+import { SubscriptionPlanNameProps } from './SubscriptionPlanNameProps'
+
+export class SubscriptionPlanName extends ValueObject<SubscriptionPlanNameProps> {
+  get value(): string {
+    return this.props.value
+  }
+
+  private constructor(props: SubscriptionPlanNameProps) {
+    super(props)
+  }
+
+  static create(subscriptionPlanName: string): Result<SubscriptionPlanName> {
+    if (!['PRO_PLAN', 'PLUS_PLAN'].includes(subscriptionPlanName)) {
+      return Result.fail<SubscriptionPlanName>(`Invalid subscription plan name ${subscriptionPlanName}`)
+    } else {
+      return Result.ok<SubscriptionPlanName>(new SubscriptionPlanName({ value: subscriptionPlanName }))
+    }
+  }
+}

packages/analytics/src/Domain/Subscription/SubscriptionPlanNameProps.ts

@@ -0,0 +1,3 @@
+export interface SubscriptionPlanNameProps {
+  value: string
+}

packages/analytics/src/Domain/Subscription/SubscriptionProps.ts

@@ -0,0 +1,8 @@
+import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
+
+export interface SubscriptionProps {
+  planName: SubscriptionPlanName
+  isFirstSubscriptionForUser: boolean
+  payedAmount: number
+  billingFrequency: number
+}

packages/analytics/src/Domain/UseCase/DomainUseCaseInterface.ts

@@ -0,0 +1,5 @@
+import { Result } from '../Core/Result'
+
+export interface DomainUseCaseInterface<T> {
+  execute(...args: any[]): Promise<Result<T>>
+}

packages/analytics/src/Domain/UseCase/GetUserAnalyticsId/GetUserAnalyticsId.spec.ts

@@ -12,7 +12,11 @@ describe('GetUserAnalyticsId', () => {
   const createUseCase = () => new GetUserAnalyticsId(analyticsEntityRepository)
 
   beforeEach(() => {
-    analyticsEntity = { id: 123 } as jest.Mocked<AnalyticsEntity>
+    analyticsEntity = {
+      id: 123,
+      userUuid: '1-2-3',
+      userEmail: 'test@test.te',
+    } as jest.Mocked<AnalyticsEntity>
 
     analyticsEntityRepository = {} as jest.Mocked<AnalyticsEntityRepositoryInterface>
     analyticsEntityRepository.findOneByUserUuid = jest.fn().mockReturnValue(analyticsEntity)
@@ -20,11 +24,11 @@ describe('GetUserAnalyticsId', () => {
   })
 
   it('should return analytics id for a user by uuid', async () => {
-    expect(await createUseCase().execute({ userUuid: '1-2-3' })).toEqual({ analyticsId: 123 })
+    expect(await (await createUseCase().execute({ userUuid: '1-2-3' })).analyticsId).toEqual(123)
   })
 
   it('should return analytics id for a user by email', async () => {
-    expect(await createUseCase().execute({ userEmail: 'test@test.te' })).toEqual({ analyticsId: 123 })
+    expect(await (await createUseCase().execute({ userEmail: 'test@test.te' })).analyticsId).toEqual(123)
   })
 
   it('should throw error if user is missing analytics entity', async () => {

packages/analytics/src/Domain/UseCase/GetUserAnalyticsId/GetUserAnalyticsId.ts

@@ -1,5 +1,7 @@
 import { inject, injectable } from 'inversify'
 import TYPES from '../../../Bootstrap/Types'
+import { Email } from '../../Common/Email'
+import { Uuid } from '../../Common/Uuid'
 import { AnalyticsEntityRepositoryInterface } from '../../Entity/AnalyticsEntityRepositoryInterface'
 import { UseCaseInterface } from '../UseCaseInterface'
 import { GetUserAnalyticsIdDTO } from './GetUserAnalyticsIdDTO'
@@ -25,6 +27,8 @@ export class GetUserAnalyticsId implements UseCaseInterface {
 
     return {
       analyticsId: analyticsEntity.id,
+      userUuid: Uuid.create(analyticsEntity.userUuid).getValue(),
+      userEmail: Email.create(analyticsEntity.userEmail).getValue(),
     }
   }
 }

packages/analytics/src/Domain/UseCase/GetUserAnalyticsId/GetUserAnalyticsIdResponse.ts

@@ -1,3 +1,8 @@
+import { Email } from '../../Common/Email'
+import { Uuid } from '../../Common/Uuid'
+
 export type GetUserAnalyticsIdResponse = {
   analyticsId: number
+  userEmail: Email
+  userUuid: Uuid
 }

packages/analytics/src/Domain/UseCase/SaveRevenueModification/SaveRevenueModification.spec.ts

@@ -0,0 +1,50 @@
+import 'reflect-metadata'
+
+import { TimerInterface } from '@standardnotes/time'
+
+import { Email } from '../../Common/Email'
+import { Uuid } from '../../Common/Uuid'
+import { MonthlyRevenue } from '../../Revenue/MonthlyRevenue'
+
+import { RevenueModification } from '../../Revenue/RevenueModification'
+import { RevenueModificationRepositoryInterface } from '../../Revenue/RevenueModificationRepositoryInterface'
+import { SubscriptionEventType } from '../../Subscription/SubscriptionEventType'
+import { SubscriptionPlanName } from '../../Subscription/SubscriptionPlanName'
+import { SaveRevenueModification } from './SaveRevenueModification'
+
+describe('SaveRevenueModification', () => {
+  let revenueModificationRepository: RevenueModificationRepositoryInterface
+  let previousMonthlyRevenue: RevenueModification
+  let timer: TimerInterface
+
+  const createUseCase = () => new SaveRevenueModification(revenueModificationRepository, timer)
+
+  beforeEach(() => {
+    previousMonthlyRevenue = {
+      newMonthlyRevenue: MonthlyRevenue.create(2).getValue(),
+    } as jest.Mocked<RevenueModification>
+
+    revenueModificationRepository = {} as jest.Mocked<RevenueModificationRepositoryInterface>
+    revenueModificationRepository.findLastByUserUuid = jest.fn().mockReturnValue(previousMonthlyRevenue)
+    revenueModificationRepository.save = jest.fn()
+
+    timer = {} as jest.Mocked<TimerInterface>
+    timer.getTimestampInMicroseconds = jest.fn().mockReturnValue(1)
+  })
+
+  it('should persist a revenue modification', async () => {
+    const revenueOrError = await createUseCase().execute({
+      billingFrequency: 1,
+      eventType: SubscriptionEventType.create('SUBSCRIPTION_PURCHASED').getValue(),
+      newSubscriber: true,
+      payedAmount: 12.99,
+      planName: SubscriptionPlanName.create('PRO_PLAN').getValue(),
+      subscriptionId: 1234,
+      userEmail: Email.create('test@test.te').getValue(),
+      userUuid: Uuid.create('1-2-3').getValue(),
+    })
+    expect(revenueOrError.isFailed()).toBeFalsy()
+    const revenue = revenueOrError.getValue()
+    expect(revenue.newMonthlyRevenue.value).toEqual(12.99)
+  })
+})

packages/analytics/src/Domain/UseCase/SaveRevenueModification/SaveRevenueModification.ts

@@ -0,0 +1,57 @@
+import { inject, injectable } from 'inversify'
+import TYPES from '../../../Bootstrap/Types'
+import { UniqueEntityId } from '../../Core/UniqueEntityId'
+import { MonthlyRevenue } from '../../Revenue/MonthlyRevenue'
+import { RevenueModification } from '../../Revenue/RevenueModification'
+import { RevenueModificationRepositoryInterface } from '../../Revenue/RevenueModificationRepositoryInterface'
+import { Subscription } from '../../Subscription/Subscription'
+import { User } from '../../User/User'
+import { Result } from '../../Core/Result'
+import { DomainUseCaseInterface } from '../DomainUseCaseInterface'
+import { SaveRevenueModificationDTO } from './SaveRevenueModificationDTO'
+import { TimerInterface } from '@standardnotes/time'
+
+@injectable()
+export class SaveRevenueModification implements DomainUseCaseInterface<RevenueModification> {
+  constructor(
+    @inject(TYPES.RevenueModificationRepository)
+    private revenueModificationRepository: RevenueModificationRepositoryInterface,
+    @inject(TYPES.Timer) private timer: TimerInterface,
+  ) {}
+
+  async execute(dto: SaveRevenueModificationDTO): Promise<Result<RevenueModification>> {
+    const user = User.create(
+      {
+        email: dto.userEmail,
+      },
+      new UniqueEntityId(dto.userUuid.value),
+    )
+    const subscription = Subscription.create(
+      {
+        isFirstSubscriptionForUser: dto.newSubscriber,
+        payedAmount: dto.payedAmount,
+        planName: dto.planName,
+        billingFrequency: dto.billingFrequency,
+      },
+      new UniqueEntityId(dto.subscriptionId),
+    )
+
+    let previousMonthlyRevenue = MonthlyRevenue.create(0).getValue()
+    const previousRevenueModification = await this.revenueModificationRepository.findLastByUserUuid(dto.userUuid)
+    if (previousRevenueModification !== null) {
+      previousMonthlyRevenue = previousRevenueModification.newMonthlyRevenue
+    }
+
+    const revenueModification = RevenueModification.create({
+      eventType: dto.eventType,
+      subscription,
+      user,
+      previousMonthlyRevenue,
+      createdAt: this.timer.getTimestampInMicroseconds(),
+    })
+
+    await this.revenueModificationRepository.save(revenueModification)
+
+    return Result.ok<RevenueModification>(revenueModification)
+  }
+}

packages/analytics/src/Domain/UseCase/SaveRevenueModification/SaveRevenueModificationDTO.ts

@@ -0,0 +1,15 @@
+import { Email } from '../../Common/Email'
+import { Uuid } from '../../Common/Uuid'
+import { SubscriptionEventType } from '../../Subscription/SubscriptionEventType'
+import { SubscriptionPlanName } from '../../Subscription/SubscriptionPlanName'
+
+export interface SaveRevenueModificationDTO {
+  eventType: SubscriptionEventType
+  payedAmount: number
+  planName: SubscriptionPlanName
+  newSubscriber: boolean
+  userUuid: Uuid
+  userEmail: Email
+  subscriptionId: number
+  billingFrequency: number
+}

packages/analytics/src/Domain/User/User.spec.ts

@@ -0,0 +1,12 @@
+import { Email } from '../Common/Email'
+import { User } from './User'
+
+describe('User', () => {
+  it('should create an entity', () => {
+    const user = User.create({
+      email: Email.create('test@test.te').getValue(),
+    })
+
+    expect(user.id.toString()).toHaveLength(36)
+  })
+})

packages/analytics/src/Domain/User/User.ts

@@ -0,0 +1,17 @@
+import { Entity } from '../Core/Entity'
+import { UniqueEntityId } from '../Core/UniqueEntityId'
+import { UserProps } from './UserProps'
+
+export class User extends Entity<UserProps> {
+  get id(): UniqueEntityId {
+    return this._id
+  }
+
+  private constructor(props: UserProps, id?: UniqueEntityId) {
+    super(props, id)
+  }
+
+  public static create(props: UserProps, id?: UniqueEntityId): User {
+    return new User(props, id)
+  }
+}

packages/analytics/src/Domain/User/UserProps.ts

@@ -0,0 +1,5 @@
+import { Email } from '../Common/Email'
+
+export interface UserProps {
+  email: Email
+}

packages/analytics/src/Infra/MySQL/MySQLAnalyticsEntityRepository.spec.ts

@@ -1,60 +0,0 @@
-import 'reflect-metadata'
-
-import { Repository, SelectQueryBuilder } from 'typeorm'
-
-import { AnalyticsEntity } from '../../Domain/Entity/AnalyticsEntity'
-
-import { MySQLAnalyticsEntityRepository } from './MySQLAnalyticsEntityRepository'
-
-describe('MySQLAnalyticsEntityRepository', () => {
-  let ormRepository: Repository<AnalyticsEntity>
-  let analyticsEntity: AnalyticsEntity
-  let queryBuilder: SelectQueryBuilder<AnalyticsEntity>
-
-  const createRepository = () => new MySQLAnalyticsEntityRepository(ormRepository)
-
-  beforeEach(() => {
-    analyticsEntity = {} as jest.Mocked<AnalyticsEntity>
-
-    queryBuilder = {} as jest.Mocked<SelectQueryBuilder<AnalyticsEntity>>
-
-    ormRepository = {} as jest.Mocked<Repository<AnalyticsEntity>>
-    ormRepository.save = jest.fn()
-    ormRepository.remove = jest.fn()
-    ormRepository.createQueryBuilder = jest.fn().mockImplementation(() => queryBuilder)
-  })
-
-  it('should save', async () => {
-    await createRepository().save(analyticsEntity)
-
-    expect(ormRepository.save).toHaveBeenCalledWith(analyticsEntity)
-  })
-
-  it('should remove', async () => {
-    await createRepository().remove(analyticsEntity)
-
-    expect(ormRepository.remove).toHaveBeenCalledWith(analyticsEntity)
-  })
-
-  it('should find one by user uuid', async () => {
-    queryBuilder.where = jest.fn().mockReturnThis()
-    queryBuilder.getOne = jest.fn().mockReturnValue(analyticsEntity)
-
-    const result = await createRepository().findOneByUserUuid('123')
-
-    expect(queryBuilder.where).toHaveBeenCalledWith('analytics_entity.user_uuid = :userUuid', { userUuid: '123' })
-
-    expect(result).toEqual(analyticsEntity)
-  })
-
-  it('should find one by user email', async () => {
-    queryBuilder.where = jest.fn().mockReturnThis()
-    queryBuilder.getOne = jest.fn().mockReturnValue(analyticsEntity)
-
-    const result = await createRepository().findOneByUserEmail('test@test.te')
-
-    expect(queryBuilder.where).toHaveBeenCalledWith('analytics_entity.user_email = :email', { email: 'test@test.te' })
-
-    expect(result).toEqual(analyticsEntity)
-  })
-})

packages/analytics/src/Infra/MySQL/MySQLRevenueModificationRepository.ts

@@ -0,0 +1,42 @@
+import { inject, injectable } from 'inversify'
+import { Repository } from 'typeorm'
+
+import TYPES from '../../Bootstrap/Types'
+import { Uuid } from '../../Domain/Common/Uuid'
+import { MapInterface } from '../../Domain/Map/MapInterface'
+import { RevenueModification } from '../../Domain/Revenue/RevenueModification'
+import { RevenueModificationRepositoryInterface } from '../../Domain/Revenue/RevenueModificationRepositoryInterface'
+import { TypeORMRevenueModification } from '../TypeORM/TypeORMRevenueModification'
+
+@injectable()
+export class MySQLRevenueModificationRepository implements RevenueModificationRepositoryInterface {
+  constructor(
+    @inject(TYPES.ORMRevenueModificationRepository)
+    private ormRepository: Repository<TypeORMRevenueModification>,
+    @inject(TYPES.RevenueModificationMap)
+    private revenueModificationMap: MapInterface<RevenueModification, TypeORMRevenueModification>,
+  ) {}
+
+  async findLastByUserUuid(userUuid: Uuid): Promise<RevenueModification | null> {
+    const persistence = await this.ormRepository
+      .createQueryBuilder()
+      .where('user_uuid = :userUuid', { userUuid: userUuid.value })
+      .orderBy('created_at', 'DESC')
+      .limit(1)
+      .getOne()
+
+    if (persistence === null) {
+      return null
+    }
+
+    return this.revenueModificationMap.toDomain(persistence)
+  }
+
+  async save(revenueModification: RevenueModification): Promise<RevenueModification> {
+    let persistence = this.revenueModificationMap.toPersistence(revenueModification)
+
+    persistence = await this.ormRepository.save(persistence)
+
+    return this.revenueModificationMap.toDomain(persistence)
+  }
+}

packages/analytics/src/Infra/TypeORM/TypeORMRevenueModification.ts

@@ -0,0 +1,67 @@
+import { Column, Entity, Index, PrimaryColumn } from 'typeorm'
+
+@Entity({ name: 'revenue_modifications' })
+export class TypeORMRevenueModification {
+  @PrimaryColumn({
+    type: 'uuid',
+    length: 36,
+  })
+  declare uuid: string
+
+  @Column({
+    name: 'subscription_id',
+  })
+  declare subscriptionId: number
+
+  @Column({
+    name: 'user_email',
+    length: 255,
+  })
+  @Index('email')
+  declare userEmail: string
+
+  @Column({
+    name: 'user_uuid',
+    length: 36,
+  })
+  @Index('user_uuid')
+  declare userUuid: string
+
+  @Column({
+    name: 'event_type',
+  })
+  declare eventType: string
+
+  @Column({
+    name: 'subscription_plan',
+  })
+  declare subscriptionPlan: string
+
+  @Column({
+    name: 'billing_frequency',
+  })
+  declare billingFrequency: number
+
+  @Column({
+    name: 'new_customer',
+  })
+  declare isNewCustomer: boolean
+
+  @Column({
+    name: 'previous_mrr',
+    type: 'float',
+  })
+  declare previousMonthlyRevenue: number
+
+  @Column({
+    name: 'new_mrr',
+    type: 'float',
+  })
+  declare newMonthlyRevenue: number
+
+  @Column({
+    name: 'created_at',
+    type: 'bigint',
+  })
+  declare createdAt: number
+}

packages/api-gateway/CHANGELOG.md

@@ -3,6 +3,26 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.37.5](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.37.4...@standardnotes/api-gateway@1.37.5) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/api-gateway
+
+## [1.37.4](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.37.3...@standardnotes/api-gateway@1.37.4) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/api-gateway
+
+## [1.37.3](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.37.2...@standardnotes/api-gateway@1.37.3) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/api-gateway
+
+## [1.37.2](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.37.1...@standardnotes/api-gateway@1.37.2) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/api-gateway
+
+## [1.37.1](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.37.0...@standardnotes/api-gateway@1.37.1) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/api-gateway
+
 # [1.37.0](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.36.14...@standardnotes/api-gateway@1.37.0) (2022-11-07)
 
 ### Features

packages/api-gateway/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/api-gateway",
-  "version": "1.37.0",
+  "version": "1.37.5",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

packages/auth/CHANGELOG.md

@@ -3,6 +3,42 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+# [1.59.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.58.0...@standardnotes/auth-server@1.59.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription canceled ([52a257a](https://github.com/standardnotes/server/commit/52a257abb16034134a50474fbbb2493a00c58b99))
+
+# [1.58.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.57.0...@standardnotes/auth-server@1.58.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription refunded ([0f65c05](https://github.com/standardnotes/server/commit/0f65c051abcff805e920f91d338e5fadda7905a9))
+
+# [1.57.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.56.0...@standardnotes/auth-server@1.57.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription expired ([5c3db2c](https://github.com/standardnotes/server/commit/5c3db2cb29a929e44b63eb8226ce4ad1d14f8a99))
+
+# [1.56.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.55.0...@standardnotes/auth-server@1.56.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription renewed ([cdb7fcf](https://github.com/standardnotes/server/commit/cdb7fcf8311fecfabe3ef9eb656cd6ec57b87de0))
+
+# [1.55.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.54.0...@standardnotes/auth-server@1.55.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription purchased ([5ea9941](https://github.com/standardnotes/server/commit/5ea9941519ffb3027527130ec869da14abc5e994))
+
+# [1.54.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.53.0...@standardnotes/auth-server@1.54.0) (2022-11-07)
+
+### Features
+
+* **auth:** remove analytics table in favor of analytics service ([49feadd](https://github.com/standardnotes/server/commit/49feadd32a5fc8994a1b63f5293d41ca60f01e02))
+
 # [1.53.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.52.1...@standardnotes/auth-server@1.53.0) (2022-11-07)
 
 ### Features

packages/auth/migrations/1667818539829-remove_analytics.ts

@@ -0,0 +1,15 @@
+import { MigrationInterface, QueryRunner } from 'typeorm'
+
+export class removeAnalytics1667818539829 implements MigrationInterface {
+  name = 'removeAnalytics1667818539829'
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query('ALTER TABLE `analytics_entities` DROP FOREIGN KEY `FK_d2717c4ce2600b9f7acb6b378c5`')
+    await queryRunner.query('DROP INDEX `REL_d2717c4ce2600b9f7acb6b378c` ON `analytics_entities`')
+    await queryRunner.query('DROP TABLE `analytics_entities`')
+  }
+
+  public async down(): Promise<void> {
+    return
+  }
+}

packages/auth/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/auth-server",
-  "version": "1.53.0",
+  "version": "1.59.0",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

packages/auth/src/Domain/Handler/SubscriptionCancelledEventHandler.spec.ts

@@ -40,6 +40,9 @@ describe('SubscriptionCancelledEventHandler', () => {
       subscriptionEndsAt: 2,
       subscriptionUpdatedAt: 2,
       lastPayedAt: 1,
+      userExistingSubscriptionsCount: 1,
+      billingFrequency: 1,
+      payAmount: 12.99,
     }
   })
 

packages/auth/src/Domain/Handler/SubscriptionExpiredEventHandler.spec.ts

@@ -72,6 +72,9 @@ describe('SubscriptionExpiredEventHandler', () => {
       timestamp,
       offline: false,
       totalActiveSubscriptionsCount: 123,
+      userExistingSubscriptionsCount: 2,
+      billingFrequency: 1,
+      payAmount: 12.99,
     }
 
     logger = {} as jest.Mocked<Logger>

packages/auth/src/Domain/Handler/SubscriptionPurchasedEventHandler.spec.ts

@@ -90,6 +90,8 @@ describe('SubscriptionPurchasedEventHandler', () => {
       newSubscriber: true,
       totalActiveSubscriptionsCount: 123,
       userRegisteredAt: dayjs.utc().valueOf() - 23,
+      billingFrequency: 12,
+      payAmount: 29.99,
     }
 
     subscriptionSettingService = {} as jest.Mocked<SubscriptionSettingServiceInterface>

packages/auth/src/Domain/Handler/SubscriptionRefundedEventHandler.spec.ts

@@ -74,6 +74,8 @@ describe('SubscriptionRefundedEventHandler', () => {
       offline: false,
       userExistingSubscriptionsCount: 3,
       totalActiveSubscriptionsCount: 1,
+      billingFrequency: 1,
+      payAmount: 12.99,
     }
 
     logger = {} as jest.Mocked<Logger>

packages/auth/src/Domain/Handler/SubscriptionRenewedEventHandler.spec.ts

@@ -81,6 +81,8 @@ describe('SubscriptionRenewedEventHandler', () => {
       subscriptionExpiresAt,
       timestamp,
       offline: false,
+      billingFrequency: 1,
+      payAmount: 12.99,
     }
 
     logger = {} as jest.Mocked<Logger>

packages/domain-events-infra/CHANGELOG.md

@@ -3,6 +3,26 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.9.18](https://github.com/standardnotes/server/compare/@standardnotes/domain-events-infra@1.9.17...@standardnotes/domain-events-infra@1.9.18) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/domain-events-infra
+
+## [1.9.17](https://github.com/standardnotes/server/compare/@standardnotes/domain-events-infra@1.9.16...@standardnotes/domain-events-infra@1.9.17) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/domain-events-infra
+
+## [1.9.16](https://github.com/standardnotes/server/compare/@standardnotes/domain-events-infra@1.9.15...@standardnotes/domain-events-infra@1.9.16) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/domain-events-infra
+
+## [1.9.15](https://github.com/standardnotes/server/compare/@standardnotes/domain-events-infra@1.9.14...@standardnotes/domain-events-infra@1.9.15) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/domain-events-infra
+
+## [1.9.14](https://github.com/standardnotes/server/compare/@standardnotes/domain-events-infra@1.9.13...@standardnotes/domain-events-infra@1.9.14) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/domain-events-infra
+
 ## [1.9.13](https://github.com/standardnotes/server/compare/@standardnotes/domain-events-infra@1.9.12...@standardnotes/domain-events-infra@1.9.13) (2022-11-07)
 
 **Note:** Version bump only for package @standardnotes/domain-events-infra

packages/domain-events-infra/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/domain-events-infra",
-  "version": "1.9.13",
+  "version": "1.9.18",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

packages/domain-events/CHANGELOG.md

@@ -3,6 +3,36 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+# [2.83.0](https://github.com/standardnotes/server/compare/@standardnotes/domain-events@2.82.0...@standardnotes/domain-events@2.83.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription canceled ([52a257a](https://github.com/standardnotes/server/commit/52a257abb16034134a50474fbbb2493a00c58b99))
+
+# [2.82.0](https://github.com/standardnotes/server/compare/@standardnotes/domain-events@2.81.0...@standardnotes/domain-events@2.82.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription refunded ([0f65c05](https://github.com/standardnotes/server/commit/0f65c051abcff805e920f91d338e5fadda7905a9))
+
+# [2.81.0](https://github.com/standardnotes/server/compare/@standardnotes/domain-events@2.80.0...@standardnotes/domain-events@2.81.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription expired ([5c3db2c](https://github.com/standardnotes/server/commit/5c3db2cb29a929e44b63eb8226ce4ad1d14f8a99))
+
+# [2.80.0](https://github.com/standardnotes/server/compare/@standardnotes/domain-events@2.79.0...@standardnotes/domain-events@2.80.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription renewed ([cdb7fcf](https://github.com/standardnotes/server/commit/cdb7fcf8311fecfabe3ef9eb656cd6ec57b87de0))
+
+# [2.79.0](https://github.com/standardnotes/server/compare/@standardnotes/domain-events@2.78.1...@standardnotes/domain-events@2.79.0) (2022-11-09)
+
+### Features
+
+* **analytics:** add saving revenue modifications upon subscription purchased ([5ea9941](https://github.com/standardnotes/server/commit/5ea9941519ffb3027527130ec869da14abc5e994))
+
 ## [2.78.1](https://github.com/standardnotes/server/compare/@standardnotes/domain-events@2.78.0...@standardnotes/domain-events@2.78.1) (2022-11-07)
 
 **Note:** Version bump only for package @standardnotes/domain-events

packages/domain-events/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/domain-events",
-  "version": "2.78.1",
+  "version": "2.83.0",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

packages/domain-events/src/Domain/Event/SubscriptionCancelledEventPayload.ts

@@ -11,4 +11,7 @@ export interface SubscriptionCancelledEventPayload {
   timestamp: number
   offline: boolean
   replaced: boolean
+  userExistingSubscriptionsCount: number
+  billingFrequency: number
+  payAmount: number
 }

packages/domain-events/src/Domain/Event/SubscriptionExpiredEventPayload.ts

@@ -7,4 +7,7 @@ export interface SubscriptionExpiredEventPayload {
   timestamp: number
   offline: boolean
   totalActiveSubscriptionsCount: number
+  userExistingSubscriptionsCount: number
+  billingFrequency: number
+  payAmount: number
 }

packages/domain-events/src/Domain/Event/SubscriptionPurchasedEventPayload.ts

@@ -12,4 +12,6 @@ export interface SubscriptionPurchasedEventPayload {
   newSubscriber: boolean
   totalActiveSubscriptionsCount: number
   userRegisteredAt: number
+  billingFrequency: number
+  payAmount: number
 }

packages/domain-events/src/Domain/Event/SubscriptionRefundedEventPayload.ts

@@ -8,4 +8,6 @@ export interface SubscriptionRefundedEventPayload {
   totalActiveSubscriptionsCount: number
   timestamp: number
   offline: boolean
+  billingFrequency: number
+  payAmount: number
 }

packages/domain-events/src/Domain/Event/SubscriptionRenewedEventPayload.ts

@@ -7,4 +7,6 @@ export interface SubscriptionRenewedEventPayload {
   subscriptionExpiresAt: number
   timestamp: number
   offline: boolean
+  billingFrequency: number
+  payAmount: number
 }

packages/event-store/CHANGELOG.md

@@ -3,6 +3,26 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.6.13](https://github.com/standardnotes/server/compare/@standardnotes/event-store@1.6.12...@standardnotes/event-store@1.6.13) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/event-store
+
+## [1.6.12](https://github.com/standardnotes/server/compare/@standardnotes/event-store@1.6.11...@standardnotes/event-store@1.6.12) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/event-store
+
+## [1.6.11](https://github.com/standardnotes/server/compare/@standardnotes/event-store@1.6.10...@standardnotes/event-store@1.6.11) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/event-store
+
+## [1.6.10](https://github.com/standardnotes/server/compare/@standardnotes/event-store@1.6.9...@standardnotes/event-store@1.6.10) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/event-store
+
+## [1.6.9](https://github.com/standardnotes/server/compare/@standardnotes/event-store@1.6.8...@standardnotes/event-store@1.6.9) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/event-store
+
 ## [1.6.8](https://github.com/standardnotes/server/compare/@standardnotes/event-store@1.6.7...@standardnotes/event-store@1.6.8) (2022-11-07)
 
 **Note:** Version bump only for package @standardnotes/event-store

packages/event-store/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/event-store",
-  "version": "1.6.8",
+  "version": "1.6.13",
   "description": "Event Store Service",
   "private": true,
   "main": "dist/src/index.js",

packages/files/CHANGELOG.md

@@ -3,6 +3,26 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.8.13](https://github.com/standardnotes/files/compare/@standardnotes/files-server@1.8.12...@standardnotes/files-server@1.8.13) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/files-server
+
+## [1.8.12](https://github.com/standardnotes/files/compare/@standardnotes/files-server@1.8.11...@standardnotes/files-server@1.8.12) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/files-server
+
+## [1.8.11](https://github.com/standardnotes/files/compare/@standardnotes/files-server@1.8.10...@standardnotes/files-server@1.8.11) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/files-server
+
+## [1.8.10](https://github.com/standardnotes/files/compare/@standardnotes/files-server@1.8.9...@standardnotes/files-server@1.8.10) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/files-server
+
+## [1.8.9](https://github.com/standardnotes/files/compare/@standardnotes/files-server@1.8.8...@standardnotes/files-server@1.8.9) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/files-server
+
 ## [1.8.8](https://github.com/standardnotes/files/compare/@standardnotes/files-server@1.8.7...@standardnotes/files-server@1.8.8) (2022-11-07)
 
 **Note:** Version bump only for package @standardnotes/files-server

packages/files/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/files-server",
-  "version": "1.8.8",
+  "version": "1.8.13",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

packages/scheduler/CHANGELOG.md

@@ -3,6 +3,26 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.13.14](https://github.com/standardnotes/server/compare/@standardnotes/scheduler-server@1.13.13...@standardnotes/scheduler-server@1.13.14) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/scheduler-server
+
+## [1.13.13](https://github.com/standardnotes/server/compare/@standardnotes/scheduler-server@1.13.12...@standardnotes/scheduler-server@1.13.13) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/scheduler-server
+
+## [1.13.12](https://github.com/standardnotes/server/compare/@standardnotes/scheduler-server@1.13.11...@standardnotes/scheduler-server@1.13.12) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/scheduler-server
+
+## [1.13.11](https://github.com/standardnotes/server/compare/@standardnotes/scheduler-server@1.13.10...@standardnotes/scheduler-server@1.13.11) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/scheduler-server
+
+## [1.13.10](https://github.com/standardnotes/server/compare/@standardnotes/scheduler-server@1.13.9...@standardnotes/scheduler-server@1.13.10) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/scheduler-server
+
 ## [1.13.9](https://github.com/standardnotes/server/compare/@standardnotes/scheduler-server@1.13.8...@standardnotes/scheduler-server@1.13.9) (2022-11-07)
 
 **Note:** Version bump only for package @standardnotes/scheduler-server

packages/scheduler/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/scheduler-server",
-  "version": "1.13.9",
+  "version": "1.13.14",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

packages/syncing-server/CHANGELOG.md

@@ -3,6 +3,26 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.11.5](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.11.4...@standardnotes/syncing-server@1.11.5) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/syncing-server
+
+## [1.11.4](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.11.3...@standardnotes/syncing-server@1.11.4) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/syncing-server
+
+## [1.11.3](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.11.2...@standardnotes/syncing-server@1.11.3) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/syncing-server
+
+## [1.11.2](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.11.1...@standardnotes/syncing-server@1.11.2) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/syncing-server
+
+## [1.11.1](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.11.0...@standardnotes/syncing-server@1.11.1) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/syncing-server
+
 # [1.11.0](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.10.25...@standardnotes/syncing-server@1.11.0) (2022-11-07)
 
 ### Features

packages/syncing-server/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/syncing-server",
-  "version": "1.11.0",
+  "version": "1.11.5",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

packages/websockets/CHANGELOG.md

@@ -3,6 +3,26 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.4.13](https://github.com/standardnotes/server/compare/@standardnotes/websockets-server@1.4.12...@standardnotes/websockets-server@1.4.13) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/websockets-server
+
+## [1.4.12](https://github.com/standardnotes/server/compare/@standardnotes/websockets-server@1.4.11...@standardnotes/websockets-server@1.4.12) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/websockets-server
+
+## [1.4.11](https://github.com/standardnotes/server/compare/@standardnotes/websockets-server@1.4.10...@standardnotes/websockets-server@1.4.11) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/websockets-server
+
+## [1.4.10](https://github.com/standardnotes/server/compare/@standardnotes/websockets-server@1.4.9...@standardnotes/websockets-server@1.4.10) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/websockets-server
+
+## [1.4.9](https://github.com/standardnotes/server/compare/@standardnotes/websockets-server@1.4.8...@standardnotes/websockets-server@1.4.9) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/websockets-server
+
 ## [1.4.8](https://github.com/standardnotes/server/compare/@standardnotes/websockets-server@1.4.7...@standardnotes/websockets-server@1.4.8) (2022-11-07)
 
 **Note:** Version bump only for package @standardnotes/websockets-server

packages/websockets/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/websockets-server",
-  "version": "1.4.8",
+  "version": "1.4.13",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

packages/workspace/CHANGELOG.md

@@ -3,6 +3,26 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.17.13](https://github.com/standardnotes/server/compare/@standardnotes/workspace-server@1.17.12...@standardnotes/workspace-server@1.17.13) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/workspace-server
+
+## [1.17.12](https://github.com/standardnotes/server/compare/@standardnotes/workspace-server@1.17.11...@standardnotes/workspace-server@1.17.12) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/workspace-server
+
+## [1.17.11](https://github.com/standardnotes/server/compare/@standardnotes/workspace-server@1.17.10...@standardnotes/workspace-server@1.17.11) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/workspace-server
+
+## [1.17.10](https://github.com/standardnotes/server/compare/@standardnotes/workspace-server@1.17.9...@standardnotes/workspace-server@1.17.10) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/workspace-server
+
+## [1.17.9](https://github.com/standardnotes/server/compare/@standardnotes/workspace-server@1.17.8...@standardnotes/workspace-server@1.17.9) (2022-11-09)
+
+**Note:** Version bump only for package @standardnotes/workspace-server
+
 ## [1.17.8](https://github.com/standardnotes/server/compare/@standardnotes/workspace-server@1.17.7...@standardnotes/workspace-server@1.17.8) (2022-11-07)
 
 **Note:** Version bump only for package @standardnotes/workspace-server

packages/workspace/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/workspace-server",
-  "version": "1.17.8",
+  "version": "1.17.13",
   "engines": {
     "node": ">=16.0.0 <17.0.0"
   },

yarn.lock

@@ -1815,6 +1815,7 @@ __metadata:
     "@types/jest": "npm:^29.1.1"
     "@types/newrelic": "npm:^7.0.3"
     "@types/node": "npm:^18.0.0"
+    "@types/uuid": "npm:^8.3.0"
     "@typescript-eslint/eslint-plugin": "npm:^5.30.0"
     aws-sdk: "npm:^2.1158.0"
     dayjs: "npm:^1.11.6"
@@ -1827,9 +1828,11 @@ __metadata:
     mysql2: "npm:^2.3.3"
     newrelic: "npm:^9.0.0"
     reflect-metadata: "npm:^0.1.13"
+    shallow-equal-object: "npm:^1.1.1"
     ts-jest: "npm:^29.0.3"
     typeorm: "npm:^0.3.6"
     typescript: "npm:^4.8.4"
+    uuid: "npm:^9.0.0"
     winston: "npm:^3.8.1"
   languageName: unknown
   linkType: soft
@@ -9969,6 +9972,13 @@ __metadata:
   languageName: node
   linkType: hard
 
+"shallow-equal-object@npm:^1.1.1":
+  version: 1.1.1
+  resolution: "shallow-equal-object@npm:1.1.1"
+  checksum: 9e5e0cd10ba5447f85038d7b104e66c15603e164b2112366f044f9447512bfb6f0b71bd9869e76824e76fae76568e94df3d9871bf5af8ab2ff78eee9487baecf
+  languageName: node
+  linkType: hard
+
 "shebang-command@npm:^2.0.0":
   version: 2.0.0
   resolution: "shebang-command@npm:2.0.0"