src/services/log-service/log-service.ts

   1 // Copyright (C) The Arvados Authors. All rights reserved.
   2 //
   3 // SPDX-License-Identifier: AGPL-3.0
   4
   5 import { AxiosInstance } from "axios";
   6 import { LogEventType, LogResource } from 'models/log';
   7 import { CommonResourceService } from "services/common-service/common-resource-service";
   8 import { ApiActions } from "services/api/api-actions";
   9 import { WebDAV } from "common/webdav";
  10 import { extractFilesData } from "services/collection-service/collection-service-files-response";
  11 import { CollectionFile } from "models/collection-file";
  12
  13 export type LogFragment = {
  14     logType: LogEventType;
  15     contents: string[];
  16 }
  17
  18 export class LogService extends CommonResourceService<LogResource> {
  19     constructor(serverApi: AxiosInstance, private apiWebdavClient: WebDAV, actions: ApiActions) {
  20         super(serverApi, "logs", actions);
  21     }
  22
  23     async listLogFiles(containerRequestUuid: string) {
  24         const request = await this.apiWebdavClient.propfind(`container_requests/${containerRequestUuid}/log`);
  25         if (request.responseXML != null) {
  26             return extractFilesData(request.responseXML)
  27                 .filter((file) => (
  28                     file.path === `/arvados/v1/container_requests/${containerRequestUuid}/log`
  29                 ));
  30         }
  31         return Promise.reject();
  32     }
  33
  34     async getLogFileContents(containerRequestUuid: string, fileRecord: CollectionFile, startByte: number, endByte: number): Promise<LogFragment> {
  35         const request = await this.apiWebdavClient.get(
  36             `container_requests/${containerRequestUuid}/log/${fileRecord.name}`,
  37             {headers: {Range: `bytes=${startByte}-${endByte}`}}
  38         );
  39         const logFileType = logFileToLogType(fileRecord);
  40
  41         if (request.responseText && logFileType) {
  42             return {
  43                 logType: logFileType,
  44                 contents: request.responseText.split(/\r?\n/),
  45             };
  46         } else {
  47             return Promise.reject();
  48         }
  49     }
  50 }
  51
  52 export const logFileToLogType = (file: CollectionFile) => (file.name.replace(/\.(txt|json)$/, '') as LogEventType);