X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/a2bf1ed3a15cf55e426c51ad8e6febd7ff2e3020..cf83b358f087a87b5ff095d3ed7a8c6920c60ffe:/src/services/collection-service/collection-service.ts diff --git a/src/services/collection-service/collection-service.ts b/src/services/collection-service/collection-service.ts index 28de14f5..90441a64 100644 --- a/src/services/collection-service/collection-service.ts +++ b/src/services/collection-service/collection-service.ts @@ -7,9 +7,7 @@ import { AxiosInstance } from "axios"; import { CollectionFile, CollectionDirectory } from "~/models/collection-file"; import { WebDAV } from "~/common/webdav"; import { AuthService } from "../auth-service/auth-service"; -import { mapTreeValues } from "~/models/tree"; -import { parseFilesResponse } from "./collection-service-files-response"; -import { fileToArrayBuffer } from "~/common/file"; +import { extractFilesData } from "./collection-service-files-response"; import { TrashableResourceService } from "~/services/common-service/trashable-resource-service"; import { ApiActions } from "~/services/api/api-actions"; @@ -17,21 +15,34 @@ export type UploadProgress = (fileId: number, loaded: number, total: number, cur export class CollectionService extends TrashableResourceService { constructor(serverApi: AxiosInstance, private webdavClient: WebDAV, private authService: AuthService, actions: ApiActions) { - super(serverApi, "collections", actions); + super(serverApi, "collections", actions, [ + 'fileCount', + 'fileSizeTotal', + 'replicationConfirmed', + 'replicationConfirmedAt', + 'storageClassesConfirmed', + 'storageClassesConfirmedAt', + 'unsignedManifestText', + 'version', + ]); } async files(uuid: string) { const request = await this.webdavClient.propfind(`c=${uuid}`); if (request.responseXML != null) { - const filesTree = parseFilesResponse(request.responseXML); - return mapTreeValues(this.extendFileURL)(filesTree); + return extractFilesData(request.responseXML); } return Promise.reject(); } async deleteFiles(collectionUuid: string, filePaths: string[]) { for (const path of filePaths) { - await this.webdavClient.delete(`c=${collectionUuid}${path}`); + const splittedPath = path.split('/'); + if (collectionUuid) { + await this.webdavClient.delete(`c=${collectionUuid}/${splittedPath[1]}`); + } else { + await this.webdavClient.delete(`c=${collectionUuid}${path}`); + } } } @@ -49,14 +60,23 @@ export class CollectionService extends TrashableResourceService ({ - ...file, - url: this.webdavClient.defaults.baseURL + file.url + '?api_token=' + this.authService.getApiToken() - }) + extendFileURL = (file: CollectionDirectory | CollectionFile) => { + const baseUrl = this.webdavClient.defaults.baseURL.endsWith('/') + ? this.webdavClient.defaults.baseURL.slice(0, -1) + : this.webdavClient.defaults.baseURL; + const apiToken = this.authService.getApiToken(); + const splittedApiToken = apiToken ? apiToken.split('/') : []; + const userApiToken = `/t=${splittedApiToken[2]}/`; + const splittedPrevFileUrl = file.url.split('/'); + const url = `${baseUrl}/${splittedPrevFileUrl[1]}${userApiToken}${splittedPrevFileUrl.slice(2).join('/')}`; + return { + ...file, + url + }; + } private async uploadFile(collectionUuid: string, file: File, fileId: number, onProgress: UploadProgress = () => { return; }) { const fileURL = `c=${collectionUuid}/${file.name}`; - const fileContent = await fileToArrayBuffer(file); const requestConfig = { headers: { 'Content-Type': 'text/octet-stream' @@ -65,7 +85,6 @@ export class CollectionService extends TrashableResourceService