1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
|
import { Client } from 'minio'
import { Readable } from 'stream'
const minioClient = new Client({
endPoint: process.env.MINIO_ENDPOINT_HOST || 'localhost',
port: parseInt(process.env.MINIO_ENDPOINT_PORT || '9000', 10),
useSSL: process.env.NODE_ENV === 'production',
accessKey: process.env.MINIO_ACCESS_KEY || '',
secretKey: process.env.MINIO_SECRET_KEY || '',
})
const BUCKET_NAME = 'storage'
export async function uploadToMinio(
key: string,
buffer: Buffer,
contentType: string
): Promise<string> {
try {
const stream = Readable.from(buffer)
await minioClient.putObject(BUCKET_NAME, key, stream, buffer.length, {
'Content-Type': contentType,
'Cache-Control': 'max-age=31536000', // 1 year cache
})
// Construct URL using the same configuration as the client
const protocol = process.env.NODE_ENV === 'production' ? 'https' : 'http'
const host = process.env.MINIO_ENDPOINT_HOST || 'localhost'
const port = process.env.MINIO_ENDPOINT_PORT || '9000'
const url = `${protocol}://${host}:${port}/${BUCKET_NAME}/${key}`
return url
} catch (error) {
console.error('Error uploading to MinIO:', error)
throw error
}
}
export async function deleteFromMinio(key: string): Promise<void> {
try {
await minioClient.removeObject(BUCKET_NAME, key)
console.log(`Deleted file: ${key}`)
} catch (error) {
console.error('Error deleting from MinIO:', error)
throw error
}
}
export async function getPresignedUploadUrl(
key: string,
expiresIn: number = 3600
): Promise<string> {
try {
return await minioClient.presignedPutObject(BUCKET_NAME, key, expiresIn)
} catch (error) {
console.error('Error generating presigned URL:', error)
throw error
}
}
export async function getFileInfo(key: string) {
try {
return await minioClient.statObject(BUCKET_NAME, key)
} catch (error) {
console.error('Error getting file info:', error)
throw error
}
}
export default minioClient
|
