feat: cached S3, dynamo and SQS clients

packages/core/src/queue/index.js

@@ -1,11 +1,17 @@
 import { SQSClient } from '@aws-sdk/client-sqs'
 
+/** @type {Record<string, import('@aws-sdk/client-sqs').SQSClient>} */
+const sqsClients = {}
+
 /**
  * @param {import('./types.js').QueueConnect | SQSClient} target 
  */
 export function connectQueue (target) {
   if (target instanceof SQSClient) {
     return target
   }
-  return new SQSClient(target)
+  if (!sqsClients[target.region]) {
+    sqsClients[target.region] = new SQSClient(target)
+  }
+  return sqsClients[target.region]
 }

packages/core/src/store/index.js

@@ -1,25 +1,36 @@
 import { S3Client } from '@aws-sdk/client-s3'
 import { DynamoDBClient } from '@aws-sdk/client-dynamodb'
 
+/** @type {Record<string, import('@aws-sdk/client-s3').S3Client>} */
+const s3Clients = {}
+
 /**
  * @param {import('./types.js').BucketConnect | S3Client} target 
  */
 export function connectBucket (target) {
   if (target instanceof S3Client) {
     return target
   }
-  return new S3Client(target)
+  if (!s3Clients[target.region]) {
+    s3Clients[target.region] = new S3Client(target)
+  }
+  return s3Clients[target.region]
 }
 
+/** @type {Record<string, import('@aws-sdk/client-dynamodb').DynamoDBClient>} */
+const dynamoClients = {}
+
 /**
  * @param {import('./types.js').TableConnect | DynamoDBClient} target 
  */
 export function connectTable (target) {
   if (target instanceof DynamoDBClient) {
     return target
   }
-
-  return new DynamoDBClient(target)
+  if (!dynamoClients[target.region]) {
+    dynamoClients[target.region] = new DynamoDBClient(target)
+  }
+  return dynamoClients[target.region]
 }
 
 /** @typedef {import('sst/constructs').TableProps} TableProps */