X-Git-Url: https://git.arvados.org/arvados-workbench2.git/blobdiff_plain/4322da0c140b34c48ecf20e20331111ad27fabaa..67d77b206ebee7c776bd4d7dbc112ebb0c7ba800:/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 f0f25a2d..0aa0aa84 100644 --- a/src/services/collection-service/collection-service.ts +++ b/src/services/collection-service/collection-service.ts @@ -7,32 +7,42 @@ 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"; -import { snakeCase } from 'lodash'; export type UploadProgress = (fileId: number, loaded: number, total: number, currentTime: number) => void; 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}`); + } } } @@ -50,13 +60,18 @@ export class CollectionService extends TrashableResourceService { + 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 encodedApiToken = apiToken ? encodeURI(apiToken) : ''; + const userApiToken = `/t=${encodedApiToken}/`; + const splittedPrevFileUrl = file.url.split('/'); + const url = `${baseUrl}/${splittedPrevFileUrl[1]}${userApiToken}${splittedPrevFileUrl.slice(2).join('/')}`; return { ...file, - url: baseUrl + file.url + url }; } @@ -70,29 +85,6 @@ export class CollectionService extends TrashableResourceService) { - if (uuid && data && data.properties) { - const { properties } = data; - const mappedData = { - ...TrashableResourceService.mapKeys(snakeCase)(data), - properties, - }; - return TrashableResourceService - .defaultResponse( - this.serverApi - .put(this.resourceType + uuid, mappedData), - this.actions, - false - ); - } - return TrashableResourceService - .defaultResponse( - this.serverApi - .put(this.resourceType + uuid, data && TrashableResourceService.mapKeys(snakeCase)(data)), - this.actions - ); + return this.webdavClient.upload(fileURL, [file], requestConfig); } }