1 files changed, 75 insertions, 0 deletions
diff --git a/client/faceAnalysis/faceAnalysis.actions.js b/client/faceAnalysis/faceAnalysis.actions.js
new file mode 100644
index 00000000..90d7156f
--- /dev/null
+++ b/client/faceAnalysis/faceAnalysis.actions.js
@@ -0,0 +1,75 @@
+// import fetchJsonp from 'fetch-jsonp'
+import * as types from '../types'
+// import { hashPath } from '../util'
+import { store } from '../store'
+import { get, post } from '../util'
+// import querystring from 'query-string'
+
+// urls
+
+const url = {
+  upload: (dataset) => process.env.API_HOST + '/api/dataset/' + dataset + '/face',
+}
+export const publicUrl = {
+}
+
+// standard loading events
+
+const loading = (tag, offset) => ({
+  type: types.faceAnalysis.loading,
+  tag,
+  offset
+})
+const loaded = (tag, data, offset = 0) => ({
+  type: types.faceAnalysis.loaded,
+  tag,
+  data,
+  offset
+})
+const error = (tag, err) => ({
+  type: types.faceAnalysis.error,
+  tag,
+  err
+})
+
+// search UI functions
+
+export const updateOptions = opt => dispatch => {
+  dispatch({ type: types.faceAnalysis.update_options, opt })
+}
+
+// API functions
+
+export const upload = (payload, file) => dispatch => {
+  // const { options } = store.getState().faceAnalysis
+  const tag = 'result'
+  const fd = new FormData()
+  fd.append('query_img', file)
+  // fd.append('limit', options.perPage)
+  // if (!query) {
+  dispatch(loading(tag))
+  // }
+  post(url.upload(payload.dataset), fd)
+    .then(data => {
+      dispatch(loaded(tag, data))
+    })
+    .catch(err => dispatch(error(tag, err)))
+}
+
+// task polling
+
+const POLL_DELAY = 500
+let pollTimeout = null
+
+export const poll = (payload, taskURL) => dispatch => {
+  const tag = 'poll'
+  clearTimeout(pollTimeout)
+  dispatch(loading(tag))
+  get(taskURL)
+    .then(data => {
+      dispatch(loaded(tag, data))
+      // check if complete
+      pollTimeout = setTimeout(() => poll(payload, taskURL), POLL_DELAY)
+    })
+    .catch(err => dispatch(error(tag, err)))
+}