Directline3 API integration

Author: treml

index.js

@@ -1,42 +1,78 @@
+const DirectLine = require('botframework-directlinejs').DirectLine
 const debug = require('debug')('botium-connector-directline3')
 
-global.XMLHttpRequest = require('xhr2');
+global.XMLHttpRequest = require('xhr2')
 
 class BotiumConnectorDirectline3 {
   constructor ({ queueBotSays, caps }) {
-   this.queueBotSays = queueBotSays
-   this.caps = caps
+    this.queueBotSays = queueBotSays
+    this.caps = caps
   }
 
   Validate () {
-   debug('Validate called')
-   return Promise.resolve()
+    debug('Validate called')
+    if (!this.caps['DIRECTLINE3_SECRET']) throw new Error('DIRECTLINE3_SECRET capability required')
+
+    return Promise.resolve()
   }
 
   Build () {
-   debug('Build called')
-   return Promise.resolve()
+    debug('Build called')
+    this.directLine = new DirectLine({
+      secret: this.caps['DIRECTLINE3_SECRET'],
+      webSocket: this.caps['DIRECTLINE3_WEBSOCKET'],
+      pollingInterval: this.caps['DIRECTLINE3_POLLINGINTERVAL']
+    })
+    return Promise.resolve()
   }
 
   Start () {
-   debug('Start called')
-   return Promise.resolve()
+    debug('Start called')
+    this.subscription = this.directLine.activity$
+      .filter(activity => activity.type === 'message' && activity.from.id !== 'me')
+      .subscribe(
+        message => {
+          debug('received message ', message)
+          const botMsg = { sender: 'bot', sourceData: message, messageText: message.text }
+          this.queueBotSays(botMsg)
+        }
+      )
+    return Promise.resolve()
   }
 
   UserSays (msg) {
-   debug('UserSays called, echo back')
-   const botMsg = { sender: 'bot', sourceData: msg.sourceData, messageText: msg.messageText }
-   this.queueBotSays(msg)
+    debug('UserSays called')
+    return new Promise((resolve, reject) => {
+      this.directLine.postActivity({
+        from: { id: msg.sender },
+        type: 'message',
+        text: msg.messageText
+      }).subscribe(
+        id => {
+          debug('Posted activity, assigned ID ', id)
+          resolve()
+        },
+        err => {
+          debug('Error posting activity', err)
+          reject(err)
+        }
+      )
+    })
   }
 
   Stop () {
-   debug('Stop called')
-   return Promise.resolve()
+    debug('Stop called')
+    if (this.subscription) {
+      this.subscription.unsubscribe()
+      this.subscription = null
+    }
+
+    return Promise.resolve()
   }
 
   Clean () {
-   debug('Clean called')
-   return Promise.resolve()
+    debug('Clean called')
+    return Promise.resolve()
   }
 }
 

package.json

@@ -6,7 +6,7 @@
   "module": "dist/botium-connector-directline3-es.js",
   "scripts": {
     "build": "npm run eslint && rollup -c",
-    "eslint": "eslint \"./src/**/*.js\" \"./test/**/*.js\""
+    "eslint": "eslint index.js"
   },
   "repository": {
     "type": "git",

samples/botium.json

@@ -2,7 +2,10 @@
   "botium": {
     "Capabilities": {
       "PROJECTNAME": "Directline3 Plugin Sample",
-      "CONTAINERMODE": "directline3"
+      "CONTAINERMODE": "directline3",
+      "DIRECTLINE3_SECRET": "7O48RCUWWTI.cwA.A9w.XyviXjUVJooJwI6I6zabVQaEAoRK_TIPx50dUazzeE8",
+      "DIRECTLINE3_WEBSOCKET": true,
+      "DIRECTLINE3_POLLINGINTERVAL": 1000
     }
   }
 }

samples/botiumFluent.js

@@ -4,7 +4,8 @@ const driver = new BotDriver()
 
 driver.BuildFluent()
   .Start()
-  .UserSaysText('hello')
+  .WaitBotSaysText(console.log)
+  .UserSaysText('Show me a hero card')
   .WaitBotSaysText(console.log)
   .UserSaysText('book a room')
   .WaitBotSaysText(console.log)