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 { CollectionDirectory, 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         }
  28         return Promise.reject();
  29     }
  30
  31     async getLogFileContents(containerRequestUuid: string, fileRecord: CollectionFile, startByte: number, endByte: number): Promise<LogFragment | undefined> {
  32         try {
  33             const request = await this.apiWebdavClient.get(
  34                 `container_requests/${containerRequestUuid}/log/${fileRecord.name}`,
  35                 {headers: {Range: `bytes=${startByte}-${endByte}`}}
  36             );
  37             const logFileType = logFileToLogType(fileRecord);
  38
  39             if (request.responseText && logFileType) {
  40                 return {
  41                     logType: logFileType,
  42                     contents: request.responseText.split(/\r?\n/),
  43                 };
  44             } else {
  45                 return undefined;
  46             }
  47         } catch(e) {
  48             return undefined;
  49         }
  50     }
  51 }
  52
  53 export const logFileToLogType = (file: CollectionFile | CollectionDirectory) => (file.name.replace(/\.(txt|json)$/, '') as LogEventType);