Function parseSubscriptionConfig

apps/sim/lib/workspace-events/subscriptions.ts:100–158

(providerConfig: unknown)

 * Returns null when the config has no recognizable event type.
 */
export function parseSubscriptionConfig(providerConfig: unknown): SimSubscriptionConfig | null {
  const config =
    providerConfig && typeof providerConfig === 'object' && !Array.isArray(providerConfig)
      ? (providerConfig as Record<string, unknown>)
      : {}

  const eventType = config.eventType
  if (
    typeof eventType !== 'string' ||
    !(SIM_EVENT_TYPES as readonly string[]).includes(eventType)
  ) {
    return null
  }

  return {
    eventType: eventType as SimEventType,
    workflowIds: parseStringArray(config.workflowIds),
    consecutiveFailures: parseBoundedNumber(
      config.consecutiveFailures,
      SIM_RULE_DEFAULTS.consecutiveFailures,
      SIM_RULE_BOUNDS.consecutiveFailures
    ),
    failureRatePercent: parseBoundedNumber(
      config.failureRatePercent,
      SIM_RULE_DEFAULTS.failureRatePercent,
      SIM_RULE_BOUNDS.failureRatePercent
    ),
    windowHours: parseBoundedNumber(
      config.windowHours,
      SIM_RULE_DEFAULTS.windowHours,
      SIM_RULE_BOUNDS.windowHours
    ),
    durationThresholdMs: parseBoundedNumber(
      config.durationThresholdMs,
      SIM_RULE_DEFAULTS.durationThresholdMs,
      SIM_RULE_BOUNDS.durationThresholdMs
    ),
    latencySpikePercent: parseBoundedNumber(
      config.latencySpikePercent,
      SIM_RULE_DEFAULTS.latencySpikePercent,
      SIM_RULE_BOUNDS.latencySpikePercent
    ),
    costThresholdCredits: parseBoundedNumber(
      config.costThresholdCredits,
      SIM_RULE_DEFAULTS.costThresholdCredits,
      SIM_RULE_BOUNDS.costThresholdCredits
    ),
    errorCountThreshold: parseBoundedNumber(
      config.errorCountThreshold,
      SIM_RULE_DEFAULTS.errorCountThreshold,
      SIM_RULE_BOUNDS.errorCountThreshold
    ),
    inactivityHours: parseBoundedNumber(
      config.inactivityHours,
      SIM_RULE_DEFAULTS.inactivityHours,
      SIM_RULE_BOUNDS.inactivityHours
    ),
  }