From 026c16ed1b1c80203e2648de482a545e22482b60 Mon Sep 17 00:00:00 2001 From: Yuqian Yang Date: Thu, 10 Apr 2025 15:12:46 +0800 Subject: HALF WORK! --- services/docker/mail-server/relay/aws/context.ts | 41 ++++++++++++++++++++++++ 1 file changed, 41 insertions(+) create mode 100644 services/docker/mail-server/relay/aws/context.ts (limited to 'services/docker/mail-server/relay/aws/context.ts') diff --git a/services/docker/mail-server/relay/aws/context.ts b/services/docker/mail-server/relay/aws/context.ts new file mode 100644 index 0000000..c4f67bc --- /dev/null +++ b/services/docker/mail-server/relay/aws/context.ts @@ -0,0 +1,41 @@ +import { + CopyObjectCommand, + DeleteObjectCommand, + S3Client, +} from "@aws-sdk/client-s3"; +import { FetchHttpHandler } from "@smithy/fetch-http-handler"; + +import { getConfigValue } from "../config.ts"; + +export class AwsContext { + readonly credentials = () => + Promise.resolve({ + accessKeyId: getConfigValue("awsAccessKeyId"), + secretAccessKey: getConfigValue("awsSecretAccessKey"), + }); + readonly requestHandler = new FetchHttpHandler(); + + get region() { + return getConfigValue("awsRegion"); + } +} + +export async function s3MoveObject( + client: S3Client, + bucket: string, + path: string, + newPath: string, +): Promise { + const copyCommand = new CopyObjectCommand({ + Bucket: bucket, + Key: newPath, + CopySource: `${bucket}/${path}`, + }); + await client.send(copyCommand); + + const deleteCommand = new DeleteObjectCommand({ + Bucket: bucket, + Key: path, + }); + await client.send(deleteCommand); +} -- cgit v1.2.3