prehistoric-systems/omnivore
1
0
Fork 0
mirror of https://github.com/omnivore-app/omnivore.git synced 2026-03-11 08:54:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

upload file only not exists

Browse source
This commit is contained in:
Hongbo Wu 2024-04-19 17:52:56 +08:00
parent 9286174ec7
commit 7a0b2f3d33
2 changed files with 14 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
packages/api/src/utils/uploads.ts
View file

@ -158,16 +158,16 @@ export const downloadStringFromBucket = async (
filePath: string
): Promise<string | null> => {
try {
const bucket = storage.bucket(bucketName)
const file = storage.bucket(bucketName).file(filePath)
const [exists] = await bucket.file(filePath).exists()
const [exists] = await file.exists()
if (!exists) {
logger.error(`File not found: ${filePath}`)
return null
}
// Download the file contents as a string
const [data] = await bucket.file(filePath).download()
const [data] = await file.download()
return data.toString()
} catch (error) {
logger.info('Error downloading file:', error)

15
packages/content-fetch/src/request_handler.ts
View file

@ -54,10 +54,17 @@ const storage = process.env.GCS_UPLOAD_SA_KEY_FILE_PATH
const bucketName = process.env.GCS_UPLOAD_BUCKET || 'omnivore-files'
export const uploadToBucket = async (filename: string, data: string) => {
await storage
.bucket(bucketName)
.file(`originalContent/${filename}`)
.save(data, { public: false, timeout: 30000 })
const file = storage.bucket(bucketName).file(`originalContent/${filename}`)
// check if the file already exists
const [exists] = await file.exists()
if (exists) {
console.log('file already exists', filename)
return
}
await file.save(data, { public: false, timeout: 30000 })
}
const hash = (content: string) =>