Merge pull request #26 from codigoencasa/feature-perf/add-telegram-events

Feature perf/add telegram events

Author: leifermendez

packages/gemini/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@builderbot-plugins/gemini-layer",
-  "version": "0.0.2",
+  "version": "0.0.2-alpha.1",
   "description": "Bot plugins for builderbot",
   "keywords": [],
   "author": "Elimeleth capuano <elimelethcapuano@gmail.com>",

packages/gemini/src/layer.ts

@@ -43,7 +43,15 @@ export const geminiLayer = async (geminiOpts: Partial<GeminiOpts>, ...bot: AnyBo
         })
 
         const answer = await model.invoke([question])
-        return await methods.flowDynamic(answer?.content as string)
+
+        if (geminiOpts?.cb) {
+            await methods.state.update({ answer: answer?.content as string })
+            await geminiOpts.cb(ctx, methods)
+
+            return 
+        }else {
+            return await methods.flowDynamic(answer?.content as string)
+        }
     }
 
     const SYSTEM = QA_PROMPT.replaceAll('{language}', 'spanish')
@@ -77,8 +85,13 @@ export const geminiLayer = async (geminiOpts: Partial<GeminiOpts>, ...bot: AnyBo
     await handleHistory([question, answer], methods.state)
 
     if (geminiOpts?.cb) {
+        await methods.state.update({ answer: answer?.content as string })
         await geminiOpts.cb(ctx, methods)
+
+        return 
+    }else {
+        return await methods.flowDynamic(answer?.content as string)
     }
 
-    return await methods.flowDynamic(answer?.content as string)
+    
 }

packages/telegram/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@builderbot-plugins/telegram",
-  "version": "1.0.0",
+  "version": "1.0.0-alpha.1",
   "description": "An telegram provider for Bot plugins framework",
   "main": "dist/index.cjs",
   "types": "dist/index.d.ts",

packages/telegram/src/provider.ts

@@ -66,12 +66,20 @@ class TelegramProvider extends ProviderClass {
 
           // Evaluamos si trae algún tipo de contendio que no sea text
           if (
-            ['photo', 'document', 'video', 'sticker']
+            ['photo', 'video']
               .some((prop) => prop in Object(messageCtx?.update?.message))
           ) {
             payload.body = utils.generateRefProvider('_event_media_')
           }
 
+          if (messageCtx?.update?.message?.location) {
+            payload.body = utils.generateRefProvider('_event_location_')
+          }
+
+          if (messageCtx?.update?.message?.document) {
+            payload.body = utils.generateRefProvider('_event_document_')
+          }
+
           // @ts-ignore
           this.emit('message', payload)
         },
@@ -140,6 +148,7 @@ class TelegramProvider extends ProviderClass {
       provider: this.vendor,
       blacklist: opts.blacklist,
       dispatch: (customEvent, payload) => {
+        // @ts-ignore
         this.emit('message', {
           body: utils.setEvent(customEvent),
           name: payload.name,