fix(basic.gblib): #307 - Fixed user context in API.

packages/basic.gblib/services/DialogKeywords.ts

@@ -61,7 +61,7 @@ import { json } from 'body-parser';
 /**
  * Default check interval for user replay
  */
- const DEFAULT_HEAR_POLL_INTERVAL = 500;
+const DEFAULT_HEAR_POLL_INTERVAL = 500;
 
 /**
  * Base services of conversation to be called by BASIC.
@@ -226,7 +226,7 @@ export class DialogKeywords {
    *
    * @example x = TODAY
    */
-  public async getToday({ }) {
+  public async getToday({}) {
     let d = new Date(),
       month = '' + (d.getMonth() + 1),
       day = '' + d.getDate(),
@@ -262,28 +262,28 @@ export class DialogKeywords {
    *
    * @example EXIT
    */
-  public async exit({ }) { }
+  public async exit({}) {}
 
   /**
    * Get active tasks.
    *
    * @example list = ACTIVE TASKS
    */
-  public async getActiveTasks({ pid }) { }
+  public async getActiveTasks({ pid }) {}
 
   /**
    * Creates a new deal.
    *
    * @example CREATE DEAL dealname,contato,empresa,amount
    */
-  public async createDeal({ pid, dealName, contact, company, amount }) { }
+  public async createDeal({ pid, dealName, contact, company, amount }) {}
 
   /**
    * Finds contacts in XRM.
    *
    * @example list = FIND CONTACT "Sandra"
    */
-  public async fndContact({ pid, name }) { }
+  public async fndContact({ pid, name }) {}
 
   public getContentLocaleWithCulture(contentLocale) {
     switch (contentLocale) {
@@ -426,10 +426,8 @@ export class DialogKeywords {
    * @example TALK TOLIST (array,member)
    *
    */
-  public async getToLst(pid,array, member) {
+  public async getToLst(pid, array, member) {
-    const {
+    const { min, user } = await DialogKeywords.getProcessInfo(pid);
-      min, user
-    } = await DialogKeywords.getProcessInfo(pid);
 
     if (!array) {
       return '<Empty>';
@@ -456,9 +454,7 @@ export class DialogKeywords {
    *
    */
   public async getHourFromDate(pid, date) {
-    const {
+    const { min, user } = await DialogKeywords.getProcessInfo(pid);
-      min, user
-    } = await DialogKeywords.getProcessInfo(pid);
 
     function addZero(i) {
       if (i < 10) {
@@ -490,7 +486,7 @@ export class DialogKeywords {
    * @example SAVE "contacts.xlsx", name, email, NOW
    *
    */
-  public async getNow({ }) {
+  public async getNow({}) {
     const contentLocale = this.min.core.getParam<string>(
       this.min.instance,
       'Default Content Language',
@@ -565,7 +561,7 @@ export class DialogKeywords {
    *
    */
   public async sendFile({ pid, filename, caption }) {
-    const mobile = await this.userMobile();
+    const mobile = await this.userMobile({pid});
     GBLog.info(`BASIC: SEND FILE (current: ${mobile},filename '${filename}'.`);
     return await this.internalSendFile({ pid, mobile, filename, caption });
   }
@@ -592,18 +588,24 @@ export class DialogKeywords {
     this['id'] = this.sys().getRandomId();
   }
 
+  private async setOption({pid, name, value})
+  {
+    const process = GBServer.globals.processes[pid];
+    let { min, user, params } = await DialogKeywords.getProcessInfo(pid);
+    const sec = new SecService();
+    await sec.setParam(user.userId, name, value);
+    GBLog.info(`BASIC: ${name} = ${value} (botId: ${min.botId})`);
+    return { min, user, params };
+  }
+
   /**
    * Defines the maximum lines to scan in spreedsheets.
    *
    * @example SET MAX LINES 5000
    *
    */
-  public async setMaxLines({ count }) {
+  public async setMaxLines({ pid, count }) {
-    if (this.user) {
+    await this.setOption({pid, name: "maxLines", value: count});
-      // #307 user.basicOptions.maxLines = count;
-    } else {
-      this.maxLines = count;
-    }
   }
 
   /**
@@ -612,8 +614,8 @@ export class DialogKeywords {
    * @example SET MAX COLUMNS 5000
    *
    */
-  public async setMaxColumns({ count }) {
+  public async setMaxColumns({ pid, count }) {
-    // #307 user.basicOptions.maxColumns = count;
+    await this.setOption({pid, name: "setMaxColumns", value: count});
   }
 
   /**
@@ -622,8 +624,9 @@ export class DialogKeywords {
    * @example SET WHOLE WORD ON
    *
    */
-  public async setWholeWord({ on }) {
+  public async setWholeWord({ pid, on }) {
-    // #307 user.basicOptions.wholeWord = (on.trim() === "on");
+    const value = (on.trim() === "on");
+    await this.setOption({pid, name: "wholeWord", value: value});
   }
 
   /**
@@ -632,8 +635,9 @@ export class DialogKeywords {
    * @example SET THEME "themename"
    *
    */
-  public async setTheme({ theme }) {
+  public async setTheme({ pid, theme }) {
-    // #307 user.basicOptions.theme = theme.trim();
+    const value = theme.trim();
+    await this.setOption({pid, name: "theme", value: value});
   }
 
   /**
@@ -642,24 +646,25 @@ export class DialogKeywords {
    * @example SET TRANSLATOR ON | OFF
    *
    */
-  public async setTranslatorOn({ on }) {
+  public async setTranslatorOn({ pid, on }) {
-    // #307 user.basicOptions.translatorOn = (on.trim() === "on");
+    const value = (on.trim() === "on");
+    await this.setOption({pid, name: "translatorOn", value: value});
   }
 
   /**
    * Returns the name of the user acquired by WhatsApp API.
    */
-  public async userName() {
+  public async userName({pid}) {
-    // #307 WhatsappDirectLine.usernames[await this.userMobile()] : 'N/A';
+    let { min, user, params } = await DialogKeywords.getProcessInfo(pid);
-    return this.sys().getRandomId();
+    return user.userName;
   }
 
   /**
    * Returns current mobile number from user in conversation.
    */
-  public async userMobile() {
+  public async userMobile({pid}) {
-    // #307 return GBMinService.userMobile();
+    let { min, user, params } = await DialogKeywords.getProcessInfo(pid);
-    return this.sys().getRandomId();
+    return user.userSystemId;
   }
 
   /**
@@ -668,10 +673,11 @@ export class DialogKeywords {
    * @example MENU
    *
    */
-  public async showMenu({ }) {
+  public async showMenu({}) {
     // https://github.com/GeneralBots/BotServer/issues/237
     // return await beginDialog('/menu');
   }
+
   private static async downloadAttachmentAndWrite(attachment) {
     const url = attachment.contentUrl;
     // https://github.com/GeneralBots/BotServer/issues/195 - '${botId}','uploads');
@@ -730,11 +736,8 @@ export class DialogKeywords {
    *
    */
   public async getHear({ pid, kind, arg }) {
-
     const process = GBServer.globals.processes[pid];
-    let {
+    let { min, user } = await DialogKeywords.getProcessInfo(pid);
-      min, user
-    } = await DialogKeywords.getProcessInfo(pid);
 
     // Handles first arg as an array of args.
 
@@ -765,8 +768,6 @@ export class DialogKeywords {
       // https://github.com/GeneralBots/BotServer/issues/266
 
       if (args && args.length > 1) {
-
-
         // https://github.com/pedroslopez/whatsapp-web.js/issues/1811
         //
         // const list = new List(
@@ -781,7 +782,6 @@ export class DialogKeywords {
         //   'Please select a product'
         // );
 
-
         // let i = 0;
         // await CollectionUtil.asyncForEach(args, async arg => {
         //   i++;
@@ -792,7 +792,6 @@ export class DialogKeywords {
         // const button = new wpp.Buttons(Messages[locale].choices, choices, ' ', ' ');
         // await this.talk(button);
 
-
         GBLog.info(`BASIC: HEAR with [${args.toString()}] (Asking for input).`);
       } else {
         GBLog.info('BASIC: HEAR (Asking for input).');
@@ -852,7 +851,7 @@ export class DialogKeywords {
         const value = extractEntity(text);
 
         if (value === null) {
-          await this.talk({ pid, text: 'Por favor,digite um e-mail válido.' });
+          await this.talk({ pid, text: 'Por favor, digite um e-mail válido.' });
           return await this.getHear({ pid, kind, arg });
         }
 
@@ -865,7 +864,7 @@ export class DialogKeywords {
         const value = extractEntity(text);
 
         if (value === null || value.length != 1) {
-          await this.talk({ pid, text: 'Por favor,digite um nome válido.' });
+          await this.talk({ pid, text: 'Por favor, digite um nome válido.' });
           return await this.getHear({ pid, kind, arg });
         }
 
@@ -878,7 +877,7 @@ export class DialogKeywords {
         const value = extractEntity(text);
 
         if (value === null || value.length != 1) {
-          await this.talk({ pid, text: 'Por favor,digite um número válido.' });
+          await this.talk({ pid, text: 'Por favor, digite um número válido.' });
           return await this.getHear({ pid, kind, arg });
         }
 
@@ -893,7 +892,7 @@ export class DialogKeywords {
         const value = extractEntity(text);
 
         if (value === null || value.length != 1) {
-          await this.talk({ pid, text: 'Por favor,digite uma data no formato 12/12/2020.' });
+          await this.talk({ pid, text: 'Por favor, digite uma data no formato 12/12/2020.' });
           return await this.getHear({ pid, kind, arg });
         }
 
@@ -906,7 +905,7 @@ export class DialogKeywords {
         const value = extractEntity(text);
 
         if (value === null || value.length != 1) {
-          await this.talk({ pid, text: 'Por favor,digite um horário no formato hh:ss.' });
+          await this.talk({ pid, text: 'Por favor, digite um horário no formato hh:ss.' });
           return await this.getHear({ pid, kind, arg });
         }
 
@@ -916,8 +915,7 @@ export class DialogKeywords {
           // https://github.com/GeneralBots/BotServer/issues/307
           if (user.locale === 'en') {
             return text.match(/(?:\d{1,3},)*\d{1,3}(?:\.\d+)?/gi);
-          }
+          } else {
-          else {
             return text.match(/(?:\d{1,3}.)*\d{1,3}(?:\,\d+)?/gi);
           }
           return [];
@@ -926,7 +924,7 @@ export class DialogKeywords {
         const value = extractEntity(text);
 
         if (value === null || value.length != 1) {
-          await this.talk({ pid, text: 'Por favor,digite um valor monetário.' });
+          await this.talk({ pid, text: 'Por favor, digite um valor monetário.' });
           return await this.getHear({ pid, kind, arg });
         }
 
@@ -943,7 +941,7 @@ export class DialogKeywords {
           return await this.getHear({ pid, kind, arg });
         }
         if (!phoneUtil.isPossibleNumber(phoneNumber)) {
-          await this.talk({ pid, text: 'Por favor,digite um número de telefone válido.' });
+          await this.talk({ pid, text: 'Por favor, digite um número de telefone válido.' });
           return await this.getHear({ pid, kind, arg });
         }
 
@@ -1053,24 +1051,23 @@ export class DialogKeywords {
   public static async getProcessInfo(pid: number) {
     const proc = GBServer.globals.processes[pid];
 
-    const min = GBServer.globals.minInstances.filter(p =>
+    const min = GBServer.globals.minInstances.filter(p => p.instance.instanceId == proc.instanceId)[0];
-      p.instance.instanceId == proc.instanceId)[0];
     const sec = new SecService();
     const user = await sec.getUserFromId(min.instance.instanceId, proc.userId);
+    const params = JSON.parse(user.params);
     return {
-      min, user
+      min,
+      user,
+      params
     };
   }
 
-
   /**
    * Talks to the user by using the specified text.
    */
   public async talk({ pid, text }) {
     GBLog.info(`BASIC: TALK '${text}'.`);
-    const {
+    const { min, user } = await DialogKeywords.getProcessInfo(pid);
-      min, user
-    } = await DialogKeywords.getProcessInfo(pid);
     if (user) {
       // TODO: const translate = this.user ? this.user.basicOptions.translatorOn : false;
 
@@ -1089,9 +1086,7 @@ export class DialogKeywords {
   private async internalSendFile({ pid, mobile, filename, caption }) {
     // Handles SEND FILE TO mobile,element in Web Automation.
 
-    const {
+    const { min, user } = await DialogKeywords.getProcessInfo(pid);
-      min, user
-    } = await DialogKeywords.getProcessInfo(pid);
     const element = filename._page ? filename._page : filename.screenshot ? filename : null;
 
     if (element) {

packages/basic.gblib/services/GBVMService.ts

@@ -1035,9 +1035,9 @@ export class GBVMService extends GBService {
     };
 
     sandbox['id'] = dk.sys().getRandomId();
-    sandbox['username'] = await dk.userName();
+    sandbox['username'] = await dk.userName({pid});
-    sandbox['mobile'] = await dk.userMobile();
+    sandbox['mobile'] = await dk.userMobile({pid});
-    sandbox['from'] = await dk.userMobile();
+    sandbox['from'] = await dk.userMobile({pid});
     sandbox['ENTER'] = String.fromCharCode(13);
     sandbox['headers'] = {};
     sandbox['data'] = {};

packages/basic.gblib/services/SystemKeywords.ts

@@ -449,6 +449,11 @@ export class SystemKeywords {
    *
    */
   public async set({ pid, file, address, value }): Promise<any> {
+
+    const {
+      min, user
+    } = await DialogKeywords.getProcessInfo(pid);
+
     // Handles calls for HTML stuff
 
     if (file._javascriptEnabled) {
@@ -463,9 +468,9 @@ export class SystemKeywords {
 
     GBLog.info(`BASIC: Defining '${address}' in '${file}' to '${value}' (SET). `);
 
-    let { baseUrl, client } = await GBDeployer.internalGetDriveClient(this.min);
+    let { baseUrl, client } = await GBDeployer.internalGetDriveClient(min);
 
-    const botId = this.min.instance.botId;
+    const botId = min.instance.botId;
     const path = `/${botId}.gbai/${botId}.gbdata`;
 
     address = address.indexOf(':') !== -1 ? address : address + ':' + address;