Compare commits

..

No commits in common. "6430be01670385f2f6868aa49577aaa347503900" and "caac9c21a8b349325d43cc1713cc79885906fb84" have entirely different histories.

3 changed files with 4 additions and 6 deletions

View File

@ -125,9 +125,6 @@ class Send extends Base
if ($successful) { if ($successful) {
$end = time()-$this->start; $end = time()-$this->start;
Log::info(sprintf('%s:- Closing [%s], sent in [%d] with [%s] items',self::LOGKEY,$this->sending->nameas,$end,$this->sending->dbids->count())); Log::info(sprintf('%s:- Closing [%s], sent in [%d] with [%s] items',self::LOGKEY,$this->sending->nameas,$end,$this->sending->dbids->count()));
} else {
Log::alert(sprintf('%s:- Closing [%s], file NOT SENT successfully',self::LOGKEY,$this->sending->nameas));
} }
$this->sending->close($successful,$node); $this->sending->close($successful,$node);

View File

@ -1029,10 +1029,12 @@ final class Binkp extends BaseProtocol
* @return bool * @return bool
* @throws \Exception * @throws \Exception
* @todo We need to not add more files this session if a node skips a file * @todo We need to not add more files this session if a node skips a file
* @todo This incorrectly records the mail/file as sent and thus it is not sent again
*/ */
private function M_skip(string $buf): bool private function M_skip(string $buf): bool
{ {
Log::alert(sprintf('%s:+ Remote request to skip the file for now [%s]',self::LOGKEY,$buf)); Log::debug(sprintf('%s:+ Remote request to skip the file for now [%s]',self::LOGKEY,$buf));
throw new \Exception('We got a skip, but we dont handle it properly');
if ($file = $this->file_parse($buf)) { if ($file = $this->file_parse($buf)) {
if ($this->send->nameas if ($this->send->nameas
@ -1048,7 +1050,6 @@ final class Binkp extends BaseProtocol
$this->sessionClear(self::SE_WAITGOT|self::SE_SENDFILE); $this->sessionClear(self::SE_WAITGOT|self::SE_SENDFILE);
$this->send->close(FALSE,$this->node); $this->send->close(FALSE,$this->node);
throw new \Exception('We got a skip, but we dont handle it properly');
} }
} else { } else {

View File

@ -228,7 +228,7 @@ class AddressIdle implements ShouldQueue
->when($ao,fn($query)=>$query->where('addresses.id',$ao->id)) ->when($ao,fn($query)=>$query->where('addresses.id',$ao->id))
->where(fn($q)=>$q->where('last_session','<',$age)->orWhereNull('last_session')) ->where(fn($q)=>$q->where('last_session','<',$age)->orWhereNull('last_session'))
->whereRaw(sprintf('((role IS NULL) OR (role=0) OR ((role & %d) > 0))',$flags)) ->whereRaw(sprintf('((role IS NULL) OR (role=0) OR ((role & %d) > 0))',$flags))
->whereRaw(sprintf('((role IS NULL) OR ((role & %d) = 0))',Address::NODE_KEEP)) ->whereRaw(sprintf('((role & %d) = 0)',Address::NODE_KEEP))
->join('systems',['systems.id'=>'addresses.system_id']) ->join('systems',['systems.id'=>'addresses.system_id'])
->ftnOrder() ->ftnOrder()
->with(['system','zone.domain']) ->with(['system','zone.domain'])