add system test and update package

aws-node-kinesis/handler.js

@@ -0,0 +1,2 @@
+export { default as producer } from './kinesis/producer';
+export { default as consumer } from './kinesis/consumer';

aws-node-kinesis/kinesis/consumer.js

@@ -0,0 +1,24 @@
+const { KinesisStreamHandler, KinesisStreamRecordPayload } = require("aws-sdk");
+
+const consumer: KinesisSreamHandler = async (event) => {
+  try {
+    for (const record of event.Records) {
+      const payload: KinesisStreamRecordPayload = record.kinesis;
+      const message: string = Buffer.from(payload.data, 'base64').toString();
+
+      console.log(
+        `Kinesis Message:
+          partition key: ${payload.partitionKey}
+          sequence number: ${payload.sequenceNumber}
+          kinesis schema version: ${payload.kinesisSchemaVersion}
+          data: ${message}
+        `);
+
+      // Do something
+    }
+  } catch (error) {
+    console.log(error);
+  }
+};
+
+export default consumer;

aws-node-kinesis/kinesis/producer.js

@@ -0,0 +1,47 @@
+import { APIGatewayProxyHandler } from 'aws-lambda';
+import { Kinesis } from 'aws-sdk';
+import { v4 as uuidv4 } from 'uuid';
+
+const kinesis = new Kinesis({
+  apiVersion: '2013-12-02',
+});
+
+const producer: APIGatewayProxyHandler = async (event) => {
+  let statusCode: number = 200;
+  let message: string;
+
+  if (!event.body) {
+    return {
+      statusCode: 400,
+      body: JSON.stringify({
+        message: 'No body was found',
+      }),
+    };
+  }
+
+  const streamName: string = 'eventStream';
+
+  try {
+    await kinesis.putRecord({
+      StreamName: streamName,
+      PartitionKey: uuidv4(),
+      Data: event.body,
+    }).promise();
+
+    message = 'Message placed in the Event Stream!';
+
+  } catch (error) {
+    console.log(error);
+    message = error;
+    statusCode = 500;
+  }
+
+  return {
+    statusCode,
+    body: JSON.stringify({
+      message,
+    }),
+  };
+};
+
+export default producer;