import { AWS, ASSET_BASE_URL } from '../constants'; import { md5 } from '../utils/crypto'; import { S3Client, CopyObjectCommand, PutObjectCommand, HeadObjectCommand } from '@aws-sdk/client-s3'; import { CloudFrontClient, CreateInvalidationCommand } from '@aws-sdk/client-cloudfront'; const { Upload } = require('@aws-sdk/lib-storage');

const stream = require('stream');

const s3Client = new S3Client({ region: AWS.region, credentials: AWS.credentials });

const cfClient = new CloudFrontClient({ region: AWS.region, credentials: AWS.credentials });

export function parseUrl(url: string) { let i = url.indexOf('/'); return { host: url.substring(0, i), path: i == -1 ? '' : url.substring(i + 1) }; }

export async function s3Copy(sourcePath: any, targetPath: any) { if (targetPath.substring(0, 1) === '/') { targetPath = targetPath.substring(1); } const bucketParams = { Bucket: AWS.bucket, CopySource: AWS.bucket + sourcePath, Key: targetPath }; console.debug('s3Copy Params:', bucketParams);

try {
    const data = await s3Client.send(new CopyObjectCommand(bucketParams));
    console.debug('Success', data);
    return data;
} catch (e) {
    console.error('s3Copy Except:', e);
    throw e;
}

}

/**

• s3 upload file

• @param body, fileStream | string

• @param targetPath string

• @returns */ export async function s3Upload(targetPath: any, body: any, contentType?: string) { if (targetPath.substring(0, 1) === '/') { targetPath = targetPath.substring(1); } const uploadParams: any = { Bucket: AWS.bucket, Key: targetPath, Body: body }; if (contentType) { if (contentType === 'text/plain') { uploadParams.ContentType = ${contentType}; charset=utf-8; } else { uploadParams.ContentType = contentType; } }

  try { const data = await s3Client.send(new PutObjectCommand(uploadParams)); console.debug('Success', data); return data; } catch (e: any) { console.error('Error', e.message); throw e; } }

/**

• s3 stream upload file

• @param body, fileStream | string

• @param targetPath string

• @returns */ export async function s3UploadStream(targetPath: any, body: any, contentType?: string) { if (targetPath.substring(0, 1) === '/') { targetPath = targetPath.substring(1); }

  const passThrough = new stream.PassThrough(); passThrough.end(body);

  const uploadParams: any = { Bucket: AWS.bucket, Key: targetPath, Body: passThrough };

  if (contentType) { if (contentType === 'text/plain') { uploadParams.ContentType = ${contentType}; charset=utf-8; } else { uploadParams.ContentType = contentType; } }

  try { const parallelUploads3 = new Upload({ client: s3Client, params: uploadParams, queueSize: 20, // 并发上传的数量 partSize: 5 * 1024 * 1024, // 每个分块的大小 leavePartsOnError: false // 如果出错是否保留已上传的分块 });

   // parallelUploads3.on('httpUploadProgress', (progress: any) => {
   //     console.log('progress:::', progress);
   // });
  
   const data = await parallelUploads3.done();
   // console.debug('Success', data);
   return data;
  

  } catch (e: any) { console.error('Error', e.message); throw e; } }

export async function cfCreateInvalidation(path: any) { const input: any = { DistributionId: AWS.distributionId, InvalidationBatch: { CallerReference: new Date().getTime(), Paths: { Items: Array.isArray(path) ? path : [path], Quantity: 1 } } }; // console.debug('cfCreateInvalidation param:', input);

try {
    const command = new CreateInvalidationCommand(input);
    const response = await cfClient.send(command);
    // console.debug('Success', response);
    return response;
} catch (e: any) {
    console.error('cfCreateInvalidation Except:', e.message);
    throw e;
}

}

export async function s3FileExists(path: string) { try { const command = new HeadObjectCommand({ Bucket: AWS.bucket, Key: path }); await s3Client.send(command); return true; } catch (error: any) { if (error?.name === 'NotFound') { return false; } throw error; } }

export async function uploadByFormData(file: any, folder: string, name?: string) { if (!file || !file?.name || !file?.data || !file?.mimetype) { throw new Error('upload: invalid parameter'); } let fileExt = ''; if (file.name) { fileExt = file.name.substring(file.name.lastIndexOf('.')); } if (!name) { name = md5(file.data); } const targetPath = folder + name + fileExt; // console.debug('path ', targetPath);

// await s3Upload(targetPath, file.data, file.mimetype);
await s3UploadStream(targetPath, file.data, file.mimetype);
await cfCreateInvalidation(targetPath);
return ASSET_BASE_URL + targetPath;

} 请帮我把上面typescript s3操作方法 改成 google cloud storage操作方法

const storage = new Storage({ projectId: 'your-google-cloud-project-id', keyFilename: 'path-to-your-service-account-file.json' });

const bucketName = 'your-bucket-name'; 这几个参数值从哪里来？

const storage = new Storage({ projectId: 'your-google-cloud-project-id', keyFilename: 'path-to-your-service-account-file.json' }); 这里keyFilename 是绝对路径，还是必须放到项目根目录的文件名？