Refactor download object and bulk action components (#5546)

browser/app/js/objects/actions.js

@@ -22,8 +22,9 @@ import {
   sortObjectsByDate
 } from "../utils"
 import { getCurrentBucket } from "../buckets/selectors"
-import { getCurrentPrefix } from "./selectors"
+import { getCurrentPrefix, getCheckedList } from "./selectors"
 import * as alertActions from "../alert/actions"
+import { minioBrowserPrefix } from "../constants"
 
 export const SET_LIST = "objects/SET_LIST"
 export const APPEND_LIST = "objects/APPEND_LIST"
@@ -32,6 +33,9 @@ export const SET_SORT_BY = "objects/SET_SORT_BY"
 export const SET_SORT_ORDER = "objects/SET_SORT_ORDER"
 export const SET_CURRENT_PREFIX = "objects/SET_CURRENT_PREFIX"
 export const SET_SHARE_OBJECT = "objects/SET_SHARE_OBJECT"
+export const CHECKED_LIST_ADD = "objects/CHECKED_LIST_ADD"
+export const CHECKED_LIST_REMOVE = "objects/CHECKED_LIST_REMOVE"
+export const CHECKED_LIST_RESET = "objects/CHECKED_LIST_RESET"
 
 export const setList = (objects, marker, isTruncated) => ({
   type: SET_LIST,
@@ -119,6 +123,7 @@ export const selectPrefix = prefix => {
   return function(dispatch, getState) {
     dispatch(setCurrentPrefix(prefix))
     dispatch(fetchObjects())
+    dispatch(resetCheckedList())
     const currentBucket = getCurrentBucket(getState())
     history.replace(`/${currentBucket}/${prefix}`)
   }
@@ -160,6 +165,16 @@ export const removeObject = object => ({
   object
 })
 
+export const deleteCheckedObjects = () => {
+  return function(dispatch, getState) {
+    const checkedObjects = getCheckedList(getState())
+    for (let i = 0; i < checkedObjects.length; i++) {
+      dispatch(deleteObject(checkedObjects[i]))
+    }
+    dispatch(resetCheckedList())
+  }
+}
+
 export const shareObject = (object, days, hours, minutes) => {
   return function(dispatch, getState) {
     const currentBucket = getCurrentBucket(getState())
@@ -206,3 +221,112 @@ export const hideShareObject = (object, url) => ({
   object: "",
   url: ""
 })
+
+export const downloadObject = object => {
+  return function(dispatch, getState) {
+    const currentBucket = getCurrentBucket(getState())
+    const currentPrefix = getCurrentPrefix(getState())
+    const objectName = `${currentPrefix}${object}`
+    const encObjectName = encodeURI(objectName)
+    if (web.LoggedIn()) {
+      return web
+        .CreateURLToken()
+        .then(res => {
+          const url = `${
+            window.location.origin
+          }${minioBrowserPrefix}/download/${currentBucket}/${encObjectName}?token=${
+            res.token
+          }`
+          window.location = url
+        })
+        .catch(err => {
+          dispatch(
+            alertActions.set({
+              type: "danger",
+              message: err.message
+            })
+          )
+        })
+    } else {
+      const url = `${
+        window.location.origin
+      }${minioBrowserPrefix}/download/${currentBucket}/${encObjectName}?token=''`
+      window.location = url
+    }
+  }
+}
+
+export const checkObject = object => ({
+  type: CHECKED_LIST_ADD,
+  object
+})
+
+export const uncheckObject = object => ({
+  type: CHECKED_LIST_REMOVE,
+  object
+})
+
+export const resetCheckedList = () => ({
+  type: CHECKED_LIST_RESET
+})
+
+export const downloadCheckedObjects = () => {
+  return function(dispatch, getState) {
+    const state = getState()
+    const req = {
+      bucketName: getCurrentBucket(state),
+      prefix: getCurrentPrefix(state),
+      objects: getCheckedList(state)
+    }
+    if (!web.LoggedIn()) {
+      const requestUrl = location.origin + "/minio/zip?token=''"
+      downloadZip(requestUrl, req, dispatch)
+    } else {
+      return web
+        .CreateURLToken()
+        .then(res => {
+          const requestUrl = `${
+            location.origin
+          }${minioBrowserPrefix}/zip?token=${res.token}`
+          downloadZip(requestUrl, req, dispatch)
+        })
+        .catch(err =>
+          dispatch(
+            alertActions.set({
+              type: "danger",
+              message: err.message
+            })
+          )
+        )
+    }
+  }
+}
+
+const downloadZip = (url, req, dispatch) => {
+  var anchor = document.createElement("a")
+  document.body.appendChild(anchor)
+
+  var xhr = new XMLHttpRequest()
+  xhr.open("POST", url, true)
+  xhr.responseType = "blob"
+
+  xhr.onload = function(e) {
+    if (this.status == 200) {
+      dispatch(resetCheckedList())
+      var blob = new Blob([this.response], {
+        type: "octet/stream"
+      })
+      var blobUrl = window.URL.createObjectURL(blob)
+      var separator = req.prefix.length > 1 ? "-" : ""
+
+      anchor.href = blobUrl
+      anchor.download =
+        req.bucketName + separator + req.prefix.slice(0, -1) + ".zip"
+
+      anchor.click()
+      window.URL.revokeObjectURL(blobUrl)
+      anchor.remove()
+    }
+  }
+  xhr.send(JSON.stringify(req))
+}