BAAS-30361: add amazon third party snippets (#47)

Author: jwongmongodb

manifest.json

@@ -19,5 +19,5 @@
       "metadata": "/snippets/triggers/project/manifest.json"
     }
   ],
-  "version": "85b9e371e7f449ce71543768fffa8e6d5e09f518"
+  "version": "b27eb194e608862bb8851f536ea449b6a28ca078"
 }

snippets/functions/third-party/awsKinesis.js

@@ -0,0 +1,26 @@
+exports = async function () {
+  const {
+    KinesisClient,
+    DescribeStreamCommand,
+  } = require("@aws-sdk/client-kinesis");
+  const kinesisClient = new KinesisClient({
+    credentials: {
+      accessKeyId: context.values.get("awsAccessKeyID"),
+      secretAccessKey: context.values.get("awsSecretAccessKey"),
+    },
+    region: "us-east-1",
+    maxAttempts: 5,
+  });
+
+  // see https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis/ for more commands
+  const describeStreamCommand = new DescribeStreamCommand({
+    StreamName: "myStreamName",
+  });
+
+  try {
+    const data = await kinesisClient.send(describeStreamCommand);
+    return data.StreamDescription.StreamName;
+  } catch (error) {
+    return error;
+  }
+};

snippets/functions/third-party/awsS3GetObject.js

@@ -0,0 +1,26 @@
+exports = async function () {
+  const {
+    S3Client,
+    GetObjectCommand,
+    PutObjectCommand,
+  } = require("@aws-sdk/client-s3");
+  const s3Client = new S3Client({
+    credentials: {
+      accessKeyId: context.values.get("awsAccessKeyID"),
+      secretAccessKey: context.values.get("awsSecretAccessKey"),
+    },
+    region: "us-east-1",
+  });
+
+  // see https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/s3/ for more details
+  const getObjectCommand = new GetObjectCommand({
+    Bucket: "myBucketName",
+    Key: context.values.get("awsBucketKey"),
+  });
+  try {
+    const data = await s3Client.send(getObjectCommand);
+    return data;
+  } catch (error) {
+    return error;
+  }
+};

snippets/functions/third-party/awsS3PutObject.js

@@ -0,0 +1,27 @@
+exports = async function () {
+  const {
+    S3Client,
+    GetObjectCommand,
+    PutObjectCommand,
+  } = require("@aws-sdk/client-s3");
+  const s3Client = new S3Client({
+    credentials: {
+      accessKeyId: context.values.get("awsAccessKeyID"),
+      secretAccessKey: context.values.get("awsSecretAccessKey"),
+    },
+    region: "us-east-1",
+  });
+
+  // see https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/s3/ for more details
+  const putObjectCommand = new PutObjectCommand({
+    Bucket: "myBucketName",
+    Key: context.values.get("awsBucketKey"),
+    Body: Buffer.from("bucket data"),
+  });
+  try {
+    const data = await s3Client.send(putObjectCommand);
+    return data;
+  } catch (error) {
+    return error;
+  }
+};

snippets/functions/third-party/awsSES.js

@@ -0,0 +1,38 @@
+exports = async function () {
+  const { SESv2Client, SendEmailCommand } = require("@aws-sdk/client-sesv2");
+  const sesv2Client = new SESv2Client({
+    credentials: {
+      accessKeyId: context.values.get("awsAccessKeyID"),
+      secretAccessKey: context.values.get("awsSecretAccessKey"),
+    },
+    region: "us-east-1",
+    maxAttempts: 5,
+  });
+
+  // see https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/sesv2/ for more detail
+  const sendEmailCommand = new SendEmailCommand({
+    FromEmailAddress: "[email protected]",
+    Destination: {
+      ToAddresses: ["[email protected]"],
+    },
+    Content: {
+      Simple: {
+        Subject: {
+          Data: "HeLLO SES",
+        },
+        Body: {
+          Text: {
+            Data: "This is a simple mail",
+          },
+        },
+      },
+    },
+  });
+
+  try {
+    const data = await sesv2Client.send(sendEmailCommand);
+    return data;
+  } catch (error) {
+    return error;
+  }
+};

snippets/functions/third-party/manifest.json

@@ -20,6 +20,30 @@
       "title": "Using node-fetch dependency",
       "snippet": "/nodeFetch.js",
       "description": "Making HTTP requests with node-fetch dependency. Atlas App Services does not support v3 of node-fetch, use v2 instead."
+    },
+    {
+      "id": "fdf44706-adbe-4880-87b5-e9c28f6110af",
+      "title": "Using AWS SES dependency",
+      "snippet": "/awsSES.js",
+      "description": "Sending an email with AWS SES. To authenticate with the AWS client, store your AccessKeyID and SecretAccessKey as values. Note: This is using AWS SDK v3."
+    },
+    {
+      "id": "fdf44706-adbe-4880-87b5-e9c28f6110ag",
+      "title": "Using AWS Kinesis dependency",
+      "snippet": "/awsKinesis.js",
+      "description": "Retrieving stream details with AWS Kinesis. To authenticate with the AWS client, store your AccessKeyID and SecretAccessKey as values. Note: This is using AWS SDK v3."
+    },
+    {
+      "id": "fdf44706-adbe-4880-87b5-e9c28f6110aa",
+      "title": "Retrieving from AWS S3 bucket",
+      "snippet": "/awsS3GetObject.js",
+      "description": "Retrieving from AWS S3 bucket with the bucket name and key. To authenticate with the AWS client, store your AccessKeyID and SecretAccessKey as values. Note: This is using AWS SDK v3."
+    },
+    {
+      "id": "fdf44706-adbe-4880-87b5-e9c28f6110ab",
+      "title": "Putting object in AWS S3 bucket",
+      "snippet": "/awsS3PutObject.js",
+      "description": "Uploads an object to an AWS S3 bucket using the specified bucket name and key. Authentication requires your AWS AccessKeyID, SecretAccessKey and BucketKey, all of which should be stored as values. This operation uses AWS SDK v3."
     }
   ]
 }