Fixes for Zmodem missed in bf3fce

app/Classes/File/Mail.php

@@ -58,7 +58,7 @@ final class Mail extends Send
 		if ($successful) {
 			$this->complete = TRUE;
 
-			Log::debug(sprintf('%s:- Successful close for [%d] - updating [%d] records.',self::LOGKEY,$this->type,$this->dbids->count()),['dbids'=>$this->dbids,'authd'=>$node->aka_remote_authed->pluck('id')]);
+			Log::info(sprintf('%s:- Successful close for [%d] - updating [%d] records.',self::LOGKEY,$this->type,$this->dbids->count()),['dbids'=>$this->dbids,'authd'=>$node->aka_remote_authed->pluck('id')]);
 
 			// Update netmail table
 			if (($this->type === Send::T_NETMAIL)

app/Classes/Protocol.php

@@ -288,6 +288,8 @@ abstract class Protocol
 		else {
 			Log::withContext(['pid'=>getmypid()]);
 
+			Log::debug(sprintf('%s:* Client session starting',self::LOGKEY));
+
 			$this->session($client,(new Address));
 		}
 

app/Classes/Protocol/EMSI.php

@@ -921,8 +921,16 @@ final class EMSI extends BaseProtocol implements CRCInterface,ZmodemInterface
 		$t1 = $this->client->timer_set(self::EMSI_HSTIMEOUT);
 		$t2 = $this->client->timer_set(self::EMSI_RESEND_TO);
 
+		$c = 0;
 		while (! $this->client->timer_expired($t1)) {
-			$ch = $this->client->read_ch(max( 1,min($this->client->timer_rest($t1),$this->client->timer_rest($t2))));
+			try {
+				$ch = $this->client->read_ch(max( 1,min($this->client->timer_rest($t1),$this->client->timer_rest($t2))));
+
+			} catch (SocketException $e) {
+				if ($c++ > 2)
+					return self::TIMEOUT;
+			}
+
 			if (static::DEBUG)
 				Log::debug(sprintf('%s:- Got [%x] (%c)',self::LOGKEY,$ch,$ch));
 
@@ -1193,7 +1201,7 @@ final class EMSI extends BaseProtocol implements CRCInterface,ZmodemInterface
 		Log::debug(sprintf('%s:+ Start WAZOO Receive',self::LOGKEY));
 
 		// @todo If the node is not defined in the DB node->address is NULL. Need to figure out how to handle those nodes.
-		$rc = (new Zmodem)->zmodem_receive($this->client,$zap,$this->recv,$this->node->address,$this->force_queue);
+		$rc = (new Zmodem($this->setup))->zmodem_receive($this->client,$zap,$this->recv,$this->node->address,$this->force_queue);
 
 		return ($rc === self::RCDO || $rc === self::ERROR);
 	}
@@ -1217,7 +1225,7 @@ final class EMSI extends BaseProtocol implements CRCInterface,ZmodemInterface
 			foreach ($this->node->aka_remote_authed as $ao) {
 				// Send mail
 				while ($this->send->mail($ao)) {
-					$z = new Zmodem;
+					$z = new Zmodem($this->setup);
 
 					if (! $z->zmodem_sendinit($this->client,$zap) && $this->send->togo_count)
 						$z->zmodem_sendfile($this->send,$this->node);
@@ -1225,7 +1233,7 @@ final class EMSI extends BaseProtocol implements CRCInterface,ZmodemInterface
 
 				// Send files
 				while ($this->send->files($ao)) {
-					$z = new Zmodem;
+					$z = new Zmodem($this->setup);
 
 					if (! $z->zmodem_sendinit($this->client,$zap) && $this->send->togo_count)
 						$z->zmodem_sendfile($this->send,$this->node);

app/Classes/Sock/SocketServer.php

@@ -127,6 +127,8 @@ final class SocketServer {
 			if (($accept = socket_accept($this->server)) === FALSE)
 				throw new SocketException(SocketException::CANT_ACCEPT,socket_strerror(socket_last_error($this->server)));
 
+			Log::debug(sprintf('%s:* TCP Loop Start',self::LOGKEY));
+
 			try {
 				$r = new SocketClient($accept);
 

app/Models/Address.php

@@ -469,7 +469,8 @@ class Address extends Model
 			->whereNotNull('export_at')
 			->whereNull('sent_at')
 			->whereNull('echomails.deleted_at')
-			->groupBy('addresses.id');
+			->groupBy('addresses.id')
+			->dontCache();
 	}
 
 	public function scopeUncollectedEchomailTotal($query)
@@ -503,7 +504,8 @@ class Address extends Model
 			->whereNotNull('export_at')
 			->whereNull('sent_at')
 			->whereNull('files.deleted_at')
-			->groupBy('addresses.id');
+			->groupBy('addresses.id')
+			->dontCache();
 	}
 
 	public function scopeUncollectedFilesTotal($query)
@@ -535,7 +537,8 @@ class Address extends Model
 			->whereNull('sent_pkt')
 			->whereNull('sent_at')
 			->whereNull('netmails.deleted_at')
-			->groupBy('addresses.id');
+			->groupBy('addresses.id')
+			->dontCache();
 	}
 
 	/**