Changed: clean socket closing

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

src/i2p-sam-datagram.ts

@@ -27,15 +27,17 @@ export class I2pSamDatagram extends I2pSamRaw {
 
   static make(c: Configuration): Promise<I2pSamDatagram> {
     return new Promise((resolve, reject): void => {
-      (async (r: I2pSamDatagram): Promise<void> => {
+      (async (d: I2pSamDatagram): Promise<void> => {
         const t: NodeJS.Timer = setTimeout((): void => {
+          d.close();
           reject(new Error('I2pSamDatagram timeout'));
-        }, r.timeout * 1000);
+        }, d.timeout * 1000);
         try {
-          await r.open();
-          await r.initSession();
-          resolve(r);
+          await d.open();
+          await d.initSession();
+          resolve(d);
         } catch (error) {
+          d.close();
           reject(error);
         } finally {
           clearTimeout(t);

src/i2p-sam-raw.ts

@@ -34,13 +34,15 @@ export class I2pSamRaw extends I2pSam {
     return new Promise((resolve, reject): void => {
       (async (r: I2pSamRaw): Promise<void> => {
         const t: NodeJS.Timer = setTimeout((): void => {
+          r.close();
           reject(new Error('I2pSamRaw timeout'));
         }, r.timeout * 1000);
         try {
           await r.open();
           await r.initSession();
           resolve(r);
         } catch (error) {
+          r.close();
           reject(error);
         } finally {
           clearTimeout(t);

src/i2p-sam-stream.ts

@@ -38,16 +38,18 @@ export class I2pSamStream extends I2pSam {
 
   static make(c: Configuration): Promise<I2pSamStream> {
     return new Promise((resolve, reject): void => {
-      (async (r: I2pSamStream): Promise<void> => {
+      (async (s: I2pSamStream): Promise<void> => {
         const t: NodeJS.Timer = setTimeout((): void => {
+          s.close();
           reject(new Error('Stream timeout'));
-        }, r.timeout * 1000);
+        }, s.timeout * 1000);
         try {
-          await r.open();
-          await r.initSession('STREAM');
-          await r.connect();
-          resolve(r);
+          await s.open();
+          await s.initSession('STREAM');
+          await s.connect();
+          resolve(s);
         } catch (error) {
+          s.close();
           reject(error);
         } finally {
           clearTimeout(t);