feat: refactor settings (#890)

* feat: refactor settings * fix verify mfa specs and data source metadata * fix: compound index field names * fix metadata binding for typeorm repository * fix responses to preserve e2e * fixes for e2e * fix recovery codes e2e * add missing specs
2026-08-04 00:15:57 -04:00 · 2023-10-26 12:42:30 +02:00
parent a5e019e290
commit 1b5078eb96
175 changed files with 4155 additions and 7701 deletions
@@ -0,0 +1,87 @@
+import { Result, Timestamps, UseCaseInterface, Uuid } from '@standardnotes/domain-core'
+import { TimerInterface } from '@standardnotes/time'
+import { SettingName } from '@standardnotes/settings'
+
+import { SetSubscriptionSettingValueDTO } from './SetSubscriptionSettingValueDTO'
+import { SubscriptionSettingRepositoryInterface } from '../../Setting/SubscriptionSettingRepositoryInterface'
+import { GetSubscriptionSetting } from '../GetSubscriptionSetting/GetSubscriptionSetting'
+import { SubscriptionSetting } from '../../Setting/SubscriptionSetting'
+import { EncryptionVersion } from '../../Encryption/EncryptionVersion'
+
+export class SetSubscriptionSettingValue implements UseCaseInterface<void> {
+  constructor(
+    private subscriptionSettingRepository: SubscriptionSettingRepositoryInterface,
+    private getSubscriptionSetting: GetSubscriptionSetting,
+    private timer: TimerInterface,
+  ) {}
+
+  async execute(dto: SetSubscriptionSettingValueDTO): Promise<Result<void>> {
+    const userSubscriptionUuidOrError = Uuid.create(dto.userSubscriptionUuid)
+    if (userSubscriptionUuidOrError.isFailed()) {
+      return Result.fail(userSubscriptionUuidOrError.getError())
+    }
+    const userSubscriptionUuid = userSubscriptionUuidOrError.getValue()
+
+    let newUserSubscriptionUuid: Uuid | undefined
+    if (dto.newUserSubscriptionUuid !== undefined) {
+      const newUserSubscriptionUuidOrError = Uuid.create(dto.newUserSubscriptionUuid)
+      if (newUserSubscriptionUuidOrError.isFailed()) {
+        return Result.fail(newUserSubscriptionUuidOrError.getError())
+      }
+      newUserSubscriptionUuid = newUserSubscriptionUuidOrError.getValue()
+    }
+
+    const settingNameOrError = SettingName.create(dto.settingName)
+    if (settingNameOrError.isFailed()) {
+      return Result.fail(settingNameOrError.getError())
+    }
+    const settingName = settingNameOrError.getValue()
+
+    if (!settingName.isASubscriptionSetting()) {
+      return Result.fail(`Setting ${settingName.value} is not a subscription setting!`)
+    }
+
+    const settingExists = await this.getSubscriptionSetting.execute({
+      userSubscriptionUuid: userSubscriptionUuid.value,
+      settingName: settingName.value,
+      allowSensitiveRetrieval: true,
+    })
+    if (settingExists.isFailed()) {
+      const timestamps = Timestamps.create(
+        this.timer.getTimestampInMicroseconds(),
+        this.timer.getTimestampInMicroseconds(),
+      ).getValue()
+
+      const subscriptionSettingOrError = SubscriptionSetting.create({
+        name: settingName.value,
+        value: dto.value,
+        userSubscriptionUuid: newUserSubscriptionUuid ?? userSubscriptionUuid,
+        serverEncryptionVersion: EncryptionVersion.Unencrypted,
+        timestamps,
+        sensitive: false,
+      })
+      if (subscriptionSettingOrError.isFailed()) {
+        return Result.fail(subscriptionSettingOrError.getError())
+      }
+      const subscriptionSetting = subscriptionSettingOrError.getValue()
+
+      await this.subscriptionSettingRepository.insert(subscriptionSetting)
+
+      return Result.ok()
+    }
+
+    const { setting } = settingExists.getValue()
+    setting.props.value = dto.value
+    setting.props.timestamps = Timestamps.create(
+      setting.props.timestamps.createdAt,
+      this.timer.getTimestampInMicroseconds(),
+    ).getValue()
+    if (newUserSubscriptionUuid !== undefined) {
+      setting.props.userSubscriptionUuid = newUserSubscriptionUuid
+    }
+
+    await this.subscriptionSettingRepository.update(setting)
+
+    return Result.ok()
+  }
+}