Function createPubSubChannel

apps/sim/lib/events/pubsub.ts:140–156

(config: PubSubChannelConfig)

}

export function createPubSubChannel<T>(config: PubSubChannelConfig): PubSubChannel<T> {
  const redisUrl = env.REDIS_URL
  if (!redisUrl) return new LocalPubSubChannel<T>(config)

  // Resolve config-derived defaults outside the try so a missing
  // REDIS_TLS_SERVERNAME (config error) surfaces instead of silently degrading
  // to the in-process EventEmitter — that would break cross-replica pub/sub.
  const connectionDefaults = getRedisConnectionDefaults(redisUrl)

  try {
    logger.info(`${config.label}: Using Redis`)
    return new RedisPubSubChannel<T>(redisUrl, connectionDefaults, config)
  } catch (err) {
    logger.error(`Failed to create Redis ${config.label}, falling back to local:`, err)
    return new LocalPubSubChannel<T>(config)
  }
}