Added: config.stream.timeoutConnect (default 60 seconds)

Changed: UDP/datagrams - removed transport compression (introduced in 5.1 - reverted)
Changed: createStream respects timeout
Fixed: tests, docs, code/docker clean-up

Signed-off-by: diva.exchange <[email protected]>

.c8rc.json

@@ -9,5 +9,5 @@
     "text-summary",
     "html"
   ],
-  "report-dir": "./coverage"
+  "report-dir": "./test/coverage"
 }

.mocharc.json

@@ -2,6 +2,5 @@
   "reporter": "list",
   "extensions": ["js"],
   "spec": ["test/compiled-lib/**/*.spec.js"],
-  "exit": true,
-  "bail": false
+  "exit": true
 }

README.md

@@ -339,6 +339,7 @@ type tSession = {
 
 type tStream = {
   destination: string;
+  timeout: number;
 };
 
 type tForward = {
@@ -387,6 +388,7 @@ const DEFAULT_CONFIGURATION: ConfigurationDefault = {
   },
   stream: {
     destination: '',
+    timeout: 60,
   },
   forward: {
     host: '',

lib/config.d.ts

@@ -1,9 +1,12 @@
+export declare const MIN_UDP_MESSAGE_LENGTH: number;
+export declare const MAX_UDP_MESSAGE_LENGTH: number;
 type tSession = {
   id?: string;
   options?: string;
 };
 type tStream = {
   destination: string;
+  timeout?: number;
 };
 type tForward = {
   host: string;

lib/i2p-sam-raw.d.ts

@@ -12,4 +12,5 @@ export declare class I2pSamRaw extends I2pSam {
   close(): void;
   protected initSession(type?: string): Promise<I2pSamRaw>;
   send(destination: string, msg: Buffer): void;
+  private s;
 }

lib/i2p-sam-stream.d.ts

@@ -7,6 +7,7 @@ export declare class I2pSamStream extends I2pSam {
   private hostForward;
   private portForward;
   private hasStream;
+  private timeout;
   static createStream(c: Configuration): Promise<I2pSamStream>;
   static createForward(c: Configuration): Promise<I2pSamStream>;
   static make(c: Configuration): Promise<I2pSamStream>;

lib/i2p-sam.d.ts

@@ -11,10 +11,10 @@ export declare class I2pSam extends EventEmitter {
   private privateKey;
   protected internalEventEmitter: EventEmitter;
   protected constructor(c: Configuration);
-  protected open(): Promise<any>;
+  protected open(): Promise<I2pSam>;
   protected close(): void;
   protected hello(socket: Socket): Promise<void>;
-  protected initSession(type: string): Promise<any>;
+  protected initSession(type: string): Promise<I2pSam>;
   protected parseReply(data: Buffer): boolean | undefined;
   private static parseReplyKeyValue;
   private generateDestination;