push.rocks/smartbucket
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2020-06-19 00:42:26 +00:00
parent 4819dd0bc5
commit b9d082f07f
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
ts/smartbucket.classes.bucket.ts
View File

@ -65,11 +65,13 @@ export class Bucket {
*/ */
public async fastGet(pathArg: string) { public async fastGet(pathArg: string) {
const done = plugins.smartpromise.defer(); const done = plugins.smartpromise.defer();
let completeFile: string = ''; let completeFile: Buffer;
const replaySubject = await this.fastGetStream(pathArg); const replaySubject = await this.fastGetStream(pathArg);
replaySubject.subscribe( replaySubject.subscribe(
chunkString => { chunk => {
completeFile += chunkString; if (completeFile) {
completeFile = Buffer.concat([completeFile, chunk]);
}
}, },
err => { err => {
console.log(err); console.log(err);
@ -82,15 +84,14 @@ export class Bucket {
return completeFile; return completeFile;
} }
public async fastGetStream(pathArg: string): Promise<plugins.smartrx.rxjs.ReplaySubject<string>> { public async fastGetStream(pathArg: string): Promise<plugins.smartrx.rxjs.ReplaySubject<Buffer>> {
const fileStream = await this.smartbucketRef.minioClient const fileStream = await this.smartbucketRef.minioClient
.getObject(this.name, pathArg) .getObject(this.name, pathArg)
.catch(e => console.log(e)); .catch(e => console.log(e));
const replaySubject = new plugins.smartrx.rxjs.ReplaySubject<string>(); const replaySubject = new plugins.smartrx.rxjs.ReplaySubject<Buffer>();
const duplexStream = plugins.streamfunction.createDuplexStream<Buffer, Buffer>( const duplexStream = plugins.streamfunction.createDuplexStream<Buffer, Buffer>(
async chunk => { async chunk => {
const chunkString = chunk.toString(); replaySubject.next(chunk);
replaySubject.next(chunkString);
return chunk; return chunk;
}, },
async cb => { async cb => {

2
ts/smartbucket.classes.directory.ts
View File

@ -184,7 +184,7 @@ export class Directory {
return result; return result;
} }
public async fastGetStream(pathArg: string): Promise<plugins.smartrx.rxjs.ReplaySubject<string>> { public async fastGetStream(pathArg: string): Promise<plugins.smartrx.rxjs.ReplaySubject<Buffer>> {
const path = plugins.path.join(this.getBasePath(), pathArg); const path = plugins.path.join(this.getBasePath(), pathArg);
const result = await this.bucketRef.fastGetStream(path); const result = await this.bucketRef.fastGetStream(path);
return result; return result;