feat(listeners): support for chaining method listeners

This commit is contained in:
xTCry [Vladislav Kh]
2021-08-01 07:31:09 +03:00
parent 0339fe15ae
commit a4cb8df434
4 changed files with 41 additions and 28 deletions

View File

@@ -22,7 +22,8 @@ import { TelegrafModuleOptions } from '../interfaces';
@Injectable()
export class ListenersExplorerService
extends BaseExplorerService
implements OnModuleInit {
implements OnModuleInit
{
private readonly telegrafParamsFactory = new TelegrafParamsFactory();
private bot: Telegraf<any>;
@@ -123,7 +124,7 @@ export class ListenersExplorerService
): void {
const methodRef = prototype[methodName];
const metadata = this.metadataAccessor.getListenerMetadata(methodRef);
if (!metadata) {
if (!metadata || metadata.length < 1) {
return undefined;
}
@@ -133,22 +134,22 @@ export class ListenersExplorerService
methodName,
);
const { method, args } = metadata;
for (const { method, args } of metadata) {
/* Basic callback */
// composer[method](...args, listenerCallbackFn);
/* Basic callback */
// composer[method](...args, listenerCallbackFn);
/* Complex callback return value handing */
composer[method](
...args,
async (ctx: Context, next: Function): Promise<void> => {
const result = await listenerCallbackFn(ctx, next);
if (result) {
await ctx.reply(String(result));
}
// TODO-Possible-Feature: Add more supported return types
},
);
/* Complex callback return value handing */
composer[method](
...args,
async (ctx: Context, next: Function): Promise<void> => {
const result = await listenerCallbackFn(ctx, next);
if (result) {
await ctx.reply(String(result));
}
// TODO-Possible-Feature: Add more supported return types
},
);
}
}
createContextCallback<T extends Record<string, unknown>>(

View File

@@ -2,7 +2,7 @@ import { Injectable } from '@nestjs/common';
import { Reflector } from '@nestjs/core';
import {
SCENE_METADATA,
LISTENER_METADATA,
LISTENERS_METADATA,
UPDATE_METADATA,
} from '../telegraf.constants';
import { ListenerMetadata } from '../interfaces';
@@ -21,8 +21,8 @@ export class MetadataAccessorService {
return !!this.reflector.get(SCENE_METADATA, target);
}
getListenerMetadata(target: Function): ListenerMetadata | undefined {
return this.reflector.get(LISTENER_METADATA, target);
getListenerMetadata(target: Function): ListenerMetadata[] | undefined {
return this.reflector.get(LISTENERS_METADATA, target);
}
getSceneMetadata(target: Function): string | undefined {