add promise responses

examples/weather-bot/bot.module.ts

@@ -0,0 +1,7 @@
+import { Module } from "../../packages/common/mod.ts";
+import { WeatherController } from "./weather.controller.ts";
+
+@Module({
+  controllers: [WeatherController],
+})
+export class BotModule {}

examples/weather-bot/main.ts

@@ -0,0 +1,9 @@
+import { TeaFactory } from "../../packages/core/factory.ts";
+import { BotModule } from "./bot.module.ts";
+
+function bootstrap() {
+  const bot = TeaFactory.create(BotModule, "BOT_TOKEN");
+  bot.start();
+}
+
+bootstrap();

examples/weather-bot/weather.controller.ts

@@ -0,0 +1,37 @@
+import {
+  Command,
+  Context,
+  Controller,
+  UpdateType,
+} from "../../packages/common/mod.ts";
+
+const weatherConditions = ["☀️🥵☀️", "❄️☃️❄️"];
+
+@Controller({ updateTypes: [UpdateType.MESSAGE] })
+export class WeatherController {
+  @Command("forecast")
+  async forecast(@Context() context: any) {
+    const randomIndex = getRandomIndex(weatherConditions);
+    if (randomIndex === 0) {
+      context.reply("The air is warming up, get ready to swim");
+    } else {
+      context.reply(
+        "The weather is going to be cold, make sure you have warm clothes",
+      );
+    }
+    await sleep(3000);
+    return context.reply(weatherConditions[randomIndex]);
+  }
+
+  @Command("current")
+  current() {
+    const randomIndex = getRandomIndex(weatherConditions);
+    return Promise.resolve(weatherConditions[randomIndex]);
+  }
+}
+
+const getRandomIndex = (array: unknown[]) =>
+  Math.trunc(Math.random() * array.length);
+
+const sleep = (time: number) =>
+  new Promise((resolve) => setTimeout(resolve, time));

packages/core/controllers/listener-builder.ts

@@ -86,7 +86,7 @@ export class ListenerBuilder {
       callback,
     );
 
-    return (context: Context) => {
+    return async (context: Context) => {
       const canActivate = this.guardsConsumer.tryActivate(
         guards,
         controllerInstance,
@@ -108,7 +108,7 @@ export class ListenerBuilder {
         );
         return;
       }
-      const callbackResponse = this.listenerProxy.call(
+      const callbackResponse = await this.listenerProxy.call(
         controllerInstance,
         callback,
         paramArgs,

packages/core/controllers/listener-proxy.ts

@@ -3,15 +3,15 @@ import { Context } from "../adapters/telegram.abstract.ts";
 import { Controller } from "../../common/interfaces/controllers/controller.interface.ts";
 
 export class ListenerProxy {
-  call(
+  async call(
     controllerInstance: Controller,
     callback: (...args: any) => any,
     paramArgs: any[],
     context: Context,
     exceptionHandler: ExceptionHandler,
   ) {
     try {
-      return callback.call(controllerInstance, ...paramArgs);
+      return await callback.call(controllerInstance, ...paramArgs);
     } catch (err) {
       exceptionHandler.handle(err, context, controllerInstance, callback);
     }