Compare commits

..

11 Commits

Author SHA1 Message Date
0bbff33fdd Added filefix %LIST
All checks were successful
Create Docker Image / Build Docker Image (x86_64) (push) Successful in 45s
Create Docker Image / Build Docker Image (arm64) (push) Successful in 1m37s
Create Docker Image / Final Docker Image Manifest (push) Successful in 10s
2024-11-26 12:44:21 +11:00
67cbfa4c64 Split out areafix command processing, implemented start of filefix 2024-11-26 12:23:07 +11:00
cf95b2dab4 Deprecate singleOrNew(), we use firstOrNew() instead 2024-11-23 23:26:06 +11:00
95969a857b Change NodelistImport display when using job:list 2024-11-23 23:26:06 +11:00
58fe142f7c Added ansitex font 2024-11-23 23:26:06 +11:00
43c4f1511d Remove unused config files 2024-11-23 23:26:06 +11:00
b2b519a2c4 Remove CommProtocolReceive commands, Remove protocol onConnect() functions, pass Setup::class to protocols 2024-11-23 23:26:05 +11:00
7352a74a12 Deprecate singleOrFail() in favour of sole() 2024-11-23 23:26:05 +11:00
5874b2aef1 Reduce the need for Mailer::class in protocols 2024-11-23 23:26:05 +11:00
ff4ecddb76 Drop updated_at from system_log 2024-11-23 23:26:05 +11:00
6c9f4facc6 Additional debugging for messages that fail quick validation during processing 2024-11-20 16:20:49 +09:30
45 changed files with 775 additions and 376 deletions

View File

@ -794,7 +794,7 @@ class Message extends FTNBase
// Quick validation that we are done
if ($ptr_content_start !== strlen($content)) {
Log::alert(sprintf('%s:! We failed parsing the message.',self::LOGKEY));
Log::alert(sprintf('%s:! We failed parsing the message start [%d] content [%d]',self::LOGKEY,$ptr_content_start,strlen($content)));
$o->msg = substr($message,0,$ptr_end);
}
}

View File

@ -160,7 +160,7 @@ abstract class Packet extends FTNBase implements \Iterator, \Countable
try {
$o->zone = Zone::where('zone_id',$o->fz)
->where('default',TRUE)
->singleOrFail();
->sole();
} catch (ModelNotFoundException $e) {
throw new InvalidPacketException(sprintf('%s:! We couldnt work out the packet zone, and there isnt a default for[%d]',self::LOGKEY,$o->fz));
@ -263,7 +263,7 @@ abstract class Packet extends FTNBase implements \Iterator, \Countable
case 'software':
Software::unguard();
$o = Software::singleOrNew(['code'=>$this->product,'type'=>Software::SOFTWARE_TOSSER]);
$o = Software::firstOrNew(['code'=>$this->product,'type'=>Software::SOFTWARE_TOSSER]);
Software::reguard();
return $o;

View File

@ -0,0 +1,50 @@
<?php
namespace App\Classes\FTN\Process\Netmail;
use Illuminate\Support\Facades\Notification;
use Illuminate\Support\Facades\Log;
use App\Classes\FTN\Process;
use App\Models\{Echomail,Netmail};
use App\Notifications\Netmails\Areafix\{InvalidPassword,NotConfiguredHere};
/**
* Process messages to Ping
*
* @package App\Classes\FTN\Process
*/
abstract class Robot extends Process
{
private const LOGKEY = 'RPR';
public static function handle(Echomail|Netmail $mo): bool
{
if (((strtolower($mo->to) !== 'areafix') && (strtolower($mo->to) !== 'filefix')) || (! ($mo instanceof Netmail)))
return FALSE;
Log::info(sprintf('%s:- Processing *FIX [%s] message from (%s) [%s]',self::LOGKEY,$mo->to,$mo->from,$mo->fftn->ftn));
// If this is not a node we manage, then respond with a sorry can help you
if (! $mo->fftn->system->sessions->count()) {
Notification::route('netmail',$mo->fftn)->notify(new NotConfiguredHere($mo));
return TRUE;
}
// If this nodes password is not correct
if ($mo->fftn->pass_fix !== strtoupper($mo->subject)) {
Notification::route('netmail',$mo->fftn)->notify(new InvalidPassword($mo));
return TRUE;
}
if ((strtolower($mo->to) === 'areafix'))
return static::areafix($mo);
if ((strtolower($mo->to) === 'filefix'))
return static::filefix($mo);
return FALSE;
}
}

View File

@ -0,0 +1,93 @@
<?php
namespace App\Classes\FTN\Process\Netmail\Robot;
use Illuminate\Support\Facades\Notification;
use Illuminate\Support\Facades\Log;
use App\Classes\FTN\Process\Netmail\Robot;
use App\Models\{Echomail,Netmail};
use App\Notifications\Netmails\Areafix\CommandsProcessed;
/**
* Process messages to Ping
*
* @package App\Classes\FTN\Process
*/
final class Areafix extends Robot
{
private const LOGKEY = 'RPA';
public const commands = 'App\\Classes\\FTN\\Process\\Netmail\\Robot\\Areafix\\';
public static function handle(Echomail|Netmail $mo): bool
{
if ((strtolower($mo->to) !== 'areafix') || (! ($mo instanceof Netmail)))
return FALSE;
Log::info(sprintf('%s:- Processing AREAFIX [%s] message from (%s) [%s]', self::LOGKEY, $mo->to, $mo->from, $mo->fftn->ftn));
return parent::handle($mo);
}
public static function areafix(Netmail $mo): bool
{
$result = collect();
$result->push('--> BEGIN <--');
foreach ($mo->body_lines as $command) {
// Skip empty lines
if (! $command)
continue;
$command = explode(' ',strtoupper(trim($command)));
// If command starts with '...' or '---', its a tear/tag line, and we have reached the end
if (str_starts_with($command[0],'...') || str_starts_with($command[0],'---')) {
Log::debug(sprintf('%s:= We got a tearline/tagline, end of processing',self::LOGKEY));
$result->push('--> END OF PROCESSING <--');
break;
// If command doesnt start with %, its an area
} elseif (! str_starts_with($command[0],'%')) {
Log::info(sprintf('%s:= Assuming command [%s] is an AREA command',self::LOGKEY,$command[0]));
array_unshift($command,'%AREA');
}
// Some commands are reserved words
switch ($x=strtolower(substr($command[0],1))) {
case 'list':
$class = self::commands.'AreaList';
break;
default:
// Parse the message body and pluck out the commands on each line
$class = self::commands.ucfirst($x);
}
if (! class_exists($class)) {
$result->push(sprintf('%-25s <-- **COMMAND UNKNOWN**',join(' ',$command)));
Log::info(sprintf('%s:! Command UNKNOWN [%s] ',self::LOGKEY,join('|',$command)),['class'=>$class]);
continue;
}
// Drop the command from the array, the rest are arguments
array_shift($command);
// Refresh our echoareas
$mo->fftn->load('echoareas');
$o = new $class($mo,$command);
$result->push($o->process());
}
// Reply with a confirmation of what commands were processed
Notification::route('netmail',$mo->fftn)->notify(new CommandsProcessed($mo,$result));
return TRUE;
}
}

View File

@ -5,7 +5,7 @@ namespace App\Classes\FTN\Process\Netmail\Robot\Areafix;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Notification;
use App\Classes\FTN\Process\Netmail\Areafix;
use App\Classes\FTN\Process\Netmail\Robot\Areafix;
use App\Notifications\Netmails\Areafix\Help as HelpNotification;
// A Help Index Command
@ -33,7 +33,7 @@ class Help extends Base
if (($file === 'Base.php') || (! str_ends_with(strtolower($file),'.php')))
continue;
$class = Areafix::areafix_commands.preg_replace('/\.php$/','',$file);
$class = Areafix::commands.preg_replace('/\.php$/','',$file);
if ($result->count())
$result->push('');

View File

@ -1,58 +1,36 @@
<?php
namespace App\Classes\FTN\Process\Netmail;
namespace App\Classes\FTN\Process\Netmail\Robot;
use Illuminate\Support\Facades\Notification;
use Illuminate\Support\Facades\Log;
use App\Classes\FTN\Process;
use App\Classes\FTN\Process\Netmail\Robot\Unknown;
use App\Classes\FTN\Process\Netmail\Robot;
use App\Models\{Echomail,Netmail};
use App\Notifications\Netmails\FixCantHandle;
use App\Notifications\Netmails\Areafix\{CommandsProcessed,InvalidPassword,NotConfiguredHere};
use App\Notifications\Netmails\Areafix\CommandsProcessed;
/**
* Process messages to Ping
*
* @package App\Classes\FTN\Process
*/
final class Areafix extends Process
final class Filefix extends Robot
{
private const LOGKEY = 'RP-';
private const LOGKEY = 'RPF';
public const areafix_commands = 'App\\Classes\\FTN\\Process\\Netmail\\Robot\\Areafix\\';
public const commands = 'App\\Classes\\FTN\\Process\\Netmail\\Robot\\Filefix\\';
public static function handle(Echomail|Netmail $mo): bool
{
if (((strtolower($mo->to) !== 'areafix') && (strtolower($mo->to) !== 'filefix')) || (! ($mo instanceof Netmail)))
if ((strtolower($mo->to) !== 'filefix') || (! ($mo instanceof Netmail)))
return FALSE;
Log::info(sprintf('%s:- Processing *FIX [%s] message from (%s) [%s]',self::LOGKEY,$mo->to,$mo->from,$mo->fftn->ftn));
Log::info(sprintf('%s:- Processing FILEFIX [%s] message from (%s) [%s]', self::LOGKEY, $mo->to, $mo->from, $mo->fftn->ftn));
// If this is not a node we manage, then respond with a sorry can help you
if (! $mo->fftn->system->sessions->count()) {
Notification::route('netmail',$mo->fftn)->notify(new NotConfiguredHere($mo));
return TRUE;
}
// If this nodes password is not correct
if ($mo->fftn->pass_fix !== strtoupper($mo->subject)) {
Notification::route('netmail',$mo->fftn)->notify(new InvalidPassword($mo));
return TRUE;
}
if ((strtolower($mo->to) === 'areafix'))
return self::areafix($mo);
if ((strtolower($mo->to) === 'filefix'))
return self::filefix($mo);
return FALSE;
return parent::handle($mo);
}
public static function areafix(Netmail $mo): bool
public static function filefix(Netmail $mo): bool
{
$result = collect();
$result->push('--> BEGIN <--');
@ -82,12 +60,12 @@ final class Areafix extends Process
// Some commands are reserved words
switch ($x=strtolower(substr($command[0],1))) {
case 'list':
$class = self::areafix_commands.'AreaList';
$class = self::commands.'AreaList';
break;
default:
// Parse the message body and pluck out the commands on each line
$class = self::areafix_commands.ucfirst($x);
$class = self::commands.ucfirst($x);
}
if (! class_exists($class)) {
@ -101,7 +79,7 @@ final class Areafix extends Process
array_shift($command);
// Refresh our echoareas
$mo->fftn->load('echoareas');
$mo->fftn->load('fileareas');
$o = new $class($mo,$command);
$result->push($o->process());
@ -112,11 +90,4 @@ final class Areafix extends Process
return TRUE;
}
public static function filefix(Netmail $mo): bool
{
Notification::route('netmail',$mo->fftn)->notify(new FixCantHandle($mo));
return TRUE;
}
}

View File

@ -0,0 +1,39 @@
<?php
namespace App\Classes\FTN\Process\Netmail\Robot\Filefix;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Notification;
use App\Classes\FTN\Process\Netmail\Robot\Areafix\Base;
use App\Notifications\Netmails\Filefix\AreaList as AreaListNotification;
// LIST - List echoareas in a domain
class AreaList extends Base
{
private const LOGKEY = 'AFS';
private const command = '%LIST';
public static function help(): array
{
return [
self::command,
' List the available fileareas in this network',
];
}
public function process(): string
{
Log::debug(sprintf('%s:- Filefix [%s] for [%s] for [%s]',self::LOGKEY,self::command,$this->mo->fftn->ftn,join('|',$this->arguments)));
if (count($this->arguments) > 1)
return sprintf('%-25s <-- INVALID COMMAND',self::command);
else {
Notification::route('netmail',$this->mo->fftn)
->notify(new AreaListNotification($this->mo));
return sprintf('%-25s <-- COMMAND PROCESSED',self::command);
}
}
}

View File

@ -0,0 +1,50 @@
<?php
namespace App\Classes\FTN\Process\Netmail\Robot\Filefix;
use App\Classes\FTN\Process\Netmail\Robot\Areafix\Base;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Notification;
use App\Classes\FTN\Process\Netmail\Robot\Filefix;
use App\Notifications\Netmails\Filefix\Help as HelpNotification;
// A Help Index Command
class Help extends Base
{
private const LOGKEY = 'FFH';
private const filefix_classes = 'app/Classes/FTN/Process/Netmail/Robot/Filefix';
private const command = '%HELP';
public static function help(): array
{
return [
self::command,
' This message!',
];
}
public function process(): string
{
Log::debug(sprintf('%s:- Processing [%s] for [%s]',self::LOGKEY,self::command,$this->mo->fftn->ftn));
$result = collect();
foreach (preg_grep('/^([^.])/',scandir(self::filefix_classes)) as $file) {
if (($file === 'Base.php') || (! str_ends_with(strtolower($file),'.php')))
continue;
$class = Filefix::commands.preg_replace('/\.php$/','',$file);
if ($result->count())
$result->push('');
$result = $result
->merge($class::help());
}
Notification::route('netmail',$this->mo->fftn)->notify(new HelpNotification($this->mo,$result));
return sprintf('%-25s <-- COMMAND PROCESSED',self::command);
}
}

View File

@ -0,0 +1,201 @@
<?php
namespace App\Classes\Fonts;
use App\Classes\Font;
final class Ansitex extends Font
{
protected const FONT = [
'a' => [
[0xda,0xc4,0xdc],
[0xb3,0xdf,0xdb],
[0x20,0x20,0x20],
],
'b' => [
[0xb3,0xc4,0xdc],
[0xb3,0x5f,0xdb],
[0x20,0x20,0x20],
],
'c' => [
[0xda,0xc4,0xdc],
[0xb3,0x5f,0xdc],
[0x20,0x20,0x20],
],
'd' => [
[0xda,0xc4,0xdb],
[0xb3,0x5f,0xdb],
[0x20,0x20,0x20],
],
'e' => [
[0xda,0xc4,0xdc],
[0xc3,0x5f,0xdc],
[0x20,0x20,0x20],
],
'f' => [
[0xda,0xc4,0xdc],
[0xc3,0x20,0x20],
[0x20,0x20,0x20],
],
'g' => [
[0xda,0xc4,0xdc],
[0xb3,0x5f,0xdb],
[0x20,0xc4,0xdf],
],
'h' => [
[0xde,0xc4,0xdc],
[0xde,0x20,0xdb],
[0x20,0x20,0x20],
],
'i' => [
[0x20,0xdf],
[0xde,0xdb],
[0x20,0x20],
],
'j' => [
[0x20,0xdf],
[0xde,0xdb],
[0xc4,0xdf],
],
'k' => [
[0xb3,0x20,0xdc],
[0xb3,0x60,0xdc],
[0x20,0x20,0x20],
],
'l' => [
[0xb3,0x20],
[0xb3,0xdc],
[0x20,0x20],
],
'm' => [
[0xda,0xda,0xdc],
[0xb3,0xb3,0xdb],
[0x20,0x20,0x20],
],
'n' => [
[0xda,0xc4,0xdc],
[0xb3,0x20,0xdb],
[0x20,0x20,0x20],
],
'o' => [
[0xda,0xc4,0xdc],
[0xb3,0x5f,0xdb],
[0x20,0x20,0x20],
],
'p' => [
[0xda,0xc4,0xdc],
[0xb3,0x5f,0xdb],
[0xc0,0x20,0x20],
],
'q' => [
[0xda,0xc4,0xdc],
[0xb3,0x5f,0xdb],
[0x20,0x20,0xdf],
],
'r' => [
[0xda,0xc4,0xdc],
[0xb3,0xc1,0x5c],
[0x20,0x20,0x20],
],
's' => [
[0xda,0xc4,0xdc],
[0x2e,0x5c,0xdc],
[0x20,0x20,0x20],
],
't' => [
[0xda,0xc2,0xdc],
[0x20,0xb3,0x20],
[0x20,0x20,0x20],
],
'u' => [
[0xda,0x20,0xdc],
[0xb3,0x5f,0xdb],
[0x20,0x20,0x20],
],
'v' => [
[0xda,0x20,0xdc],
[0x60,0x5c,0xdb],
[0x20,0x20,0x20],
],
'w' => [
[0xda,0xda,0xdb],
[0x60,0x5c,0xdb],
[0x20,0x20,0x20],
],
'x' => [
[0xda,0x20,0xdc],
[0xda,0xdf,0xdc],
[0x20,0x20,0x20],
],
'y' => [
[0xda,0x20,0xdc],
[0xb3,0x5f,0xdb],
[0x20,0xc4,0xdf],
],
'z' => [
[0xda,0xc4,0xdc],
[0x2e,0x2f,0xdc],
[0x20,0x20,0x20],
],
'1' => [
[0xc4,0xdc],
[0x20,0xdb],
[0x20,0x20],
],
'2' => [
[0xfe,0xc4,0xdc],
[0xda,0x2f,0xdc],
[0x20,0x20,0x20],
],
'3' => [
[0xda,0xc4,0xdc],
[0xda,0xf0,0xdb],
[0x20,0x20,0x20],
],
'4' => [
[0xde,0x20,0xdc],
[0xc0,0xc4,0xdb],
[0x20,0x20,0x20],
],
'5' => [
[0xda,0xc4,0xdc],
[0x2e,0x2d,0xdc],
[0x20,0x20,0x20],
],
'6' => [
[0xde,0xc4,0xbf],
[0xb3,0x5f,0xdb],
[0x20,0x20,0x20],
],
'7' => [
[0xfe,0x2d,0xbf],
[0x20,0xde,0x20],
[0x20,0x20,0x20],
],
'8' => [
[0xda,0xc4,0xdc],
[0xc3,0xf0,0xdb],
[0x20,0x20,0x20],
],
'9' => [
[0xda,0xc4,0xdc],
[0xd4,0xc4,0xdb],
[0x20,0x20,0x20],
],
'0' => [
[0xda,0xc4,0xdc],
[0xb3,0x5f,0xdb],
[0x20,0x20,0x20],
],
'#' => [
[0xdc,0xba,0xdc],
[0xfe,0xba,0xfe],
[0x20,0x20,0x20],
],
'!' => [
[0xdb],
[0xfe],
[0x20],
],
];
}

View File

@ -3,11 +3,10 @@
namespace App\Classes;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\Log;
use App\Classes\File\{Receive,Send};
use App\Classes\Protocol\EMSI;
use App\Classes\Protocol\{Binkp,DNS,EMSI,Zmodem};
use App\Classes\Sock\Exception\SocketException;
use App\Classes\Sock\SocketClient;
use App\Models\{Address,Mailer,Setup,System,SystemLog};
@ -98,10 +97,10 @@ abstract class Protocol
// File transfer status
public const FOP_OK = 0;
public const FOP_CONT = 1;
public const FOP_SKIP = 2;
public const FOP_ERROR = 3;
public const FOP_OK = 0;
public const FOP_CONT = 1;
public const FOP_SKIP = 2;
public const FOP_ERROR = 3;
public const FOP_SUSPEND = 4;
public const FOP_GOT = 5;
@ -123,10 +122,13 @@ abstract class Protocol
protected array $capability; // @todo make private
/** @var bool Are we originating a connection */
protected bool $originate;
/** Our comms details */
/** @var bool Is the application down for maintenance */
protected bool $down = FALSE;
/** @var int Our mailer ID for logging purposes */
private int $mailer_id;
private array $comms;
protected bool $force_queue = FALSE;
@ -135,9 +137,31 @@ abstract class Protocol
abstract protected function protocol_session(bool $force_queue=FALSE): int;
public function __construct()
/**
* @param Setup $setup
* @throws \Exception
*/
public function __construct(Setup $setup)
{
$this->setup = Config::get('setup',Setup::findOrFail(config('app.id')));
$this->setup = $setup;
// Some initialisation details
switch (get_class($this)) {
case Binkp::class:
$this->mailer_id = Mailer::where('name','BINKP')->sole()->id;
break;
case DNS::class:
case Zmodem::class:
break;
case EMSI::class:
$this->mailer_id = Mailer::where('name','EMSI')->sole()->id;
break;
default:
throw new \Exception('not handled'.get_class($this));
}
}
/**
@ -246,20 +270,27 @@ abstract class Protocol
* Incoming Protocol session
*
* @param SocketClient $client
* @return int|null
* @return int
* @throws SocketException
*/
public function onConnect(SocketClient $client): ?int
public function onConnect(SocketClient $client): int
{
$pid = pcntl_fork();
if ($pid === -1)
throw new SocketException(SocketException::CANT_ACCEPT,'Could not fork process');
// If our parent returns a PID, we've forked
if ($pid)
Log::info(sprintf('%s:+ New connection from [%s], thread [%d] created',self::LOGKEY,$client->address_remote,$pid));
// Parent return ready for next connection
// This is the new thread
else {
Log::withContext(['pid'=>getmypid()]);
$this->session($client,(new Address));
}
return $pid;
}
@ -302,6 +333,7 @@ abstract class Protocol
* Our addresses to send to the remote
*
* @return Collection
* @throws \Exception
*/
protected function our_addresses(): Collection
{
@ -325,15 +357,14 @@ abstract class Protocol
}
/**
* Initialise our Session
* Setup a session with a remote client
*
* @param Mailer $mo
* @param SocketClient $client
* @param Address|null $o
* @param SocketClient $client Socket details of session
* @param Address|null $o If we have an address, we originated a session to this Address
* @return int
* @throws \Exception
*/
public function session(Mailer $mo,SocketClient $client,Address $o=NULL): int
public function session(SocketClient $client,Address $o=NULL): int
{
if ($o->exists)
Log::withContext(['ftn'=>$o->ftn]);
@ -366,12 +397,10 @@ abstract class Protocol
// We are an IP node
$this->optionSet(self::O_TCP);
$this->client = $client;
// @todo This appears to be a bug in laravel? Need to call app()->isDownForMaintenance() twice?
app()->isDownForMaintenance();
$this->down = app()->isDownForMaintenance();
switch ($mo->name) {
case 'EMSI':
switch (get_class($this)) {
case EMSI::class:
Log::debug(sprintf('%s:- Starting EMSI',self::LOGKEY));
$rc = $this->protocol_init();
@ -385,7 +414,7 @@ abstract class Protocol
break;
case 'BINKP':
case Binkp::class:
Log::debug(sprintf('%s:- Starting BINKP',self::LOGKEY));
$rc = $this->protocol_session($this->originate);
@ -393,13 +422,11 @@ abstract class Protocol
break;
default:
Log::error(sprintf('%s:! Unsupported session type [%d]',self::LOGKEY,$mo->id));
Log::error(sprintf('%s:! Unsupported session type [%s]',self::LOGKEY,get_class($this)));
return self::S_FAILURE;
}
// @todo Unlock outbounds
// @todo These flags determine when we connect to the remote.
// If the remote indicated that they dont support file requests (NRQ) or temporarily hold them (HRQ)
if (($this->node->optionGet(self::O_NRQ) && (! $this->setup->optionGet(EMSI::F_IGNORE_NRQ,'emsi_options'))) || $this->node->optionGet(self::O_HRQ))
@ -430,6 +457,7 @@ abstract class Protocol
if ($so && $so->exists) {
foreach ($this->node->aka_other as $aka)
// @todo For disabled zones, we shouldnt refuse to record the address
// @todo If the system hasnt presented an address for a configured period (eg: 30 days) assume it no longer carries it
if ((! Address::findFTN($aka)) && ($oo=Address::createFTN($aka,$so))) {
$oo->validated = TRUE;
$oo->save();
@ -441,7 +469,7 @@ abstract class Protocol
$slo->items_sent_size = $this->send->total_sent_bytes;
$slo->items_recv = $this->recv->total_recv;
$slo->items_recv_size = $this->recv->total_recv_bytes;
$slo->mailer_id = $mo->id;
$slo->mailer_id = $this->mailer_id;
$slo->sessiontime = $this->node->session_time;
$slo->result = ($rc & self::S_MASK);
$slo->originate = $this->originate;
@ -455,12 +483,6 @@ abstract class Protocol
}
}
// @todo Optional after session execution event
// if ($this->node->start_time && $this->setup->cfg('CFG_AFTERSESSION')) {}
// @todo Optional after session includes mail event
// if ($this->node->start_time && $this->setup->cfg('CFG_AFTERMAIL')) {}
return $rc;
}

View File

@ -12,9 +12,8 @@ use App\Classes\Crypt;
use App\Classes\Node;
use App\Classes\Protocol as BaseProtocol;
use App\Classes\Sock\Exception\SocketException;
use App\Classes\Sock\SocketClient;
use App\Exceptions\{FileGrewException,InvalidFTNException};
use App\Models\{Address,Mailer,Setup};
use App\Models\{Address,Setup};
final class Binkp extends BaseProtocol
{
@ -142,27 +141,6 @@ final class Binkp extends BaseProtocol
*/
private Crypt $crypt_out;
/**
* Incoming BINKP session
*
* @param SocketClient $client
* @return int|null
* @throws SocketException
*/
public function onConnect(SocketClient $client): ?int
{
// If our parent returns a PID, we've forked
if (! parent::onConnect($client)) {
Log::withContext(['pid'=>getmypid()]);
$this->session(Mailer::where('name','BINKP')->singleOrFail(),$client,(new Address));
$this->client->close();
exit(0);
}
return NULL;
}
/**
* BINKD handshake
*

View File

@ -6,7 +6,6 @@ use Illuminate\Support\Facades\Log;
use Illuminate\Support\Str;
use App\Classes\Protocol as BaseProtocol;
use App\Classes\Sock\SocketClient;
use App\Models\{Address,Domain,Mailer};
/**
@ -64,22 +63,6 @@ final class DNS extends BaseProtocol
public const DNS_TYPE_OPT = 41; // OPT Records
public const DNS_TYPE_DS = 43; // DS Records (Delegation signer RFC 4034)
public function onConnect(SocketClient $client): ?int
{
// If our parent returns a PID, we've forked
if (! parent::onConnect($client)) {
Log::withContext(['pid'=>getmypid()]);
$this->client = $client;
$this->protocol_session();
Log::debug(sprintf('%s:= onConnect - Connection closed [%s]',self::LOGKEY,$client->address_remote));
exit(0);
}
return NULL;
}
protected function protocol_init(): int
{
// N/A
@ -179,11 +162,11 @@ final class DNS extends BaseProtocol
switch ($labels->first()) {
case '_binkp':
$mailer = Mailer::where('name','BINKP')->singleOrFail();
$mailer = Mailer::where('name','BINKP')->sole();
break;
case '_ifcico':
$mailer = Mailer::where('name','EMSI')->singleOrFail();
$mailer = Mailer::where('name','EMSI')->sole();
break;
default:

View File

@ -7,11 +7,10 @@ use Illuminate\Support\Facades\Log;
use App\Classes\Protocol as BaseProtocol;
use App\Classes\Sock\Exception\SocketException;
use App\Classes\Sock\SocketClient;
use App\Exceptions\InvalidFTNException;
use App\Interfaces\CRC as CRCInterface;
use App\Interfaces\Zmodem as ZmodemInterface;
use App\Models\{Address,Mailer,Setup};
use App\Models\{Address,Setup};
use App\Traits\CRC as CRCTrait;
// http://ftsc.org/docs/fsc-0056.001
@ -82,27 +81,6 @@ final class EMSI extends BaseProtocol implements CRCInterface,ZmodemInterface
'1'=>self::P_ZMODEM,
];
/**
* Incoming EMSI session
*
* @param SocketClient $client
* @return int|null
* @throws SocketException
*/
public function onConnect(SocketClient $client): ?int
{
// If our parent returns a PID, we've forked
if (! parent::onConnect($client)) {
Log::withContext(['pid'=>getmypid()]);
$this->session(Mailer::where('name','EMSI')->singleOrFail(),$client,(new Address));
$this->client->close();
exit(0);
}
return NULL;
}
/**
* Send our welcome banner
*

View File

@ -10,7 +10,7 @@ use App\Classes\Sock\Exception\SocketException;
use App\Classes\Sock\SocketClient;
use App\Interfaces\CRC as CRCInterface;
use App\Interfaces\Zmodem as ZmodemInterface;
use App\Models\{Address,Mailer};
use App\Models\Address;
use App\Traits\CRC as CRCTrait;
/**
@ -202,27 +202,6 @@ final class Zmodem extends Protocol implements CRCInterface,ZmodemInterface
private string $rxbuf = '';
private string $txbuf = '';
/**
* @param SocketClient $client
* @return null
* @throws SocketException
*/
public function onConnect(SocketClient $client): ?int
{
// If our parent returns a PID, we've forked
if (! parent::onConnect($client)) {
Log::withContext(['pid'=>getmypid()]);
$this->session(Mailer::where('name','ZMODEM')->singleOrFail(),$client);
$this->client->close();
Log::info(sprintf('%s:= onConnect - Connection closed [%s]',self::LOGKEY,$client->address_remote));
exit(0);
}
return NULL;
}
/**
* Initialise our session
*/

View File

@ -141,7 +141,11 @@ final class SocketServer {
continue;
}
$this->handler[0]->{$this->handler[1]}($r);
// If the handler returns a value, then that is the main thread
if (! $this->handler[0]->{$this->handler[1]}($r)) {
$r->close();
exit(0);
}
}
}

View File

@ -30,7 +30,7 @@ class AddressIdle extends Command
*/
public function handle(): int
{
$do = Domain::where('name',$this->argument('domain'))->singleOrFail();
$do = Domain::where('name',$this->argument('domain'))->sole();
return Job::dispatchSync($do,$this->option('ftn') ? Address::findFTN($this->option('ftn')) : NULL);
}

View File

@ -1,53 +0,0 @@
<?php
namespace App\Console\Commands;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Log;
use App\Classes\Protocol\Binkp;
use App\Classes\Sock\Exception\SocketException;
use App\Classes\Sock\SocketServer;
use App\Models\Setup;
class CommBinkpReceive extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'comm:binkp:receive';
/**
* The console command description.
*
* @var string
*/
protected $description = 'BINKP receive';
/**
* Execute the console command.
*
* @return mixed
* @throws SocketException
*/
public function handle()
{
Log::info('Listening for BINKP connections...');
$o = Setup::findOrFail(config('app.id'));
$server = new SocketServer($o->binkp_port,$o->binkp_bind);
$server->handler = [new Binkp,'onConnect'];
try {
$server->listen();
} catch (SocketException $e) {
if ($e->getMessage() === 'Can\'t accept connections: "Success"')
Log::debug('Server Terminated');
else
Log::emergency('Uncaught Message: '.$e->getMessage());
}
}
}

View File

@ -27,8 +27,6 @@ class CommBinkpSend extends Command
*/
protected $description = 'BINKP send';
private const ID = 'BINKP';
/**
* Execute the console command.
*
@ -42,7 +40,7 @@ class CommBinkpSend extends Command
Log::info(sprintf('CBS:- Call BINKP send for %s',$ao->ftn));
$mo = Mailer::where('name',self::ID)->singleOrFail();
$mo = Mailer::where('name','BINKP')->sole();
if ($this->option('now'))
Job::dispatchSync($ao,$mo);

View File

@ -1,53 +0,0 @@
<?php
namespace App\Console\Commands;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Log;
use App\Classes\Protocol\EMSI;
use App\Classes\Sock\Exception\SocketException;
use App\Classes\Sock\SocketServer;
use App\Models\Setup;
class CommEMSIReceive extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'comm:emsi:receive';
/**
* The console command description.
*
* @var string
*/
protected $description = 'EMSI receive';
/**
* Execute the console command.
*
* @return mixed
* @throws \Exception
*/
public function handle()
{
Log::info('Listening for EMSI connections...');
$o = Setup::findOrFail(config('app.id'));
$server = new SocketServer($o->emsi_port,$o->emsi_bind);
$server->handler = [new EMSI,'onConnect'];
try {
$server->listen();
} catch (SocketException $e) {
if ($e->getMessage() === 'Can\'t accept connections: "Success"')
Log::debug('Server Terminated');
else
Log::emergency('Uncaught Message: '.$e->getMessage());
}
}
}

View File

@ -27,8 +27,6 @@ class CommEMSISend extends Command
*/
protected $description = 'EMSI send';
private const ID = 'EMSI';
/**
* Execute the console command.
*
@ -42,7 +40,7 @@ class CommEMSISend extends Command
Log::info(sprintf('CES:- Call EMSI send for %s',$ao->ftn));
$mo = Mailer::where('name',self::ID)->singleOrFail();
$mo = Mailer::where('name','EMSI')->sole();
if ($this->option('now'))
Job::dispatchSync($ao,$mo);

View File

@ -16,7 +16,7 @@ class ZoneCheck extends Command
public function handle(): int
{
$do = Domain::where('name',$this->argument('domain'))->singleOrFail();
$do = Domain::where('name',$this->argument('domain'))->sole();
foreach ($do->zones->sortby('zone_id') as $zo) {
if ($this->option('zone') && ($this->option('zone') != $zo->zone_id))

View File

@ -34,7 +34,8 @@ class EchoareaImport extends Command
*/
public function handle(): int
{
$do = Domain::where('name',strtolower($this->argument('domain')))->singleOrFail();
$do = Domain::where('name',strtolower($this->argument('domain')))->single();
return Job::dispatchSync($this->argument('file'),$do,$this->option('prefix') ?: '',$this->option('unlink'));
}
}

View File

@ -34,7 +34,8 @@ class FileareaImport extends Command
*/
public function handle(): int
{
$do = Domain::where('name',strtolower($this->argument('domain')))->singleOrFail();
$do = Domain::where('name',strtolower($this->argument('domain')))->sole();
return Job::dispatchSync($this->argument('file'),$do,$this->option('prefix') ?: '',$this->option('unlink'));
}
}

View File

@ -40,7 +40,7 @@ class Rescan extends Command
if (! $this->argument('area'))
throw new \Exception('Areaname is required');
$fao = Filearea::where('name',$this->argument('area'))->singleOrFail();
$fao = Filearea::where('name',$this->argument('area'))->sole();
if ($fao->domain_id !== $ao->zone->domain_id)
throw new \Exception(sprintf('File area [%s] is not in domain [%s] for FTN [%s]',$fao->name,$ao->zone->domain->name,$ao->ftn));

View File

@ -33,7 +33,7 @@ class NodesNew extends Command
*/
public function handle(): int
{
$do = Domain::where('name',$this->argument('domain'))->singleOrFail();
$do = Domain::where('name',$this->argument('domain'))->sole();
$ao = NULL;
if ($this->option('netmail')) {

View File

@ -50,7 +50,7 @@ class ServerStart extends Command
'address'=>$o->binkp_bind,
'port'=>$o->binkp_port,
'proto'=>SOCK_STREAM,
'class'=>new Binkp,
'class'=>new Binkp($o),
]);
if ($o->emsi_active)
@ -58,7 +58,7 @@ class ServerStart extends Command
'address'=>$o->emsi_bind,
'port'=>$o->emsi_port,
'proto'=>SOCK_STREAM,
'class'=>new EMSI,
'class'=>new EMSI($o),
]);
if ($o->dns_active)
@ -66,7 +66,7 @@ class ServerStart extends Command
'address'=>$o->dns_bind,
'port'=>$o->dns_port,
'proto'=>SOCK_DGRAM,
'class'=>new DNS,
'class'=>new DNS($o),
]);
$children = collect();

View File

@ -25,7 +25,7 @@ class UserCodeSend extends Command
public function handle(): int
{
$ao = Address::findFTN($this->argument('ftn'));
$uo = User::where('email',$this->argument('email'))->singleOrFail();
$uo = User::where('email',$this->argument('email'))->sole();
Notification::route('netmail',$ao->uplink())->notify(new AddressLink($uo));

View File

@ -69,7 +69,7 @@ class ZoneController extends Controller
$o->save();
$zo = Zone::where('zone_id',$request->zone_id)
->where('domain_id',$request->domain_id)
->singleOrFail();
->sole();
// Find the zones 0/0 address, and assign it to this host.
$ao = Address::where('zone_id',$zo->id)

View File

@ -10,6 +10,7 @@ use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\ManuallyFailedException;
use Illuminate\Queue\MaxAttemptsExceededException;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Notification;
@ -85,6 +86,7 @@ class AddressPoll implements ShouldQueue, ShouldBeUnique
}
Log::info(sprintf('%s:- Polling [%s] - attempt [%d]',self::LOGKEY,$this->ao->ftn,$this->attempts()));
$setup = Config::get('setup',Setup::findOrFail(config('app.id')));
foreach ($this->ao->system->mailer_preferred as $o) {
// If we chose a protocol, skip to find the mailer details for it
@ -93,14 +95,12 @@ class AddressPoll implements ShouldQueue, ShouldBeUnique
switch ($o->name) {
case 'BINKP':
$s = new Binkp;
$mo = Mailer::where('name','BINKP')->singleOrFail();
$s = new Binkp($setup);
break;
case 'EMSI':
$s = new EMSI;
$mo = Mailer::where('name','EMSI')->singleOrFail();
$s = new EMSI($setup);
break;
@ -116,7 +116,7 @@ class AddressPoll implements ShouldQueue, ShouldBeUnique
try {
$client = SocketClient::create($this->ao->system->address,$o->pivot->port);
if (($s->session($mo,$client,$this->ao) & Protocol::S_MASK) === Protocol::S_OK) {
if (($s->session($client,$this->ao) & Protocol::S_MASK) === Protocol::S_OK) {
Log::info(sprintf('%s:= Connection ended successfully with [%s] (%s)',self::LOGKEY,$client->address_remote,$this->ao->ftn));
return;

View File

@ -62,7 +62,9 @@ class NodelistImport implements ShouldQueue
{
switch ($key) {
case 'jobname':
return sprintf('%s-%s',$this->domain?->name,is_object($this->file) ? $this->file->name : $this->file);
return ($this->domain)
? sprintf('%s-%s',$this->domain?->name,(is_object($this->file) ? $this->file->name : $this->file))
: (is_object($this->file) ? $this->file->name : $this->file);
default:
return NULL;
@ -144,8 +146,8 @@ class NodelistImport implements ShouldQueue
return;
}
$mailer_binkp = Mailer::where('name','BINKP')->singleOrFail();
$mailer_emsi = Mailer::where('name','EMSI')->singleOrFail();
$mailer_binkp = Mailer::where('name','BINKP')->sole();
$mailer_emsi = Mailer::where('name','EMSI')->sole();
$p = $c = 0;

View File

@ -34,7 +34,7 @@ class TicProcess implements ShouldQueue
*/
public function __construct(private string $file,private ?string $domain=NULL)
{
$this->do = $domain ? Domain::where('name',$domain)->singleOrFail() : NULL;
$this->do = $domain ? Domain::where('name',$domain)->sole() : NULL;
$this->onQueue(self::QUEUE);
}

View File

@ -120,7 +120,7 @@ class Address extends Model
// Check Domain exists
Domain::unguard();
$do = Domain::singleOrNew(['name'=>$ftn['d']]);
$do = Domain::firstOrNew(['name'=>$ftn['d']]);
Domain::reguard();
if (! $do->exists) {
@ -143,7 +143,7 @@ class Address extends Model
// Create zone
Zone::unguard();
$zo = Zone::singleOrNew(['domain_id'=>$do->id,'zone_id'=>$ftn['z']]);
$zo = Zone::firstOrNew(['domain_id'=>$do->id,'zone_id'=>$ftn['z']]);
Zone::reguard();
if (! $zo->exists) {

View File

@ -6,6 +6,8 @@ use Illuminate\Database\Eloquent\Model;
class SystemLog extends Model
{
const UPDATED_AT = null;
/* RELATIONS */
public function mailer()

View File

@ -12,12 +12,12 @@ class AreaList extends Netmails
{
use MessagePath,PageTemplate;
private const LOGKEY = 'ACH';
private const LOGKEY = 'ACL';
private Netmail $mo;
/**
* Reply to a areafix, commands unknown.
* Reply to a areafix AREALIST commands.
*
* @param Netmail $mo
*/

View File

@ -16,7 +16,7 @@ class Help extends Netmails
private const LOGKEY = 'ACH';
/**
* Reply to a areafix, commands unknown.
* Reply to an areafix HELP commands.
*
* @param Netmail $mo
* @param Collection $commands

View File

@ -0,0 +1,103 @@
<?php
namespace App\Notifications\Netmails\Filefix;
use Illuminate\Support\Facades\Log;
use App\Notifications\Netmails;
use App\Models\Netmail;
use App\Traits\{MessagePath,PageTemplate};
class AreaList extends Netmails
{
use MessagePath,PageTemplate;
private const LOGKEY = 'FCL';
private Netmail $mo;
/**
* Reply to a filefix AREALIST commands.
*
* @param Netmail $mo
*/
public function __construct(Netmail $mo)
{
parent::__construct();
$this->mo = $mo->withoutRelations();
}
/**
* Get the mail representation of the notification.
*
* @param mixed $notifiable
* @return Netmail
* @throws \Exception
*/
public function toNetmail(object $notifiable): Netmail
{
$o = $this->setupNetmail($notifiable);
$ao = $notifiable->routeNotificationFor(static::via);
Log::info(sprintf('%s:+ Responding to filefix for a node [%s] LIST processed',self::LOGKEY,$ao->ftn));
$o->to = $this->mo->from;
$o->replyid = $this->mo->msgid;
$o->subject = 'Filefix - List';
// Message
$msg = $this->page(FALSE,'Filefix');
$msg->addText("Here are the list of available filereas:\r\r\r\r");
$areas = $ao->domain
->fileareas
->filter(fn($item)=>$item->active && ($item->can_read($ao->security) || $item->can_write($ao->security)));
if ($areas->count()) {
$msg->addText(sprintf(":---:-%s-:-%s-:-%s-:\r",
str_repeat('-',10),
str_repeat('-',48),
str_repeat('-',5),
));
$msg->addText(sprintf(": : %-10s : %-48s : %-5s :\r",'AREA','DESCRIPTION','FILES'));
$msg->addText(sprintf(":---:-%s-:-%s-:-%s-:\r",
str_repeat('-',10),
str_repeat('-',48),
str_repeat('-',5),
));
foreach ($areas as $eao) {
$msg->addText(sprintf(":%s%s%s: %-10s : %-48s : %5d :\r",
($x=$ao->echoareas->contains($eao)) ? '*' : ' ',
(! $x ? '+' : ' '),
($eao->can_read($ao->security) && (! $eao->can_write($ao->security)))
? 'R'
: (((! $eao->can_read($ao->security)) && $eao->can_write($ao->security)) ? 'W' : ' '),
$eao->name,
$eao->description,
$eao->files()->count(),
));
}
$msg->addText(sprintf(":---:-%s-:-%s-:-%s-:\r",
str_repeat('-',10),
str_repeat('-',48),
str_repeat('-',5),
));
$msg->addText("\r'*' = Subscribed, '+' = available, 'R' = read only, 'W' = write only\r");
} else {
$msg->addText(sprintf('No areas available to you from domain [%s]',$ao->domain->name));
}
$o->msg = $msg->render();
$o->set_tagline = 'Why did the chicken cross the road? The robot programmed it.';
$o->save();
return $o;
}
}

View File

@ -0,0 +1,63 @@
<?php
namespace App\Notifications\Netmails\Filefix;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Log;
use App\Notifications\Netmails;
use App\Models\Netmail;
use App\Traits\{MessagePath,PageTemplate};
class Help extends Netmails
{
use MessagePath,PageTemplate;
private const LOGKEY = 'FCH';
/**
* Reply to a filefix HELP commands.
*
* @param Netmail $mo
* @param Collection $commands
*/
public function __construct(private Netmail $mo,private Collection $commands)
{
parent::__construct();
}
/**
* Get the mail representation of the notification.
*
* @param mixed $notifiable
* @return Netmail
* @throws \Exception
*/
public function toNetmail(object $notifiable): Netmail
{
$o = $this->setupNetmail($notifiable);
$ao = $notifiable->routeNotificationFor(static::via);
Log::info(sprintf('%s:+ Responding to filefix for a node [%s] HELP processed',self::LOGKEY,$ao->ftn));
$o->to = $this->mo->from;
$o->replyid = $this->mo->msgid;
$o->subject = 'Filefix - Help';
// Message
$msg = $this->page(FALSE,'Filefix');
$msg->addText("Here are the list of commands available to you:\r\r\r\r");
foreach ($this->commands as $command) {
$msg->addText("$command\r");
}
$o->msg = $msg->render();
$o->set_tagline = 'Why did the chicken cross the road? The robot programmed it.';
$o->save();
return $o;
}
}

View File

@ -17,11 +17,11 @@ use App\Listeners\EchomailListener;
use App\Listeners\Matrix\MessageListener;
use App\Notifications\Channels\{EchomailChannel,MatrixChannel,NetmailChannel};
use App\Models\{Echomail,Netmail,User};
use App\Traits\SingleOrFail;
use App\Traits\Single;
class AppServiceProvider extends ServiceProvider
{
use SingleOrFail;
use Single;
/**
* Register any application services.
@ -52,7 +52,7 @@ class AppServiceProvider extends ServiceProvider
*/
public function boot()
{
static::bootSingleOrFail();
static::bootSingle();
// Add our page assets
Blade::directive('pa',function($expression) {

25
app/Traits/Single.php Normal file
View File

@ -0,0 +1,25 @@
<?php
/**
* Add eloquent queries single(), singleOrNew()
*/
namespace App\Traits;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\ModelNotFoundException;
trait Single
{
private static function bootSingle(): void
{
// When a query should return 1 object, or NULL if it doesnt
Builder::macro('single',function () {
$result = $this->get();
if ($result->count() === 1)
return $result->first();
return NULL;
});
}
}

View File

@ -1,49 +0,0 @@
<?php
/**
* Add eloquent queries single(), singleOrFail(), singleOrNew()
*/
namespace App\Traits;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\ModelNotFoundException;
trait SingleOrFail
{
private static function bootSingleOrFail(): void
{
// When a query should return 1 object, or FAIL if it doesnt
// @deprecated use sole()
Builder::macro('singleOrFail',function () {
$result = $this->get();
if (($x=$result->count()) === 1)
return $result->first();
if ($x === 0)
throw new ModelNotFoundException('Query brings back 0 record(s) called for singleOrFail()');
else
throw new \Exception(sprintf('Query brings back %d record(s) called for singleOrFail()',$x));
});
// When a query should return 1 object, or NULL if it doesnt
Builder::macro('single',function () {
$result = $this->get();
if ($result->count() === 1)
return $result->first();
return NULL;
});
// When a query should return 1 object, or NULL if it doesnt
Builder::macro('singleOrNew',function ($args) {
$result = $this->where($args)->get();
if ($result->count() === 1)
return $result->first();
return $this->newModelInstance($args);
});
}
}

View File

@ -9,6 +9,7 @@ return [
// Netmail
'robots' => [
\App\Classes\FTN\Process\Netmail\Ping::class,
\App\Classes\FTN\Process\Netmail\Areafix::class,
\App\Classes\FTN\Process\Netmail\Robot\Areafix::class,
\App\Classes\FTN\Process\Netmail\Robot\Filefix::class,
],
];

View File

@ -0,0 +1,28 @@
<?php
use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;
return new class extends Migration
{
/**
* Run the migrations.
*/
public function up(): void
{
Schema::table('system_logs', function (Blueprint $table) {
$table->dropColumn(['updated_at']);
});
}
/**
* Reverse the migrations.
*/
public function down(): void
{
Schema::table('system_logs', function (Blueprint $table) {
$table->timestamp('updated_at');
});
}
};

View File

@ -38,7 +38,7 @@ class TestNodeHierarchy extends Seeder
]);
foreach (['a','b'] as $domain) {
$do = Domain::where('name',$domain)->singleOrFail();
$do = Domain::where('name',$domain)->sole();
$this->hierarchy($do,100);
$this->hierarchy($do,101);
}
@ -84,7 +84,7 @@ class TestNodeHierarchy extends Seeder
'updated_at'=>Carbon::now(),
]);
$zo = Zone::where('zone_id',$zoneid)->where('domain_id',$domain->id)->singleOrFail();
$zo = Zone::where('zone_id',$zoneid)->where('domain_id',$domain->id)->sole();
if (self::DEBUG)
dump(['zo'=>$zo->zone_id,'rid'=>0,'hid'=>0,'nid'=>0]);

View File

@ -1,16 +0,0 @@
<?php
/*
|--------------------------------------------------------------------------
| Broadcast Channels
|--------------------------------------------------------------------------
|
| Here you may register all of the event broadcasting channels that your
| application supports. The given channel authorization callbacks are
| used to check if an authenticated user can listen to the channel.
|
*/
Broadcast::channel('App.User.{id}', function ($user, $id) {
return (int) $user->id === (int) $id;
});

View File

@ -57,7 +57,7 @@ class RoutingTest extends TestCase
{
//$this->seed(TestNodeHierarchy::class);
$do = Domain::where('name','a')->singleOrFail();
$do = Domain::where('name','a')->sole();
$zo = $do->zones->where('zone_id',100)->pop();
return $zo->addresses;
}