fix: move redis url env check to runtime & allow to pass by arg

Author: EastSun5566

src/api.js

@@ -16,8 +16,6 @@ import * as time from 'lib0/time'
 const logWorker = logging.createModuleLogger('@y/redis/api/worker')
 // const logApi = logging.createModuleLogger('@y/redis/api')
 
-export const redisUrl = env.ensureConf('ysr-redis')
-
 let ydocUpdateCallback = env.getConf('ydoc-update-callback')
 if (ydocUpdateCallback != null && ydocUpdateCallback.slice(-1) !== '/') {
   ydocUpdateCallback += '/'
@@ -103,7 +101,7 @@ export class Api {
    * @param {string=} prefix
    * @param {string=} url
    */
-  constructor (store, prefix = 'y', url = redisUrl) {
+  constructor (store, prefix = 'y', url) {
     this.store = store
     this.prefix = prefix
     this.consumername = random.uuidv4()
@@ -120,7 +118,7 @@ export class Api {
     this.redisWorkerGroupName = this.prefix + ':worker'
     this._destroyed = false
     this.redis = redis.createClient({
-      url,
+      url: url || env.ensureConf('ysr-redis'),
       // scripting: https://github.com/redis/node-redis/#lua-scripts
       scripts: {
         addMessage: redis.defineScript({

src/socketio.js

@@ -35,10 +35,11 @@ class YSocketIOServer {
  * @param {import('./storage.js').AbstractStorage} store
  * @param {Object} conf
  * @param {string} [conf.redisPrefix]
+ * @param {string} [conf.redisUrl]
  * @param {import('./y-socket-io/y-socket-io.js').YSocketIOConfiguration['authenticate']} conf.authenticate
  */
-export const registerYSocketIOServer = async (io, store, conf) => {
-  const app = new YSocketIO(io, { authenticate: conf.authenticate })
-  const { client, subscriber } = await app.initialize(store, conf)
+export const registerYSocketIOServer = async (io, store, { authenticate, redisUrl, redisPrefix }) => {
+  const app = new YSocketIO(io, { authenticate })
+  const { client, subscriber } = await app.initialize(store, { redisUrl, redisPrefix })
   return new YSocketIOServer(app, client, subscriber)
 }