refactor(capture): expose an Event Emitter API

src/services/capture.js

@@ -1,16 +1,22 @@
-import {
+import EventEmitter from 'eventemitter3'
-  GIF_WIDTH,
-  GIF_HEIGHT,
-  GIF_FRAME_RATE
-} from '/constants.js'
 
 import {
   makeRectangle,
   crop
 } from '/services/rectangle.js'
 
-export function capture (commit, mediaStream, duration) {
+import {
-  return new Promise((resolve, reject) => {
+  GIF_WIDTH,
+  GIF_HEIGHT,
+  GIF_FRAME_RATE
+} from '/constants.js'
+
+
+
+export function capture (mediaStream, duration) {
+  const emitter = new EventEmitter()
+
+  Promise.resolve().then(() => {
     const video = document.createElement('video')
     video.autoplay = true
     video.setAttribute('playsinline', '')
@@ -40,8 +46,6 @@ export function capture (commit, mediaStream, duration) {
 
       const intervalId = setInterval(() => {
         if (imageDataList.length < totalFrames) {
-          console.log(`Capturing frame ${imageDataList.length + 1} / ${totalFrames}`)
-
           canvasContext.drawImage(
             video,
             soureRectangle.x,
@@ -63,11 +67,11 @@ export function capture (commit, mediaStream, duration) {
 
           imageDataList.push(imageData)
 
-          commit('updateCaptureState', imageDataList.length / totalFrames * 100)
+          emitter.emit('progress', imageDataList.length / totalFrames)
         } else {
           clearInterval(intervalId)
 
-          resolve({
+          emitter.emit('done', {
             imageDataList,
             imageWidth: GIF_WIDTH,
             imageHeight: GIF_HEIGHT,
@@ -77,4 +81,7 @@ export function capture (commit, mediaStream, duration) {
       }, delayTime)
     })
   })
+  .catch(error => emitter.emit('error', error))
+
+  return emitter;
 }

src/store.js

@@ -111,14 +111,17 @@ export default new Vuex.Store({
     },
     capture ({ commit, dispatch, state }) {
       commit('startCapture')
+      const capturing = capture(state.mediaStream, state.timer.selected * 1000)
 
-      capture(commit, state.mediaStream, state.timer.selected * 1000)
+      capturing.once('error', error => console.error(error))
-        .then(captureData => {
+
-          commit('stopCapture')
+      capturing.on('progress', value => commit('updateCaptureState', Math.round(value * 100)))
-          commit('updateCaptureState', 0)
+
-          dispatch('encode', captureData)
+      capturing.once('done', captureData => {
-        })
+        commit('stopCapture')
-        .catch(error => console.error(error))
+        commit('updateCaptureState', 0)
+        dispatch('encode', captureData)
+      })
     },
     encode ({ commit }, captureData) {
       commit('startEncoding')