107 lines
2.9 KiB
JavaScript
107 lines
2.9 KiB
JavaScript
import * as FileSystem from "expo-file-system";
|
|
import { all, call, put, select, takeLatest } from "redux-saga/effects";
|
|
import { handleUpload } from "../../util/document-upload.utility";
|
|
import {
|
|
uploadPhotosFailure,
|
|
uploadPhotosSuccess,
|
|
removeAllPhotos,
|
|
} from "./photos.actions";
|
|
import PhotosActionTypes from "./photos.types";
|
|
|
|
export function* onRemovePhotos() {
|
|
yield takeLatest(PhotosActionTypes.REMOVE_PHOTOS, removePhotosAction);
|
|
}
|
|
export function* removePhotosAction({ payload: photoIdsToRemove }) {
|
|
try {
|
|
const photos = yield select((state) => state.photos.photos);
|
|
const fps = photos
|
|
.filter((p) => !photoIdsToRemove.includes(p.id))
|
|
.map((p) => p.uri);
|
|
|
|
const all = [];
|
|
fps.forEach((f) => all.push(FileSystem.deleteAsync(f)));
|
|
|
|
yield Promise.all(all);
|
|
} catch (error) {
|
|
console.log("Saga Error: removePhotos", error);
|
|
}
|
|
}
|
|
|
|
export function* onRemoveAllPhotos() {
|
|
yield takeLatest(PhotosActionTypes.REMOVE_ALL_PHOTOS, removeAllPhotosAction);
|
|
}
|
|
export function* removeAllPhotosAction() {
|
|
try {
|
|
//Physically delete all photosSagas.
|
|
const fps = (yield FileSystem.readDirectoryAsync(
|
|
FileSystem.documentDirectory + "photos"
|
|
)).map((f) => {
|
|
return FileSystem.documentDirectory + "photos/" + f;
|
|
});
|
|
const all = [];
|
|
fps.forEach((f) => all.push(FileSystem.deleteAsync(f)));
|
|
yield Promise.all(all);
|
|
|
|
console.log("All photos deleted.");
|
|
} catch (error) {
|
|
console.log("Saga Error: onRemoveAllPhotos", error);
|
|
}
|
|
}
|
|
|
|
export function* onUploadAllPhotos() {
|
|
yield takeLatest(
|
|
PhotosActionTypes.UPLOAD_ALL_PHOTOS_START,
|
|
uploadAllPhotosAction
|
|
);
|
|
}
|
|
|
|
export function* uploadAllPhotosAction() {
|
|
try {
|
|
const photos = yield select((state) => state.photos.photos);
|
|
const bodyshop = yield select((state) => state.user.bodyshop);
|
|
const user = yield select((state) => state.user);
|
|
const actions = [];
|
|
photos.forEach(function (p) {
|
|
actions.push(
|
|
call(
|
|
handleUpload,
|
|
...[
|
|
{
|
|
uri: p.uri,
|
|
onError: handleOnError,
|
|
onProgress: handleOnProgress,
|
|
onSuccess: handleOnSuccess,
|
|
},
|
|
{
|
|
bodyshop: bodyshop,
|
|
jobId: p.jobId,
|
|
uploaded_by: user.currentUser.email,
|
|
photo: p,
|
|
},
|
|
]
|
|
)
|
|
);
|
|
});
|
|
yield all(actions);
|
|
yield put(removeAllPhotos());
|
|
yield put(uploadPhotosSuccess());
|
|
} catch (error) {
|
|
console.log("Saga Error: uploadAllPhotosAction", error);
|
|
yield put(uploadPhotosFailure(error));
|
|
}
|
|
}
|
|
|
|
function handleOnError(...props) {
|
|
console.log("HandleOnError", props);
|
|
}
|
|
function handleOnProgress(...props) {
|
|
console.log("HandleOnProgress", props);
|
|
}
|
|
function handleOnSuccess(...props) {
|
|
console.log("handleOnSuccess", props);
|
|
}
|
|
|
|
export function* photosSagas() {
|
|
yield all([call(onRemoveAllPhotos), call(onUploadAllPhotos)]);
|
|
}
|