smartbucket/ts/smartbucket.classes.directory.ts

140 lines
3.6 KiB
TypeScript
Raw Normal View History

2019-10-14 18:55:07 +00:00
import * as plugins from './smartbucket.plugins';
2019-10-16 16:12:18 +00:00
import { Bucket } from './smartbucket.classes.bucket';
import { File } from './smartbucket.classes.file';
2019-10-14 18:55:07 +00:00
2019-10-16 16:12:18 +00:00
export class Directory {
public bucketRef: Bucket;
2019-10-16 17:11:28 +00:00
public parentDirectory: Directory;
public name: string;
2019-10-16 16:12:18 +00:00
public tree: string[];
public files: string[];
public folders: string[];
2019-10-16 17:11:28 +00:00
constructor(bucketRefArg: Bucket, parentDiretory: Directory, name: string) {
2019-10-16 16:12:18 +00:00
this.bucketRef = bucketRefArg;
2019-10-16 17:11:28 +00:00
this.parentDirectory = parentDiretory;
this.name = name;
}
/**
* returns an array of parent directories
*/
public getParentDirectories(): Directory[] {
let parentDirectories: Directory[] = [];
if (this.parentDirectory) {
parentDirectories.push(this.parentDirectory);
parentDirectories = parentDirectories.concat(this.parentDirectory.getParentDirectories());
}
return parentDirectories;
}
/**
* returns the directory level
*/
public getDirectoryLevel(): number {
return this.getParentDirectories().length;
2019-10-16 17:15:48 +00:00
}
2019-10-16 17:11:28 +00:00
/**
* updates the base path
*/
public getBasePath(): string {
const parentDirectories = this.getParentDirectories();
let basePath = '';
2019-10-16 17:15:48 +00:00
for (const parentDir of parentDirectories) {
2019-10-16 17:11:28 +00:00
basePath = parentDir.name + '/' + basePath;
}
return basePath;
2019-10-16 16:12:18 +00:00
}
/**
* lists all files
*/
public async listFiles(): Promise<File[]> {
const done = plugins.smartpromise.defer();
const fileNameStream = await this.bucketRef.smartbucketRef.minioClient.listObjectsV2(
this.bucketRef.name,
2019-10-16 17:11:28 +00:00
this.getBasePath()
2019-10-16 16:12:18 +00:00
);
const fileArray: File[] = [];
2019-10-16 17:15:48 +00:00
const duplexStream = plugins.streamfunction.createDuplexStream<string, void>(
async fileName => {
fileArray.push(new File(this, fileName));
},
async tools => {
done.resolve();
}
);
2019-10-16 16:12:18 +00:00
fileNameStream.pipe(duplexStream);
await done.promise;
return fileArray;
}
/**
* lists all folders
*/
2019-10-16 17:11:28 +00:00
public async listDirectories(): Promise<Directory[]> {
2019-10-16 16:12:18 +00:00
const done = plugins.smartpromise.defer();
const completeDirStream = await this.bucketRef.smartbucketRef.minioClient.listObjectsV2(
this.bucketRef.name,
2019-10-16 17:11:28 +00:00
this.getBasePath(),
2019-10-16 16:12:18 +00:00
true
);
2019-10-16 17:11:28 +00:00
const directoryArray: Directory[] = [];
2019-10-16 17:15:48 +00:00
const duplexStream = plugins.streamfunction.createDuplexStream<plugins.minio.BucketItem, void>(
async fileName => {
console.log(fileName);
const subtractedPath = fileName.name.replace(this.getBasePath(), '');
if (subtractedPath.includes('/')) {
const dirName = fileName.name.split('/')[0];
if (directoryArray.find(directory => directory.name === dirName)) {
return;
}
directoryArray.push(new Directory(this.bucketRef, this, dirName));
2019-10-16 17:11:28 +00:00
}
2019-10-16 17:15:48 +00:00
},
async tools => {
done.resolve();
2019-10-16 17:11:28 +00:00
}
2019-10-16 17:15:48 +00:00
);
2019-10-16 16:12:18 +00:00
completeDirStream.pipe(duplexStream);
await done.promise;
2019-10-16 17:11:28 +00:00
return directoryArray;
2019-10-16 16:12:18 +00:00
}
/**
* gets an array that has all objects with a certain prefix;
*/
public async getTreeArray() {
const treeArray = await this.bucketRef.smartbucketRef.minioClient.listObjectsV2(
this.bucketRef.name,
2019-10-16 17:11:28 +00:00
this.getBasePath(),
2019-10-16 16:12:18 +00:00
true
);
}
2019-10-16 17:11:28 +00:00
/**
* gets a sub directory
*/
public async getSubDirectory(): Promise<Directory> {
return this;
// TODO
}
/**
* moves the directory
*/
2019-10-16 17:15:48 +00:00
public async move() {
2019-10-16 17:11:28 +00:00
// TODO
}
/**
* creates a file within this directory
2019-10-16 17:15:48 +00:00
* @param relativePathArg
2019-10-16 17:11:28 +00:00
*/
public async createFile(relativePathArg) {
let completeFilePath: string = '';
}
2019-10-16 16:12:18 +00:00
}