file = $file; $this->ao = $ao; $this->rcvd_time = $rcvd_time; } public function __get($key): mixed { switch ($key) { case 'subject': return $this->file->name; default: return NULL; } } /** * When calling MessageProcess - we assume that the packet is from a valid source, and * the destination (netmail/echomail) is also valid */ public function handle() { Log::info(sprintf('%s:- Processing mail %s [%s]',self::LOGKEY,$this->file->whatType() === Item::IS_PKT ? 'PACKET' : 'ARCHIVE',$this->file->nameas)); $fs = Storage::disk(config('fido.local_disk')); // @todo Catch files that we cannot process, eg: ARJ bundles. try { $f = new File($this->file->full_name); $processed = FALSE; foreach ($f as $packet) { $pkt = Packet::process($packet,Arr::get(stream_get_meta_data($packet),'uri'),$f->itemSize(),$this->ao->zone->domain); // Check the messages are from the uplink if ($this->ao->system->addresses->search(function($item) use ($pkt) { return $item->id === $pkt->fftn_o->id; }) === FALSE) { Log::error(sprintf('%s:! Packet [%s] is not from this link? [%d]',self::LOGKEY,$pkt->fftn_o->ftn,$this->ao->system_id)); break; } // Check the packet password if (strtoupper($this->ao->session('pktpass')) !== strtoupper($pkt->password)) { Log::error(sprintf('%s:! Packet from [%s] with password [%s] is invalid.',self::LOGKEY,$this->ao->ftn,$pkt->password)); Notification::route('netmail',$this->ao)->notify(new PacketPasswordInvalid($pkt->password,$this->file->nameas)); break; } Log::info(sprintf('%s:- Packet has [%d] messages',self::LOGKEY,$pkt->count())); // Queue messages if there are too many in the packet. if ($queue = ($pkt->count() > config('fido.queue_msgs'))) Log::info(sprintf('%s:- Messages will be sent to the queue for processing',self::LOGKEY)); $count = 0; foreach ($pkt as $msg) { Log::info(sprintf('%s:- Mail from [%s] to [%s]',self::LOGKEY,$msg->fftn,$msg->tftn)); // @todo Quick check that the packet should be processed by us. // @todo validate that the packet's zone is in the domain. /* * // @todo generate exception when echomail for an area that doesnt exist * // @todo generate exception when echomail for an area sender cannot post to * // @todo generate exception when echomail for an area sender not subscribed to * // @todo generate exception when echomail comes from a system not defined here * // @todo generate exception when echomail comes from a system doesnt exist * * // @todo generate exception when netmail to system that doesnt exist (node/point) * // @todo generate exception when netmail from system that doesnt exist (node/point) * // @todo generate warning when netmail comes from a system not defined here * * // @todo generate exception when packet has wrong password */ try { // Dispatch job. if ($queue) MessageProcess::dispatch($msg,$f->pktName(),$this->ao->withoutRelations(),$pkt->fftn_o->withoutRelations(),$this->rcvd_time); else MessageProcess::dispatchSync($msg,$f->pktName(),$this->ao->withoutRelations(),$pkt->fftn_o->withoutRelations(),$this->rcvd_time); } catch (\Exception $e) { Log::error(sprintf('%s:! Got error dispatching message [%s] (%d:%s-%s).',self::LOGKEY,$msg->msgid,$e->getLine(),$e->getFile(),$e->getMessage())); } $count++; } if ($count === $pkt->count()) $processed = TRUE; } if (! $processed) { Log::alert(sprintf('%s:- Not deleting packet [%s], it doesnt seem to be processed?',self::LOGKEY,$this->file->nameas)); } else { // If we want to keep the packet, we could do that logic here if (config('fido.packet_keep')) { $dir = sprintf('%s/%s',config('fido.dir'),Carbon::now()->format('Ymd')); Log::debug(sprintf('%s:- Moving processed packet [%s] to [%s]',self::LOGKEY,$this->file->rel_name,$dir)); try { if ($fs->makeDirectory($dir)) { $fs->move($this->file->rel_name,$x=sprintf('%s/%s',$dir,$this->file->pref_name)); Log::info(sprintf('%s:- Moved processed packet [%s] to [%s]',self::LOGKEY,$this->file->rel_name,$x)); } else Log::error(sprintf('%s:! Unable to create dir [%s]',self::LOGKEY,$dir)); } catch (UnableToMoveFile $e) { Log::error(sprintf('%s:! Unable to move packet [%s] to [%s] (%s)',self::LOGKEY,$this->file->full_name,$dir,$e->getMessage())); } catch (\Exception $e) { Log::error(sprintf('%s:! Failed moving packet [%s] to [%s] (%s)',self::LOGKEY,$this->file->full_name,$dir,$e->getMessage())); } } else { Log::debug(sprintf('%s:- Deleting processed packet [%s]',self::LOGKEY,$this->file->full_name)); // @todo Change this to use Storage::disk() unlink($this->file->full_name); } } } catch (InvalidPacketException $e) { Log::error(sprintf('%s:- Not deleting packet [%s], as it generated an InvalidPacketException',self::LOGKEY,$this->file->nameas),['e'=>$e->getMessage()]); } catch (\Exception $e) { Log::error(sprintf('%s:- Not deleting packet [%s], as it generated an uncaught exception',self::LOGKEY,$this->file->nameas),['e'=>$e->getMessage()]); } } }