Function testOrganizationS3Config

apps/web/actions/organization/storage.ts:427–451

(input: S3ConfigInput)

}

export async function testOrganizationS3Config(input: S3ConfigInput) {
	await requireOrganizationStorageManagerPro(input.organizationId);
	const credentials = await getS3InputCredentials(input);
	const controller = new AbortController();
	const timeoutId = setTimeout(() => controller.abort(), 5000);
	const s3Client = new S3Client({
		endpoint: input.endpoint || undefined,
		region: input.region,
		credentials: {
			accessKeyId: credentials.accessKeyId,
			secretAccessKey: credentials.secretAccessKey,
		},
	});

	try {
		await s3Client.send(new HeadBucketCommand({ Bucket: input.bucketName }), {
			abortSignal: controller.signal,
		});
		return { success: true };
	} catch (error) {
		throw new Error(getS3ConnectionErrorMessage(error, input.bucketName));
	} finally {
		clearTimeout(timeoutId);
	}
}

export async function setOrganizationStorageProvider({
	organizationId,