version: 4.1.2

diva-exchange · Jul 13, 2022 · df22389 · df22389
1 parent 4fe7565
commit df22389
Show file tree

Hide file tree

Showing 6 changed files with 149 additions and 144 deletions.
diff --git a/dist/config.d.ts b/dist/config.d.ts
@@ -1,5 +1,6 @@
 declare type tSession = {
   id?: string;
+  options?: string;
 };
 declare type tStream = {
   destination: string;

diff --git a/dist/config.js b/dist/config.js
@@ -6,6 +6,7 @@ const DEFAULT_LENGTH_SESSION = 16;
 const DEFAULT_CONFIGURATION = {
     session: {
         id: '',
+        options: '',
     },
     stream: {
         destination: '',

diff --git a/dist/i2p-sam.d.ts b/dist/i2p-sam.d.ts
@@ -1,4 +1,6 @@
 /// <reference types="node" />
+/// <reference types="node" />
+/// <reference types="node" />
 import { EventEmitter } from 'events';
 import { Config, Configuration } from './config';
 import { Socket } from 'net';

diff --git a/dist/i2p-sam.js b/dist/i2p-sam.js
@@ -105,16 +105,17 @@ class I2pSam extends events_1.EventEmitter {
             let s = `SESSION CREATE ID=${this.config.session.id} DESTINATION=${this.privateKey} `;
             switch (type) {
                 case 'STREAM':
-                    s += 'STYLE=STREAM\n';
+                    s += 'STYLE=STREAM';
                     break;
                 case 'DATAGRAM':
                 case 'RAW':
-                    s += `STYLE=${type} PORT=${this.config.listen.portForward} HOST=${this.config.listen.hostForward}\n`;
+                    s += `STYLE=${type} PORT=${this.config.listen.portForward} HOST=${this.config.listen.hostForward}`;
                     break;
             }
             this.internalEventEmitter.removeAllListeners();
             this.internalEventEmitter.once('error', reject);
             this.internalEventEmitter.once('session', resolve);
+            s += (this.config.session.options ? ' ' + this.config.session.options : '') + '\n';
             this.socketControl.write(s, (error) => {
                 error && reject(error);
             });