132 lines
3.4 KiB
JavaScript
132 lines
3.4 KiB
JavaScript
import axios from 'axios'
|
|
import { Blob } from 'node:buffer'
|
|
import { log } from './log.mjs'
|
|
import { cloudflareImages as config } from '../config.mjs'
|
|
|
|
// We'll use this a bunch
|
|
const headers = { Authorization: `Bearer ${config.token}` }
|
|
|
|
/*
|
|
* Method that does the actual image upload to cloudflare
|
|
* Use this for a new image that does not yet exist
|
|
*/
|
|
export async function storeImage(props, isTest = false) {
|
|
if (isTest) return props.id || false
|
|
|
|
const form = getFormData(props)
|
|
let result
|
|
try {
|
|
result = await axios.post(config.api, form, { headers })
|
|
} catch (err) {
|
|
if (err.response.status == 409) {
|
|
/*
|
|
* Image already exists.
|
|
* Cloudflare does not support udating the image,
|
|
* so we need to delete it and upload again
|
|
*/
|
|
try {
|
|
log.warn(props.id, 'Called storeImage when replaceImage should have been used')
|
|
await axios.delete(`${config.api}/${props.id}`)
|
|
result = await axios.post(config.api, form, { headers })
|
|
} catch (err) {
|
|
console.log('Failed to replace image on cloudflare', err)
|
|
}
|
|
} else {
|
|
console.log('Failed to upload image to cloudflare', err.response.data)
|
|
}
|
|
}
|
|
|
|
return result.data?.result?.id ? result.data.result.id : false
|
|
}
|
|
|
|
/*
|
|
* Method that does the actual image upload to cloudflare
|
|
* Use this to replace an existing image
|
|
*/
|
|
export async function replaceImage(props, isTest = false) {
|
|
if (isTest) return props.id || false
|
|
const form = getFormData(props)
|
|
// Ignore errors on delete, probably means the image does not exist
|
|
try {
|
|
await axios.delete(`${config.api}/${props.id}`, { headers })
|
|
} catch (err) {
|
|
// It's fine
|
|
log.info(`Could not delete image ${props.id}`)
|
|
}
|
|
let result
|
|
try {
|
|
result = await axios.post(config.api, form, { headers })
|
|
} catch (err) {
|
|
console.log('Failed to replace image on cloudflare', err)
|
|
}
|
|
|
|
return result?.data?.result?.id ? result.data.result.id : false
|
|
}
|
|
|
|
/*
|
|
* Method that uploads an image to cloudflare
|
|
* Use this to merely ensure the image exists (will fail silently if it does)
|
|
*/
|
|
export async function ensureImage(props, isTest = false) {
|
|
if (isTest) return props.id || false
|
|
const form = getFormData(props)
|
|
try {
|
|
await axios.post(config.api, form, { headers })
|
|
} catch (err) {
|
|
// It's fine
|
|
}
|
|
|
|
return props.id
|
|
}
|
|
|
|
/*
|
|
* Method that removes an image fron cloudflare
|
|
*/
|
|
export async function removeImage(id) {
|
|
try {
|
|
await axios.delete(`${config.api}/${id}`, { headers })
|
|
} catch (err) {
|
|
return false
|
|
}
|
|
|
|
return true
|
|
}
|
|
|
|
/*
|
|
* Helper method to construct the form data for cloudflare
|
|
*/
|
|
function getFormData({
|
|
id,
|
|
metadata = {},
|
|
url = false,
|
|
b64 = false,
|
|
blob = false,
|
|
data = false,
|
|
notPublic = false,
|
|
}) {
|
|
const form = new FormData()
|
|
// Data can be either a URL or b64
|
|
if (data) {
|
|
if (data.slice(0, 4) === 'http') url = data
|
|
else b64 = data
|
|
}
|
|
form.append('id', id)
|
|
form.append('metadata', JSON.stringify(metadata))
|
|
// Handle base-64 encoded data
|
|
if (b64) form.append('file', b64ToBlob(b64), id)
|
|
// Handle binary data
|
|
else if (blob) form.append('file', blob)
|
|
// Handle URL-based upload
|
|
else if (url) form.append('url', url)
|
|
// Handle requireSignedURLs
|
|
if (notPublic) form.append('requireSignedURLs', true)
|
|
|
|
return form
|
|
}
|
|
|
|
/*
|
|
* Helper method to turn a data-uri into binary data
|
|
*/
|
|
function b64ToBlob(dataUri) {
|
|
return new Blob([new Buffer.from(dataUri.split(';base64,').pop(), 'base64')])
|
|
}
|