lnmessage - npm Package Compare versions

Comparing version 0.1.0 to 0.2.0

dist/crypto.d.ts

 /// <reference types="node" />
 import { Buffer } from 'buffer';
-export declare function sha256(input: Buffer): Buffer;
+export declare function sha256(input: Uint8Array): Buffer;
 export declare function ecdh(pubkey: Uint8Array, privkey: Uint8Array): Buffer;
@@ -5,0 +5,0 @@ export declare function hmacHash(key: Buffer, input: Buffer): Buffer;

dist/crypto.js

 import { Buffer } from 'buffer';
-import secp256k1 from 'secp256k1';
+import * as secp256k1 from '@noble/secp256k1';
 import { createCipher, createDecipher } from './chacha/index.js';
@@ -11,3 +11,4 @@ import { hmac } from '@noble/hashes/hmac';
 export function ecdh(pubkey, privkey) {
-    return Buffer.from(secp256k1.ecdh(pubkey, privkey));
+    const point = secp256k1.Point.fromHex(secp256k1.getSharedSecret(privkey, pubkey));
+    return Buffer.from(sha256(point.toRawBytes(true)));
 }
@@ -33,3 +34,3 @@ export function hmacHash(key, input) {
 export function getPublicKey(privKey, compressed = true) {
-    return Buffer.from(secp256k1.publicKeyCreate(privKey, compressed));
+    return Buffer.from(secp256k1.getPublicKey(privKey, compressed));
 }
@@ -89,6 +90,12 @@ /**
 export function validPublicKey(publicKey) {
-    return secp256k1.publicKeyVerify(Buffer.from(publicKey, 'hex'));
+    try {
+        secp256k1.Point.fromHex(publicKey);
+        return true;
+    }
+    catch (e) {
+        return false;
+    }
 }
 export function validPrivateKey(privateKey) {
-    return secp256k1.privateKeyVerify(typeof privateKey === 'string' ? Buffer.from(privateKey, 'hex') : privateKey);
+    return secp256k1.utils.isValidPrivateKey(privateKey);
 }
@@ -95,0 +102,0 @@ export function createRandomBytes(length) {

dist/index.d.ts

 /// <reference types="node" />
+/// <reference types="node" />
 import { BehaviorSubject, Observable } from 'rxjs';
@@ -6,2 +7,4 @@ import { Buffer } from 'buffer';
 import type { WebSocket as NodeWebSocket } from 'ws';
+import type { Socket as TCPSocket } from 'net';
+import type SocketWrapper from './socket-wrapper.js';
 import { LnWebSocketOptions, JsonRpcSuccessResponse, JsonRpcErrorResponse, Logger, CommandoRequest, ConnectionStatus } from './types.js';
@@ -28,3 +31,5 @@ declare class LnMessage {
     /**The WebSocket instance*/
-    socket: WebSocket | NodeWebSocket | null;
+    socket: WebSocket | NodeWebSocket | null | SocketWrapper;
+    /**TCP socket instance*/
+    tcpSocket?: TCPSocket;
     /**
@@ -31,0 +36,0 @@ * @deprecated Use connectionStatus$ instead

dist/index.js

@@ -34,2 +34,4 @@ import { BehaviorSubject, firstValueFrom, Subject } from 'rxjs';
     socket;
+    /**TCP socket instance*/
+    tcpSocket;
     /**
@@ -71,3 +73,3 @@ * @deprecated Use connectionStatus$ instead
         validateInit(options);
-        const { remoteNodePublicKey, wsProxy, wsProtocol = 'wss:', privateKey, ip, port = 9735, logger } = options;
+        const { remoteNodePublicKey, wsProxy, wsProtocol = 'wss:', privateKey, ip, port = 9735, logger, tcpSocket } = options;
         this._ls = Buffer.from(privateKey || createRandomPrivateKey(), 'hex');
@@ -87,2 +89,3 @@ this._es = Buffer.from(createRandomPrivateKey(), 'hex');
         this.Buffer = Buffer;
+        this.tcpSocket = tcpSocket;
         this._handshakeState = HANDSHAKE_STATE.INITIATOR_INITIATING;
@@ -119,4 +122,11 @@ this._decryptedMsgs$ = new Subject();
         this._attemptReconnect = attemptReconnect;
-        this.socket = new (typeof window === 'undefined' ? (await import('ws')).default : window.WebSocket)(this.wsUrl);
-        this.socket.binaryType = 'arraybuffer';
+        this.socket = this.tcpSocket
+            ? new (await import('./socket-wrapper.js')).default(this.wsUrl, this.tcpSocket)
+            : typeof globalThis.WebSocket === 'undefined'
+                ? new (await import('ws')).default(this.wsUrl)
+                : new globalThis.WebSocket(this.wsUrl);
+        if (this.socket.binaryType) {
+            ;
+            this.socket.binaryType = 'arraybuffer';
+        }
         this.socket.onopen = async () => {
@@ -123,0 +133,0 @@ this._log('info', 'WebSocket is connected');

dist/noise-state.js

@@ -118,3 +118,3 @@ import { Buffer } from 'buffer';
         this.ck = tempK1.subarray(0, 32);
-        this.tempK1 = tempK1.subarray(32);
+        this.tempK1 = Buffer.from(tempK1.subarray(32));
         // 5. c = encryptWithAD(temp_k1, 0, h, zero)
@@ -177,3 +177,3 @@ const c = ccpEncrypt(this.tempK1, Buffer.alloc(12), this.h, Buffer.alloc(0));
         this.ck = tempK3.subarray(0, 32);
-        this.tempK3 = tempK3.subarray(32);
+        this.tempK3 = Buffer.from(tempK3.subarray(32));
         // 5. t = encryptWithAD(temp_k3, 0, h, zero)
@@ -236,3 +236,3 @@ const t = ccpEncrypt(this.tempK3, Buffer.alloc(12), this.h, Buffer.alloc(0));
         this.ck = tempK2.subarray(0, 32);
-        this.tempK2 = tempK2.subarray(32);
+        this.tempK2 = Buffer.from(tempK2.subarray(32));
         // 5. c = encryptWithAd(temp_k2, 0, h, zero)
@@ -239,0 +239,0 @@ const c = ccpEncrypt(this.tempK2, Buffer.alloc(12), this.h, Buffer.alloc(0));

dist/types.d.ts

 /// <reference types="node" />
+/// <reference types="node" />
 import type { Buffer } from 'buffer';
+import type { Socket as TCPSocket } from 'net';
 export declare type LnWebSocketOptions = {
@@ -28,2 +30,4 @@ /**
     wsProtocol?: 'ws:' | 'wss:';
+    /**In nodejs or react native you can connect directly via a TCP socket */
+    tcpSocket?: TCPSocket;
     /**
@@ -30,0 +34,0 @@ * 32 byte hex encoded private key to be used as the local node secret.

package.json

 {
   "name": "lnmessage",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "description": "Talk to Lightning nodes from your browser",
@@ -13,2 +13,3 @@ "main": "dist/index.js",
   "license": "MIT",
+  "repository": "github:aaronbarnardsound/lnmessage",
   "scripts": {
@@ -30,7 +31,7 @@ "build": "tsc"
     "@noble/hashes": "^1.2.0",
+    "@noble/secp256k1": "^1.7.1",
     "buffer": "^6.0.3",
     "rxjs": "^7.5.7",
-    "secp256k1": "^5.0.0",
     "ws": "^8.12.1"
   }
 }

README.md

@@ -7,3 +7,3 @@ # lnmessage
 
-- Connect to a lightning node via a WebSocket connection.
+- Connect to a lightning node via a WebSocket or TCP Socket connection.
 - Works in the Browser and Node without any polyfilling.
@@ -88,2 +88,4 @@ - Initialise with a session secret to have a persistent node public key for the browser.
   wsProtocol?: 'ws:' | 'wss:'
+  /**In Nodejs or React Native you can connect directly via a TCP socket */
+  tcpSocket?: TCPSocket
   /**
@@ -90,0 +92,0 @@ * 32 byte hex encoded private key to be used as the local node secret.

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

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

No repository

Supply chain risk

Package does not have a linked source code repository. Without this field, a package will have no reference to the location of the source code use to generate the package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

253513

increased by1.72%

Number of package files

72

increased by4.35%

Lines of code

4346

increased by1.85%

Number of lines in readme file

263

increased by0.77%

Dependency changes

• + Added@noble/secp256k1@^1.7.1

• + Added@noble/secp256k1@1.7.1(transitive)

• - Removedsecp256k1@^5.0.0

• - Removedbn.js@4.12.0(transitive)

• - Removedbrorand@1.1.0(transitive)

• - Removedelliptic@6.5.7(transitive)

• - Removedhash.js@1.1.7(transitive)

• - Removedhmac-drbg@1.0.1(transitive)

• - Removedinherits@2.0.4(transitive)

• - Removedminimalistic-assert@1.0.1(transitive)

• - Removedminimalistic-crypto-utils@1.0.1(transitive)

• - Removednode-addon-api@5.1.0(transitive)

• - Removednode-gyp-build@4.8.2(transitive)

• - Removedsecp256k1@5.0.0(transitive)