chore(core): core-bot and router logic to work with botState

packages/botonic-core/src/core-bot.ts

@@ -6,6 +6,7 @@ import {
   BotonicEvent,
   BotRequest,
   BotResponse,
+  BotState,
   Locales,
   MessageEventAck,
   MessageEventFrom,
@@ -81,26 +82,30 @@ export class CoreBot {
           )
   }
 
-  getString(id: string, session: Session): string {
-    // @ts-ignore
-    return getString(this.locales, session.__locale, id)
+  getString(id: string, botState: BotState): string {
+    if (!botState.locale) {
+      console.error('Locale is not defined')
+      return ''
+    }
+    return getString(this.locales, botState.locale, id)
   }
 
-  setLocale(locale: string, session: Session): void {
-    session.__locale = locale
+  setLocale(locale: string, botState: BotState): void {
+    botState.locale = locale
   }
 
   async input({
     input,
     session,
-    lastRoutePath,
+    botState,
     dataProvider,
   }: BotRequest): Promise<BotResponse> {
-    session = session || {}
-    if (!session.__locale) session.__locale = 'en'
+    if (!botState.locale) botState.locale = 'en'
+    // @ts-ignore
+    const userId = input.userId
+
+    const parsedUserEvent = this.botonicOutputParser.inputToBotonicEvent(input)
 
-    const parsedUserEvent = this.botonicOutputParser.parseFromUserInput(input)
-    const userId = session.user.id
     if (dataProvider) {
       // TODO: Next iterations. Review cycle of commited events to DB when messages change their ACK
       // @ts-ignore
@@ -120,7 +125,7 @@ export class CoreBot {
         'pre',
         input,
         session,
-        lastRoutePath,
+        botState,
         undefined,
         undefined,
         dataProvider
@@ -133,7 +138,7 @@ export class CoreBot {
           ...(await getComputedRoutes(this.routes, {
             input,
             session,
-            lastRoutePath,
+            botState,
           })),
           ...this.defaultRoutes,
         ],
@@ -144,18 +149,19 @@ export class CoreBot {
     const output = (this.router as Router).processInput(
       input,
       session,
-      lastRoutePath
+      botState
     )
+
     const request = {
-      getString: stringId => this.getString(stringId, session),
-      setLocale: locale => this.setLocale(locale, session),
+      getString: stringId => this.getString(stringId, botState),
+      setLocale: locale => this.setLocale(locale, botState),
       session: session || {},
       params: output.params || {},
       input: input,
       plugins: this.plugins,
       defaultTyping: this.defaultTyping,
       defaultDelay: this.defaultDelay,
-      lastRoutePath,
+      botState,
       dataProvider,
     }
 
@@ -170,14 +176,15 @@ export class CoreBot {
       console.error(e)
     }
 
-    lastRoutePath = output.lastRoutePath
+    botState.lastRoutePath = output.botState.lastRoutePath
+
     if (this.plugins) {
       await runPlugins(
         this.plugins,
         'post',
         input,
         session,
-        lastRoutePath,
+        botState,
         response,
         messageEvents,
         dataProvider
@@ -199,13 +206,25 @@ export class CoreBot {
       }
     }
 
-    session.is_first_interaction = false
+    botState.isFirstInteraction = false
+
+    if (dataProvider) {
+      const user = await dataProvider.getUser(userId)
+      if (!user) {
+        // throw error
+      } else {
+        const updatedUser = { ...user, session, botState }
+        // @ts-ignore
+        await dataProvider.updateUser(updatedUser)
+      }
+    }
+    // TODO: return also updatedUser?
     return {
       input,
       response,
       messageEvents,
       session,
-      lastRoutePath,
+      botState,
       dataProvider,
     }
   }

packages/botonic-core/src/data-provider/dynamodb-utils.ts

@@ -49,9 +49,15 @@ export function getUserEntity(table: Table): Entity<any> {
       },
       userId: [SORT_KEY_NAME, 0],
       websocketId: 'string',
+      name: 'string',
+      userName: 'string',
+      channel: 'string',
+      idFromChannel: 'string',
       isOnline: 'boolean',
       route: 'string',
-      session: 'string',
+      session: 'map',
+      botState: 'map',
+      details: 'map',
     },
     table,
   })

packages/botonic-core/src/handoff.ts

@@ -57,7 +57,7 @@ export async function getOpenQueues(
 }
 
 export class HandOffBuilder {
-  _session: SessionWithBotonicAction
+  _botState: any
   _queue: string
   _onFinish: string
   _email: string
@@ -66,8 +66,8 @@ export class HandOffBuilder {
   _caseInfo: string
   _shadowing: boolean
 
-  constructor(session: SessionWithBotonicAction) {
-    this._session = session
+  constructor(botState: any) {
+    this._botState = botState
   }
 
   withQueue(queueNameOrId: string): this {
@@ -112,7 +112,7 @@ export class HandOffBuilder {
 
   async handOff(): Promise<void> {
     return _humanHandOff(
-      this._session,
+      this._botState,
       this._queue,
       this._onFinish,
       this._email,
@@ -154,7 +154,7 @@ interface HubtypeHandoffParams {
   on_finish?: string
 }
 async function _humanHandOff(
-  session: SessionWithBotonicAction,
+  botState: any,
   queueNameOrId = '',
   onFinish: string,
   agentEmail = '',
@@ -185,7 +185,8 @@ async function _humanHandOff(
   if (onFinish) {
     params.on_finish = onFinish
   }
-  session._botonic_action = `create_case:${JSON.stringify(params)}`
+  botState.botonicAction = `create_case:${JSON.stringify(params)}`
+  botState.isHandoff = true
 }
 
 export async function storeCaseRating(
@@ -256,14 +257,14 @@ export async function getAgentVacationRanges(
 }
 
 export function cancelHandoff(
-  session: SessionWithBotonicAction,
+  botState: any,
   typification: string | null = null
 ): void {
   let action = 'discard_case'
   if (typification) action = `${action}:${JSON.stringify({ typification })}`
-  session._botonic_action = action
+  botState.botonicAction = action
 }
 
-export function deleteUser(session: SessionWithBotonicAction): void {
-  session._botonic_action = `delete_user`
+export function deleteUser(botState: any): void {
+  botState.botonicAction = `delete_user`
 }

packages/botonic-core/src/hubtype-service.ts

@@ -2,7 +2,7 @@ import axios, { AxiosResponse } from 'axios'
 import Pusher, { AuthOptions, Channel } from 'pusher-js'
 import Channels from 'pusher-js/types/src/core/channels/channels'
 
-import { Input, SessionUser } from './models'
+import { Input } from './models'
 import { getWebpackEnvVar } from './utils'
 
 interface UnsentInput {
@@ -21,7 +21,7 @@ interface ServerConfig {
 }
 interface HubtypeServiceArgs {
   appId: string
-  user: SessionUser
+  user: any
   lastMessageId: string
   lastMessageUpdateDate: string
   onEvent: any
@@ -50,7 +50,7 @@ const PONG_TIMEOUT = 5 * 1000 // https://pusher.com/docs/channels/using_channels
  */
 export class HubtypeService {
   appId: string
-  user: SessionUser
+  user: any
   lastMessageId: string
   lastMessageUpdateDate: string
   onEvent: any
@@ -213,7 +213,7 @@ export class HubtypeService {
   /**
    * @return {Promise<void>}
    */
-  async postMessage(user: SessionUser, message: any): Promise<void> {
+  async postMessage(user: any, message: any): Promise<void> {
     try {
       // @ts-ignore
       await this.init(user)

packages/botonic-core/src/output-parser/botonic-output-parser.ts

@@ -28,7 +28,7 @@ export class BotonicOutputParser {
    * to be saved. This is, converting a botonic input like: '{id: 'msgId', data: 'rawData', payload: 'somePayload'}'
    * into a BotonicEvent with the expected properties.
    */
-  parseFromUserInput(input: any): Partial<BotonicEvent> {
+  inputToBotonicEvent(input: any): Partial<BotonicEvent> {
     return this.factory.parse(input)
   }
 

packages/botonic-core/src/plugins.ts

@@ -1,5 +1,12 @@
 import { DataProvider } from './data-provider'
-import { BotonicEvent, Input, PluginConfig, RoutePath, Session } from './models'
+import {
+  BotonicEvent,
+  BotState,
+  Input,
+  PluginConfig,
+  RoutePath,
+  Session,
+} from './models'
 
 type PluginMode = 'pre' | 'post'
 
@@ -26,7 +33,7 @@ export async function runPlugins(
   mode: PluginMode,
   input: Input,
   session: Session,
-  lastRoutePath: RoutePath,
+  botState: BotState,
   response: string | null = null,
   messageEvents: Partial<BotonicEvent>[] | null = null,
   dataProvider?: DataProvider
@@ -35,12 +42,12 @@ export async function runPlugins(
     const p = await plugins[key]
     try {
       if (mode === 'pre')
-        await p.pre({ input, session, lastRoutePath, dataProvider })
+        await p.pre({ input, session, botState, dataProvider })
       if (mode === 'post')
         await p.post({
           input,
           session,
-          lastRoutePath,
+          botState,
           response,
           messageEvents,
           dataProvider,