4.0.4

Author: KloakIT

core/tools/imap.js

@@ -563,7 +563,7 @@ class ImapServerSwitchStream extends Stream.Transform {
         this.Tag = `A${this.imapServer.TagCount1()}`;
         this.cmd = `APPEND "${this.imapServer.writeFolder}" {${out.length}${this.imapServer.literalPlus ? '+' : ''}}`;
         this.cmd = `${this.Tag} ${this.cmd}`;
-        const time = out.length + 15000;
+        const time = out.length + 30000;
         this.debug ? debugOut(this.cmd, false, this.imapServer.listenFolder || this.imapServer.imapSerialID) : null;
         if (!this.writable) {
             //console.log (`[${ this.imapServer.imapSerialID }] ImapServerSwitchStream append !this.writable doing imapServer.socket.end ()`)
@@ -632,7 +632,7 @@ class ImapServerSwitchStream extends Stream.Transform {
         this.Tag = `A${this.imapServer.TagCount1()}`;
         this.cmd = `APPEND "${folderName}" {${_length}${this.imapServer.literalPlus ? '+' : ''}}`;
         this.cmd = `${this.Tag} ${this.cmd}`;
-        const _time = _length / 1000 + 20000;
+        const _time = _length + 1000 * 60;
         this.debug ? debugOut(this.cmd, false, this.imapServer.listenFolder || this.imapServer.imapSerialID) : null;
         if (!this.writable) {
             return this.doCommandCallback(new Error('! imap.writable '));
@@ -717,7 +717,7 @@ class ImapServerSwitchStream extends Stream.Transform {
         this.appendWaitResponsrTimeOut = timers_1.setTimeout(() => {
             //this.imapServer.emit ( 'error', new Error (`${ this.cmd } timeout!`))
             return this.doCommandCallback(new Error(`${this.cmd} timeout!`));
-        }, this.imapServer.fetching + 15000);
+        }, this.imapServer.fetching + 1000 * 60);
         if (this.writable) {
             return this.push(this.cmd + '\r\n');
         }

core/tools/imap.ts

@@ -691,7 +691,7 @@ class ImapServerSwitchStream extends Stream.Transform {
         this.Tag = `A${ this.imapServer.TagCount1() }`
         this.cmd = `APPEND "${ this.imapServer.writeFolder }" {${ out.length }${ this.imapServer.literalPlus ? '+' : ''}}`
         this.cmd = `${ this.Tag } ${ this.cmd }`
-        const time = out.length + 15000
+        const time = out.length + 30000
         this.debug ? debugOut ( this.cmd, false, this.imapServer.listenFolder || this.imapServer.imapSerialID ) : null
         if ( !this.writable ) {
             //console.log (`[${ this.imapServer.imapSerialID }] ImapServerSwitchStream append !this.writable doing imapServer.socket.end ()`)
@@ -701,7 +701,7 @@ class ImapServerSwitchStream extends Stream.Transform {
         this.push ( this.cmd + '\r\n' )
 
         this.appendWaitResponsrTimeOut = setTimeout (() => {
-            return this.doCommandCallback( new Error ( `IMAP append TIMEOUT` ))
+            return this.doCommandCallback ( new Error ( `IMAP append TIMEOUT` ))
 		}, time )
 
         //console.log (`*************************************  append time = [${ time }] `)
@@ -776,7 +776,7 @@ class ImapServerSwitchStream extends Stream.Transform {
 		this.Tag = `A${ this.imapServer.TagCount1() }`
 		this.cmd = `APPEND "${ folderName }" {${ _length }${ this.imapServer.literalPlus ? '+' : ''}}`
 		this.cmd = `${ this.Tag } ${ this.cmd }`
-		const _time = _length / 1000 + 20000
+		const _time = _length + 1000 * 60
 		this.debug ? debugOut ( this.cmd, false, this.imapServer.listenFolder || this.imapServer.imapSerialID ) : null
 		if ( !this.writable ) {
 			return this.doCommandCallback ( new Error ('! imap.writable '))
@@ -889,7 +889,7 @@ class ImapServerSwitchStream extends Stream.Transform {
         this.appendWaitResponsrTimeOut = setTimeout (() => {
             //this.imapServer.emit ( 'error', new Error (`${ this.cmd } timeout!`))
             return this.doCommandCallback ( new Error (`${ this.cmd } timeout!`))
-        }, this.imapServer.fetching + 15000 )
+        }, this.imapServer.fetching + 1000 * 60 )
 
         if ( this.writable ) {
 

package.json

@@ -1,6 +1,6 @@
 {
 	"name": "conet",
-	"version": "4.0.2",
+	"version": "4.0.4",
 	"license": "MIT",
 	"description": "CoNET",
 	"repository": {