Austin/WorkerJS_CloudFlare_ImageBed
1
0
Fork 0
mirror of https://github.com/BlueSkyXN/WorkerJS_CloudFlare_ImageBed.git synced 2024-11-15 19:22:21 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

0.9.8

Browse Source 
撤销S3FB
This commit is contained in:
BlueSkyXN 2024-09-20 15:54:40 +08:00
parent 1052c6f5e1
commit eaf03d9634
1 changed files with 0 additions and 92 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

92
cloudflare-worker-js-api/worker.js
View File

@ -62,9 +62,6 @@ async function handleRequest(request) {
case '/upload/tgphimg':
response = await handleTgphimgRequest(request);
break;
case '/upload/s3filebase':
response = await handles3filebaseRequest(request);
break;
default:
response = new Response('Not Found', { status: 404 });
break;
@ -662,93 +659,4 @@ async function handleRequest(request) {
return new Response('Error: ' + await response.text(), { status: response.status });
}
}
import { AwsClient } from 'aws4fetch';
async function handles3filebaseRequest(request) {
if (request.method !== 'POST') {
return new Response('Method not allowed', { status: 405 });
}
try {
const formData = await request.formData();
const file = formData.get('image'); // 期待表单字段名为'image'
if (!file) {
return new Response('No file uploaded', { status: 400 });
}
// 将文件内容读取为ArrayBuffer
const fileContent = await file.arrayBuffer();
// 从环境变量中获取s3filebase_key，并解析出bucket_name、access_key和secret_key
const s3filebaseKey = S3FILEBASE_KEY; // S3FILEBASE_KEY是您的环境变量
const [bucketName, accessKeyId, secretAccessKey] = s3filebaseKey.split('|');
// 检查是否成功解析
if (!bucketName || !accessKeyId || !secretAccessKey) {
return new Response('Server configuration error: Invalid S3FILEBASE_KEY', { status: 500 });
}
const region = 'us-east-1'; // Filebase默认使用'us-east-1'
const service = 's3';
const host = 's3.filebase.com';
// 生成带时间戳的文件名
const fileName = file.name || 'upload';
const timestamp = new Date().toISOString().replace(/[:\-]|\.\d{3}/g, '');
const s3FileKey = `${fileName}_${timestamp}`;
// 创建 AwsClient 实例
const aws = new AwsClient({
accessKeyId,
secretAccessKey,
service,
region,
});
// 构建上传文件的 URL
const url = `https://${host}/${bucketName}/${s3FileKey}`;
// 发起 PUT 请求上传文件
const uploadResponse = await aws.fetch(url, {
method: 'PUT',
headers: {
'Content-Type': 'application/octet-stream',
},
body: fileContent,
});
if (!uploadResponse.ok) {
const errorText = await uploadResponse.text();
return new Response(`Upload failed with status: ${uploadResponse.status}, error: ${errorText}`, { status: uploadResponse.status });
}
// 发起 HEAD 请求获取元数据以获得 CID
const metadataResponse = await aws.fetch(url, {
method: 'HEAD',
});
if (!metadataResponse.ok) {
const errorText = await metadataResponse.text();
return new Response(`Failed to retrieve metadata with status: ${metadataResponse.status}, error: ${errorText}`, { status: metadataResponse.status });
}
// 从元数据中提取 CID
const cid = metadataResponse.headers.get('x-amz-meta-cid');
if (!cid) {
return new Response('CID not found in metadata.', { status: 500 });
}
// 构建访问 URL
const accessUrl = `https://ipfs.filebase.io/ipfs/${cid}`;
// 返回访问 URL
return new Response(accessUrl, {
status: 200,
headers: { 'Content-Type': 'text/plain' },
});
} catch (error) {
return new Response(`Internal Server Error: ${error.message}`, { status: 500 });
}
}