Listens for links, chat complete a video if that's where the link points

builtins/__tests__/core.spec.js

@@ -379,6 +379,24 @@ describe('core', () => {
     })
   })
 
+  describe('media links', () => {
+    it('recognize vimeo link', done => {
+      core.userAgent.emit('SET_STAGED_MESSAGE', {message: {text: 'https://vimeo.com/channels/staffpicks/182359265'}, tag: 123})
+      setImmediate(() => {
+        const result = [{media: {type: 'video', url: 'https://fpdl.vimeocdn.com/vimeo-prod-skyfire-std-us/01/1471/7/182359265/598591373.mp4?token=580bd041_0x7c0f833a1498c994291875b53acdb7a682c60bb3', size: {height: 1080, width: 1920}}}]
+        expect(core.userAgent.emit).toHaveBeenCalledWith('SET_CHAT_COMPLETE_RESULTS', {results: result, replyTag: 123})
+      })
+    })
+
+    it('recognize instagram link', done => {
+      core.userAgent.emit('SET_STAGED_MESSAGE', {message: {text: 'https://www.instagram.com/p/5XcsWuERgS/?taken-by=azaaza'}, tag: 123})
+      setImmediate(() => {
+        const result = [{media: {type: "video", url: 'https://scontent.cdninstagram.com/t50.2886-16/11773248_1618146288461442_1339867767_n.mp4', size: {height: 640, width: 640}}}]
+        expect(core.userAgent.emit).toHaveBeenCalledWith('SET_CHAT_COMPLETE_RESULTS', {results: result, replyTag: 123})
+      })
+    })
+  })
+
   describe('emoji tokens', () => {
     it('recognizes smile', done => {
       core.userAgent.emit('SET_STAGED_MESSAGE', {message: {text: 'hello :smile:'}, tag: 123})

builtins/core.other.js

@@ -82,6 +82,59 @@ feature.listen({
   }
 })
 
+// Media Picker
+// Paste in a URL and if we understand it, show a chat complete to embed
+// the URL
+
+feature.listen({
+  to: 'link',
+  on({url}) {
+    // Savedeo seems to 500 error with https urls
+    const videoURL = url.replace(/https/, 'http')
+
+    return fetch('https://savedeo.p.mashape.com/download', {
+      method: 'POST',
+      body: `url=${videoURL}`,
+      headers: {
+        'X-Mashape-Key': '249RMQR2QbmshxAArl8lInJnrDM0p1Tgt3UjsnXmcTbcTqqMLp',
+        'Content-Type': 'application/x-www-form-urlencoded'
+      }})
+    .then(response => response.json())
+    .then(mediaData => {
+      const mp4s = mediaData.formats.filter(m => m.ext === 'mp4')
+      const mp3s = mediaData.formats.filter(m => m.ext === 'mp3')
+
+      if (mp4s.length !== 0) {
+        const mp4 = mp4s[0]
+        // Instagram videos don't have a height/width in their JSON
+        // Could parse it out from the format field, but being lazy.
+        const size = {height: mp4.height || 640, width: mp4.width || 640}
+
+        // The link format for YouTube doesn't include an .mp4 at the end, which
+        // means Other Chat doesn't know how to display it.
+        //
+        // @tony suggests we use {stageMessage: attachments[]} in the LinkListener
+        // but currently that doesn't seem to be getting called.
+
+        return {
+          chatCompletions: [{media: {type: 'video', url: mp4.url, size}}]
+        }
+      }
+
+      else if (mp3s.length !== 0) {
+        return {
+          chatCompletions: [
+            {media: {type: 'image', url: mediaData.thumbnail, size: {height: 100, width: 100}}},
+            {media: {type: 'audio', url: mp3s[0].url}}
+          ]
+        }
+      }
+
+      return {chatCompletions: []}
+    })
+  }
+})
+
 // Emoji tokens
 const emoji = getEmoji()
 feature.listen({

lib/Feature.js

@@ -1,9 +1,12 @@
 import * as Events from './Events'
 import Chatternet from './Chatternet'
+
 import CommandListener from './CommandListener'
+import LinkListener from './LinkListener'
 import MentionListener from './MentionListener'
 import TokenListener from './TokenListener'
 import WordListener from './WordListener'
+
 import {environment} from './environment'
 import {userAgent} from './userAgent'
 
@@ -75,6 +78,7 @@ class Feature {
     if (to.commands) this._listeners.push(new CommandListener({commands: to.commands, on}))
     if (to.words) this._listeners.push(new WordListener({words: to.words, on}))
     if (to.tokens) this._listeners.push(new TokenListener({tokens: to.tokens, on}))
+    if (to === 'link') this._listeners.push(new LinkListener({on}))
     if (!this._userAgent) {
       this._userAgent = userAgent
       this._userAgent.on(Events.ACTIVATE_CHAT_COMPLETE_RESULT, event => {

lib/LinkListener.js

@@ -0,0 +1,50 @@
+import Listener from './Listener'
+
+/**
+ * Listens for URLS entered by the user. Matches to end of string only.
+ *
+ * @inheritdoc
+ */
+
+const endingURLRegexp = /((http[s]?|ftp):\/)?\/?([^:\/\s]+)((\/\w+)*\/)([\w\-\.]+[^#?\s]+)(.*)?(#[\w\-]+)?$/
+
+class LinkListener extends Listener {
+  /**
+   * @callback LinkListener#onCallback
+   * @return {?(Promise|Listener~Result)} - The resulting action that the
+   *     user agent should take in response to this ;oml.
+   */
+
+  /**
+   * @param {LinkListener#onCallback} on - Called when one a link is found.
+   */
+  constructor({on}) {
+    super()
+    this._on = on
+  }
+
+  onActivateChatCompleteResult(action, result, message) {
+    // TODO: This does not seem to get called?
+    // That is, adding a console.log('boom') will not print 'boom'
+    // and adding a return doesn't effect behavior.
+    if (action !== 'default' || !result.text) return null
+    return {stagedMessage: {text: result.text}}
+  }
+
+  onSetStagedMessage(message) {
+    // Get text typed so far
+    const {text} = message
+
+    const match = text.match(endingURLRegexp)
+    const linkURL = match ? match[0] : null
+
+    if (linkURL && !linkURL.match(/ /)) {
+      const result = this._on({url: linkURL})
+      return result instanceof Promise ? result : Promise.resolve(result)
+    }
+
+    return Promise.resolve({chatCompletions: []})
+  }
+}
+
+export default LinkListener