backup

data/aurora/README.md

@@ -0,0 +1,4 @@
+# Aurora
+
+## Database authentication
+- IAM DB Auth (optional)

msk/node/index.js

@@ -0,0 +1,18 @@
+import KafkaManager from '@davidkhala/kafka/index.js';
+
+import {generateAuthToken} from 'aws-msk-iam-sasl-signer-js';
+
+export default class MSK extends KafkaManager {
+	constructor(brokers) {
+		const sasl = {
+			mechanism: 'oauthbearer',
+			oauthBearerProvider: async () => {
+				const authTokenResponse = await generateAuthToken();
+				return {
+					value: authTokenResponse.token
+				};
+			}
+		};
+		super(brokers, {sasl});
+	}
+}

msk/node/package.json

@@ -0,0 +1,23 @@
+{
+  "name": "@davidkhala/aws-msk",
+  "version": "0.0.0",
+  "main": "index.js",
+  "scripts": {
+    "test": "mocha test"
+  },
+  "devDependencies": {
+    "mocha": "latest"
+  },
+  "dependencies": {
+    "@davidkhala/kafka": "latest",
+    "aws-msk-iam-sasl-signer-js": "latest"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/davidkhala/aws-collections.git"
+  },
+  "publishConfig": {
+    "access": "public"
+  },
+  "type": "module"
+}

msk/node/test/index.js

@@ -0,0 +1 @@
+// TODO WIP