vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: move all upload logic to BinaryOutputService

Browse Source
This commit is contained in:
karishmas6
2024-10-16 13:40:26 +05:30
parent a75d40918b
commit 04fbf17c3a
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
server/src/storage/mino.ts
View File

@@ -74,7 +74,7 @@ class BinaryOutputService {
try { try {
const minioKey = `${plainRun.runId}/${key}`; const minioKey = `${plainRun.runId}/${key}`;
await run.uploadBinaryOutputToMinioBucket(minioKey, binaryData); await this.uploadBinaryOutputToMinioBucket(run, minioKey, binaryData);
// Save the Minio URL in the result object // Save the Minio URL in the result object
uploadedBinaryOutput[key] = `minio://${this.bucketName}/${minioKey}`; uploadedBinaryOutput[key] = `minio://${this.bucketName}/${minioKey}`;
@@ -94,6 +94,20 @@ class BinaryOutputService {
return uploadedBinaryOutput; return uploadedBinaryOutput;
} }
async uploadBinaryOutputToMinioBucket(run: Run, key: string, data: Buffer): Promise<void> {
const bucketName = 'maxun-run-screenshots';
try {
console.log(`Uploading to bucket ${bucketName} with key ${key}`);
await minioClient.putObject(bucketName, key, data, data.length, { 'Content-Type': 'image/png' });
const plainRun = run.toJSON();
plainRun.binaryOutput[key] = `minio://${bucketName}/${key}`;
console.log(`Successfully uploaded to MinIO: minio://${bucketName}/${key}`);
} catch (error) {
console.error(`Error uploading to MinIO bucket: ${bucketName} with key: ${key}`, error);
throw error;
}
}
} }
export { minioClient, BinaryOutputService }; export { minioClient, BinaryOutputService };