Async configuration does not allow an array of BullModuleOptions[]

[CodebyOmar]

BullModule.forRootAsync({
  import: [PayModule],
  inject: [PayService],
  useFactory: async (payService: PayService) => {
    return [
      {
        name: 'settlement',
        options: {
          redis: {
            port: 6379
          }
       },
       {
        name: 'collation',
        options: {
          redis: {
            port: 6379
          }
        }
      }
    ]  
  }
})

[fwoelffel]

Might be related to #12

[fwoelffel]

Hi @CodebyOmar could you provide some information on the observed behavior?

[CodebyOmar]

I went through the code;

export interface BullModuleOptions {
  name?: string;
  options?: Bull.QueueOptions;
  processors?: BullQueueProcessor[];
}

export interface BullOptionsFactory {
  createBullOptions(): Promise<BullModuleOptions> | BullModuleOptions;
}

export interface BullModuleAsyncOptions extends Pick<ModuleMetadata, 'imports'> {
  name?: string;
  useExisting?: Type<BullOptionsFactory>;
  useClass?: Type<BullOptionsFactory>;
  useFactory?: (...args: any[]) => Promise<BullModuleOptions> | BullModuleOptions;
  inject?: any[];
}

Notice: The function createBullOptions in the interface BullOptionsFactory returns a promise of BullModuleOptions or BullModuleOptions but an array of BullModuleOptions is not specified.

[CodebyOmar]

Has anyone found a solution to this? Its critical to our project right now please.

[fwoelffel]

Hi @CodebyOmar
I've worked on this today and came up with a working implementation of the requested feature. You're right, this should've been done from the beginning.

However, things do not work exactly as suggested by you code sample but rather like this:

BullModule.forRootAsync([
  {
    name: 'settlement',
    imports: [PayModule],
    inject: [PayService],
    useFactory: (payService: PayService) => ({
      options: {
        redis: {
          port: 6379
        }
      }
    })
  },
  {
    name: 'collation',
    imports: [PayModule],
    inject: [PayService],
    useFactory: (payService: PayService) => ({
      options: {
        redis: {
          port: 6379
        }
      }
    })
  },
])

I'll most probably release this tomorrow. I'd like to add some more tests before. Feel free to share your feedback about this implementation since it does not exactly match your expectations.