pg-logical-replication - npm Package Compare versions

Comparing version 2.0.4 to 2.0.5

dist/index.d.ts

@@ -1,8 +0,8 @@
-export * from './logical-replication-service';
-export * from './output-plugins/test_decoding/test-decoding-plugin';
-export * from './output-plugins/pgoutput';
-export * from './output-plugins/wal2json/wal2json-plugin';
-export * from './output-plugins/wal2json/wal2json-plugin-options.type';
-export * from './output-plugins/wal2json/wal2json-plugin-output.type';
-export * from './output-plugins/decoderbufs/decoderbufs-plugin';
-export * from './output-plugins/decoderbufs/decoderbufs-plugin-output.type';
+export * from './logical-replication-service.js';
+export * from './output-plugins/test_decoding/test-decoding-plugin.js';
+export * from './output-plugins/pgoutput/index.js';
+export * from './output-plugins/wal2json/wal2json-plugin-options.type.js';
+export * from './output-plugins/wal2json/wal2json-plugin-output.type.js';
+export * from './output-plugins/wal2json/wal2json-plugin.js';
+export * from './output-plugins/decoderbufs/decoderbufs-plugin-output.type.js';
+export * from './output-plugins/decoderbufs/decoderbufs-plugin.js';

dist/index.js

@@ -17,9 +17,9 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-__exportStar(require("./logical-replication-service"), exports);
-__exportStar(require("./output-plugins/test_decoding/test-decoding-plugin"), exports);
-__exportStar(require("./output-plugins/pgoutput"), exports);
-__exportStar(require("./output-plugins/wal2json/wal2json-plugin"), exports);
-__exportStar(require("./output-plugins/wal2json/wal2json-plugin-options.type"), exports);
-__exportStar(require("./output-plugins/wal2json/wal2json-plugin-output.type"), exports);
-__exportStar(require("./output-plugins/decoderbufs/decoderbufs-plugin"), exports);
-__exportStar(require("./output-plugins/decoderbufs/decoderbufs-plugin-output.type"), exports);
+__exportStar(require("./logical-replication-service.js"), exports);
+__exportStar(require("./output-plugins/test_decoding/test-decoding-plugin.js"), exports);
+__exportStar(require("./output-plugins/pgoutput/index.js"), exports);
+__exportStar(require("./output-plugins/wal2json/wal2json-plugin-options.type.js"), exports);
+__exportStar(require("./output-plugins/wal2json/wal2json-plugin-output.type.js"), exports);
+__exportStar(require("./output-plugins/wal2json/wal2json-plugin.js"), exports);
+__exportStar(require("./output-plugins/decoderbufs/decoderbufs-plugin-output.type.js"), exports);
+__exportStar(require("./output-plugins/decoderbufs/decoderbufs-plugin.js"), exports);

dist/logical-replication-service.d.ts

 import EventEmitter2 from 'eventemitter2';
 import { ClientConfig } from 'pg';
-import { AbstractPlugin } from './output-plugins/abstract.plugin';
+import { AbstractPlugin } from './output-plugins/abstract.plugin.js';
 export interface ReplicationClientConfig extends ClientConfig {
@@ -5,0 +5,0 @@ replication: 'database';

dist/output-plugins/decoderbufs/decoderbufs-plugin.d.ts

 /// <reference types="node" />
-import { AbstractPlugin } from '../abstract.plugin';
 import { Client } from 'pg';
+import { AbstractPlugin } from '../abstract.plugin.js';
 export interface ProtocolBuffersPluginOptions {
@@ -5,0 +5,0 @@ }

dist/output-plugins/decoderbufs/decoderbufs-plugin.js

@@ -7,5 +7,5 @@ "use strict";
 exports.ProtocolBuffersPlugin = void 0;
-const abstract_plugin_1 = require("../abstract.plugin");
-const pg_logicaldec_proto_1 = __importDefault(require("./pg_logicaldec.proto"));
-class ProtocolBuffersPlugin extends abstract_plugin_1.AbstractPlugin {
+const abstract_plugin_js_1 = require("../abstract.plugin.js");
+const pg_logicaldec_proto_js_1 = __importDefault(require("./pg_logicaldec.proto.js"));
+class ProtocolBuffersPlugin extends abstract_plugin_js_1.AbstractPlugin {
     constructor(options) {
@@ -15,3 +15,3 @@ super(options || {});
             const protobufjs = require('protobufjs');
-            this.proto = protobufjs.Root.fromJSON(pg_logicaldec_proto_1.default);
+            this.proto = protobufjs.Root.fromJSON(pg_logicaldec_proto_js_1.default);
             this.rowMessage = this.proto.lookupType('RowMessage');
@@ -18,0 +18,0 @@ }

dist/output-plugins/pgoutput/index.d.ts

@@ -1,2 +0,2 @@
-export * from './pgoutput-plugin';
-export * as Pgoutput from './pgoutput.types';
+export * from './pgoutput-plugin.js';
+export * as Pgoutput from './pgoutput.types.js';

dist/output-plugins/pgoutput/index.js

@@ -30,3 +30,3 @@ "use strict";
 exports.Pgoutput = void 0;
-__exportStar(require("./pgoutput-plugin"), exports);
-exports.Pgoutput = __importStar(require("./pgoutput.types"));
+__exportStar(require("./pgoutput-plugin.js"), exports);
+exports.Pgoutput = __importStar(require("./pgoutput.types.js"));

dist/output-plugins/pgoutput/pgoutput-parser.d.ts

 /// <reference types="node" />
-import { Message, MessageRelation } from './pgoutput.types';
+import { Message, MessageRelation } from './pgoutput.types.js';
 export declare class PgoutputParser {
@@ -4,0 +4,0 @@ _typeCache: Map<number, {

dist/output-plugins/pgoutput/pgoutput-parser.js

@@ -6,3 +6,3 @@ "use strict";
 const pg_1 = require("pg");
-const binary_reader_1 = require("./binary-reader");
+const binary_reader_js_1 = require("./binary-reader.js");
 class PgoutputParser {
@@ -14,3 +14,3 @@ constructor() {
     parse(buf) {
-        const reader = new binary_reader_1.BinaryReader(buf);
+        const reader = new binary_reader_js_1.BinaryReader(buf);
         const tag = reader.readUint8();
@@ -17,0 +17,0 @@ switch (tag) {

dist/output-plugins/pgoutput/pgoutput-plugin.d.ts

 /// <reference types="node" />
 import { Client } from 'pg';
-import { AbstractPlugin } from '../abstract.plugin';
-import { Message, Options } from './pgoutput.types';
+import { AbstractPlugin } from '../abstract.plugin.js';
+import { Message, Options } from './pgoutput.types.js';
 export declare class PgoutputPlugin extends AbstractPlugin<Options> {
@@ -6,0 +6,0 @@ private parser;

dist/output-plugins/pgoutput/pgoutput-plugin.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.PgoutputPlugin = void 0;
-const abstract_plugin_1 = require("../abstract.plugin");
-const pgoutput_parser_1 = require("./pgoutput-parser");
-class PgoutputPlugin extends abstract_plugin_1.AbstractPlugin {
+const abstract_plugin_js_1 = require("../abstract.plugin.js");
+const pgoutput_parser_js_1 = require("./pgoutput-parser.js");
+class PgoutputPlugin extends abstract_plugin_js_1.AbstractPlugin {
     constructor(options) {
         super(options);
-        this.parser = new pgoutput_parser_1.PgoutputParser();
+        this.parser = new pgoutput_parser_js_1.PgoutputParser();
     }
@@ -11,0 +11,0 @@ get name() {

dist/output-plugins/test_decoding/decoder.d.ts

@@ -1,7 +0,1 @@
-declare const _module: {
-    SyntaxError: {
-        (message: any, expected: any, found: any, location: any): void;
-        buildMessage(expected: any, found: any): string;
-    };
-    parse: (input: any, options: any) => {};
-};
+export {};

dist/output-plugins/test_decoding/decoder.js

@@ -8,2 +8,3 @@ "use strict";
  */
+Object.defineProperty(exports, "__esModule", { value: true });
 /*
@@ -10,0 +11,0 @@ * PEG Source

dist/output-plugins/test_decoding/test-decoding-plugin.d.ts

 /// <reference types="node" />
-import { AbstractPlugin } from '../abstract.plugin';
 import { Client } from 'pg';
+import { AbstractPlugin } from '../abstract.plugin.js';
 export interface TestDecodingPluginOptions {
@@ -5,0 +5,0 @@ /**

dist/output-plugins/test_decoding/test-decoding-plugin.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.TestDecodingPlugin = void 0;
-const abstract_plugin_1 = require("../abstract.plugin");
+const abstract_plugin_js_1 = require("../abstract.plugin.js");
 const decoder = require('./decoder');
-class TestDecodingPlugin extends abstract_plugin_1.AbstractPlugin {
+class TestDecodingPlugin extends abstract_plugin_js_1.AbstractPlugin {
     constructor(options) {
@@ -8,0 +8,0 @@ super(options || {});

dist/output-plugins/wal2json/wal2json-plugin.d.ts

 /// <reference types="node" />
-import { AbstractPlugin } from '../abstract.plugin';
 import { Client } from 'pg';
-import { Wal2JsonPluginOptions } from './wal2json-plugin-options.type';
+import { AbstractPlugin } from '../abstract.plugin.js';
+import { Wal2JsonPluginOptions } from './wal2json-plugin-options.type.js';
 /**
@@ -6,0 +6,0 @@ * wal2json

dist/output-plugins/wal2json/wal2json-plugin.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.Wal2JsonPlugin = void 0;
-const abstract_plugin_1 = require("../abstract.plugin");
-const wal2json_plugin_options_type_1 = require("./wal2json-plugin-options.type");
+const abstract_plugin_js_1 = require("../abstract.plugin.js");
+const wal2json_plugin_options_type_js_1 = require("./wal2json-plugin-options.type.js");
 /**
@@ -10,3 +10,3 @@ * wal2json
  */
-class Wal2JsonPlugin extends abstract_plugin_1.AbstractPlugin {
+class Wal2JsonPlugin extends abstract_plugin_js_1.AbstractPlugin {
     constructor(options) {
@@ -21,3 +21,3 @@ super(options || {});
         Object.entries(this.options).map(([key, value]) => {
-            if (wal2json_plugin_options_type_1.StringOptionKeys.includes(key))
+            if (wal2json_plugin_options_type_js_1.StringOptionKeys.includes(key))
                 options.push(`"${dashCase(key)}" '${value}'`);
@@ -24,0 +24,0 @@ else

package.json

 {
   "name": "pg-logical-replication",
-  "version": "2.0.4",
+  "version": "2.0.5",
   "description": "PostgreSQL Location Replication client - logical WAL replication streaming",
@@ -115,4 +115,7 @@ "main": "dist/index.js",
     "maxConcurrency": 1,
-    "maxWorkers": 1
+    "maxWorkers": 1,
+    "moduleNameMapper": {
+      "^(\\.{1,2}/.*)\\.js$": "$1"
+    }
   }
 }

README.md

 # pg-logical-replication
-
 - [PostgreSQL Logical Replication](https://www.postgresql.org/docs/current/logical-replication.html) client for node.js
@@ -18,3 +17,2 @@ - Supported plugins
 ## 1. Install
-
 - **pg-logical-replication** depends on [pq(node-postgres)  >= 6.2.2](https://github.com/brianc/node-postgres)
@@ -21,0 +19,0 @@ and [eventemitter2](https://www.npmjs.com/package/eventemitter2)

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

124026

increased by0.06%

Worsened metrics

Lines of code

2976

decreased by-0.17%

Number of lines in readme file

178

decreased by-1.11%

Number of medium supply chain risk alerts

1

increased byInfinity%

No dependency changes