93 lines
2.3 KiB
TypeScript
93 lines
2.3 KiB
TypeScript
import axios from "axios";
|
|
import {
|
|
IFolderData,
|
|
IExtractedComicBookCoverFile,
|
|
} from "../../server/interfaces/folder.interface";
|
|
import { API_BASE_URI, SOCKET_BASE_URI } from "../constants/endpoints";
|
|
import { io } from "socket.io-client";
|
|
import {
|
|
IMS_COMICBOOK_METADATA_FETCHED,
|
|
IMS_SOCKET_CONNECTION_CONNECTED,
|
|
IMS_RECENT_COMICS_FETCHED,
|
|
} from "../constants/action-types";
|
|
|
|
export async function walkFolder(path: string): Promise<Array<IFolderData>> {
|
|
return axios
|
|
.request<Array<IFolderData>>({
|
|
url: "http://localhost:3000/api/import/walkFolders",
|
|
method: "POST",
|
|
data: {
|
|
basePathToWalk: path,
|
|
},
|
|
transformResponse: (r: string) => JSON.parse(r),
|
|
})
|
|
.then((response) => {
|
|
const { data } = response;
|
|
return data;
|
|
})
|
|
.catch((error) => error);
|
|
}
|
|
|
|
export const fetchComicBookMetadata = (options) => async (dispatch) => {
|
|
const extractionOptions = {
|
|
sourceFolder: options,
|
|
extractTarget: "cover",
|
|
targetExtractionFolder: "./userdata/covers",
|
|
extractionMode: "bulk",
|
|
paginationOptions: {
|
|
pageLimit: 25,
|
|
page: 1,
|
|
},
|
|
};
|
|
const walkedFolders = await walkFolder("./comics");
|
|
|
|
const socket = io(SOCKET_BASE_URI, {
|
|
reconnectionDelayMax: 10000,
|
|
});
|
|
|
|
socket.on("connect", () => {
|
|
console.log(`connect ${socket.id}`);
|
|
dispatch({
|
|
type: IMS_SOCKET_CONNECTION_CONNECTED,
|
|
socketConnected: true,
|
|
});
|
|
});
|
|
|
|
socket.on("disconnect", () => {
|
|
console.log(`disconnect`);
|
|
});
|
|
socket.emit("importComicsInDB", {
|
|
action: "getComicCovers",
|
|
params: {
|
|
extractionOptions,
|
|
walkedFolders,
|
|
},
|
|
});
|
|
|
|
socket.on("comicBookCoverMetadata", (data: IExtractedComicBookCoverFile) => {
|
|
dispatch({
|
|
type: IMS_COMICBOOK_METADATA_FETCHED,
|
|
data,
|
|
dataTransferred: true,
|
|
});
|
|
});
|
|
};
|
|
|
|
export const getRecentlyImportedComicBooks = (options) => async (dispatch) => {
|
|
const { paginationOptions } = options;
|
|
return axios
|
|
.request({
|
|
url: "http://localhost:3000/api/import/getRecentlyImportedComicBooks",
|
|
method: "POST",
|
|
data: {
|
|
paginationOptions,
|
|
},
|
|
})
|
|
.then((response) => {
|
|
dispatch({
|
|
type: IMS_RECENT_COMICS_FETCHED,
|
|
data: response.data.docs,
|
|
});
|
|
});
|
|
};
|