chore(release): publish new version

- @standardnotes/analytics@2.16.0

packages/analytics/CHANGELOG.md

@@ -3,6 +3,30 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+# [2.16.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.15.1...@standardnotes/analytics@2.16.0) (2022-12-20)
+
+### Features
+
+* **analytics:** add active users stats to report ([6e16620](https://github.com/standardnotes/server/commit/6e1662038c3340fb60939464616789bab7639160))
+
+## [2.15.1](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.15.0...@standardnotes/analytics@2.15.1) (2022-12-20)
+
+### Bug Fixes
+
+* **auth:** add persisting statistics for all subscription plans ([addedb3](https://github.com/standardnotes/server/commit/addedb3091ddae81618d56663e18f2ae76a43c4e))
+
+# [2.15.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.14.0...@standardnotes/analytics@2.15.0) (2022-12-19)
+
+### Features
+
+* **auth:** add requesting persisting statistics ([a35271f](https://github.com/standardnotes/server/commit/a35271fbb399b68a3ac7021395d8063707fba222))
+
+# [2.14.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.13.0...@standardnotes/analytics@2.14.0) (2022-12-19)
+
+### Features
+
+* **analytics:** add persisting statistics on demand ([0f84575](https://github.com/standardnotes/server/commit/0f8457534c1829c58f3c036749d262307ddeb779))
+
 # [2.13.0](https://github.com/standardnotes/server/compare/@standardnotes/analytics@2.12.27...@standardnotes/analytics@2.13.0) (2022-12-19)
 
 ### Features

packages/analytics/bin/report.ts

@@ -8,7 +8,6 @@ import { EmailLevel } from '@standardnotes/domain-core'
 import { DomainEventPublisherInterface } from '@standardnotes/domain-events'
 import { AnalyticsActivity } from '../src/Domain/Analytics/AnalyticsActivity'
 import { Period } from '../src/Domain/Time/Period'
-import { StatisticsMeasure } from '../src/Domain/Statistics/StatisticsMeasure'
 import { AnalyticsStoreInterface } from '../src/Domain/Analytics/AnalyticsStoreInterface'
 import { StatisticsStoreInterface } from '../src/Domain/Statistics/StatisticsStoreInterface'
 import { PeriodKeyGeneratorInterface } from '../src/Domain/Time/PeriodKeyGeneratorInterface'
@@ -19,6 +18,7 @@ import { DomainEventFactoryInterface } from '../src/Domain/Event/DomainEventFact
 import { CalculateMonthlyRecurringRevenue } from '../src/Domain/UseCase/CalculateMonthlyRecurringRevenue/CalculateMonthlyRecurringRevenue'
 import { getBody, getSubject } from '../src/Domain/Email/DailyAnalyticsReport'
 import { TimerInterface } from '@standardnotes/time'
+import { StatisticMeasureName } from '../src/Domain/Statistics/StatisticMeasureName'
 
 const requestReport = async (
   analyticsStore: AnalyticsStoreInterface,
@@ -115,12 +115,16 @@ const requestReport = async (
   }> = []
 
   const thirtyDaysStatisticsNames = [
-    StatisticsMeasure.MRR,
-    StatisticsMeasure.AnnualPlansMRR,
-    StatisticsMeasure.MonthlyPlansMRR,
-    StatisticsMeasure.FiveYearPlansMRR,
-    StatisticsMeasure.PlusPlansMRR,
-    StatisticsMeasure.ProPlansMRR,
+    StatisticMeasureName.NAMES.MRR,
+    StatisticMeasureName.NAMES.AnnualPlansMRR,
+    StatisticMeasureName.NAMES.MonthlyPlansMRR,
+    StatisticMeasureName.NAMES.FiveYearPlansMRR,
+    StatisticMeasureName.NAMES.PlusPlansMRR,
+    StatisticMeasureName.NAMES.ProPlansMRR,
+    StatisticMeasureName.NAMES.ActiveUsers,
+    StatisticMeasureName.NAMES.ActiveFreeUsers,
+    StatisticMeasureName.NAMES.ActivePlusUsers,
+    StatisticMeasureName.NAMES.ActiveProUsers,
   ]
   for (const statisticName of thirtyDaysStatisticsNames) {
     statisticsOverTime.push({
@@ -130,7 +134,7 @@ const requestReport = async (
     })
   }
 
-  const monthlyStatisticsNames = [StatisticsMeasure.MRR]
+  const monthlyStatisticsNames = [StatisticMeasureName.NAMES.MRR]
   for (const statisticName of monthlyStatisticsNames) {
     statisticsOverTime.push({
       name: statisticName,
@@ -140,22 +144,22 @@ const requestReport = async (
   }
 
   const statisticMeasureNames = [
-    StatisticsMeasure.Income,
-    StatisticsMeasure.PlusSubscriptionInitialAnnualPaymentsIncome,
-    StatisticsMeasure.PlusSubscriptionInitialMonthlyPaymentsIncome,
-    StatisticsMeasure.PlusSubscriptionRenewingAnnualPaymentsIncome,
-    StatisticsMeasure.PlusSubscriptionRenewingMonthlyPaymentsIncome,
-    StatisticsMeasure.ProSubscriptionInitialAnnualPaymentsIncome,
-    StatisticsMeasure.ProSubscriptionInitialMonthlyPaymentsIncome,
-    StatisticsMeasure.ProSubscriptionRenewingAnnualPaymentsIncome,
-    StatisticsMeasure.ProSubscriptionRenewingMonthlyPaymentsIncome,
-    StatisticsMeasure.Refunds,
-    StatisticsMeasure.RegistrationLength,
-    StatisticsMeasure.SubscriptionLength,
-    StatisticsMeasure.RegistrationToSubscriptionTime,
-    StatisticsMeasure.RemainingSubscriptionTimePercentage,
-    StatisticsMeasure.NewCustomers,
-    StatisticsMeasure.TotalCustomers,
+    StatisticMeasureName.NAMES.Income,
+    StatisticMeasureName.NAMES.PlusSubscriptionInitialAnnualPaymentsIncome,
+    StatisticMeasureName.NAMES.PlusSubscriptionInitialMonthlyPaymentsIncome,
+    StatisticMeasureName.NAMES.PlusSubscriptionRenewingAnnualPaymentsIncome,
+    StatisticMeasureName.NAMES.PlusSubscriptionRenewingMonthlyPaymentsIncome,
+    StatisticMeasureName.NAMES.ProSubscriptionInitialAnnualPaymentsIncome,
+    StatisticMeasureName.NAMES.ProSubscriptionInitialMonthlyPaymentsIncome,
+    StatisticMeasureName.NAMES.ProSubscriptionRenewingAnnualPaymentsIncome,
+    StatisticMeasureName.NAMES.ProSubscriptionRenewingMonthlyPaymentsIncome,
+    StatisticMeasureName.NAMES.Refunds,
+    StatisticMeasureName.NAMES.RegistrationLength,
+    StatisticMeasureName.NAMES.SubscriptionLength,
+    StatisticMeasureName.NAMES.RegistrationToSubscriptionTime,
+    StatisticMeasureName.NAMES.RemainingSubscriptionTimePercentage,
+    StatisticMeasureName.NAMES.NewCustomers,
+    StatisticMeasureName.NAMES.TotalCustomers,
   ]
   const statisticMeasures: Array<{
     name: string
@@ -190,7 +194,10 @@ const requestReport = async (
 
     const totalCustomerCounts: Array<number> = []
     for (const dailyPeriodKey of dailyPeriodKeys) {
-      const customersCount = await statisticsStore.getMeasureTotal(StatisticsMeasure.TotalCustomers, dailyPeriodKey)
+      const customersCount = await statisticsStore.getMeasureTotal(
+        StatisticMeasureName.NAMES.TotalCustomers,
+        dailyPeriodKey,
+      )
       totalCustomerCounts.push(customersCount)
     }
     const filteredTotalCustomerCounts = totalCustomerCounts.filter((count) => !!count)

packages/analytics/jest.config.js

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

packages/analytics/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/analytics",
-  "version": "2.13.0",
+  "version": "2.16.0",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

packages/analytics/src/Bootstrap/Container.ts

@@ -52,6 +52,9 @@ import { RevenueModification } from '../Domain/Revenue/RevenueModification'
 import { RevenueModificationMap } from '../Domain/Map/RevenueModificationMap'
 import { SaveRevenueModification } from '../Domain/UseCase/SaveRevenueModification/SaveRevenueModification'
 import { CalculateMonthlyRecurringRevenue } from '../Domain/UseCase/CalculateMonthlyRecurringRevenue/CalculateMonthlyRecurringRevenue'
+import { PersistStatistic } from '../Domain/UseCase/PersistStatistic/PersistStatistic'
+import { StatisticMeasureRepositoryInterface } from '../Domain/Statistics/StatisticMeasureRepositoryInterface'
+import { StatisticPersistenceRequestedEventHandler } from '../Domain/Handler/StatisticPersistenceRequestedEventHandler'
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const newrelicFormatter = require('@newrelic/winston-enricher')
@@ -132,6 +135,29 @@ export class ContainerConfigLoader {
     container.bind(TYPES.NEW_RELIC_ENABLED).toConstantValue(env.get('NEW_RELIC_ENABLED', true))
     container.bind(TYPES.ADMIN_EMAILS).toConstantValue(env.get('ADMIN_EMAILS').split(','))
 
+    // Services
+    container.bind<DomainEventFactory>(TYPES.DomainEventFactory).to(DomainEventFactory)
+    container.bind<PeriodKeyGeneratorInterface>(TYPES.PeriodKeyGenerator).toConstantValue(new PeriodKeyGenerator())
+    container
+      .bind<AnalyticsStoreInterface>(TYPES.AnalyticsStore)
+      .toConstantValue(new RedisAnalyticsStore(container.get(TYPES.PeriodKeyGenerator), container.get(TYPES.Redis)))
+    container
+      .bind<StatisticsStoreInterface>(TYPES.StatisticsStore)
+      .toConstantValue(new RedisStatisticsStore(container.get(TYPES.PeriodKeyGenerator), container.get(TYPES.Redis)))
+    container.bind<TimerInterface>(TYPES.Timer).toConstantValue(new Timer())
+
+    if (env.get('SNS_TOPIC_ARN', true)) {
+      container
+        .bind<SNSDomainEventPublisher>(TYPES.DomainEventPublisher)
+        .toConstantValue(new SNSDomainEventPublisher(container.get(TYPES.SNS), container.get(TYPES.SNS_TOPIC_ARN)))
+    } else {
+      container
+        .bind<RedisDomainEventPublisher>(TYPES.DomainEventPublisher)
+        .toConstantValue(
+          new RedisDomainEventPublisher(container.get(TYPES.Redis), container.get(TYPES.REDIS_EVENTS_CHANNEL)),
+        )
+    }
+
     // Repositories
     container
       .bind<AnalyticsEntityRepositoryInterface>(TYPES.AnalyticsEntityRepository)
@@ -139,6 +165,9 @@ export class ContainerConfigLoader {
     container
       .bind<RevenueModificationRepositoryInterface>(TYPES.RevenueModificationRepository)
       .to(MySQLRevenueModificationRepository)
+    container
+      .bind<StatisticMeasureRepositoryInterface>(TYPES.StatisticMeasureRepository)
+      .toConstantValue(new RedisStatisticsStore(container.get(TYPES.PeriodKeyGenerator), container.get(TYPES.Redis)))
 
     // ORM
     container
@@ -154,6 +183,9 @@ export class ContainerConfigLoader {
     container
       .bind<CalculateMonthlyRecurringRevenue>(TYPES.CalculateMonthlyRecurringRevenue)
       .to(CalculateMonthlyRecurringRevenue)
+    container
+      .bind<PersistStatistic>(TYPES.PersistStatistic)
+      .toConstantValue(new PersistStatistic(container.get(TYPES.StatisticMeasureRepository)))
 
     // Hanlders
     container.bind<UserRegisteredEventHandler>(TYPES.UserRegisteredEventHandler).to(UserRegisteredEventHandler)
@@ -181,35 +213,20 @@ export class ContainerConfigLoader {
       .bind<SubscriptionReactivatedEventHandler>(TYPES.SubscriptionReactivatedEventHandler)
       .to(SubscriptionReactivatedEventHandler)
     container.bind<RefundProcessedEventHandler>(TYPES.RefundProcessedEventHandler).to(RefundProcessedEventHandler)
+    container
+      .bind<StatisticPersistenceRequestedEventHandler>(TYPES.StatisticPersistenceRequestedEventHandler)
+      .toConstantValue(
+        new StatisticPersistenceRequestedEventHandler(
+          container.get(TYPES.PersistStatistic),
+          container.get(TYPES.Logger),
+        ),
+      )
 
     // Maps
     container
       .bind<MapperInterface<RevenueModification, TypeORMRevenueModification>>(TYPES.RevenueModificationMap)
       .to(RevenueModificationMap)
 
-    // Services
-    container.bind<DomainEventFactory>(TYPES.DomainEventFactory).to(DomainEventFactory)
-    container.bind<PeriodKeyGeneratorInterface>(TYPES.PeriodKeyGenerator).toConstantValue(new PeriodKeyGenerator())
-    container
-      .bind<AnalyticsStoreInterface>(TYPES.AnalyticsStore)
-      .toConstantValue(new RedisAnalyticsStore(container.get(TYPES.PeriodKeyGenerator), container.get(TYPES.Redis)))
-    container
-      .bind<StatisticsStoreInterface>(TYPES.StatisticsStore)
-      .toConstantValue(new RedisStatisticsStore(container.get(TYPES.PeriodKeyGenerator), container.get(TYPES.Redis)))
-    container.bind<TimerInterface>(TYPES.Timer).toConstantValue(new Timer())
-
-    if (env.get('SNS_TOPIC_ARN', true)) {
-      container
-        .bind<SNSDomainEventPublisher>(TYPES.DomainEventPublisher)
-        .toConstantValue(new SNSDomainEventPublisher(container.get(TYPES.SNS), container.get(TYPES.SNS_TOPIC_ARN)))
-    } else {
-      container
-        .bind<RedisDomainEventPublisher>(TYPES.DomainEventPublisher)
-        .toConstantValue(
-          new RedisDomainEventPublisher(container.get(TYPES.Redis), container.get(TYPES.REDIS_EVENTS_CHANNEL)),
-        )
-    }
-
     const eventHandlers: Map<string, DomainEventHandlerInterface> = new Map([
       ['USER_REGISTERED', container.get(TYPES.UserRegisteredEventHandler)],
       ['ACCOUNT_DELETION_REQUESTED', container.get(TYPES.AccountDeletionRequestedEventHandler)],
@@ -222,6 +239,7 @@ export class ContainerConfigLoader {
       ['SUBSCRIPTION_EXPIRED', container.get(TYPES.SubscriptionExpiredEventHandler)],
       ['SUBSCRIPTION_REACTIVATED', container.get(TYPES.SubscriptionReactivatedEventHandler)],
       ['REFUND_PROCESSED', container.get(TYPES.RefundProcessedEventHandler)],
+      ['STATISTIC_PERSISTENCE_REQUESTED', container.get(TYPES.StatisticPersistenceRequestedEventHandler)],
     ])
 
     if (env.get('SQS_QUEUE_URL', true)) {

packages/analytics/src/Bootstrap/Types.ts

@@ -15,6 +15,7 @@ const TYPES = {
   // Repositories
   AnalyticsEntityRepository: Symbol.for('AnalyticsEntityRepository'),
   RevenueModificationRepository: Symbol.for('RevenueModificationRepository'),
+  StatisticMeasureRepository: Symbol.for('StatisticMeasureRepository'),
   // ORM
   ORMAnalyticsEntityRepository: Symbol.for('ORMAnalyticsEntityRepository'),
   ORMRevenueModificationRepository: Symbol.for('ORMRevenueModificationRepository'),
@@ -22,6 +23,7 @@ const TYPES = {
   GetUserAnalyticsId: Symbol.for('GetUserAnalyticsId'),
   SaveRevenueModification: Symbol.for('SaveRevenueModification'),
   CalculateMonthlyRecurringRevenue: Symbol.for('CalculateMonthlyRecurringRevenue'),
+  PersistStatistic: Symbol.for('PersistStatistic'),
   // Handlers
   UserRegisteredEventHandler: Symbol.for('UserRegisteredEventHandler'),
   AccountDeletionRequestedEventHandler: Symbol.for('AccountDeletionRequestedEventHandler'),
@@ -34,6 +36,7 @@ const TYPES = {
   SubscriptionExpiredEventHandler: Symbol.for('SubscriptionExpiredEventHandler'),
   SubscriptionReactivatedEventHandler: Symbol.for('SubscriptionReactivatedEventHandler'),
   RefundProcessedEventHandler: Symbol.for('RefundProcessedEventHandler'),
+  StatisticPersistenceRequestedEventHandler: Symbol.for('StatisticPersistenceRequestedEventHandler'),
   // Maps
   RevenueModificationMap: Symbol.for('RevenueModificationMap'),
   // Services

packages/analytics/src/Domain/Email/daily-analytics-report.html.ts

@@ -2,7 +2,7 @@
 import { TimerInterface } from '@standardnotes/time'
 
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
+import { StatisticMeasureName } from '../Statistics/StatisticMeasureName'
 import { Period } from '../Time/Period'
 
 const getChartUrls = (
@@ -417,156 +417,170 @@ export const html = (data: any, timer: TimerInterface) => {
       a.name === AnalyticsActivity.DeleteAccount && a.period === Period.Last30Days,
   )
   const incomeMeasureYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.Income && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.Income && a.period === Period.Yesterday,
   )
   const refundMeasureYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.Refunds && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.Refunds && a.period === Period.Yesterday,
   )
   const incomeYesterday = incomeMeasureYesterday?.totalValue ?? 0
   const refundsYesterday = refundMeasureYesterday?.totalValue ?? 0
   const revenueYesterday = incomeYesterday - refundsYesterday
 
   const subscriptionLengthMeasureYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.SubscriptionLength && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.SubscriptionLength && a.period === Period.Yesterday,
   )
   const subscriptionLengthDurationYesterday = timer.convertMicrosecondsToTimeStructure(
     Math.floor(subscriptionLengthMeasureYesterday?.average ?? 0),
   )
 
   const subscriptionRemainingTimePercentageMeasureYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.RemainingSubscriptionTimePercentage && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.RemainingSubscriptionTimePercentage && a.period === Period.Yesterday,
   )
   const subscriptionRemainingTimePercentageYesterday = Math.floor(
     subscriptionRemainingTimePercentageMeasureYesterday?.average ?? 0,
   )
 
   const registrationLengthMeasureYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.RegistrationLength && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.RegistrationLength && a.period === Period.Yesterday,
   )
   const registrationLengthDurationYesterday = timer.convertMicrosecondsToTimeStructure(
     Math.floor(registrationLengthMeasureYesterday?.average ?? 0),
   )
 
   const registrationToSubscriptionMeasureYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.RegistrationToSubscriptionTime && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.RegistrationToSubscriptionTime && a.period === Period.Yesterday,
   )
   const registrationToSubscriptionDurationYesterday = timer.convertMicrosecondsToTimeStructure(
     Math.floor(registrationToSubscriptionMeasureYesterday?.average ?? 0),
   )
 
   const incomeMeasureThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.Income && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.Income && a.period === Period.ThisMonth,
   )
   const refundMeasureThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.Refunds && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.Refunds && a.period === Period.ThisMonth,
   )
   const incomeThisMonth = incomeMeasureThisMonth?.totalValue ?? 0
   const refundsThisMonth = refundMeasureThisMonth?.totalValue ?? 0
   const revenueThisMonth = incomeThisMonth - refundsThisMonth
 
   const subscriptionLengthMeasureThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.SubscriptionLength && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.SubscriptionLength && a.period === Period.ThisMonth,
   )
   const subscriptionLengthDurationThisMonth = timer.convertMicrosecondsToTimeStructure(
     Math.floor(subscriptionLengthMeasureThisMonth?.average ?? 0),
   )
 
   const subscriptionRemainingTimePercentageMeasureThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.RemainingSubscriptionTimePercentage && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.RemainingSubscriptionTimePercentage && a.period === Period.ThisMonth,
   )
   const subscriptionRemainingTimePercentageThisMonth = Math.floor(
     subscriptionRemainingTimePercentageMeasureThisMonth?.average ?? 0,
   )
 
   const registrationLengthMeasureThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.RegistrationLength && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.RegistrationLength && a.period === Period.ThisMonth,
   )
   const registrationLengthDurationThisMonth = timer.convertMicrosecondsToTimeStructure(
     Math.floor(registrationLengthMeasureThisMonth?.average ?? 0),
   )
 
   const registrationToSubscriptionMeasureThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.RegistrationToSubscriptionTime && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.RegistrationToSubscriptionTime && a.period === Period.ThisMonth,
   )
   const registrationToSubscriptionDurationThisMonth = timer.convertMicrosecondsToTimeStructure(
     Math.floor(registrationToSubscriptionMeasureThisMonth?.average ?? 0),
   )
 
   const plusSubscriptionsInitialAnnualPaymentsYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.PlusSubscriptionInitialAnnualPaymentsIncome && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.PlusSubscriptionInitialAnnualPaymentsIncome &&
+      a.period === Period.Yesterday,
   )
   const plusSubscriptionsInitialMonthlyPaymentsYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.PlusSubscriptionInitialMonthlyPaymentsIncome && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.PlusSubscriptionInitialMonthlyPaymentsIncome &&
+      a.period === Period.Yesterday,
   )
   const plusSubscriptionsRenewingAnnualPaymentsYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.PlusSubscriptionRenewingAnnualPaymentsIncome && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.PlusSubscriptionRenewingAnnualPaymentsIncome &&
+      a.period === Period.Yesterday,
   )
   const plusSubscriptionsRenewingMonthlyPaymentsYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.PlusSubscriptionRenewingMonthlyPaymentsIncome && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.PlusSubscriptionRenewingMonthlyPaymentsIncome &&
+      a.period === Period.Yesterday,
   )
   const proSubscriptionsInitialAnnualPaymentsYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.ProSubscriptionInitialAnnualPaymentsIncome && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.ProSubscriptionInitialAnnualPaymentsIncome && a.period === Period.Yesterday,
   )
   const proSubscriptionsInitialMonthlyPaymentsYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.ProSubscriptionInitialMonthlyPaymentsIncome && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.ProSubscriptionInitialMonthlyPaymentsIncome &&
+      a.period === Period.Yesterday,
   )
   const proSubscriptionsRenewingAnnualPaymentsYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.ProSubscriptionRenewingAnnualPaymentsIncome && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.ProSubscriptionRenewingAnnualPaymentsIncome &&
+      a.period === Period.Yesterday,
   )
   const proSubscriptionsRenewingMonthlyPaymentsYesterday = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.ProSubscriptionRenewingMonthlyPaymentsIncome && a.period === Period.Yesterday,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.ProSubscriptionRenewingMonthlyPaymentsIncome &&
+      a.period === Period.Yesterday,
   )
   const plusSubscriptionsInitialAnnualPaymentsThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.PlusSubscriptionInitialAnnualPaymentsIncome && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.PlusSubscriptionInitialAnnualPaymentsIncome &&
+      a.period === Period.ThisMonth,
   )
   const plusSubscriptionsInitialMonthlyPaymentsThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.PlusSubscriptionInitialMonthlyPaymentsIncome && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.PlusSubscriptionInitialMonthlyPaymentsIncome &&
+      a.period === Period.ThisMonth,
   )
   const plusSubscriptionsRenewingAnnualPaymentsThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.PlusSubscriptionRenewingAnnualPaymentsIncome && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.PlusSubscriptionRenewingAnnualPaymentsIncome &&
+      a.period === Period.ThisMonth,
   )
   const plusSubscriptionsRenewingMonthlyPaymentsThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.PlusSubscriptionRenewingMonthlyPaymentsIncome && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.PlusSubscriptionRenewingMonthlyPaymentsIncome &&
+      a.period === Period.ThisMonth,
   )
   const proSubscriptionsInitialAnnualPaymentsThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.ProSubscriptionInitialAnnualPaymentsIncome && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.ProSubscriptionInitialAnnualPaymentsIncome && a.period === Period.ThisMonth,
   )
   const proSubscriptionsInitialMonthlyPaymentsThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.ProSubscriptionInitialMonthlyPaymentsIncome && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.ProSubscriptionInitialMonthlyPaymentsIncome &&
+      a.period === Period.ThisMonth,
   )
   const proSubscriptionsRenewingAnnualPaymentsThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.ProSubscriptionRenewingAnnualPaymentsIncome && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.ProSubscriptionRenewingAnnualPaymentsIncome &&
+      a.period === Period.ThisMonth,
   )
   const proSubscriptionsRenewingMonthlyPaymentsThisMonth = data.statisticMeasures.find(
-    (a: { name: StatisticsMeasure; period: Period }) =>
-      a.name === StatisticsMeasure.ProSubscriptionRenewingMonthlyPaymentsIncome && a.period === Period.ThisMonth,
+    (a: { name: string; period: Period }) =>
+      a.name === StatisticMeasureName.NAMES.ProSubscriptionRenewingMonthlyPaymentsIncome &&
+      a.period === Period.ThisMonth,
   )
 
   const mrrOverTime = data.statisticsOverTime.find(

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

@@ -1,69 +0,0 @@
-import 'reflect-metadata'
-
-import { AccountDeletionRequestedEvent } from '@standardnotes/domain-events'
-import { AccountDeletionRequestedEventHandler } from './AccountDeletionRequestedEventHandler'
-import { TimerInterface } from '@standardnotes/time'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
-import { Period } from '../Time/Period'
-import { AnalyticsEntityRepositoryInterface } from '../Entity/AnalyticsEntityRepositoryInterface'
-
-describe('AccountDeletionRequestedEventHandler', () => {
-  let event: AccountDeletionRequestedEvent
-  let analyticsEntityRepository: AnalyticsEntityRepositoryInterface
-  let analyticsStore: AnalyticsStoreInterface
-  let statisticsStore: StatisticsStoreInterface
-  let timer: TimerInterface
-
-  const createHandler = () =>
-    new AccountDeletionRequestedEventHandler(analyticsEntityRepository, analyticsStore, statisticsStore, timer)
-
-  beforeEach(() => {
-    event = {} as jest.Mocked<AccountDeletionRequestedEvent>
-    event.createdAt = new Date(1)
-    event.payload = {
-      userUuid: '1-2-3',
-      userCreatedAtTimestamp: 1,
-      regularSubscriptionUuid: '2-3-4',
-    }
-
-    analyticsEntityRepository = {} as jest.Mocked<AnalyticsEntityRepositoryInterface>
-    analyticsEntityRepository.findOneByUserUuid = jest.fn().mockReturnValue({ id: 3 })
-    analyticsEntityRepository.remove = jest.fn()
-
-    analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
-    analyticsStore.markActivity = jest.fn()
-
-    statisticsStore = {} as jest.Mocked<StatisticsStoreInterface>
-    statisticsStore.incrementMeasure = jest.fn()
-
-    timer = {} as jest.Mocked<TimerInterface>
-    timer.getTimestampInMicroseconds = jest.fn().mockReturnValue(123)
-  })
-
-  it('should mark account deletion and registration length', async () => {
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalledWith(['DeleteAccount'], 3, [
-      Period.Today,
-      Period.ThisWeek,
-      Period.ThisMonth,
-    ])
-    expect(statisticsStore.incrementMeasure).toHaveBeenCalledWith('registration-length', 122, [
-      Period.Today,
-      Period.ThisWeek,
-      Period.ThisMonth,
-    ])
-    expect(analyticsEntityRepository.remove).toHaveBeenCalled()
-  })
-
-  it('should not mark anything if entity is not found', async () => {
-    analyticsEntityRepository.findOneByUserUuid = jest.fn().mockReturnValue(null)
-
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).not.toHaveBeenCalled()
-    expect(statisticsStore.incrementMeasure).not.toHaveBeenCalled()
-    expect(analyticsEntityRepository.remove).not.toHaveBeenCalled()
-  })
-})

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

@@ -6,7 +6,7 @@ import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
 import { AnalyticsEntityRepositoryInterface } from '../Entity/AnalyticsEntityRepositoryInterface'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
+import { StatisticMeasureName } from '../Statistics/StatisticMeasureName'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { Period } from '../Time/Period'
 
@@ -33,7 +33,7 @@ export class AccountDeletionRequestedEventHandler implements DomainEventHandlerI
     ])
 
     const registrationLength = this.timer.getTimestampInMicroseconds() - event.payload.userCreatedAtTimestamp
-    await this.statisticsStore.incrementMeasure(StatisticsMeasure.RegistrationLength, registrationLength, [
+    await this.statisticsStore.incrementMeasure(StatisticMeasureName.NAMES.RegistrationLength, registrationLength, [
       Period.Today,
       Period.ThisWeek,
       Period.ThisMonth,

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

@@ -1,34 +0,0 @@
-import 'reflect-metadata'
-
-import { PaymentFailedEvent } from '@standardnotes/domain-events'
-
-import { PaymentFailedEventHandler } from './PaymentFailedEventHandler'
-import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-
-describe('PaymentFailedEventHandler', () => {
-  let event: PaymentFailedEvent
-  let getUserAnalyticsId: GetUserAnalyticsId
-  let analyticsStore: AnalyticsStoreInterface
-
-  const createHandler = () => new PaymentFailedEventHandler(getUserAnalyticsId, analyticsStore)
-
-  beforeEach(() => {
-    getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
-    getUserAnalyticsId.execute = jest.fn().mockReturnValue({ analyticsId: 3 })
-
-    analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
-    analyticsStore.markActivity = jest.fn()
-
-    event = {} as jest.Mocked<PaymentFailedEvent>
-    event.payload = {
-      userEmail: 'test@test.com',
-    }
-  })
-
-  it('should mark payment failed for analytics', async () => {
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalled()
-  })
-})

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

@@ -1,75 +0,0 @@
-import 'reflect-metadata'
-
-import { PaymentSuccessEvent } from '@standardnotes/domain-events'
-
-import { PaymentSuccessEventHandler } from './PaymentSuccessEventHandler'
-import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
-import { Logger } from 'winston'
-import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { Period } from '../Time/Period'
-
-describe('PaymentSuccessEventHandler', () => {
-  let event: PaymentSuccessEvent
-  let getUserAnalyticsId: GetUserAnalyticsId
-  let analyticsStore: AnalyticsStoreInterface
-  let statisticsStore: StatisticsStoreInterface
-  let logger: Logger
-
-  const createHandler = () =>
-    new PaymentSuccessEventHandler(getUserAnalyticsId, analyticsStore, statisticsStore, logger)
-
-  beforeEach(() => {
-    getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
-    getUserAnalyticsId.execute = jest.fn().mockReturnValue({ analyticsId: 3 })
-
-    analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
-    analyticsStore.markActivity = jest.fn()
-
-    statisticsStore = {} as jest.Mocked<StatisticsStoreInterface>
-    statisticsStore.incrementMeasure = jest.fn()
-
-    event = {} as jest.Mocked<PaymentSuccessEvent>
-    event.payload = {
-      userEmail: 'test@test.com',
-      amount: 12.45,
-      billingFrequency: 12,
-      paymentType: 'initial',
-      subscriptionName: 'PRO_PLAN',
-    }
-
-    logger = {} as jest.Mocked<Logger>
-    logger.warn = jest.fn()
-  })
-
-  it('should mark payment success for analytics', async () => {
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalled()
-    expect(statisticsStore.incrementMeasure).toHaveBeenNthCalledWith(
-      2,
-      'pro-subscription-initial-annual-payments-income',
-      12.45,
-      [Period.Today, Period.ThisWeek, Period.ThisMonth],
-    )
-  })
-
-  it('should mark non-detailed payment success statistics for analytics', async () => {
-    event.payload = {
-      userEmail: 'test@test.com',
-      amount: 12.45,
-      billingFrequency: 13,
-      paymentType: 'initial',
-      subscriptionName: 'PRO_PLAN',
-    }
-
-    await createHandler().handle(event)
-
-    expect(statisticsStore.incrementMeasure).toBeCalledTimes(1)
-    expect(statisticsStore.incrementMeasure).toHaveBeenNthCalledWith(1, 'income', 12.45, [
-      Period.Today,
-      Period.ThisWeek,
-      Period.ThisMonth,
-    ])
-  })
-})

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

@@ -6,7 +6,7 @@ import { Logger } from 'winston'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
+import { StatisticMeasureName } from '../Statistics/StatisticMeasureName'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { Period } from '../Time/Period'
 import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
@@ -20,15 +20,27 @@ export class PaymentSuccessEventHandler implements DomainEventHandlerInterface {
         [
           PaymentType.Initial,
           new Map([
-            [SubscriptionBillingFrequency.Monthly, StatisticsMeasure.PlusSubscriptionInitialMonthlyPaymentsIncome],
-            [SubscriptionBillingFrequency.Annual, StatisticsMeasure.PlusSubscriptionInitialAnnualPaymentsIncome],
+            [
+              SubscriptionBillingFrequency.Monthly,
+              StatisticMeasureName.NAMES.PlusSubscriptionInitialMonthlyPaymentsIncome,
+            ],
+            [
+              SubscriptionBillingFrequency.Annual,
+              StatisticMeasureName.NAMES.PlusSubscriptionInitialAnnualPaymentsIncome,
+            ],
           ]),
         ],
         [
           PaymentType.Renewal,
           new Map([
-            [SubscriptionBillingFrequency.Monthly, StatisticsMeasure.PlusSubscriptionRenewingMonthlyPaymentsIncome],
-            [SubscriptionBillingFrequency.Annual, StatisticsMeasure.PlusSubscriptionRenewingAnnualPaymentsIncome],
+            [
+              SubscriptionBillingFrequency.Monthly,
+              StatisticMeasureName.NAMES.PlusSubscriptionRenewingMonthlyPaymentsIncome,
+            ],
+            [
+              SubscriptionBillingFrequency.Annual,
+              StatisticMeasureName.NAMES.PlusSubscriptionRenewingAnnualPaymentsIncome,
+            ],
           ]),
         ],
       ]),
@@ -39,15 +51,27 @@ export class PaymentSuccessEventHandler implements DomainEventHandlerInterface {
         [
           PaymentType.Initial,
           new Map([
-            [SubscriptionBillingFrequency.Monthly, StatisticsMeasure.ProSubscriptionInitialMonthlyPaymentsIncome],
-            [SubscriptionBillingFrequency.Annual, StatisticsMeasure.ProSubscriptionInitialAnnualPaymentsIncome],
+            [
+              SubscriptionBillingFrequency.Monthly,
+              StatisticMeasureName.NAMES.ProSubscriptionInitialMonthlyPaymentsIncome,
+            ],
+            [
+              SubscriptionBillingFrequency.Annual,
+              StatisticMeasureName.NAMES.ProSubscriptionInitialAnnualPaymentsIncome,
+            ],
           ]),
         ],
         [
           PaymentType.Renewal,
           new Map([
-            [SubscriptionBillingFrequency.Monthly, StatisticsMeasure.ProSubscriptionRenewingMonthlyPaymentsIncome],
-            [SubscriptionBillingFrequency.Annual, StatisticsMeasure.ProSubscriptionRenewingAnnualPaymentsIncome],
+            [
+              SubscriptionBillingFrequency.Monthly,
+              StatisticMeasureName.NAMES.ProSubscriptionRenewingMonthlyPaymentsIncome,
+            ],
+            [
+              SubscriptionBillingFrequency.Annual,
+              StatisticMeasureName.NAMES.ProSubscriptionRenewingAnnualPaymentsIncome,
+            ],
           ]),
         ],
       ]),
@@ -69,7 +93,7 @@ export class PaymentSuccessEventHandler implements DomainEventHandlerInterface {
       Period.ThisMonth,
     ])
 
-    const statisticMeasures = [StatisticsMeasure.Income]
+    const statisticMeasures = [StatisticMeasureName.NAMES.Income]
 
     const detailedMeasure = this.DETAILED_MEASURES.get(event.payload.subscriptionName as SubscriptionName)
       ?.get(event.payload.paymentType as PaymentType)

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

@@ -1,36 +0,0 @@
-import 'reflect-metadata'
-
-import { RefundProcessedEvent } from '@standardnotes/domain-events'
-
-import { RefundProcessedEventHandler } from './RefundProcessedEventHandler'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
-import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
-import { Period } from '../Time/Period'
-
-describe('RefundProcessedEventHandler', () => {
-  let event: RefundProcessedEvent
-  let statisticsStore: StatisticsStoreInterface
-
-  const createHandler = () => new RefundProcessedEventHandler(statisticsStore)
-
-  beforeEach(() => {
-    statisticsStore = {} as jest.Mocked<StatisticsStoreInterface>
-    statisticsStore.incrementMeasure = jest.fn()
-
-    event = {} as jest.Mocked<RefundProcessedEvent>
-    event.payload = {
-      userEmail: 'test@test.com',
-      amount: 12.45,
-    }
-  })
-
-  it('should mark refunds for statistics', async () => {
-    await createHandler().handle(event)
-
-    expect(statisticsStore.incrementMeasure).toHaveBeenCalledWith(StatisticsMeasure.Refunds, 12.45, [
-      Period.Today,
-      Period.ThisWeek,
-      Period.ThisMonth,
-    ])
-  })
-})

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

@@ -2,7 +2,7 @@ import { DomainEventHandlerInterface, RefundProcessedEvent } from '@standardnote
 import { inject, injectable } from 'inversify'
 
 import TYPES from '../../Bootstrap/Types'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
+import { StatisticMeasureName } from '../Statistics/StatisticMeasureName'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { Period } from '../Time/Period'
 
@@ -11,7 +11,7 @@ export class RefundProcessedEventHandler implements DomainEventHandlerInterface
   constructor(@inject(TYPES.StatisticsStore) private statisticsStore: StatisticsStoreInterface) {}
 
   async handle(event: RefundProcessedEvent): Promise<void> {
-    await this.statisticsStore.incrementMeasure(StatisticsMeasure.Refunds, event.payload.amount, [
+    await this.statisticsStore.incrementMeasure(StatisticMeasureName.NAMES.Refunds, event.payload.amount, [
       Period.Today,
       Period.ThisWeek,
       Period.ThisMonth,

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

@@ -0,0 +1,19 @@
+import { DomainEventHandlerInterface, StatisticPersistenceRequestedEvent } from '@standardnotes/domain-events'
+import { Logger } from 'winston'
+import { PersistStatistic } from '../UseCase/PersistStatistic/PersistStatistic'
+
+export class StatisticPersistenceRequestedEventHandler implements DomainEventHandlerInterface {
+  constructor(private persistStatistic: PersistStatistic, private logger: Logger) {}
+
+  async handle(event: StatisticPersistenceRequestedEvent): Promise<void> {
+    const result = await this.persistStatistic.execute({
+      date: event.payload.date,
+      statisticMeasureName: event.payload.statisticMeasureName,
+      value: event.payload.value,
+    })
+
+    if (result.isFailed()) {
+      this.logger.error(result.getError())
+    }
+  }
+}

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

@@ -1,104 +0,0 @@
-import 'reflect-metadata'
-
-import { SubscriptionName } from '@standardnotes/common'
-import { Result } from '@standardnotes/domain-core'
-import { SubscriptionCancelledEvent } from '@standardnotes/domain-events'
-
-import { SubscriptionCancelledEventHandler } from './SubscriptionCancelledEventHandler'
-import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
-import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
-import { Period } from '../Time/Period'
-import { RevenueModification } from '../Revenue/RevenueModification'
-import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
-import { Logger } from 'winston'
-
-describe('SubscriptionCancelledEventHandler', () => {
-  let event: SubscriptionCancelledEvent
-  let getUserAnalyticsId: GetUserAnalyticsId
-  let analyticsStore: AnalyticsStoreInterface
-  let statisticsStore: StatisticsStoreInterface
-  let saveRevenueModification: SaveRevenueModification
-  let logger: Logger
-
-  const createHandler = () =>
-    new SubscriptionCancelledEventHandler(
-      getUserAnalyticsId,
-      analyticsStore,
-      statisticsStore,
-      saveRevenueModification,
-      logger,
-    )
-
-  beforeEach(() => {
-    logger = {} as jest.Mocked<Logger>
-    logger.error = jest.fn()
-
-    getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
-    getUserAnalyticsId.execute = jest.fn().mockReturnValue({ analyticsId: 3 })
-
-    analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
-    analyticsStore.markActivity = jest.fn()
-
-    statisticsStore = {} as jest.Mocked<StatisticsStoreInterface>
-    statisticsStore.incrementMeasure = jest.fn()
-
-    event = {} as jest.Mocked<SubscriptionCancelledEvent>
-    event.createdAt = new Date(1)
-    event.type = 'SUBSCRIPTION_CANCELLED'
-    event.payload = {
-      subscriptionId: 1,
-      userEmail: 'test@test.com',
-      subscriptionName: SubscriptionName.ProPlan,
-      subscriptionCreatedAt: 1642395451515000,
-      subscriptionUpdatedAt: 1642395451515001,
-      lastPayedAt: 1642395451515001,
-      subscriptionEndsAt: 1642395451515000 + 10,
-      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 () => {
-    event.payload.timestamp = 1642395451516000
-
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalled()
-    expect(statisticsStore.incrementMeasure).toHaveBeenCalledWith(StatisticsMeasure.SubscriptionLength, 1000, [
-      Period.Today,
-      Period.ThisWeek,
-      Period.ThisMonth,
-    ])
-    expect(saveRevenueModification.execute).toHaveBeenCalled()
-  })
-
-  it('should not track statistics for subscriptions that are in a legacy 5 year plan', async () => {
-    event.payload.timestamp = 1642395451516000
-    event.payload.subscriptionEndsAt = 1642395451515000 + 126_230_400_000_001
-    event.payload.subscriptionCreatedAt = 1642395451515000
-
-    await createHandler().handle(event)
-
-    expect(statisticsStore.incrementMeasure).not.toHaveBeenCalled()
-    expect(saveRevenueModification.execute).toHaveBeenCalled()
-  })
-
-  it('should log failure to save revenue modification', async () => {
-    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.fail('Oops'))
-
-    event.payload.timestamp = 1642395451516000
-
-    await createHandler().handle(event)
-
-    expect(logger.error).toHaveBeenCalled()
-  })
-})

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

@@ -6,13 +6,13 @@ import { Username } from '@standardnotes/domain-core'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-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'
+import { StatisticMeasureName } from '../Statistics/StatisticMeasureName'
 
 @injectable()
 export class SubscriptionCancelledEventHandler implements DomainEventHandlerInterface {
@@ -58,7 +58,7 @@ export class SubscriptionCancelledEventHandler implements DomainEventHandlerInte
     }
 
     const subscriptionLength = event.payload.timestamp - event.payload.subscriptionCreatedAt
-    await this.statisticsStore.incrementMeasure(StatisticsMeasure.SubscriptionLength, subscriptionLength, [
+    await this.statisticsStore.incrementMeasure(StatisticMeasureName.NAMES.SubscriptionLength, subscriptionLength, [
       Period.Today,
       Period.ThisWeek,
       Period.ThisMonth,
@@ -70,7 +70,7 @@ export class SubscriptionCancelledEventHandler implements DomainEventHandlerInte
     const remainingSubscriptionPercentage = Math.floor((remainingSubscriptionTime / totalSubscriptionTime) * 100)
 
     await this.statisticsStore.incrementMeasure(
-      StatisticsMeasure.RemainingSubscriptionTimePercentage,
+      StatisticMeasureName.NAMES.RemainingSubscriptionTimePercentage,
       remainingSubscriptionPercentage,
       [Period.Today, Period.ThisWeek, Period.ThisMonth],
     )

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

@@ -1,79 +0,0 @@
-import 'reflect-metadata'
-
-import { SubscriptionName } from '@standardnotes/common'
-import { SubscriptionExpiredEvent } from '@standardnotes/domain-events'
-import { Result } from '@standardnotes/domain-core'
-
-import { SubscriptionExpiredEventHandler } from './SubscriptionExpiredEventHandler'
-import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
-import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
-import { RevenueModification } from '../Revenue/RevenueModification'
-import { Logger } from 'winston'
-
-describe('SubscriptionExpiredEventHandler', () => {
-  let event: SubscriptionExpiredEvent
-  let getUserAnalyticsId: GetUserAnalyticsId
-  let analyticsStore: AnalyticsStoreInterface
-  let statisticsStore: StatisticsStoreInterface
-  let saveRevenueModification: SaveRevenueModification
-  let logger: Logger
-
-  const createHandler = () =>
-    new SubscriptionExpiredEventHandler(
-      getUserAnalyticsId,
-      analyticsStore,
-      statisticsStore,
-      saveRevenueModification,
-      logger,
-    )
-
-  beforeEach(() => {
-    logger = {} as jest.Mocked<Logger>
-    logger.error = jest.fn()
-
-    event = {} as jest.Mocked<SubscriptionExpiredEvent>
-    event.createdAt = new Date(1)
-    event.type = 'SUBSCRIPTION_EXPIRED'
-    event.payload = {
-      subscriptionId: 1,
-      userEmail: 'test@test.com',
-      subscriptionName: SubscriptionName.PlusPlan,
-      timestamp: 1,
-      offline: false,
-      totalActiveSubscriptionsCount: 123,
-      userExistingSubscriptionsCount: 2,
-      billingFrequency: 1,
-      payAmount: 12.99,
-    }
-
-    getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
-    getUserAnalyticsId.execute = jest.fn().mockReturnValue({ analyticsId: 3 })
-
-    analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
-    analyticsStore.markActivity = jest.fn()
-
-    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 () => {
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalled()
-    expect(statisticsStore.setMeasure).toHaveBeenCalled()
-    expect(saveRevenueModification.execute).toHaveBeenCalled()
-  })
-
-  it('should log failure to save revenue modification', async () => {
-    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.fail('Oops'))
-
-    await createHandler().handle(event)
-
-    expect(logger.error).toHaveBeenCalled()
-  })
-})

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

@@ -6,7 +6,7 @@ import { Logger } from 'winston'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
+import { StatisticMeasureName } from '../Statistics/StatisticMeasureName'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
 import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
@@ -33,7 +33,7 @@ export class SubscriptionExpiredEventHandler implements DomainEventHandlerInterf
     )
 
     await this.statisticsStore.setMeasure(
-      StatisticsMeasure.TotalCustomers,
+      StatisticMeasureName.NAMES.TotalCustomers,
       event.payload.totalActiveSubscriptionsCount,
       [Period.Today, Period.ThisWeek, Period.ThisMonth, Period.ThisYear],
     )

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

@@ -1,102 +0,0 @@
-import 'reflect-metadata'
-
-import { SubscriptionName } from '@standardnotes/common'
-import { SubscriptionPurchasedEvent } from '@standardnotes/domain-events'
-import { Result } from '@standardnotes/domain-core'
-
-import { SubscriptionPurchasedEventHandler } from './SubscriptionPurchasedEventHandler'
-import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
-import { Period } from '../Time/Period'
-import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
-import { RevenueModification } from '../Revenue/RevenueModification'
-import { Logger } from 'winston'
-
-describe('SubscriptionPurchasedEventHandler', () => {
-  let event: SubscriptionPurchasedEvent
-  let subscriptionExpiresAt: number
-  let getUserAnalyticsId: GetUserAnalyticsId
-  let analyticsStore: AnalyticsStoreInterface
-  let statisticsStore: StatisticsStoreInterface
-  let saveRevenueModification: SaveRevenueModification
-  let logger: Logger
-
-  const createHandler = () =>
-    new SubscriptionPurchasedEventHandler(
-      getUserAnalyticsId,
-      analyticsStore,
-      statisticsStore,
-      saveRevenueModification,
-      logger,
-    )
-
-  beforeEach(() => {
-    logger = {} as jest.Mocked<Logger>
-    logger.error = jest.fn()
-
-    statisticsStore = {} as jest.Mocked<StatisticsStoreInterface>
-    statisticsStore.incrementMeasure = jest.fn()
-    statisticsStore.setMeasure = jest.fn()
-
-    event = {} as jest.Mocked<SubscriptionPurchasedEvent>
-    event.createdAt = new Date(1)
-    event.type = 'SUBSCRIPTION_PURCHASED'
-    event.payload = {
-      subscriptionId: 1,
-      userEmail: 'test@test.com',
-      subscriptionName: SubscriptionName.ProPlan,
-      subscriptionExpiresAt,
-      timestamp: 60,
-      offline: false,
-      discountCode: null,
-      limitedDiscountPurchased: false,
-      newSubscriber: true,
-      totalActiveSubscriptionsCount: 123,
-      userRegisteredAt: 23,
-      billingFrequency: 12,
-      payAmount: 29.99,
-    }
-
-    getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
-    getUserAnalyticsId.execute = jest.fn().mockReturnValue({ analyticsId: 3 })
-
-    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 () => {
-    event.payload.newSubscriber = false
-
-    await createHandler().handle(event)
-
-    expect(statisticsStore.incrementMeasure).not.toHaveBeenCalled()
-  })
-
-  it('should update analytics on limited discount offer purchasing', async () => {
-    event.payload.limitedDiscountPurchased = true
-
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalledWith(['limited-discount-offer-purchased'], 3, [Period.Today])
-  })
-
-  it('should log failure to save revenue modification', async () => {
-    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.fail('Oops'))
-
-    await createHandler().handle(event)
-
-    expect(logger.error).toHaveBeenCalled()
-  })
-})

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

@@ -6,7 +6,7 @@ import { Logger } from 'winston'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
+import { StatisticMeasureName } from '../Statistics/StatisticMeasureName'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
 import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
@@ -45,18 +45,18 @@ export class SubscriptionPurchasedEventHandler implements DomainEventHandlerInte
 
     if (event.payload.newSubscriber) {
       await this.statisticsStore.incrementMeasure(
-        StatisticsMeasure.RegistrationToSubscriptionTime,
+        StatisticMeasureName.NAMES.RegistrationToSubscriptionTime,
         event.payload.timestamp - event.payload.userRegisteredAt,
         [Period.Today, Period.ThisWeek, Period.ThisMonth],
       )
-      await this.statisticsStore.incrementMeasure(StatisticsMeasure.NewCustomers, 1, [
+      await this.statisticsStore.incrementMeasure(StatisticMeasureName.NAMES.NewCustomers, 1, [
         Period.Today,
         Period.ThisWeek,
         Period.ThisMonth,
         Period.ThisYear,
       ])
       await this.statisticsStore.setMeasure(
-        StatisticsMeasure.TotalCustomers,
+        StatisticMeasureName.NAMES.TotalCustomers,
         event.payload.totalActiveSubscriptionsCount,
         [Period.Today, Period.ThisWeek, Period.ThisMonth, Period.ThisYear],
       )

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

@@ -1,46 +0,0 @@
-import 'reflect-metadata'
-
-import { SubscriptionName } from '@standardnotes/common'
-import { SubscriptionReactivatedEvent } from '@standardnotes/domain-events'
-
-import { SubscriptionReactivatedEventHandler } from './SubscriptionReactivatedEventHandler'
-import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { Period } from '../Time/Period'
-
-describe('SubscriptionReactivatedEventHandler', () => {
-  let event: SubscriptionReactivatedEvent
-  let getUserAnalyticsId: GetUserAnalyticsId
-  let analyticsStore: AnalyticsStoreInterface
-
-  const createHandler = () => new SubscriptionReactivatedEventHandler(analyticsStore, getUserAnalyticsId)
-
-  beforeEach(() => {
-    event = {} as jest.Mocked<SubscriptionReactivatedEvent>
-    event.createdAt = new Date(1)
-    event.payload = {
-      previousSubscriptionId: 1,
-      currentSubscriptionId: 2,
-      userEmail: 'test@test.com',
-      subscriptionName: SubscriptionName.PlusPlan,
-      subscriptionExpiresAt: 5,
-      discountCode: 'exit-20',
-    }
-
-    getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
-    getUserAnalyticsId.execute = jest.fn().mockReturnValue({ analyticsId: 3 })
-
-    analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
-    analyticsStore.markActivity = jest.fn()
-  })
-
-  it('should mark subscription reactivated activity for analytics', async () => {
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalledWith(['subscription-reactivated'], 3, [
-      Period.Today,
-      Period.ThisWeek,
-      Period.ThisMonth,
-    ])
-  })
-})

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

@@ -1,110 +0,0 @@
-import 'reflect-metadata'
-
-import { SubscriptionName } from '@standardnotes/common'
-import { SubscriptionRefundedEvent } from '@standardnotes/domain-events'
-import { Result } from '@standardnotes/domain-core'
-
-import { GetUserAnalyticsId } from '../UseCase/GetUserAnalyticsId/GetUserAnalyticsId'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-
-import { SubscriptionRefundedEventHandler } from './SubscriptionRefundedEventHandler'
-import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
-import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
-import { Period } from '../Time/Period'
-import { RevenueModification } from '../Revenue/RevenueModification'
-import { SaveRevenueModification } from '../UseCase/SaveRevenueModification/SaveRevenueModification'
-import { Logger } from 'winston'
-
-describe('SubscriptionRefundedEventHandler', () => {
-  let event: SubscriptionRefundedEvent
-  let getUserAnalyticsId: GetUserAnalyticsId
-  let analyticsStore: AnalyticsStoreInterface
-  let statisticsStore: StatisticsStoreInterface
-  let saveRevenueModification: SaveRevenueModification
-  let logger: Logger
-
-  const createHandler = () =>
-    new SubscriptionRefundedEventHandler(
-      getUserAnalyticsId,
-      analyticsStore,
-      statisticsStore,
-      saveRevenueModification,
-      logger,
-    )
-
-  beforeEach(() => {
-    logger = {} as jest.Mocked<Logger>
-    logger.error = jest.fn()
-
-    event = {} as jest.Mocked<SubscriptionRefundedEvent>
-    event.createdAt = new Date(1)
-    event.type = 'SUBSCRIPTION_REFUNDED'
-    event.payload = {
-      subscriptionId: 1,
-      userEmail: 'test@test.com',
-      subscriptionName: SubscriptionName.PlusPlan,
-      timestamp: 1,
-      offline: false,
-      userExistingSubscriptionsCount: 3,
-      totalActiveSubscriptionsCount: 1,
-      billingFrequency: 1,
-      payAmount: 12.99,
-    }
-
-    getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
-    getUserAnalyticsId.execute = jest.fn().mockReturnValue({ analyticsId: 3 })
-
-    analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
-    analyticsStore.markActivity = jest.fn()
-    analyticsStore.wasActivityDone = jest.fn().mockReturnValue(true)
-
-    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 () => {
-    event.payload.userExistingSubscriptionsCount = 1
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalledWith([AnalyticsActivity.SubscriptionRefunded], 3, [
-      Period.Today,
-      Period.ThisWeek,
-      Period.ThisMonth,
-    ])
-
-    expect(analyticsStore.markActivity).toHaveBeenCalledWith([AnalyticsActivity.NewCustomersChurn], 3, [
-      Period.ThisMonth,
-    ])
-
-    expect(saveRevenueModification.execute).toHaveBeenCalled()
-  })
-
-  it('should mark churn for existing customer', async () => {
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalledWith([AnalyticsActivity.ExistingCustomersChurn], 3, [
-      Period.ThisMonth,
-    ])
-  })
-
-  it('should not mark churn if customer did not purchase subscription in defined analytic periods', async () => {
-    analyticsStore.wasActivityDone = jest.fn().mockReturnValue(false)
-
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).not.toHaveBeenCalledWith([AnalyticsActivity.ExistingCustomersChurn], 3, [
-      Period.ThisMonth,
-    ])
-  })
-
-  it('should log failure to save revenue modification', async () => {
-    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.fail('Oops'))
-
-    await createHandler().handle(event)
-
-    expect(logger.error).toHaveBeenCalled()
-  })
-})

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

@@ -6,7 +6,7 @@ import { Logger } from 'winston'
 import TYPES from '../../Bootstrap/Types'
 import { AnalyticsActivity } from '../Analytics/AnalyticsActivity'
 import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { StatisticsMeasure } from '../Statistics/StatisticsMeasure'
+import { StatisticMeasureName } from '../Statistics/StatisticMeasureName'
 import { StatisticsStoreInterface } from '../Statistics/StatisticsStoreInterface'
 import { SubscriptionEventType } from '../Subscription/SubscriptionEventType'
 import { SubscriptionPlanName } from '../Subscription/SubscriptionPlanName'
@@ -70,7 +70,7 @@ export class SubscriptionRefundedEventHandler implements DomainEventHandlerInter
     }
 
     await this.statisticsStore.setMeasure(
-      StatisticsMeasure.TotalCustomers,
+      StatisticMeasureName.NAMES.TotalCustomers,
       event.payload.totalActiveSubscriptionsCount,
       [Period.Today, Period.ThisWeek, Period.ThisMonth, Period.ThisYear],
     )

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

@@ -1,68 +0,0 @@
-import 'reflect-metadata'
-
-import { SubscriptionName } from '@standardnotes/common'
-import { SubscriptionRenewedEvent } from '@standardnotes/domain-events'
-import { Result } from '@standardnotes/domain-core'
-
-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 { Logger } from 'winston'
-
-describe('SubscriptionRenewedEventHandler', () => {
-  let event: SubscriptionRenewedEvent
-  let getUserAnalyticsId: GetUserAnalyticsId
-  let analyticsStore: AnalyticsStoreInterface
-  let saveRevenueModification: SaveRevenueModification
-  let logger: Logger
-
-  const createHandler = () =>
-    new SubscriptionRenewedEventHandler(getUserAnalyticsId, analyticsStore, saveRevenueModification, logger)
-
-  beforeEach(() => {
-    logger = {} as jest.Mocked<Logger>
-    logger.error = jest.fn()
-
-    event = {} as jest.Mocked<SubscriptionRenewedEvent>
-    event.createdAt = new Date(1)
-    event.type = 'SUBSCRIPTION_RENEWED'
-    event.payload = {
-      subscriptionId: 1,
-      userEmail: 'test@test.com',
-      subscriptionName: SubscriptionName.ProPlan,
-      subscriptionExpiresAt: 2,
-      timestamp: 1,
-      offline: false,
-      billingFrequency: 1,
-      payAmount: 12.99,
-    }
-
-    getUserAnalyticsId = {} as jest.Mocked<GetUserAnalyticsId>
-    getUserAnalyticsId.execute = jest.fn().mockReturnValue({ analyticsId: 3 })
-
-    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 () => {
-    await createHandler().handle(event)
-
-    expect(analyticsStore.markActivity).toHaveBeenCalled()
-    expect(analyticsStore.unmarkActivity).toHaveBeenCalled()
-    expect(saveRevenueModification.execute).toHaveBeenCalled()
-  })
-
-  it('should log failure to save revenue modification', async () => {
-    saveRevenueModification.execute = jest.fn().mockReturnValue(Result.fail('Oops'))
-
-    await createHandler().handle(event)
-
-    expect(logger.error).toHaveBeenCalled()
-  })
-})

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

@@ -1,47 +0,0 @@
-import 'reflect-metadata'
-
-import { UserRegisteredEvent } from '@standardnotes/domain-events'
-import { ProtocolVersion } from '@standardnotes/common'
-
-import { UserRegisteredEventHandler } from './UserRegisteredEventHandler'
-import { AnalyticsEntityRepositoryInterface } from '../Entity/AnalyticsEntityRepositoryInterface'
-import { AnalyticsStoreInterface } from '../Analytics/AnalyticsStoreInterface'
-import { Period } from '../Time/Period'
-
-describe('UserRegisteredEventHandler', () => {
-  let analyticsEntityRepository: AnalyticsEntityRepositoryInterface
-  let event: UserRegisteredEvent
-  let analyticsStore: AnalyticsStoreInterface
-
-  const createHandler = () => new UserRegisteredEventHandler(analyticsEntityRepository, analyticsStore)
-
-  beforeEach(() => {
-    event = {} as jest.Mocked<UserRegisteredEvent>
-    event.createdAt = new Date(1)
-    event.payload = {
-      userUuid: '1-2-3',
-      email: 'test@test.te',
-      protocolVersion: ProtocolVersion.V004,
-    }
-
-    analyticsStore = {} as jest.Mocked<AnalyticsStoreInterface>
-    analyticsStore.markActivity = jest.fn()
-
-    analyticsEntityRepository = {} as jest.Mocked<AnalyticsEntityRepositoryInterface>
-    analyticsEntityRepository.save = jest.fn().mockImplementation((entity) => ({
-      ...entity,
-      id: 1,
-    }))
-  })
-
-  it('should save analytics entity upon user registration', async () => {
-    await createHandler().handle(event)
-
-    expect(analyticsEntityRepository.save).toHaveBeenCalled()
-    expect(analyticsStore.markActivity).toHaveBeenCalledWith(['register'], 1, [
-      Period.Today,
-      Period.ThisWeek,
-      Period.ThisMonth,
-    ])
-  })
-})

packages/analytics/src/Domain/Statistics/StatisticMeasure.ts

@@ -0,0 +1,25 @@
+import { Result, Entity, UniqueEntityId } from '@standardnotes/domain-core'
+
+import { StatisticMeasureProps } from './StatisticMeasureProps'
+
+export class StatisticMeasure extends Entity<StatisticMeasureProps> {
+  get id(): UniqueEntityId {
+    return this._id
+  }
+
+  get name(): string {
+    return this.props.name.value
+  }
+
+  get value(): number {
+    return this.props.value
+  }
+
+  private constructor(props: StatisticMeasureProps, id?: UniqueEntityId) {
+    super(props, id)
+  }
+
+  static create(props: StatisticMeasureProps, id?: UniqueEntityId): Result<StatisticMeasure> {
+    return Result.ok<StatisticMeasure>(new StatisticMeasure(props, id))
+  }
+}

packages/analytics/src/Domain/Statistics/StatisticMeasureName.spec.ts

@@ -0,0 +1,18 @@
+import { StatisticMeasureName } from './StatisticMeasureName'
+
+describe('StatisticMeasureName', () => {
+  it('should create a value object', () => {
+    const valueOrError = StatisticMeasureName.create('pro-subscription-initial-monthly-payments-income')
+
+    expect(valueOrError.isFailed()).toBeFalsy()
+    expect(valueOrError.getValue().value).toEqual('pro-subscription-initial-monthly-payments-income')
+  })
+
+  it('should not create an invalid value object', () => {
+    for (const value of ['', undefined, null, 0, 'foobar']) {
+      const valueOrError = StatisticMeasureName.create(value as string)
+
+      expect(valueOrError.isFailed()).toBeTruthy()
+    }
+  })
+})

packages/analytics/src/Domain/Statistics/StatisticMeasureName.ts

@@ -0,0 +1,51 @@
+import { ValueObject, Result } from '@standardnotes/domain-core'
+
+import { StatisticMeasureNameProps } from './StatisticMeasureNameProps'
+
+export class StatisticMeasureName extends ValueObject<StatisticMeasureNameProps> {
+  static readonly NAMES = {
+    Income: 'income',
+    PlusSubscriptionInitialMonthlyPaymentsIncome: 'plus-subscription-initial-monthly-payments-income',
+    ProSubscriptionInitialMonthlyPaymentsIncome: 'pro-subscription-initial-monthly-payments-income',
+    PlusSubscriptionInitialAnnualPaymentsIncome: 'plus-subscription-initial-annual-payments-income',
+    ProSubscriptionInitialAnnualPaymentsIncome: 'pro-subscription-initial-annual-payments-income',
+    PlusSubscriptionRenewingMonthlyPaymentsIncome: 'plus-subscription-renewing-monthly-payments-income',
+    ProSubscriptionRenewingMonthlyPaymentsIncome: 'pro-subscription-renewing-monthly-payments-income',
+    PlusSubscriptionRenewingAnnualPaymentsIncome: 'plus-subscription-renewing-annual-payments-income',
+    ProSubscriptionRenewingAnnualPaymentsIncome: 'pro-subscription-renewing-annual-payments-income',
+    SubscriptionLength: 'subscription-length',
+    RegistrationLength: 'registration-length',
+    RegistrationToSubscriptionTime: 'registration-to-subscription-time',
+    RemainingSubscriptionTimePercentage: 'remaining-subscription-time-percentage',
+    Refunds: 'refunds',
+    NewCustomers: 'new-customers',
+    TotalCustomers: 'total-customers',
+    MRR: 'mrr',
+    MonthlyPlansMRR: 'monthly-plans-mrr',
+    AnnualPlansMRR: 'annual-plans-mrr',
+    FiveYearPlansMRR: 'five-year-plans-mrr',
+    ProPlansMRR: 'pro-plans-mrr',
+    PlusPlansMRR: 'plus-plans-mrr',
+    ActiveUsers: 'active-users',
+    ActiveProUsers: 'active-pro-users',
+    ActivePlusUsers: 'active-plus-users',
+    ActiveFreeUsers: 'active-free-users',
+  }
+
+  get value(): string {
+    return this.props.value
+  }
+
+  private constructor(props: StatisticMeasureNameProps) {
+    super(props)
+  }
+
+  static create(name: string): Result<StatisticMeasureName> {
+    const isValidName = Object.values(this.NAMES).includes(name)
+    if (!isValidName) {
+      return Result.fail<StatisticMeasureName>(`Invalid statistics measure name: ${name}`)
+    } else {
+      return Result.ok<StatisticMeasureName>(new StatisticMeasureName({ value: name }))
+    }
+  }
+}

packages/analytics/src/Domain/Statistics/StatisticMeasureNameProps.ts

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

packages/analytics/src/Domain/Statistics/StatisticMeasureProps.ts

@@ -0,0 +1,7 @@
+import { StatisticMeasureName } from './StatisticMeasureName'
+
+export interface StatisticMeasureProps {
+  name: StatisticMeasureName
+  value: number
+  date: Date
+}

packages/analytics/src/Domain/Statistics/StatisticMeasureRepositoryInterface.ts

@@ -0,0 +1,5 @@
+import { StatisticMeasure } from './StatisticMeasure'
+
+export interface StatisticMeasureRepositoryInterface {
+  save(statisticMeasure: StatisticMeasure): Promise<void>
+}

packages/analytics/src/Domain/Statistics/StatisticsMeasure.ts

@@ -1,24 +0,0 @@
-export enum StatisticsMeasure {
-  Income = 'income',
-  PlusSubscriptionInitialMonthlyPaymentsIncome = 'plus-subscription-initial-monthly-payments-income',
-  ProSubscriptionInitialMonthlyPaymentsIncome = 'pro-subscription-initial-monthly-payments-income',
-  PlusSubscriptionInitialAnnualPaymentsIncome = 'plus-subscription-initial-annual-payments-income',
-  ProSubscriptionInitialAnnualPaymentsIncome = 'pro-subscription-initial-annual-payments-income',
-  PlusSubscriptionRenewingMonthlyPaymentsIncome = 'plus-subscription-renewing-monthly-payments-income',
-  ProSubscriptionRenewingMonthlyPaymentsIncome = 'pro-subscription-renewing-monthly-payments-income',
-  PlusSubscriptionRenewingAnnualPaymentsIncome = 'plus-subscription-renewing-annual-payments-income',
-  ProSubscriptionRenewingAnnualPaymentsIncome = 'pro-subscription-renewing-annual-payments-income',
-  SubscriptionLength = 'subscription-length',
-  RegistrationLength = 'registration-length',
-  RegistrationToSubscriptionTime = 'registration-to-subscription-time',
-  RemainingSubscriptionTimePercentage = 'remaining-subscription-time-percentage',
-  Refunds = 'refunds',
-  NewCustomers = 'new-customers',
-  TotalCustomers = 'total-customers',
-  MRR = 'mrr',
-  MonthlyPlansMRR = 'monthly-plans-mrr',
-  AnnualPlansMRR = 'annual-plans-mrr',
-  FiveYearPlansMRR = 'five-year-plans-mrr',
-  ProPlansMRR = 'pro-plans-mrr',
-  PlusPlansMRR = 'plus-plans-mrr',
-}

packages/analytics/src/Domain/Statistics/StatisticsStoreInterface.ts

@@ -1,5 +1,4 @@
 import { Period } from '../Time/Period'
-import { StatisticsMeasure } from './StatisticsMeasure'
 
 export interface StatisticsStoreInterface {
   incrementSNJSVersionUsage(snjsVersion: string): Promise<void>
@@ -8,13 +7,13 @@ export interface StatisticsStoreInterface {
   getYesterdaySNJSUsage(): Promise<Array<{ version: string; count: number }>>
   getYesterdayApplicationUsage(): Promise<Array<{ version: string; count: number }>>
   getYesterdayOutOfSyncIncidents(): Promise<number>
-  incrementMeasure(measure: StatisticsMeasure, value: number, periods: Period[]): Promise<void>
-  setMeasure(measure: StatisticsMeasure, value: number, periods: Period[]): Promise<void>
-  getMeasureAverage(measure: StatisticsMeasure, period: Period): Promise<number>
-  getMeasureTotal(measure: StatisticsMeasure, periodOrPeriodKey: Period | string): Promise<number>
-  getMeasureIncrementCounts(measure: StatisticsMeasure, period: Period): Promise<number>
+  incrementMeasure(measure: string, value: number, periods: Period[]): Promise<void>
+  setMeasure(measure: string, value: number, periods: Period[]): Promise<void>
+  getMeasureAverage(measure: string, period: Period): Promise<number>
+  getMeasureTotal(measure: string, periodOrPeriodKey: Period | string): Promise<number>
+  getMeasureIncrementCounts(measure: string, period: Period): Promise<number>
   calculateTotalCountOverPeriod(
-    measure: StatisticsMeasure,
+    measure: string,
     period: Period,
   ): Promise<Array<{ periodKey: string; totalCount: number }>>
 }

packages/analytics/src/Domain/Time/PeriodKeyGenerator.ts

@@ -137,7 +137,7 @@ export class PeriodKeyGenerator implements PeriodKeyGeneratorInterface {
     return `${this.getYear(date)}-${this.getMonth(date)}`
   }
 
-  private getDailyKey(date?: Date): string {
+  getDailyKey(date?: Date): string {
     date = date ?? new Date()
 
     return `${this.getYear(date)}-${this.getMonth(date)}-${this.getDayOfTheMonth(date)}`

packages/analytics/src/Domain/Time/PeriodKeyGeneratorInterface.ts

@@ -2,6 +2,7 @@ import { Period } from './Period'
 
 export interface PeriodKeyGeneratorInterface {
   getPeriodKey(period: Period): string
+  getDailyKey(date?: Date): string
   convertPeriodKeyToPeriod(periodKey: string): Period
   getDiscretePeriodKeys(period: Period): string[]
 }

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

@@ -1,7 +1,7 @@
 import 'reflect-metadata'
 
 import { RevenueModificationRepositoryInterface } from '../../Revenue/RevenueModificationRepositoryInterface'
-import { StatisticsMeasure } from '../../Statistics/StatisticsMeasure'
+import { StatisticMeasureName } from '../../Statistics/StatisticMeasureName'
 import { StatisticsStoreInterface } from '../../Statistics/StatisticsStoreInterface'
 import { Period } from '../../Time/Period'
 
@@ -24,7 +24,7 @@ describe('CalculateMonthlyRecurringRevenue', () => {
   it('should calculate the MRR diff and persist it as a statistic', async () => {
     await createUseCase().execute({})
 
-    expect(statisticsStore.setMeasure).toHaveBeenCalledWith(StatisticsMeasure.MRR, 123.45, [
+    expect(statisticsStore.setMeasure).toHaveBeenCalledWith(StatisticMeasureName.NAMES.MRR, 123.45, [
       Period.Today,
       Period.ThisMonth,
       Period.ThisYear,

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

@@ -5,11 +5,11 @@ import { Result } from '@standardnotes/domain-core'
 import TYPES from '../../../Bootstrap/Types'
 import { MonthlyRevenue } from '../../Revenue/MonthlyRevenue'
 import { RevenueModificationRepositoryInterface } from '../../Revenue/RevenueModificationRepositoryInterface'
-import { StatisticsMeasure } from '../../Statistics/StatisticsMeasure'
 import { StatisticsStoreInterface } from '../../Statistics/StatisticsStoreInterface'
 import { Period } from '../../Time/Period'
 import { DomainUseCaseInterface } from '../DomainUseCaseInterface'
 import { CalculateMonthlyRecurringRevenueDTO } from './CalculateMonthlyRecurringRevenueDTO'
+import { StatisticMeasureName } from '../../Statistics/StatisticMeasureName'
 
 @injectable()
 export class CalculateMonthlyRecurringRevenue implements DomainUseCaseInterface<MonthlyRevenue> {
@@ -24,7 +24,7 @@ export class CalculateMonthlyRecurringRevenue implements DomainUseCaseInterface<
       billingFrequencies: [SubscriptionBillingFrequency.Annual, SubscriptionBillingFrequency.Monthly],
     })
 
-    await this.statisticsStore.setMeasure(StatisticsMeasure.MRR, mrrDiff, [
+    await this.statisticsStore.setMeasure(StatisticMeasureName.NAMES.MRR, mrrDiff, [
       Period.Today,
       Period.ThisMonth,
       Period.ThisYear,
@@ -34,7 +34,7 @@ export class CalculateMonthlyRecurringRevenue implements DomainUseCaseInterface<
       billingFrequencies: [SubscriptionBillingFrequency.Monthly],
     })
 
-    await this.statisticsStore.setMeasure(StatisticsMeasure.MonthlyPlansMRR, monthlyPlansMrrDiff, [
+    await this.statisticsStore.setMeasure(StatisticMeasureName.NAMES.MonthlyPlansMRR, monthlyPlansMrrDiff, [
       Period.Today,
       Period.ThisMonth,
       Period.ThisYear,
@@ -44,7 +44,7 @@ export class CalculateMonthlyRecurringRevenue implements DomainUseCaseInterface<
       billingFrequencies: [SubscriptionBillingFrequency.Annual],
     })
 
-    await this.statisticsStore.setMeasure(StatisticsMeasure.AnnualPlansMRR, annualPlansMrrDiff, [
+    await this.statisticsStore.setMeasure(StatisticMeasureName.NAMES.AnnualPlansMRR, annualPlansMrrDiff, [
       Period.Today,
       Period.ThisMonth,
       Period.ThisYear,
@@ -54,7 +54,7 @@ export class CalculateMonthlyRecurringRevenue implements DomainUseCaseInterface<
       billingFrequencies: [SubscriptionBillingFrequency.FiveYear],
     })
 
-    await this.statisticsStore.setMeasure(StatisticsMeasure.FiveYearPlansMRR, fiveYearPlansMrrDiff, [
+    await this.statisticsStore.setMeasure(StatisticMeasureName.NAMES.FiveYearPlansMRR, fiveYearPlansMrrDiff, [
       Period.Today,
       Period.ThisMonth,
       Period.ThisYear,
@@ -65,7 +65,7 @@ export class CalculateMonthlyRecurringRevenue implements DomainUseCaseInterface<
       billingFrequencies: [SubscriptionBillingFrequency.Annual, SubscriptionBillingFrequency.Monthly],
     })
 
-    await this.statisticsStore.setMeasure(StatisticsMeasure.ProPlansMRR, proPlansMrrDiff, [
+    await this.statisticsStore.setMeasure(StatisticMeasureName.NAMES.ProPlansMRR, proPlansMrrDiff, [
       Period.Today,
       Period.ThisMonth,
       Period.ThisYear,
@@ -76,7 +76,7 @@ export class CalculateMonthlyRecurringRevenue implements DomainUseCaseInterface<
       billingFrequencies: [SubscriptionBillingFrequency.Annual, SubscriptionBillingFrequency.Monthly],
     })
 
-    await this.statisticsStore.setMeasure(StatisticsMeasure.PlusPlansMRR, plusPlansMrrDiff, [
+    await this.statisticsStore.setMeasure(StatisticMeasureName.NAMES.PlusPlansMRR, plusPlansMrrDiff, [
       Period.Today,
       Period.ThisMonth,
       Period.ThisYear,

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

@@ -0,0 +1,31 @@
+import { Result, UseCaseInterface } from '@standardnotes/domain-core'
+
+import { StatisticMeasure } from '../../Statistics/StatisticMeasure'
+import { StatisticMeasureName } from '../../Statistics/StatisticMeasureName'
+import { StatisticMeasureRepositoryInterface } from '../../Statistics/StatisticMeasureRepositoryInterface'
+import { PersistStatisticDTO } from './PersistStatisticDTO'
+
+export class PersistStatistic implements UseCaseInterface<StatisticMeasure> {
+  constructor(private statisticMeasureRepository: StatisticMeasureRepositoryInterface) {}
+
+  async execute(dto: PersistStatisticDTO): Promise<Result<StatisticMeasure>> {
+    const statisticMeasureNameOrError = StatisticMeasureName.create(dto.statisticMeasureName)
+    if (statisticMeasureNameOrError.isFailed()) {
+      return Result.fail(`Could not persist statistic measure: ${statisticMeasureNameOrError.getError()}`)
+    }
+
+    const statisticMeasureOrError = StatisticMeasure.create({
+      date: dto.date,
+      name: statisticMeasureNameOrError.getValue(),
+      value: dto.value,
+    })
+    if (statisticMeasureOrError.isFailed()) {
+      return Result.fail(`Could not persist statistic measure: ${statisticMeasureOrError.getError()}`)
+    }
+    const statisticMeasure = statisticMeasureOrError.getValue()
+
+    await this.statisticMeasureRepository.save(statisticMeasure)
+
+    return Result.ok(statisticMeasure)
+  }
+}

packages/analytics/src/Domain/UseCase/PersistStatistic/PersistStatisticDTO.ts

@@ -0,0 +1,5 @@
+export interface PersistStatisticDTO {
+  statisticMeasureName: string
+  value: number
+  date: Date
+}

packages/analytics/src/Infra/Redis/RedisStatisticsStore.ts

@@ -1,16 +1,23 @@
 import * as IORedis from 'ioredis'
 
-import { StatisticsMeasure } from '../../Domain/Statistics/StatisticsMeasure'
+import { StatisticMeasure } from '../../Domain/Statistics/StatisticMeasure'
+import { StatisticMeasureRepositoryInterface } from '../../Domain/Statistics/StatisticMeasureRepositoryInterface'
 
 import { StatisticsStoreInterface } from '../../Domain/Statistics/StatisticsStoreInterface'
 import { Period } from '../../Domain/Time/Period'
 import { PeriodKeyGeneratorInterface } from '../../Domain/Time/PeriodKeyGeneratorInterface'
 
-export class RedisStatisticsStore implements StatisticsStoreInterface {
+export class RedisStatisticsStore implements StatisticsStoreInterface, StatisticMeasureRepositoryInterface {
   constructor(private periodKeyGenerator: PeriodKeyGeneratorInterface, private redisClient: IORedis.Redis) {}
 
+  async save(statisticMeasure: StatisticMeasure): Promise<void> {
+    const periodKey = this.periodKeyGenerator.getDailyKey(statisticMeasure.props.date)
+
+    await this.setMeasure(statisticMeasure.name, statisticMeasure.value, [periodKey])
+  }
+
   async calculateTotalCountOverPeriod(
-    measure: StatisticsMeasure,
+    measure: string,
     period: Period,
   ): Promise<{ periodKey: string; totalCount: number }[]> {
     if (
@@ -38,7 +45,7 @@ export class RedisStatisticsStore implements StatisticsStoreInterface {
     return counts
   }
 
-  async getMeasureIncrementCounts(measure: StatisticsMeasure, period: Period): Promise<number> {
+  async getMeasureIncrementCounts(measure: string, period: Period): Promise<number> {
     const increments = await this.redisClient.get(
       `count:increments:${measure}:timespan:${this.periodKeyGenerator.getPeriodKey(period)}`,
     )
@@ -49,17 +56,22 @@ export class RedisStatisticsStore implements StatisticsStoreInterface {
     return +increments
   }
 
-  async setMeasure(measure: StatisticsMeasure, value: number, periods: Period[]): Promise<void> {
+  async setMeasure(measure: string, value: number, periodsOrPeriodKeys: Period[] | string[]): Promise<void> {
     const pipeline = this.redisClient.pipeline()
 
-    for (const period of periods) {
-      pipeline.set(`count:measure:${measure}:timespan:${this.periodKeyGenerator.getPeriodKey(period)}`, value)
+    for (const periodOrPeriodKey of periodsOrPeriodKeys) {
+      let periodKey = periodOrPeriodKey
+      if (!isNaN(+periodOrPeriodKey)) {
+        periodKey = this.periodKeyGenerator.getPeriodKey(periodOrPeriodKey as Period)
+      }
+
+      pipeline.set(`count:measure:${measure}:timespan:${periodKey}`, value)
     }
 
     await pipeline.exec()
   }
 
-  async getMeasureTotal(measure: StatisticsMeasure, periodOrPeriodKey: Period | string): Promise<number> {
+  async getMeasureTotal(measure: string, periodOrPeriodKey: Period | string): Promise<number> {
     let periodKey = periodOrPeriodKey
     if (!isNaN(+periodOrPeriodKey)) {
       periodKey = this.periodKeyGenerator.getPeriodKey(periodOrPeriodKey as Period)
@@ -74,7 +86,7 @@ export class RedisStatisticsStore implements StatisticsStoreInterface {
     return +totalValue
   }
 
-  async incrementMeasure(measure: StatisticsMeasure, value: number, periods: Period[]): Promise<void> {
+  async incrementMeasure(measure: string, value: number, periods: Period[]): Promise<void> {
     const pipeline = this.redisClient.pipeline()
 
     for (const period of periods) {
@@ -85,7 +97,7 @@ export class RedisStatisticsStore implements StatisticsStoreInterface {
     await pipeline.exec()
   }
 
-  async getMeasureAverage(measure: StatisticsMeasure, period: Period): Promise<number> {
+  async getMeasureAverage(measure: string, period: Period): Promise<number> {
     const increments = await this.getMeasureIncrementCounts(measure, period)
 
     if (increments === 0) {

packages/api-gateway/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.41.1](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.41.0...@standardnotes/api-gateway@1.41.1) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/api-gateway
+
 # [1.41.0](https://github.com/standardnotes/api-gateway/compare/@standardnotes/api-gateway@1.40.2...@standardnotes/api-gateway@1.41.0) (2022-12-19)
 
 ### Features

packages/api-gateway/package.json

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

packages/auth/CHANGELOG.md

@@ -3,6 +3,40 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.70.3](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.70.2...@standardnotes/auth-server@1.70.3) (2022-12-20)
+
+### Bug Fixes
+
+* **auth:** add persisting statistics for all subscription plans ([addedb3](https://github.com/standardnotes/server/commit/addedb3091ddae81618d56663e18f2ae76a43c4e))
+
+## [1.70.2](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.70.1...@standardnotes/auth-server@1.70.2) (2022-12-20)
+
+### Bug Fixes
+
+* **auth:** docker command ([85d2f42](https://github.com/standardnotes/server/commit/85d2f42f473110e8dfca975bfecc7a56823bdef4))
+
+## [1.70.1](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.70.0...@standardnotes/auth-server@1.70.1) (2022-12-20)
+
+### Bug Fixes
+
+* **auth:** saving subscription plan name in session traces ([3064d03](https://github.com/standardnotes/server/commit/3064d03aa9a2ac9ca3acfff30480ea8629faeb14))
+
+# [1.70.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.69.1...@standardnotes/auth-server@1.70.0) (2022-12-19)
+
+### Features
+
+* **auth:** add requesting persisting statistics ([a35271f](https://github.com/standardnotes/server/commit/a35271fbb399b68a3ac7021395d8063707fba222))
+
+## [1.69.1](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.69.0...@standardnotes/auth-server@1.69.1) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/auth-server
+
+# [1.69.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.68.0...@standardnotes/auth-server@1.69.0) (2022-12-19)
+
+### Features
+
+* **auth:** add session traces cleanup procedure ([147d8fd](https://github.com/standardnotes/server/commit/147d8fd9af89d2b97cd68eefac36e53d14d511bf))
+
 # [1.68.0](https://github.com/standardnotes/server/compare/@standardnotes/auth-server@1.67.3...@standardnotes/auth-server@1.68.0) (2022-12-19)
 
 ### Features

packages/auth/bin/cleanup.ts

@@ -0,0 +1,38 @@
+import 'reflect-metadata'
+
+import 'newrelic'
+
+import { Logger } from 'winston'
+
+import { ContainerConfigLoader } from '../src/Bootstrap/Container'
+import TYPES from '../src/Bootstrap/Types'
+import { Env } from '../src/Bootstrap/Env'
+import { CleanupSessionTraces } from '../src/Domain/UseCase/CleanupSessionTraces/CleanupSessionTraces'
+
+const container = new ContainerConfigLoader()
+void container.load().then((container) => {
+  const env: Env = new Env()
+  env.load()
+
+  const logger: Logger = container.get(TYPES.Logger)
+
+  logger.info('Starting session traces cleanup')
+
+  const cleanupSessionTraces: CleanupSessionTraces = container.get(TYPES.CleanupSessionTraces)
+
+  Promise.resolve(
+    cleanupSessionTraces.execute({
+      date: new Date(),
+    }),
+  )
+    .then(() => {
+      logger.info('Expired session traces cleaned.')
+
+      process.exit(0)
+    })
+    .catch((error) => {
+      logger.error(`Could not clean session traces: ${error.message}`)
+
+      process.exit(1)
+    })
+})

packages/auth/bin/stats.ts

@@ -0,0 +1,40 @@
+import 'reflect-metadata'
+
+import 'newrelic'
+
+import { Logger } from 'winston'
+import { TimerInterface } from '@standardnotes/time'
+
+import { ContainerConfigLoader } from '../src/Bootstrap/Container'
+import TYPES from '../src/Bootstrap/Types'
+import { Env } from '../src/Bootstrap/Env'
+import { PersistStatistics } from '../src/Domain/UseCase/PersistStatistics/PersistStatistics'
+
+const container = new ContainerConfigLoader()
+void container.load().then((container) => {
+  const env: Env = new Env()
+  env.load()
+
+  const logger: Logger = container.get(TYPES.Logger)
+
+  logger.info('Starting session traces cleanup')
+
+  const persistStats: PersistStatistics = container.get(TYPES.PersistStatistics)
+  const timer: TimerInterface = container.get(TYPES.Timer)
+
+  Promise.resolve(
+    persistStats.execute({
+      sessionsInADay: timer.getUTCDateNDaysAgo(1),
+    }),
+  )
+    .then(() => {
+      logger.info('Stats persisted.')
+
+      process.exit(0)
+    })
+    .catch((error) => {
+      logger.error(`Could not persist stats: ${error.message}`)
+
+      process.exit(1)
+    })
+})

packages/auth/docker/entrypoint.sh

@@ -19,6 +19,16 @@ case "$COMMAND" in
     yarn workspace @standardnotes/auth-server worker
     ;;
 
+  'cleanup' )
+    echo "[Docker] Starting Cleanup..."
+    yarn workspace @standardnotes/auth-server cleanup
+    ;;
+
+  'stats' )
+    echo "[Docker] Starting Persisting Stats..."
+    yarn workspace @standardnotes/auth-server stats
+    ;;
+
   'email-daily-backup' )
     echo "[Docker] Starting Email Daily Backup..."
     yarn workspace @standardnotes/auth-server daily-backup:email

packages/auth/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/auth-server",
-  "version": "1.68.0",
+  "version": "1.70.3",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },
@@ -19,6 +19,8 @@
     "test": "jest --coverage --config=./jest.config.js --maxWorkers=50%",
     "start": "yarn node dist/bin/server.js",
     "worker": "yarn node dist/bin/worker.js",
+    "cleanup": "yarn node dist/bin/cleanup.js",
+    "stats": "yarn node dist/bin/stats.js",
     "daily-backup:email": "yarn node dist/bin/backup.js email daily",
     "user-email-backup": "yarn node dist/bin/user_email_backup.js",
     "daily-backup:dropbox": "yarn node dist/bin/backup.js dropbox daily",

packages/auth/src/Bootstrap/Container.ts

@@ -201,6 +201,8 @@ import { SessionTracePersistenceMapper } from '../Mapping/SessionTracePersistenc
 import { SessionTrace } from '../Domain/Session/SessionTrace'
 import { TypeORMSessionTrace } from '../Infra/TypeORM/TypeORMSessionTrace'
 import { TraceSession } from '../Domain/UseCase/TraceSession/TraceSession'
+import { CleanupSessionTraces } from '../Domain/UseCase/CleanupSessionTraces/CleanupSessionTraces'
+import { PersistStatistics } from '../Domain/UseCase/PersistStatistics/PersistStatistics'
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const newrelicFormatter = require('@newrelic/winston-enricher')
@@ -499,6 +501,19 @@ export class ContainerConfigLoader {
           container.get(TYPES.SESSION_TRACE_DAYS_TTL),
         ),
       )
+    container
+      .bind<PersistStatistics>(TYPES.PersistStatistics)
+      .toConstantValue(
+        new PersistStatistics(
+          container.get(TYPES.SessionTraceRepository),
+          container.get(TYPES.DomainEventPublisher),
+          container.get(TYPES.DomainEventFactory),
+        ),
+      )
+
+    container
+      .bind<CleanupSessionTraces>(TYPES.CleanupSessionTraces)
+      .toConstantValue(new CleanupSessionTraces(container.get(TYPES.SessionTraceRepository)))
     container.bind<AuthenticateUser>(TYPES.AuthenticateUser).to(AuthenticateUser)
     container.bind<AuthenticateRequest>(TYPES.AuthenticateRequest).to(AuthenticateRequest)
     container.bind<RefreshSessionToken>(TYPES.RefreshSessionToken).to(RefreshSessionToken)

packages/auth/src/Bootstrap/Types.ts

@@ -125,6 +125,8 @@ const TYPES = {
   CreateCrossServiceToken: Symbol.for('CreateCrossServiceToken'),
   ProcessUserRequest: Symbol.for('ProcessUserRequest'),
   TraceSession: Symbol.for('TraceSession'),
+  CleanupSessionTraces: Symbol.for('CleanupSessionTraces'),
+  PersistStatistics: Symbol.for('PersistStatistics'),
   // Handlers
   UserRegisteredEventHandler: Symbol.for('UserRegisteredEventHandler'),
   AccountDeletionRequestedEventHandler: Symbol.for('AccountDeletionRequestedEventHandler'),

packages/auth/src/Domain/Event/DomainEventFactory.ts

@@ -19,6 +19,7 @@ import {
   UserContentSizeRecalculationRequestedEvent,
   MuteEmailsSettingChangedEvent,
   EmailRequestedEvent,
+  StatisticPersistenceRequestedEvent,
 } from '@standardnotes/domain-events'
 import { Predicate, PredicateVerificationResult } from '@standardnotes/predicates'
 import { TimerInterface } from '@standardnotes/time'
@@ -31,6 +32,25 @@ import { DomainEventFactoryInterface } from './DomainEventFactoryInterface'
 export class DomainEventFactory implements DomainEventFactoryInterface {
   constructor(@inject(TYPES.Timer) private timer: TimerInterface) {}
 
+  createStatisticPersistenceRequestedEvent(dto: {
+    statisticMeasureName: string
+    value: number
+    date: Date
+  }): StatisticPersistenceRequestedEvent {
+    return {
+      type: 'STATISTIC_PERSISTENCE_REQUESTED',
+      createdAt: this.timer.getUTCDate(),
+      meta: {
+        correlation: {
+          userIdentifier: '-',
+          userIdentifierType: 'email',
+        },
+        origin: DomainEventService.Auth,
+      },
+      payload: dto,
+    }
+  }
+
   createMuteEmailsSettingChangedEvent(dto: {
     username: string
     mute: boolean

packages/auth/src/Domain/Event/DomainEventFactoryInterface.ts

@@ -17,6 +17,7 @@ import {
   UserContentSizeRecalculationRequestedEvent,
   MuteEmailsSettingChangedEvent,
   EmailRequestedEvent,
+  StatisticPersistenceRequestedEvent,
 } from '@standardnotes/domain-events'
 import { InviteeIdentifierType } from '../SharedSubscription/InviteeIdentifierType'
 
@@ -88,4 +89,9 @@ export interface DomainEventFactoryInterface {
     mute: boolean
     emailSubscriptionRejectionLevel: string
   }): MuteEmailsSettingChangedEvent
+  createStatisticPersistenceRequestedEvent(dto: {
+    statisticMeasureName: string
+    value: number
+    date: Date
+  }): StatisticPersistenceRequestedEvent
 }

packages/auth/src/Domain/Role/RoleToSubscriptionMap.spec.ts

@@ -41,4 +41,23 @@ describe('RoleToSubscriptionMap', () => {
       },
     ])
   })
+
+  it('should filter our subscription roles from an array of roles', () => {
+    const roles = [
+      {
+        name: RoleName.CoreUser,
+      } as jest.Mocked<Role>,
+      {
+        name: RoleName.FilesBetaUser,
+      } as jest.Mocked<Role>,
+      {
+        name: RoleName.PlusUser,
+      } as jest.Mocked<Role>,
+    ]
+    expect(createMap().filterSubscriptionRoles(roles)).toEqual([
+      {
+        name: RoleName.PlusUser,
+      },
+    ])
+  })
 })

packages/auth/src/Domain/Role/RoleToSubscriptionMap.ts

@@ -17,6 +17,10 @@ export class RoleToSubscriptionMap implements RoleToSubscriptionMapInterface {
     return roles.filter((role) => this.nonSubscriptionRoles.includes(role.name as RoleName))
   }
 
+  filterSubscriptionRoles(roles: Role[]): Array<Role> {
+    return roles.filter((role) => !this.nonSubscriptionRoles.includes(role.name as RoleName))
+  }
+
   getSubscriptionNameForRoleName(roleName: RoleName): SubscriptionName | undefined {
     return this.roleNameToSubscriptionNameMap.get(roleName)
   }

packages/auth/src/Domain/Role/RoleToSubscriptionMapInterface.ts

@@ -3,6 +3,7 @@ import { Role } from './Role'
 
 export interface RoleToSubscriptionMapInterface {
   filterNonSubscriptionRoles(roles: Role[]): Array<Role>
+  filterSubscriptionRoles(roles: Role[]): Array<Role>
   getSubscriptionNameForRoleName(roleName: RoleName): SubscriptionName | undefined
   getRoleNameForSubscriptionName(subscriptionName: SubscriptionName): RoleName | undefined
 }

packages/auth/src/Domain/Session/SessionTraceRepositoryInterface.ts

@@ -1,8 +1,11 @@
-import { Uuid } from '@standardnotes/domain-core'
+import { SubscriptionPlanName, Uuid } from '@standardnotes/domain-core'
 
 import { SessionTrace } from './SessionTrace'
 
 export interface SessionTraceRepositoryInterface {
   save(sessionTrace: SessionTrace): Promise<void>
+  removeExpiredBefore(date: Date): Promise<void>
   findOneByUserUuidAndDate(userUuid: Uuid, date: Date): Promise<SessionTrace | null>
+  countByDate(date: Date): Promise<number>
+  countByDateAndSubscriptionPlanName(date: Date, subscriptionPlanName: SubscriptionPlanName): Promise<number>
 }

packages/auth/src/Domain/UseCase/CleanupSessionTraces/CleanupSessionTraces.spec.ts

@@ -0,0 +1,19 @@
+import { SessionTraceRepositoryInterface } from '../../Session/SessionTraceRepositoryInterface'
+import { CleanupSessionTraces } from './CleanupSessionTraces'
+
+describe('CleanupSessionTraces', () => {
+  let sessionTracesRepository: SessionTraceRepositoryInterface
+
+  const createUseCase = () => new CleanupSessionTraces(sessionTracesRepository)
+
+  beforeEach(() => {
+    sessionTracesRepository = {} as jest.Mocked<SessionTraceRepositoryInterface>
+    sessionTracesRepository.removeExpiredBefore = jest.fn()
+  })
+
+  it('should remove stale session traces', async () => {
+    await createUseCase().execute({ date: new Date() })
+
+    expect(sessionTracesRepository.removeExpiredBefore).toHaveBeenCalled()
+  })
+})

packages/auth/src/Domain/UseCase/CleanupSessionTraces/CleanupSessionTraces.ts

@@ -0,0 +1,14 @@
+import { Result, UseCaseInterface } from '@standardnotes/domain-core'
+
+import { SessionTraceRepositoryInterface } from '../../Session/SessionTraceRepositoryInterface'
+import { CleanupSessionTracesDTO } from './CleanupSessionTracesDTO'
+
+export class CleanupSessionTraces implements UseCaseInterface<string> {
+  constructor(private sessionTracesRepository: SessionTraceRepositoryInterface) {}
+
+  async execute(dto: CleanupSessionTracesDTO): Promise<Result<string>> {
+    await this.sessionTracesRepository.removeExpiredBefore(dto.date)
+
+    return Result.ok('Session traces removed')
+  }
+}

packages/auth/src/Domain/UseCase/CleanupSessionTraces/CleanupSessionTracesDTO.ts

@@ -0,0 +1,3 @@
+export interface CleanupSessionTracesDTO {
+  date: Date
+}

packages/auth/src/Domain/UseCase/CreateCrossServiceToken/CreateCrossServiceToken.spec.ts

@@ -67,7 +67,7 @@ describe('CreateCrossServiceToken', () => {
     userRepository.findOneByUuid = jest.fn().mockReturnValue(user)
 
     roleToSubscriptionMap = {} as jest.Mocked<RoleToSubscriptionMapInterface>
-    roleToSubscriptionMap.filterNonSubscriptionRoles = jest.fn().mockReturnValue([RoleName.NAMES.PlusUser])
+    roleToSubscriptionMap.filterSubscriptionRoles = jest.fn().mockReturnValue([RoleName.NAMES.PlusUser])
     roleToSubscriptionMap.getSubscriptionNameForRoleName = jest
       .fn()
       .mockReturnValue(SubscriptionPlanName.NAMES.PlusPlan)
@@ -170,7 +170,7 @@ describe('CreateCrossServiceToken', () => {
   })
 
   it('should trace session without a subscription role', async () => {
-    roleToSubscriptionMap.filterNonSubscriptionRoles = jest.fn().mockReturnValue([])
+    roleToSubscriptionMap.filterSubscriptionRoles = jest.fn().mockReturnValue([])
 
     await createUseCase().execute({
       user,

packages/auth/src/Domain/UseCase/CreateCrossServiceToken/CreateCrossServiceToken.ts

@@ -102,7 +102,7 @@ export class CreateCrossServiceToken implements UseCaseInterface {
   }
 
   private getSubscriptionNameFromRoles(roles: Array<Role>): string | null {
-    const nonSubscriptionRoles = this.roleToSubscriptionMap.filterNonSubscriptionRoles(roles)
+    const nonSubscriptionRoles = this.roleToSubscriptionMap.filterSubscriptionRoles(roles)
     if (nonSubscriptionRoles.length === 0) {
       return null
     }

packages/auth/src/Domain/UseCase/PersistStatistics/PersistStatistics.spec.ts

@@ -0,0 +1,33 @@
+import { DomainEventPublisherInterface, StatisticPersistenceRequestedEvent } from '@standardnotes/domain-events'
+
+import { DomainEventFactoryInterface } from '../../Event/DomainEventFactoryInterface'
+import { SessionTraceRepositoryInterface } from '../../Session/SessionTraceRepositoryInterface'
+
+import { PersistStatistics } from './PersistStatistics'
+
+describe('PersistStatistics', () => {
+  let sessionTracesRepository: SessionTraceRepositoryInterface
+  let domainEventPublisher: DomainEventPublisherInterface
+  let domainEventFactory: DomainEventFactoryInterface
+  const createUseCase = () => new PersistStatistics(sessionTracesRepository, domainEventPublisher, domainEventFactory)
+
+  beforeEach(() => {
+    sessionTracesRepository = {} as jest.Mocked<SessionTraceRepositoryInterface>
+    sessionTracesRepository.countByDate = jest.fn().mockReturnValue(1)
+    sessionTracesRepository.countByDateAndSubscriptionPlanName = jest.fn().mockReturnValue(2)
+
+    domainEventFactory = {} as jest.Mocked<DomainEventFactoryInterface>
+    domainEventFactory.createStatisticPersistenceRequestedEvent = jest
+      .fn()
+      .mockReturnValue({} as jest.Mocked<StatisticPersistenceRequestedEvent>)
+
+    domainEventPublisher = {} as jest.Mocked<DomainEventPublisherInterface>
+    domainEventPublisher.publish = jest.fn()
+  })
+
+  it('should request statistic persistence', async () => {
+    await createUseCase().execute({ sessionsInADay: new Date() })
+
+    expect(domainEventPublisher.publish).toHaveBeenCalledTimes(4)
+  })
+})

packages/auth/src/Domain/UseCase/PersistStatistics/PersistStatistics.ts

@@ -0,0 +1,61 @@
+import { Result, SubscriptionPlanName, UseCaseInterface } from '@standardnotes/domain-core'
+import { DomainEventPublisherInterface } from '@standardnotes/domain-events'
+import { DomainEventFactoryInterface } from '../../Event/DomainEventFactoryInterface'
+import { SessionTraceRepositoryInterface } from '../../Session/SessionTraceRepositoryInterface'
+import { PersistStatisticsDTO } from './PersistStatisticsDTO'
+
+export class PersistStatistics implements UseCaseInterface<string> {
+  constructor(
+    private sessionTracesRepository: SessionTraceRepositoryInterface,
+    private domainEventPublisher: DomainEventPublisherInterface,
+    private domainEventFactory: DomainEventFactoryInterface,
+  ) {}
+
+  async execute(dto: PersistStatisticsDTO): Promise<Result<string>> {
+    const countSessionsInADay = await this.sessionTracesRepository.countByDate(dto.sessionsInADay)
+    await this.domainEventPublisher.publish(
+      this.domainEventFactory.createStatisticPersistenceRequestedEvent({
+        statisticMeasureName: 'active-users',
+        value: countSessionsInADay,
+        date: dto.sessionsInADay,
+      }),
+    )
+
+    const proSubscriptionPlanName = SubscriptionPlanName.create(SubscriptionPlanName.NAMES.ProPlan).getValue()
+    const countProSessionsInADay = await this.sessionTracesRepository.countByDateAndSubscriptionPlanName(
+      dto.sessionsInADay,
+      proSubscriptionPlanName,
+    )
+    await this.domainEventPublisher.publish(
+      this.domainEventFactory.createStatisticPersistenceRequestedEvent({
+        statisticMeasureName: 'active-pro-users',
+        value: countProSessionsInADay,
+        date: dto.sessionsInADay,
+      }),
+    )
+
+    const plusSubscriptionPlanName = SubscriptionPlanName.create(SubscriptionPlanName.NAMES.PlusPlan).getValue()
+    const countPlusSessionsInADay = await this.sessionTracesRepository.countByDateAndSubscriptionPlanName(
+      dto.sessionsInADay,
+      plusSubscriptionPlanName,
+    )
+    await this.domainEventPublisher.publish(
+      this.domainEventFactory.createStatisticPersistenceRequestedEvent({
+        statisticMeasureName: 'active-plus-users',
+        value: countPlusSessionsInADay,
+        date: dto.sessionsInADay,
+      }),
+    )
+
+    const countFreeSessionsInADay = countSessionsInADay - countProSessionsInADay - countPlusSessionsInADay
+    await this.domainEventPublisher.publish(
+      this.domainEventFactory.createStatisticPersistenceRequestedEvent({
+        statisticMeasureName: 'active-free-users',
+        value: countFreeSessionsInADay,
+        date: dto.sessionsInADay,
+      }),
+    )
+
+    return Result.ok('Statistics persisted.')
+  }
+}

packages/auth/src/Domain/UseCase/PersistStatistics/PersistStatisticsDTO.ts

@@ -0,0 +1,3 @@
+export interface PersistStatisticsDTO {
+  sessionsInADay: Date
+}

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

@@ -1,4 +1,4 @@
-import { MapperInterface, Uuid } from '@standardnotes/domain-core'
+import { MapperInterface, SubscriptionPlanName, Uuid } from '@standardnotes/domain-core'
 import { Repository } from 'typeorm'
 import { SessionTrace } from '../../Domain/Session/SessionTrace'
 import { SessionTraceRepositoryInterface } from '../../Domain/Session/SessionTraceRepositoryInterface'
@@ -10,6 +10,35 @@ export class MySQLSessionTraceRepository implements SessionTraceRepositoryInterf
     private mapper: MapperInterface<SessionTrace, TypeORMSessionTrace>,
   ) {}
 
+  async countByDateAndSubscriptionPlanName(date: Date, subscriptionPlanName: SubscriptionPlanName): Promise<number> {
+    return this.ormRepository
+      .createQueryBuilder('trace')
+      .where('trace.creation_date = :creationDate', {
+        creationDate: new Date(date.getFullYear(), date.getMonth(), date.getDate()),
+      })
+      .andWhere('trace.subscription_plan_name = :subscriptionPlanName', {
+        subscriptionPlanName: subscriptionPlanName.value,
+      })
+      .getCount()
+  }
+
+  async countByDate(date: Date): Promise<number> {
+    return this.ormRepository
+      .createQueryBuilder('trace')
+      .where('trace.creation_date = :creationDate', {
+        creationDate: new Date(date.getFullYear(), date.getMonth(), date.getDate()),
+      })
+      .getCount()
+  }
+
+  async removeExpiredBefore(date: Date): Promise<void> {
+    await this.ormRepository
+      .createQueryBuilder()
+      .delete()
+      .where('expires_at < :date', { date: date.toISOString() })
+      .execute()
+  }
+
   async findOneByUserUuidAndDate(userUuid: Uuid, date: Date): Promise<SessionTrace | null> {
     const typeOrm = await this.ormRepository
       .createQueryBuilder('trace')

packages/domain-events-infra/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.9.58](https://github.com/standardnotes/server/compare/@standardnotes/domain-events-infra@1.9.57...@standardnotes/domain-events-infra@1.9.58) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/domain-events-infra
+
 ## [1.9.57](https://github.com/standardnotes/server/compare/@standardnotes/domain-events-infra@1.9.56...@standardnotes/domain-events-infra@1.9.57) (2022-12-19)
 
 **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.57",
+  "version": "1.9.58",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

packages/domain-events/CHANGELOG.md

@@ -3,6 +3,12 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+# [2.105.0](https://github.com/standardnotes/server/compare/@standardnotes/domain-events@2.104.2...@standardnotes/domain-events@2.105.0) (2022-12-19)
+
+### Features
+
+* **analytics:** add persisting statistics on demand ([0f84575](https://github.com/standardnotes/server/commit/0f8457534c1829c58f3c036749d262307ddeb779))
+
 ## [2.104.2](https://github.com/standardnotes/server/compare/@standardnotes/domain-events@2.104.1...@standardnotes/domain-events@2.104.2) (2022-12-19)
 
 ### Bug Fixes

packages/domain-events/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/domain-events",
-  "version": "2.104.2",
+  "version": "2.105.0",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

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

@@ -0,0 +1,8 @@
+import { DomainEventInterface } from './DomainEventInterface'
+
+import { StatisticPersistenceRequestedEventPayload } from './StatisticPersistenceRequestedEventPayload'
+
+export interface StatisticPersistenceRequestedEvent extends DomainEventInterface {
+  type: 'STATISTIC_PERSISTENCE_REQUESTED'
+  payload: StatisticPersistenceRequestedEventPayload
+}

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

@@ -0,0 +1,5 @@
+export interface StatisticPersistenceRequestedEventPayload {
+  statisticMeasureName: string
+  value: number
+  date: Date
+}

packages/domain-events/src/Domain/index.ts

@@ -58,6 +58,8 @@ export * from './Event/SharedSubscriptionInvitationCanceledEvent'
 export * from './Event/SharedSubscriptionInvitationCanceledEventPayload'
 export * from './Event/SharedSubscriptionInvitationCreatedEvent'
 export * from './Event/SharedSubscriptionInvitationCreatedEventPayload'
+export * from './Event/StatisticPersistenceRequestedEvent'
+export * from './Event/StatisticPersistenceRequestedEventPayload'
 export * from './Event/SubscriptionCancelledEvent'
 export * from './Event/SubscriptionCancelledEventPayload'
 export * from './Event/SubscriptionPurchasedEvent'

packages/event-store/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.6.55](https://github.com/standardnotes/server/compare/@standardnotes/event-store@1.6.54...@standardnotes/event-store@1.6.55) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/event-store
+
 ## [1.6.54](https://github.com/standardnotes/server/compare/@standardnotes/event-store@1.6.53...@standardnotes/event-store@1.6.54) (2022-12-19)
 
 ### Bug Fixes

packages/event-store/package.json

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

packages/files/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.9.1](https://github.com/standardnotes/files/compare/@standardnotes/files-server@1.9.0...@standardnotes/files-server@1.9.1) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/files-server
+
 # [1.9.0](https://github.com/standardnotes/files/compare/@standardnotes/files-server@1.8.52...@standardnotes/files-server@1.9.0) (2022-12-19)
 
 ### Features

packages/files/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/files-server",
-  "version": "1.9.0",
+  "version": "1.9.1",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

packages/revisions/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.10.1](https://github.com/standardnotes/server/compare/@standardnotes/revisions-server@1.10.0...@standardnotes/revisions-server@1.10.1) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/revisions-server
+
 # [1.10.0](https://github.com/standardnotes/server/compare/@standardnotes/revisions-server@1.9.28...@standardnotes/revisions-server@1.10.0) (2022-12-19)
 
 ### Features

packages/revisions/package.json

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

packages/scheduler/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.16.1](https://github.com/standardnotes/server/compare/@standardnotes/scheduler-server@1.16.0...@standardnotes/scheduler-server@1.16.1) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/scheduler-server
+
 # [1.16.0](https://github.com/standardnotes/server/compare/@standardnotes/scheduler-server@1.15.8...@standardnotes/scheduler-server@1.16.0) (2022-12-19)
 
 ### Features

packages/scheduler/package.json

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

packages/syncing-server/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.28.1](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.28.0...@standardnotes/syncing-server@1.28.1) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/syncing-server
+
 # [1.28.0](https://github.com/standardnotes/syncing-server-js/compare/@standardnotes/syncing-server@1.27.0...@standardnotes/syncing-server@1.28.0) (2022-12-19)
 
 ### Bug Fixes

packages/syncing-server/package.json

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

packages/websockets/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.5.1](https://github.com/standardnotes/server/compare/@standardnotes/websockets-server@1.5.0...@standardnotes/websockets-server@1.5.1) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/websockets-server
+
 # [1.5.0](https://github.com/standardnotes/server/compare/@standardnotes/websockets-server@1.4.53...@standardnotes/websockets-server@1.5.0) (2022-12-19)
 
 ### Features

packages/websockets/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/websockets-server",
-  "version": "1.5.0",
+  "version": "1.5.1",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },

packages/workspace/CHANGELOG.md

@@ -3,6 +3,10 @@
 All notable changes to this project will be documented in this file.
 See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.
 
+## [1.19.1](https://github.com/standardnotes/server/compare/@standardnotes/workspace-server@1.19.0...@standardnotes/workspace-server@1.19.1) (2022-12-19)
+
+**Note:** Version bump only for package @standardnotes/workspace-server
+
 # [1.19.0](https://github.com/standardnotes/server/compare/@standardnotes/workspace-server@1.18.6...@standardnotes/workspace-server@1.19.0) (2022-12-19)
 
 ### Features

packages/workspace/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@standardnotes/workspace-server",
-  "version": "1.19.0",
+  "version": "1.19.1",
   "engines": {
     "node": ">=18.0.0 <19.0.0"
   },