muerwre/vault-frontend
1
0
Fork 0
mirror of https://github.com/muerwre/vault-frontend.git synced 2025-05-01 23:56:41 +07:00
Code Packages Activity Actions

tried to make upload sagas

Browse source
This commit is contained in:
muerwre 2019-08-07 15:09:28 +07:00
parent caf85c104f
commit 3872ff5903
9 changed files with 180 additions and 80 deletions
Download patch file Download diff file Expand all files Collapse all files

58
src/redux/uploads/sagas.ts
View file

@ -1,11 +1,11 @@
import { takeEvery, all, spawn, call, put, take, fork, race } from 'redux-saga/effects';
import { UPLOAD_ACTIONS } from '~/redux/uploads/constants';
import { uploadUploadFiles } from './actions';
import { uploadUploadFiles, uploadSetStatus, uploadAddStatus, uploadDropStatus } from './actions';
import { reqWrapper } from '../auth/sagas';
import { createUploader, uploadGetThumb } from '~/utils/uploader';
import { HTTP_RESPONSES } from '~/utils/api';
import { VALIDATORS } from '~/utils/validators';
import { UUID, IFileWithUUID, IResultWithStatus } from '../types';
import { UUID, IFileWithUUID } from '../types';
function* uploadCall({ temp_id, onProgress, file }) {
return yield call(reqWrapper, console.log, { file, onProgress });
@ -14,9 +14,8 @@ function* uploadCall({ temp_id, onProgress, file }) {
function* onUploadProgress(chan) {
while (true) {
const { progress, temp_id }: { progress: number; temp_id: string } = yield take(chan);
console.log('progress', { progress, temp_id });
// replace with the one, that changes upload status with progress
// yield put(inventoryUploadSet(temp_id, { progress }));
yield put(uploadSetStatus(temp_id, { progress }));
}
}
@ -35,52 +34,55 @@ function* uploadWorker(file: File, temp_id: UUID) {
return yield call(promise, { temp_id, file });
}
function* uploadFile({ file, temp_id }: IFileWithUUID): IResultWithStatus<any> {
function* uploadFile({ file, temp_id }: IFileWithUUID) {
if (!file.type || !VALIDATORS.IS_IMAGE_MIME(file.type)) {
return { error: 'File_Not_Image', status: HTTP_RESPONSES.BAD_REQUEST, data: {} };
}
const preview = yield call(uploadGetThumb, file);
// yield put(inventoryUploadAdd( // replace with the one, what adds file upload status
// temp_id,
// {
// ...EMPTY_INVENTORY_UPLOAD,
// preview,
// is_uploading: true,
// type: file.type,
// },
// ));
yield put(
uploadAddStatus(
// replace with the one, what adds file upload status
temp_id,
{
preview,
is_uploading: true,
type: file.type,
}
)
);
const { result, cancel, cancel_editing, save_inventory } = yield race({
result: call(uploadWorker, file, temp_id),
cancel: call(uploadCancelWorker, temp_id),
// subject_cancel: call(uploadSubjectCancelWorker, subject)
// add here CANCEL_UPLOADS worker, that will watch for subject
// cancel_editing: take(UPLOAD_ACTIONS.CANCEL_EDITING),
// save_inventory: take(INVENTORY_ACTIONS.SAVE_INVENTORY),
}) as any;
if (cancel || cancel_editing || save_inventory) {
// return yield put(inventoryUploadDrop(temp_id)); // replace with the one, that will delete file upload status record
return { error: null, status: HTTP_RESPONSES.NOT_FOUND, data: {} };
return yield put(uploadDropStatus(temp_id));
}
const { data, error } = result;
if (error) {
// replace with the one, that changes file upload status to error
// return yield put(inventoryUploadSet(temp_id, { is_uploading: false, error: data.detail || error }));
return { error: null, status: HTTP_RESPONSES.NOT_FOUND, data: {} };
return yield put(
uploadSetStatus(temp_id, { is_uploading: false, error: data.detail || error })
);
}
// replace with the one, that updates upload status with actual data
// yield put(inventoryUploadSet(temp_id, {
// is_uploading: false,
// error: null,
// uuid: data.uuid,
// url: data.url,
// thumbnail_url: data.url,
// }));
yield put(
uploadSetStatus(temp_id, {
is_uploading: false,
error: null,
uuid: data.uuid,
url: data.url,
thumbnail_url: data.url,
})
);
return { error: null, status: HTTP_RESPONSES.CREATED, data: {} }; // add file here as data
}