diff --git a/server/src/models/Run.ts b/server/src/models/Run.ts index d8abe0dd..1ea1d4a8 100644 --- a/server/src/models/Run.ts +++ b/server/src/models/Run.ts @@ -51,6 +51,17 @@ class Run extends Model implements RunAttr await minioClient.putObject(bucketName, key, data); this.binaryOutput[key] = `minio://${bucketName}/${key}`; } + + public async getBinaryOutputFromMinioBucket(key: string): Promise { + const bucketName = ''; + const stream = await minioClient.getObject(bucketName, key); + return new Promise((resolve, reject) => { + const chunks: Buffer[] = []; + stream.on('data', (chunk) => chunks.push(chunk)); + stream.on('end', () => resolve(Buffer.concat(chunks))); + stream.on('error', reject); + }); + } } Run.init(