clrghouz/app/Models/Echomail.php

173 lines
3.6 KiB
PHP
Raw Normal View History

2019-04-27 13:57:39 +00:00
<?php
namespace App\Models;
2021-09-06 13:39:32 +00:00
use Carbon\Carbon;
2021-08-29 01:48:27 +00:00
use Illuminate\Support\Collection;
2021-08-29 14:44:20 +00:00
use Illuminate\Support\Facades\DB;
2021-09-06 13:39:32 +00:00
use Illuminate\Support\Facades\Log;
use Jenssegers\Mongodb\Eloquent\Model;
use Jenssegers\Mongodb\Eloquent\SoftDeletes;
2019-04-27 13:57:39 +00:00
use App\Classes\FTN\Message;
use App\Interfaces\Packet;
2021-08-11 13:45:30 +00:00
use App\Traits\{EncodeUTF8,MsgID,UseMongo};
2021-09-06 13:39:32 +00:00
final class Echomail extends Model implements Packet
2019-04-27 13:57:39 +00:00
{
2021-08-11 13:45:30 +00:00
use SoftDeletes,MsgID,UseMongo,EncodeUTF8;
2021-09-06 13:39:32 +00:00
private const LOGKEY = 'ME-';
2021-08-11 13:45:30 +00:00
protected $collection = FALSE;
2021-09-14 13:14:13 +00:00
protected $casts = [ 'kludges' => 'json' ];
2021-08-11 13:45:30 +00:00
private const cast_utf8 = [
2021-08-26 12:32:32 +00:00
'subject',
'msg',
'origin',
'tearline',
'tagline',
2021-08-11 13:45:30 +00:00
];
2019-04-27 13:57:39 +00:00
protected $dates = ['datetime'];
2021-09-06 13:39:32 +00:00
public static function boot()
{
parent::boot();
static::created(function($model) {
if (! $model->echoarea_id) {
Log::alert(sprintf('%s:- Message has no echo area, no exporting',self::LOGKEY,$model->id));
return;
}
// See if we need to export this message.
$exportto = $model->echoarea->addresses->pluck('system')->diff($model->seenby->pluck('system'));
$export_ao = collect();
foreach ($model->echoarea->domain->zones as $zo) {
foreach ($exportto as $so) {
$export_ao = $export_ao->merge($so->match($zo));
}
}
// Add to export
foreach ($export_ao as $ao) {
Log::info(sprintf('%s:- Exporting message [%s] to [%s]',self::LOGKEY,$model->id,$ao->ftn));
DB::table('address_echomail')->insert([
'address_id'=>$ao->id,
'echomail_id'=>$model->id,
'export_date'=>Carbon::now()
]);
}
$model->seenby = $model->seenby->merge($export_ao);
$model->save();
});
}
/* RELATIONS */
2019-04-27 13:57:39 +00:00
2021-09-06 13:39:32 +00:00
public function echoarea()
{
return $this->belongsTo(Echoarea::class);
}
public function fftn()
2019-04-27 13:57:39 +00:00
{
return $this
->setConnection('pgsql')
->belongsTo(Address::class)
->withTrashed();
2019-04-27 13:57:39 +00:00
}
2021-08-29 01:48:27 +00:00
/* ATTRIBUTES */
2021-09-14 13:14:13 +00:00
public function getKludgesAttribute(string $value): Collection
{
return collect($this->castAttribute('kludges',$value));
}
2021-09-06 13:39:32 +00:00
public function getPathAttribute(?array $value): Collection
2021-08-29 01:48:27 +00:00
{
2021-09-06 13:39:32 +00:00
if (is_null($value))
return collect();
2021-08-29 14:44:20 +00:00
return Address::whereIn('id',$value)
->orderBy(DB::raw(sprintf("position (id::text in '(%s)')",join(',',$value))))
2021-09-06 13:39:32 +00:00
->get();
2021-08-29 01:48:27 +00:00
}
2021-09-06 13:39:32 +00:00
public function getSeenByAttribute(?array $value): Collection
2021-08-29 01:48:27 +00:00
{
2021-09-06 13:39:32 +00:00
if (is_null($value))
return collect();
return Address::whereIn('id',$value)->get();
2021-08-29 01:48:27 +00:00
}
/* METHODS */
2021-08-11 13:45:30 +00:00
public function jsonSerialize(): array
{
return $this->encode();
}
/**
* Return this model as a packet
*/
public function packet(Address $ao): Message
2019-04-27 13:57:39 +00:00
{
2021-09-06 13:39:32 +00:00
Log::debug(sprintf('%s:Bundling [%s]',self::LOGKEY,$this->id));
// @todo Dont bundle mail to nodes that have been disabled, or addresses that have been deleted
$o = new Message;
$o->header = [
'onode' => $this->fftn->node_id,
'dnode' => $ao->node_id,
'onet' => $this->fftn->host_id,
'dnet' => $ao->host_id,
'flags' => 0, // @todo?
'cost' => 0,
'date'=>$this->datetime->format('d M y H:i:s'),
];
$o->tzutc = $this->datetime->utcOffset($this->tzoffset)->getOffsetString('');
$o->user_to = $this->to;
$o->user_from = $this->from;
$o->subject = $this->subject;
2021-09-06 13:39:32 +00:00
$o->echoarea = $this->echoarea->name;
$o->flags = $this->flags;
2021-09-14 13:14:13 +00:00
if ($this->kludges)
$o->kludge = $this->kludges;
$o->kludge->put('mid',$this->id);
$o->msgid = $this->msgid;
if ($this->reply)
$o->reply = $this->reply;
$o->message = $this->msg;
if ($this->tagline)
$o->tagline = $this->tagline;
if ($this->tearline)
$o->tearline = $this->tearline;
if ($this->origin)
$o->origin = $this->origin;
// @todo SEENBY
// @todo PATH
2021-09-06 13:39:32 +00:00
$o->packed = TRUE;
return $o;
2019-04-27 13:57:39 +00:00
}
}