BAAS-30361: add amazon third party snippets

Author: jwongmongodb

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,
+  });
+  const params = {
+    StreamName: "myStreamName",
+  };
+
+  // see https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/kinesis/ for more commands
+  const describeStreamCommand = new DescribeStreamCommand(params);
+  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 !== null && data.ETag !== "";
+  } 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",
+      "snippets": "/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",
+      "snippets": "/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",
+      "snippets": "/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",
+      "snippets": "/awsS3PutObject.js",
+      "description": "Putting an object into 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."
     }
   ]
 }