使用 Redux-Thunk / Axios 从 onUploadProgress 事件调度动作

Dispatching action from onUploadProgress event using Redux-Thunk / Axios

以下代码上传文件没有问题,并按预期响应成功或失败,但是,我无法弄清楚如何从 onUploadProgress 事件调度我的 uploadFileProgress 操作。我可以 console.log 进度/百分比,当我尝试将调度包装在 IIFE 中时,我触发了调度不是函数错误。希望这是我遗漏的一个小问题。提前致谢!

export function uploadFile(values, callback = () => {}) {
  const uploadFileData = new FormData();
  uploadFileData.append('fileName', values.fileName);
  uploadFileData.append('file', values.file);
  uploadFileData.append('file', {
    filename: values.filename,
    contentType: values.contentType,
  });
  const uploadProgress = {
    onUploadProgress: (ProgressEvent) => {
      let progressData = 0;
      const totalLength = ProgressEvent.lengthComputable ? ProgressEvent.total : ProgressEvent.target.getResponseHeader('content-length') || ProgressEvent.target.getResponseHeader('x-decompressed-content-length');
      if (totalLength !== null) {
        progressData = Math.round((ProgressEvent.loaded * 100) / totalLength);
      }
      return function action(dispatch) {
        dispatch(uploadFileUpload(progressData));
      };
    },
  };
  const configPlusProgress = Object.assign(uploadProgress, config);
  const request = () => axios.post(myURL, uploadFileData, configPlusProgress);
  return function action(dispatch) {
    dispatch(uploadFileLoading(true));
    return request()
      .then((response) => {
        if (response.status !== 201) {
          dispatch(uploadFileFail());
          throw Error(response.statusText);
        }
        dispatch(uploadFileLoading(false));
        return response;
      })
      .then(response => dispatch(uploadFileSuccess(response)))
      .then(() => callback())
      .catch(err => dispatch(uploadFileFail(err)));
  };
}

我无法完全修复您的代码,但这是一个基本函数,其中 redux-thunk 执行异步操作并使用操作。

const doSomeAsyncStuff = () =>
    async ( dispatch ) => {
         try {
             const response = await someAsyncStuff();
             return dispatch( someSuccessAction( response.data );
         } catch ( error ) {
             return dispatch( someFailureAction( err );
         }
    }

当然redux-thunk必须要加上中间件

为什么要从 onUploadProgress 函数返回一个函数

return function action(dispatch) {
    dispatch(uploadFileUpload(progressData));
  };

你可以

dispatch(uploadFileUpload(progressData));

将您的请求配置移动到返回的函数中(其中 dispatch 函数将可访问):

export function uploadFile(values, callback = () => {}) {
  const uploadFileData = new FormData();
  uploadFileData.append('fileName', values.fileName);
  uploadFileData.append('file', values.file);
  uploadFileData.append('file', {
    filename: values.filename,
    contentType: values.contentType,
  });
  return function action(dispatch) {
    const uploadProgress = {
      onUploadProgress: (ProgressEvent) => {
        let progressData = 0;
        const totalLength = ProgressEvent.lengthComputable ? ProgressEvent.total : ProgressEvent.target.getResponseHeader('content-length') || ProgressEvent.target.getResponseHeader('x-decompressed-content-length');
        if (totalLength !== null) {
          progressData = Math.round((ProgressEvent.loaded * 100) / totalLength);
        }

        dispatch(uploadFileUpload(progressData));
      },
    };
    const configPlusProgress = Object.assign(uploadProgress, config);
    const request = () => axios.post(myURL, uploadFileData, configPlusProgress);

    dispatch(uploadFileLoading(true));
    return request()
      .then((response) => {
        if (response.status !== 201) {
          dispatch(uploadFileFail());
          throw Error(response.statusText);
        }
        dispatch(uploadFileLoading(false));
        return response;
      })
      .then(response => dispatch(uploadFileSuccess(response)))
      .then(() => callback())
      .catch(err => dispatch(uploadFileFail(err)));
  };
}

另外 onUploadProgress 应该只是 dipatch 上传进度事件。