services/self-service/src/main/resources/webapp/src/app/core/services/bucket-browser.service.ts

import { Injectable } from '@angular/core';
import {Observable} from 'rxjs';
import {catchError, map} from 'rxjs/operators';
import {ErrorUtils} from '../util';
import {ApplicationServiceFacade} from './applicationServiceFacade.service';

export class TodoItemNode {
  children: TodoItemNode[];
  item: string;
  id: string;
  object: any;
}

export class TodoItemFlatNode {
  item: string;
  level: number;
  expandable: boolean;
}

@Injectable({
  providedIn: 'root'
})
export class BucketBrowserService {
  constructor(private applicationServiceFacade: ApplicationServiceFacade) {
  }

  public getBucketData(bucket, endpoint): Observable<{}> {
    const url = `/${bucket}/endpoint/${endpoint}`;
    return this.applicationServiceFacade
      .buildGetBucketData(url)
      .pipe(
        map(response => response),
        catchError(ErrorUtils.handleServiceError));
  }

  public downloadFile(data) {
    return this.applicationServiceFacade
      .buildDownloadFileFromBucket(data)
      .pipe(
        map(response => response),
        catchError(ErrorUtils.handleServiceError));
  }

  public uploadFile(data) {
    return this.applicationServiceFacade
      .buildUploadFileToBucket(data)
      .pipe(
        map(response => response),
        catchError(ErrorUtils.handleServiceError));
  }

  public createFolder(data) {
    return this.applicationServiceFacade
      .buildCreateFolderInBucket(data)
      .pipe(
        map(response => response),
        catchError(ErrorUtils.handleServiceError));
  }

  public deleteFile(data) {
    return this.applicationServiceFacade
      .buildDeleteFileFromBucket(data)
      .pipe(
        map(response => response),
        catchError(ErrorUtils.handleServiceError));
  }
}