@acuris/eventstore-postgresql - npm Package Compare versions

Comparing version 1.1.2 to 1.1.4

dist/PgEventSource.d.ts

@@ -8,2 +8,3 @@ import * as Pg from "pg";
 export declare function pgConfigForAWSAsync(region: string, hostname: string, port: number, database: string, username: string): Promise<Pg.ClientConfig>;
+export declare function pgAsyncConfigForAWS(region: string, hostname: string, port: number, database: string, username: string): Pg.ClientConfig;
 export declare function pgConfigForRDS(region: string, clusterIdentifier: string, username: string, readonly?: boolean): Promise<Pg.ClientConfig>;
@@ -10,0 +11,0 @@ export declare class PgEventSource implements EventSource {

dist/PgEventSource.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.PgEventSource = exports.pgConfigForRDS = exports.pgConfigForAWSAsync = exports.pgConfigForAWS = void 0;
+exports.PgEventSource = exports.pgConfigForRDS = exports.pgAsyncConfigForAWS = exports.pgConfigForAWSAsync = exports.pgConfigForAWS = void 0;
 const PgSchemaManager_1 = require("./PgSchemaManager");
@@ -31,2 +31,20 @@ const eventstore_api_1 = require("@acuris/eventstore-api");
 exports.pgConfigForAWSAsync = pgConfigForAWSAsync;
+function pgAsyncConfigForAWS(region, hostname, port, database, username) {
+    const AWS = require("aws-sdk");
+    const signer = new AWS.RDS.Signer({ hostname, username, port, region });
+    return {
+        host: hostname, user: username, port, database, ssl: { rejectUnauthorized: false },
+        password() {
+            return new Promise((resolve, reject) => {
+                signer.getAuthToken({}, (err, token) => {
+                    if (err)
+                        reject(err);
+                    else
+                        resolve(token);
+                });
+            });
+        }
+    };
+}
+exports.pgAsyncConfigForAWS = pgAsyncConfigForAWS;
 async function pgConfigForRDS(region, clusterIdentifier, username, readonly = false) {
@@ -39,3 +57,3 @@ const AWS = require("aws-sdk");
         throw new Error(`Cluster "${clusterIdentifier}" not found`);
-    return pgConfigForAWSAsync(region, readonly ? clusterInfo.ReaderEndpoint : clusterInfo.Endpoint, clusterInfo.Port, clusterInfo.DatabaseName, username);
+    return pgAsyncConfigForAWS(region, readonly ? clusterInfo.ReaderEndpoint : clusterInfo.Endpoint, clusterInfo.Port, clusterInfo.DatabaseName, username);
 }
@@ -42,0 +60,0 @@ exports.pgConfigForRDS = pgConfigForRDS;

package.json

 {
   "name": "@acuris/eventstore-postgresql",
   "private": false,
-  "version": "1.1.2",
+  "version": "1.1.4",
   "description": "Eventstore implementation storing events in Postgresql",
@@ -6,0 +6,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

31281

increased by2.76%

Lines of code

682

increased by2.87%

No dependency changes