feat: implement managed storage plans and provider settings

- Added new UI schema for managing storage plans, including catalog, pricing, and product configurations.
- Introduced StoragePlanService to handle storage plan operations and integrate with existing billing services.
- Updated SuperAdmin settings to include managed storage provider configurations.
- Enhanced localization files with new keys for storage plan management.
- Implemented API endpoints for fetching and updating storage plans.

Signed-off-by: Innei <[email protected]>

Author: Innei

be/apps/core/src/locales/ui-schema/en.ts

@@ -298,6 +298,37 @@ const enUiSchema = {
           },
         },
       },
+      'storage-plans': {
+        title: 'Storage plans',
+        description: 'Managed storage catalog, pricing, and Creem products for storage subscriptions.',
+        fields: {
+          catalog: {
+            title: 'Plan catalog',
+            description:
+              'Manage storage plans for managed B2 space. Use the dashboard editor; JSON is no longer required.',
+            placeholder: 'Configured via dashboard',
+            helper: 'Plans include name/description/capacity and active flag.',
+          },
+          pricing: {
+            title: 'Storage pricing',
+            description: 'Monthly price and currency per storage plan.',
+            placeholder: 'Configured via dashboard',
+            helper: 'Blank values fall back to defaults or hide pricing.',
+          },
+          products: {
+            title: 'Creem products',
+            description: 'Creem product per storage plan for checkout and portal.',
+            placeholder: 'Configured via dashboard',
+            helper: 'Blank values hide the upgrade entry for that plan.',
+          },
+          'managed-provider': {
+            title: 'Managed provider key',
+            description: 'Provider ID from storage providers list that backs managed storage plans (e.g., b2-managed).',
+            placeholder: 'b2-managed',
+            helper: 'Used by backend to issue upload/read credentials for managed tenants.',
+          },
+        },
+      },
       oauth: {
         title: 'OAuth providers',
         description: 'Configure shared third-party login providers for all tenants.',

be/apps/core/src/locales/ui-schema/zh-CN.ts

@@ -296,6 +296,36 @@ const zhCnUiSchema = {
           },
         },
       },
+      'storage-plans': {
+        title: '存储计划',
+        description: '管理托管存储方案的目录、定价以及 Creem 商品映射。',
+        fields: {
+          catalog: {
+            title: '计划目录',
+            description: '存储计划的名称/描述/容量与启用状态，建议在控制台中编辑，无需手填 JSON。',
+            placeholder: '通过控制台编辑',
+            helper: '包含 plan id、name、description、capacityBytes、isActive 等字段。',
+          },
+          pricing: {
+            title: '存储定价',
+            description: '每个存储计划的月费与币种。',
+            placeholder: '通过控制台编辑',
+            helper: '留空回退到默认值或隐藏价格。',
+          },
+          products: {
+            title: 'Creem 商品',
+            description: '为存储计划绑定 Creem 商品 ID，用于结算与用户门户。',
+            placeholder: '通过控制台编辑',
+            helper: '留空则该计划不会展示升级入口。',
+          },
+          'managed-provider': {
+            title: '托管存储 Provider Key',
+            description: '与存储提供商列表中的配置项对应（例如 b2-managed）。',
+            placeholder: 'b2-managed',
+            helper: '后端将用该 Provider 为托管存储租户发放上传/读取权限。',
+          },
+        },
+      },
       oauth: {
         title: 'OAuth 登录渠道',
         description: '统一配置所有租户可用的第三方登录渠道。',

be/apps/core/src/modules/configuration/system-setting/system-setting.constants.ts

@@ -7,6 +7,13 @@ import {
   BILLING_PLAN_PRODUCTS_SETTING_KEY,
 } from 'core/modules/platform/billing/billing-plan.constants'
 import type { BillingPlanId, BillingPlanQuota } from 'core/modules/platform/billing/billing-plan.types'
+import {
+  DEFAULT_STORAGE_PLAN_CATALOG,
+  STORAGE_PLAN_CATALOG_SETTING_KEY,
+  STORAGE_PLAN_PRICING_SETTING_KEY,
+  STORAGE_PLAN_PRODUCTS_SETTING_KEY,
+} from 'core/modules/platform/billing/storage-plan.constants'
+import type { StoragePlanCatalog } from 'core/modules/platform/billing/storage-plan.types'
 import { z } from 'zod'
 
 const nonEmptyString = z.string().trim().min(1)
@@ -114,6 +121,36 @@ export const SYSTEM_SETTING_DEFINITIONS = {
     defaultValue: {},
     isSensitive: false,
   },
+  storagePlanCatalog: {
+    key: STORAGE_PLAN_CATALOG_SETTING_KEY,
+    schema: z.record(z.string(), z.any()),
+    defaultValue: DEFAULT_STORAGE_PLAN_CATALOG satisfies StoragePlanCatalog,
+    isSensitive: false,
+  },
+  storagePlanProducts: {
+    key: STORAGE_PLAN_PRODUCTS_SETTING_KEY,
+    schema: z.record(z.string(), z.any()),
+    defaultValue: {},
+    isSensitive: false,
+  },
+  storagePlanPricing: {
+    key: STORAGE_PLAN_PRICING_SETTING_KEY,
+    schema: z.record(z.string(), z.any()),
+    defaultValue: {},
+    isSensitive: false,
+  },
+  managedStorageProvider: {
+    key: 'system.storage.managed.provider',
+    schema: z.string().trim().min(1).nullable(),
+    defaultValue: null as string | null,
+    isSensitive: false,
+  },
+  managedStorageProviders: {
+    key: 'system.storage.managed.providers',
+    schema: z.string(),
+    defaultValue: '[]',
+    isSensitive: true,
+  },
 } as const
 
 const BILLING_PLAN_QUOTA_KEYS = [

be/apps/core/src/modules/configuration/system-setting/system-setting.service.ts

@@ -16,12 +16,24 @@ import type {
   BillingPlanProductConfigs,
   BillingPlanQuota,
 } from 'core/modules/platform/billing/billing-plan.types'
+import type {
+  StoragePlanCatalog,
+  StoragePlanPricingConfigs,
+  StoragePlanProductConfigs,
+} from 'core/modules/platform/billing/storage-plan.types'
 import { sql } from 'drizzle-orm'
 import { injectable } from 'tsyringe'
 import type { ZodType } from 'zod'
 import { z } from 'zod'
 
 import { getUiSchemaTranslator } from '../../ui/ui-schema/ui-schema.i18n'
+import type { BuilderStorageProvider } from '../setting/storage-provider.utils'
+import {
+  maskStorageProviderSecrets,
+  mergeStorageProviderSecrets,
+  parseStorageProviders,
+  serializeStorageProviders,
+} from '../setting/storage-provider.utils'
 import type { SystemSettingDbField } from './system-setting.constants'
 import {
   BILLING_PLAN_FIELD_DESCRIPTORS,
@@ -135,6 +147,29 @@ export class SystemSettingService {
       BILLING_PLAN_PRICING_SCHEMA,
       {},
     ) as BillingPlanPricingConfigs
+    const storagePlanCatalog = this.parseSetting(
+      rawValues[SYSTEM_SETTING_DEFINITIONS.storagePlanCatalog.key],
+      STORAGE_PLAN_CATALOG_SCHEMA,
+      SYSTEM_SETTING_DEFINITIONS.storagePlanCatalog.defaultValue as StoragePlanCatalog,
+    ) as StoragePlanCatalog
+    const storagePlanProducts = this.parseSetting(
+      rawValues[SYSTEM_SETTING_DEFINITIONS.storagePlanProducts.key],
+      STORAGE_PLAN_PRODUCTS_SCHEMA,
+      {},
+    ) as StoragePlanProductConfigs
+    const storagePlanPricing = this.parseSetting(
+      rawValues[SYSTEM_SETTING_DEFINITIONS.storagePlanPricing.key],
+      STORAGE_PLAN_PRICING_SCHEMA,
+      {},
+    ) as StoragePlanPricingConfigs
+    const managedStorageProvider = this.parseSetting(
+      rawValues[SYSTEM_SETTING_DEFINITIONS.managedStorageProvider.key],
+      SYSTEM_SETTING_DEFINITIONS.managedStorageProvider.schema,
+      SYSTEM_SETTING_DEFINITIONS.managedStorageProvider.defaultValue,
+    )
+    const managedStorageProviders = this.parseManagedStorageProviders(
+      rawValues[SYSTEM_SETTING_DEFINITIONS.managedStorageProviders.key],
+    )
     return {
       allowRegistration,
       maxRegistrableUsers,
@@ -151,6 +186,11 @@ export class SystemSettingService {
       billingPlanOverrides,
       billingPlanProducts,
       billingPlanPricing,
+      storagePlanCatalog,
+      storagePlanProducts,
+      storagePlanPricing,
+      managedStorageProvider,
+      managedStorageProviders,
     }
   }
 
@@ -169,6 +209,26 @@ export class SystemSettingService {
     return settings.billingPlanPricing ?? {}
   }
 
+  async getStoragePlanCatalog(): Promise<StoragePlanCatalog> {
+    const settings = await this.getSettings()
+    return settings.storagePlanCatalog ?? {}
+  }
+
+  async getStoragePlanProducts(): Promise<StoragePlanProductConfigs> {
+    const settings = await this.getSettings()
+    return settings.storagePlanProducts ?? {}
+  }
+
+  async getStoragePlanPricing(): Promise<StoragePlanPricingConfigs> {
+    const settings = await this.getSettings()
+    return settings.storagePlanPricing ?? {}
+  }
+
+  async getManagedStorageProviderKey(): Promise<string | null> {
+    const settings = await this.getSettings()
+    return settings.managedStorageProvider ?? null
+  }
+
   async getOverview(): Promise<SystemSettingOverview> {
     const settings = await this.getSettings()
     const totalUsers = await this.getTotalUserCount()
@@ -194,9 +254,17 @@ export class SystemSettingService {
 
     const updates: Array<{ field: SystemSettingDbField; value: unknown }> = []
 
-    const enqueueUpdate = <K extends SystemSettingDbField>(field: K, value: unknown) => {
+    const enqueueUpdate = <K extends SystemSettingDbField>(
+      field: K,
+      value: unknown,
+      currentValue?: SystemSettings[K],
+    ) => {
       updates.push({ field, value })
-      ;(current as unknown as Record<string, unknown>)[field] = value
+      if (currentValue !== undefined) {
+        ;(current as unknown as Record<string, unknown>)[field] = currentValue
+      } else {
+        ;(current as unknown as Record<string, unknown>)[field] = value
+      }
     }
 
     if (patch.allowRegistration !== undefined && patch.allowRegistration !== current.allowRegistration) {
@@ -287,6 +355,37 @@ export class SystemSettingService {
       }
     }
 
+    if (patch.storagePlanCatalog !== undefined) {
+      const parsed = STORAGE_PLAN_CATALOG_SCHEMA.parse(patch.storagePlanCatalog)
+      enqueueUpdate('storagePlanCatalog', parsed)
+    }
+
+    if (patch.storagePlanProducts !== undefined) {
+      const parsed = STORAGE_PLAN_PRODUCTS_SCHEMA.parse(patch.storagePlanProducts)
+      enqueueUpdate('storagePlanProducts', parsed)
+    }
+
+    if (patch.storagePlanPricing !== undefined) {
+      const parsed = STORAGE_PLAN_PRICING_SCHEMA.parse(patch.storagePlanPricing)
+      enqueueUpdate('storagePlanPricing', parsed)
+    }
+
+    if (patch.managedStorageProvider !== undefined && patch.managedStorageProvider !== current.managedStorageProvider) {
+      enqueueUpdate('managedStorageProvider', this.normalizeNullableString(patch.managedStorageProvider))
+    }
+
+    if (patch.managedStorageProviders !== undefined) {
+      const normalizedProviders = this.normalizeManagedStorageProvidersPatch(
+        patch.managedStorageProviders,
+        current.managedStorageProviders ?? [],
+      )
+      const nextSerialized = serializeStorageProviders(normalizedProviders)
+      const currentSerialized = serializeStorageProviders(current.managedStorageProviders ?? [])
+      if (nextSerialized !== currentSerialized) {
+        enqueueUpdate('managedStorageProviders', nextSerialized, normalizedProviders)
+      }
+    }
+
     if (updates.length === 0) {
       return current
     }
@@ -309,6 +408,10 @@ export class SystemSettingService {
     const map = {} as SystemSettingValueMap
 
     ;(Object.keys(SYSTEM_SETTING_DEFINITIONS) as SystemSettingDbField[]).forEach((field) => {
+      if (field === 'managedStorageProviders') {
+        ;(map as Record<string, unknown>)[field] = maskStorageProviderSecrets(settings.managedStorageProviders ?? [])
+        return
+      }
       ;(map as Record<string, unknown>)[field] = settings[field]
     })
 
@@ -342,6 +445,51 @@ export class SystemSettingService {
     return map
   }
 
+  private parseManagedStorageProviders(raw: unknown): BuilderStorageProvider[] {
+    if (!raw) {
+      return []
+    }
+
+    if (Array.isArray(raw) || typeof raw === 'object') {
+      try {
+        return parseStorageProviders(JSON.stringify(raw))
+      } catch {
+        return []
+      }
+    }
+
+    if (typeof raw === 'string') {
+      const normalized = raw.trim()
+      if (!normalized) {
+        return []
+      }
+      return parseStorageProviders(normalized)
+    }
+
+    return []
+  }
+
+  private normalizeManagedStorageProvidersPatch(
+    patch: unknown,
+    current: BuilderStorageProvider[],
+  ): BuilderStorageProvider[] {
+    let normalized: string
+    if (typeof patch === 'string') {
+      normalized = patch
+    } else if (patch == null) {
+      normalized = '[]'
+    } else {
+      try {
+        normalized = JSON.stringify(patch)
+      } catch {
+        normalized = '[]'
+      }
+    }
+
+    const incoming = parseStorageProviders(normalized)
+    return mergeStorageProviderSecrets(incoming, current ?? [])
+  }
+
   private extractPlanFieldUpdates(patch: UpdateSystemSettingsInput): PlanFieldUpdateSummary {
     const summary: PlanFieldUpdateSummary = {
       hasUpdates: false,
@@ -608,6 +756,17 @@ const PLAN_PRICING_ENTRY_SCHEMA = z.object({
 
 const BILLING_PLAN_PRICING_SCHEMA = z.record(z.string(), PLAN_PRICING_ENTRY_SCHEMA).default({})
 
+const STORAGE_PLAN_CATALOG_ENTRY_SCHEMA = z.object({
+  name: z.string().trim().min(1),
+  description: z.string().trim().nullable().optional(),
+  capacityBytes: z.number().int().min(0).nullable().optional(),
+  isActive: z.boolean().optional(),
+})
+
+const STORAGE_PLAN_CATALOG_SCHEMA = z.record(z.string(), STORAGE_PLAN_CATALOG_ENTRY_SCHEMA).default({})
+const STORAGE_PLAN_PRODUCTS_SCHEMA = z.record(z.string(), PLAN_PRODUCT_ENTRY_SCHEMA).default({})
+const STORAGE_PLAN_PRICING_SCHEMA = z.record(z.string(), PLAN_PRICING_ENTRY_SCHEMA).default({})
+
 type PlanQuotaUpdateMap = Partial<Record<BillingPlanId, Partial<BillingPlanQuota>>>
 type PlanPricingUpdateMap = Partial<Record<BillingPlanId, Partial<BillingPlanPricing>>>
 type PlanProductUpdateMap = Partial<Record<BillingPlanId, BillingPlanPaymentInfo>>

be/apps/core/src/modules/configuration/system-setting/system-setting.types.ts

@@ -3,8 +3,14 @@ import type {
   BillingPlanPricingConfigs,
   BillingPlanProductConfigs,
 } from 'core/modules/platform/billing/billing-plan.types'
+import type {
+  StoragePlanCatalog,
+  StoragePlanPricingConfigs,
+  StoragePlanProductConfigs,
+} from 'core/modules/platform/billing/storage-plan.types'
 import type { UiSchema } from 'core/modules/ui/ui-schema/ui-schema.type'
 
+import type { BuilderStorageProvider } from '../setting/storage-provider.utils'
 import type { BillingPlanSettingField, SystemSettingDbField, SystemSettingField } from './system-setting.constants'
 
 export interface SystemSettings {
@@ -23,6 +29,11 @@ export interface SystemSettings {
   billingPlanOverrides: BillingPlanOverrides
   billingPlanProducts: BillingPlanProductConfigs
   billingPlanPricing: BillingPlanPricingConfigs
+  storagePlanCatalog: StoragePlanCatalog
+  storagePlanProducts: StoragePlanProductConfigs
+  storagePlanPricing: StoragePlanPricingConfigs
+  managedStorageProvider: string | null
+  managedStorageProviders: BuilderStorageProvider[]
 }
 
 export type SystemSettingValueMap = {