Update TestNodeHierarchy to include a fuller FTN setup for testing. Update testing.

This commit is contained in:
Deon George 2024-11-25 13:46:16 +11:00
parent 6f2c970b1f
commit bc3407e9d4
9 changed files with 548 additions and 373 deletions

View File

@ -5,6 +5,8 @@ APP_DEBUG=true
APP_URL=http://clrghouz APP_URL=http://clrghouz
APP_TIMEZONE=Australia/Melbourne APP_TIMEZONE=Australia/Melbourne
CACHE_STORE=array
LOG_CHANNEL=stderr LOG_CHANNEL=stderr
LOG_LEVEL=debug LOG_LEVEL=debug
@ -13,7 +15,7 @@ DB_HOST=postgres-test
DB_PORT=5432 DB_PORT=5432
DB_DATABASE=test DB_DATABASE=test
DB_USERNAME=test DB_USERNAME=test
DB_PASSWORD=test DB_PASSWORD=password
BROADCAST_DRIVER=log BROADCAST_DRIVER=log
CACHE_DRIVER=file CACHE_DRIVER=file

View File

@ -22,6 +22,10 @@ class File extends FileBase implements \Iterator
{ {
parent::__construct($path,$checkPath); parent::__construct($path,$checkPath);
if ($this->getExtension() === 'pkt')
$this->canHandle = TRUE;
else
switch ($x=$this->guessExtension()) { switch ($x=$this->guessExtension()) {
case 'zip': case 'zip':
$this->canHandle = TRUE; $this->canHandle = TRUE;

View File

@ -25,7 +25,7 @@ class ZoneCheck extends Command
$this->warn('Zone: '.$zo->zone_id); $this->warn('Zone: '.$zo->zone_id);
$this->info(sprintf('- Our address(es): %s',our_address($do)->pluck('ftn4d')->join(','))); $this->info(sprintf('- Our address(es): %s',our_address($do)->pluck('ftn4d')->join(',')));
$this->table(['id','ftn','role','parent','children','downlinks','uplink','send from','region_id','system','notes'],$zo->addresses()->FTNorder()->active()->with(['system'])->dontCache()->get()->transform(function($item) { $this->table(['id','ftn','role','parent','children','downlinks','uplink','send from','region_id','system','notes'],$zo->addresses()->FTNorder()->active()->with(['system'])->get()->transform(function($item) {
return [ return [
'id'=>$item->id, 'id'=>$item->id,
'ftn'=>$item->ftn4d, 'ftn'=>$item->ftn4d,

View File

@ -14,7 +14,7 @@ use Illuminate\Support\Facades\Log;
use App\Classes\FTN\{Message,Packet}; use App\Classes\FTN\{Message,Packet};
use App\Exceptions\InvalidFTNException; use App\Exceptions\InvalidFTNException;
use App\Traits\{QueryCacheableConfig,ScopeActive}; use App\Traits\ScopeActive;
/** /**
* This represents an FTN AKA. * This represents an FTN AKA.
@ -48,7 +48,7 @@ use App\Traits\{QueryCacheableConfig,ScopeActive};
class Address extends Model class Address extends Model
{ {
use QueryCacheableConfig,ScopeActive,SoftDeletes; use ScopeActive,SoftDeletes;
private const LOGKEY = 'MA-'; private const LOGKEY = 'MA-';
@ -359,8 +359,8 @@ class Address extends Model
// We can only work out region/zone if we have a domain - this is for 2D parsing // We can only work out region/zone if we have a domain - this is for 2D parsing
if ($matches[5] ?? NULL) { if ($matches[5] ?? NULL) {
$o = new self; $o = new self;
$o->host_id = $matches[2]; $o->host_id = (int)$matches[2];
$o->node_id = $matches[3]; $o->node_id = (int)$matches[3];
$o->point_id = empty($matches[4]) ? 0 : (int)$matches[4]; $o->point_id = empty($matches[4]) ? 0 : (int)$matches[4];
if ($matches[1] !== "0") { if ($matches[1] !== "0") {
@ -469,8 +469,7 @@ class Address extends Model
->whereNotNull('export_at') ->whereNotNull('export_at')
->whereNull('sent_at') ->whereNull('sent_at')
->whereNull('echomails.deleted_at') ->whereNull('echomails.deleted_at')
->groupBy('addresses.id') ->groupBy('addresses.id');
->dontCache();
} }
public function scopeUncollectedEchomailTotal($query) public function scopeUncollectedEchomailTotal($query)
@ -504,8 +503,7 @@ class Address extends Model
->whereNotNull('export_at') ->whereNotNull('export_at')
->whereNull('sent_at') ->whereNull('sent_at')
->whereNull('files.deleted_at') ->whereNull('files.deleted_at')
->groupBy('addresses.id') ->groupBy('addresses.id');
->dontCache();
} }
public function scopeUncollectedFilesTotal($query) public function scopeUncollectedFilesTotal($query)
@ -537,8 +535,7 @@ class Address extends Model
->whereNull('sent_pkt') ->whereNull('sent_pkt')
->whereNull('sent_at') ->whereNull('sent_at')
->whereNull('netmails.deleted_at') ->whereNull('netmails.deleted_at')
->groupBy('addresses.id') ->groupBy('addresses.id');
->dontCache();
} }
/** /**
@ -639,7 +636,7 @@ class Address extends Model
public function nodes_hub(): HasMany public function nodes_hub(): HasMany
{ {
return $this->hasMany(Address::class,'hub_id','id') return $this->hasMany(Address::class,'hub_id','id')
->select(['id','addresses.zone_id','host_id','node_id','point_id','system_id']) ->select(['id','addresses.zone_id','region_id','host_id','node_id','point_id','system_id'])
->active() ->active()
->FTNorder() ->FTNorder()
->with([ ->with([
@ -810,7 +807,7 @@ class Address extends Model
public function getIsHostedAttribute(): bool public function getIsHostedAttribute(): bool
{ {
return strlen($this->getPassSessionAttribute()) > 0; return strlen($this->getPassSessionAttribute() ?: '') > 0;
} }
public function getIsHoldAttribute(): bool public function getIsHoldAttribute(): bool
@ -943,60 +940,96 @@ class Address extends Model
} }
/** /**
* Find the immediate children dependent on this record * This is the children of this record, as per normal FTN routing ZC -> RC -> NC -> HUB -> Node -> Point
*
* This a ZC would return all records for the Zone,
* An RC would only return records in the region, etc
* *
* @return Collection * @return Collection
* @see self::parent()
*/ */
public function children(): Collection public function children(): Collection
{ {
// If we are a point, our parent is the boss // If we are a point, our parent is the boss
switch ($this->role_id) { switch ($this->role_id) {
case self::NODE_NN: // Normal Nodes -> Points case self::NODE_NN: // Normal Nodes
return $this->nodes_point; $o = self::active()
->where('zone_id',$this->zone_id)
->where('region_id',$this->region_id)
->where('host_id',$this->host_id)
->where('node_id',$this->node_id);
case self::NODE_HC: // Hubs -> Normal Nodes break;
return $this->nodes_hub;
case self::NODE_NC: // Nets -> Normal Nodes, excluding Hub's Nodes case self::NODE_HC: // Hubs
return $this->nodes_net->diff($this $o = self::active()
->nodes_net ->where('zone_id',$this->zone_id)
->filter(function($item) { return $item->role_id === Address::NODE_HC; }) ->where('region_id',$this->region_id)
->transform(function($item) { return $item->children(); }) ->where('host_id',$this->host_id)
->flatten()); ->where('hub_id',$this->id)
->where('id','<>',$this->id)
->get();
case self::NODE_RC: // Regions, excluding NC's Nodes // Need to add in points of this hub's nodes
return $this->nodes_region->diff($this return $o->merge(
->nodes_region self::active()
->filter(function($item) { return $item->role_id === Address::NODE_NC; }) ->where('zone_id',$this->zone_id)
->transform(function($item) { return $item->nodes_net; }) ->where('region_id',$this->region_id)
->flatten()); ->where('host_id',$this->host_id)
->whereIn('node_id',$o->pluck('node_id'))
->where('point_id','<>',0)
->get()
);
case self::NODE_ZC: // Zones, excluding RC's Nodes case self::NODE_NC: // Nets
return $this->nodes_zone->diff($this $o = self::active()
->nodes_zone ->where('zone_id',$this->zone_id)
->filter(function($item) { return $item->role_id === Address::NODE_RC; }) ->where('region_id',$this->region_id)
->transform(function($item) { return $item->nodes_region; }) ->where('host_id',$this->host_id);
->flatten());
}
break;
case self::NODE_RC: // Regions
$o = self::active()
->where('zone_id',$this->zone_id)
->where('region_id',$this->region_id);
break;
case self::NODE_ZC: // Zone
$o = self::active()
->where('zone_id',$this->zone_id);
break;
default:
return new Collection; return new Collection;
} }
return $o
->where('id','<>',$this->id)
->get();
}
/** /**
* Find who we should forward mail onto, taking into account session details that we have * Contrast to children(), this takes into account authentication details, and we route mail to this
* address (because we have session details) and it's children.
* *
* @return Collection * @return Collection
* @throws \Exception * @throws \Exception
* @see self::children()
* @see self::uplink()
*/ */
public function downlinks(): Collection public function downlinks(): Collection
{ {
// We have no session data for this address, by definition it has no children // We have no session data for this address, (and its not our address), by definition it has no children
if (! $this->is_hosted && (! our_address()->pluck('id')->contains($this->id))) if (! $this->is_hosted && (! our_address()->pluck('id')->contains($this->id)))
return new Collection; return new Collection;
// If this system is not marked to default route for this address // If this system is not marked to default route for this address
if (! $this->is_default_route) { if (! $this->is_default_route) {
$children = $this->children(); $children = $this->children()
->push($this);
// We route everything for this domain // We route everything for this domain
} else { } else {
@ -1016,15 +1049,17 @@ class Address extends Model
// Exclude links and their children. // Exclude links and their children.
$exclude = collect(); $exclude = collect();
foreach (our_nodes($this->zone->domain)->merge(our_address($this->zone->domain)) as $o) { foreach (our_nodes($this->zone->domain)->diff([$this]) as $o) {
// We only exclude downlink children
if ($o->role_id < $this->role_id)
continue;
// If this address is in our list, remove it and it's children // If this address is in our list, remove it and it's children
if ($children->contains($o)) {
$exclude = $exclude->merge($o->children()); $exclude = $exclude->merge($o->children());
$exclude->push($o); $exclude->push($o);
} }
}
return $children->filter(function($item) use ($exclude) { return ! $exclude->pluck('id')->contains($item->id);}); return $children->diff($exclude);
} }
/** /**
@ -1032,6 +1067,7 @@ class Address extends Model
* *
* @return \Illuminate\Support\Collection * @return \Illuminate\Support\Collection
* @throws \Exception * @throws \Exception
* @deprecated use children()
*/ */
public function downstream(): \Illuminate\Support\Collection public function downstream(): \Illuminate\Support\Collection
{ {
@ -1073,11 +1109,10 @@ class Address extends Model
'origin:id,value', 'origin:id,value',
'echoarea:id,name,domain_id', 'echoarea:id,name,domain_id',
'echoarea.domain:id,name', 'echoarea.domain:id,name',
'fftn:id,zone_id,host_id,node_id,point_id', 'fftn:id,zone_id,region_id,host_id,node_id,point_id',
'fftn.zone:id,domain_id,zone_id', 'fftn.zone:id,domain_id,zone_id',
'fftn.zone.domain:id,name', 'fftn.zone.domain:id,name',
]) ]);
->dontCache();
} }
/** /**
@ -1097,7 +1132,7 @@ class Address extends Model
->with([ ->with([
'filearea:id,name,domain_id', 'filearea:id,name,domain_id',
'filearea.domain:id,name', 'filearea.domain:id,name',
'fftn:id,zone_id,host_id,node_id,point_id', 'fftn:id,zone_id,region_id,host_id,node_id,point_id',
'fftn.zone:id,domain_id,zone_id', 'fftn.zone:id,domain_id,zone_id',
'fftn.zone.domain:id,name', 'fftn.zone.domain:id,name',
]) ])
@ -1137,7 +1172,7 @@ class Address extends Model
$role = self::NODE_ZC; $role = self::NODE_ZC;
} }
if (is_null($role)) if (isset($this->region_id) && is_null($role))
Log::alert(sprintf('%s:! Address ROLE [%d] could not be determined for [%s]',self::LOGKEY,($this->role & Address::NODE_ALL),$this->ftn)); Log::alert(sprintf('%s:! Address ROLE [%d] could not be determined for [%s]',self::LOGKEY,($this->role & Address::NODE_ALL),$this->ftn));
return $role; return $role;
@ -1291,18 +1326,20 @@ class Address extends Model
} }
/** /**
* Find the immediate parent for this node. * Find the immediate parent for this address, as per normal FTN routing ZC <- RC <- NC <- HUB <- Node <- Point
* *
* @return Address|null * @return Address|null
* @throws \Exception * @throws \Exception
* @see self::children()
*/ */
public function parent(): ?Address public function parent(): ?Address
{ {
// If we are a point, our parent is the boss // If we are a point, our parent is the boss
switch ($this->role_id) { switch ($this->role_id) {
case self::NODE_POINT: // BOSS Node case self::NODE_POINT: // BOSS Node
return Address::active() return self::active()
->where('zone_id',$this->zone_id) ->where('zone_id',$this->zone_id)
->where('region_id',$this->region_id)
->where('host_id',$this->host_id) ->where('host_id',$this->host_id)
->where('node_id',$this->node_id) ->where('node_id',$this->node_id)
->where('point_id',0) ->where('point_id',0)
@ -1314,16 +1351,17 @@ class Address extends Model
// Else fall through // Else fall through
case self::NODE_HC: // RC case self::NODE_HC: // NC
return Address::active() return self::active()
->where('zone_id',$this->zone_id) ->where('zone_id',$this->zone_id)
->where('region_id',$this->region_id)
->where('host_id',$this->host_id) ->where('host_id',$this->host_id)
->where('node_id',0) ->where('node_id',0)
->where('point_id',0) ->where('point_id',0)
->single(); ->single();
case self::NODE_NC: // RC case self::NODE_NC: // RC
return Address::active() return self::active()
->where('zone_id',$this->zone_id) ->where('zone_id',$this->zone_id)
->where('region_id',$this->region_id) ->where('region_id',$this->region_id)
->where('host_id',$this->region_id) ->where('host_id',$this->region_id)
@ -1332,7 +1370,7 @@ class Address extends Model
->single(); ->single();
case self::NODE_RC: // ZC case self::NODE_RC: // ZC
return Address::active() return self::active()
->where('zone_id',$this->zone_id) ->where('zone_id',$this->zone_id)
->where('region_id',0) ->where('region_id',0)
->where('node_id',0) ->where('node_id',0)
@ -1356,10 +1394,13 @@ class Address extends Model
} }
/** /**
* Get the appropriate parent for this address, taking into account who we have session information with * Contrast to parent(), this takes into account authentication details, and we route mail to this
* address (because we have session details) with that uplink.
* *
* @return Address|$this|null * @return Address|$this|null
* @throws \Exception * @throws \Exception
* @see self::parent()
* @see self::downlinks()
*/ */
public function uplink(): ?Address public function uplink(): ?Address
{ {
@ -1371,15 +1412,17 @@ class Address extends Model
if ($this->is_hosted) if ($this->is_hosted)
return $this; return $this;
// Traverse up our parents until we have one with session details
if ($x=$this->parent()?->uplink()) { if ($x=$this->parent()?->uplink()) {
return $x; return $x;
// See if we have a node registered as the default route for this zone
} else { } else {
$sz = SystemZone::whereIn('zone_id',$this->domain->zones->pluck('id')) $sz = SystemZone::whereIn('zone_id',$this->domain->zones->pluck('id'))
->where('default',TRUE) ->where('default',TRUE)
->single(); ->single();
return $sz?->system->addresses->sortBy('security')->last(); return $sz?->system->akas->sortBy('security')->last();
} }
} }
} }

View File

@ -289,7 +289,7 @@ final class Echomail extends Model implements Packet
public function seenby() public function seenby()
{ {
return $this->belongsToMany(Address::class,'echomail_seenby') return $this->belongsToMany(Address::class,'echomail_seenby')
->select(['id','zone_id','host_id','node_id']) ->select(['addresses.id','zone_id','host_id','node_id'])
->withPivot(['export_at','sent_at','sent_pkt']) ->withPivot(['export_at','sent_at','sent_pkt'])
->dontCache() ->dontCache()
->FTN2DOrder(); ->FTN2DOrder();

View File

@ -2,6 +2,11 @@
namespace Database\Seeders; namespace Database\Seeders;
/**
* Our testing heirarchy.
*
*/
use Carbon\Carbon; use Carbon\Carbon;
use Illuminate\Database\Seeder; use Illuminate\Database\Seeder;
use Illuminate\Support\Facades\DB; use Illuminate\Support\Facades\DB;
@ -10,34 +15,26 @@ use App\Models\{Address, Domain, Setup, System, Zone};
class TestNodeHierarchy extends Seeder class TestNodeHierarchy extends Seeder
{ {
public const DEBUG=FALSE; public const DEBUG = TRUE;
/** /**
* Run the database seeds. * Run the database seeds.
* *
* @return void * @return void
* @throws \Exception
*/ */
public function run() public function run()
{ {
foreach (['a','b','c','d','e','f'] as $domain) {
DB::table('domains') DB::table('domains')
->insert([ ->insert([
'name'=>'a', 'name'=>$domain,
'active'=>TRUE, 'active'=>TRUE,
'public'=>TRUE, 'public'=>TRUE,
'created_at'=>Carbon::now(), 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(), 'updated_at'=>Carbon::now(),
]); ]);
DB::table('domains')
->insert([
'name'=>'b',
'active'=>TRUE,
'public'=>TRUE,
'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(),
]);
foreach (['a','b'] as $domain) {
$do = Domain::where('name',$domain)->sole(); $do = Domain::where('name',$domain)->sole();
$this->hierarchy($do,100); $this->hierarchy($do,100);
$this->hierarchy($do,101); $this->hierarchy($do,101);
@ -45,9 +42,38 @@ class TestNodeHierarchy extends Seeder
// Configure my addresses // Configure my addresses
$so = Setup::findOrFail(config('app.id')); $so = Setup::findOrFail(config('app.id'));
// ZC 100:0/0@a
$ao = Address::findFTN('100:0/0@a'); $ao = Address::findFTN('100:0/0@a');
$so->system_id = $ao->system_id; $ao->system_id = $so->system_id;
$so->save(); $ao->save();
// RC 100:1/0@b
$ao = Address::findFTN('100:1/0@b');
$ao->system_id = $so->system_id;
$ao->save();
// NC 100:20/0@c
$ao = Address::findFTN('100:20/0@c');
$ao->system_id = $so->system_id;
$ao->save();
// HUB 100:30/100@d
$ao = Address::findFTN('100:30/100@d');
$ao->system_id = $so->system_id;
$ao->save();
// NODE 100:40/101@e
$ao = Address::findFTN('100:40/101@e');
$ao->system_id = $so->system_id;
$ao->save();
// POINT 100:50/101.3277@f
$ao = Address::createFTN('100:50/101.3277@f',$so->system);
$so->system->name = 'Clearing Houz TEST';
$so->system->address = 'localhost';
$so->system->save();
// Add file area // Add file area
DB::table('fileareas') DB::table('fileareas')
@ -66,9 +92,7 @@ class TestNodeHierarchy extends Seeder
private function hierarchy(Domain $domain,int $zoneid) private function hierarchy(Domain $domain,int $zoneid)
{ {
$hosts = [1,2,3,4,5]; $levels = [1,2,3,4,5];
$hubs = [10,20,30,40,50];
$nodes = [100,200,300,400,500];
$hubnodes = [-2,-1,+1,+2,+3]; $hubnodes = [-2,-1,+1,+2,+3];
$so = $this->system(sprintf('ZC %s-%s',$domain->name,$zoneid)); $so = $this->system(sprintf('ZC %s-%s',$domain->name,$zoneid));
@ -85,185 +109,196 @@ class TestNodeHierarchy extends Seeder
]); ]);
$zo = Zone::where('zone_id',$zoneid)->where('domain_id',$domain->id)->sole(); $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]);
// ZC if (self::DEBUG)
printf("- ZC %d:%d/%d.%d@%s\n",$zo->zone_id,0,0,0,$domain->name);
$region_id = 0;
// ZC Address
DB::table('addresses') DB::table('addresses')
->insert([ ->insert([
'zone_id'=>$zo->id, 'zone_id'=>$zo->id,
'active'=>TRUE, 'active'=>TRUE,
'validated'=>TRUE, 'region_id'=>$region_id,
'region_id'=>0, 'host_id'=>$region_id,
'host_id'=>0,
'node_id'=>0, 'node_id'=>0,
'point_id'=>0, 'point_id'=>0,
'system_id'=>$so->id, 'system_id'=>$so->id,
'role'=>Address::NODE_ZC,
'created_at'=>Carbon::now(), 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(), 'updated_at'=>Carbon::now(),
]); ]);
// ZC Nodes // ZC Nodes
foreach ($nodes as $nid) { foreach ($hubnodes as $hnid) {
if (self::DEBUG) $host_id = $region_id*100+$hnid+3;
dump(['rid'=>$zo->zone_id,'hid'=>$zo->zone_id,'nid'=>$nid]);
$so = $this->system(sprintf('ZC Node 0/%d',$nid)); if (self::DEBUG)
printf(" - NODE %d:%d/%d.%d@%s\n",$zo->zone_id,$region_id,$host_id,0,$domain->name);
$so = $this->system(sprintf('ZC Node 0/%d',$host_id));
DB::table('addresses') DB::table('addresses')
->insert([ ->insert([
'zone_id'=>$zo->id, 'zone_id'=>$zo->id,
'active'=>TRUE, 'active'=>TRUE,
'validated'=>TRUE, 'region_id'=>$region_id,
'region_id'=>0, 'host_id'=>$region_id,
'host_id'=>0, 'node_id'=>$host_id,
'node_id'=>$nid,
'point_id'=>0, 'point_id'=>0,
'system_id'=>$so->id, 'system_id'=>$so->id,
'role'=>Address::NODE_NN,
'created_at'=>Carbon::now(), 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(), 'updated_at'=>Carbon::now(),
]); ]);
} }
// RC
foreach ($levels as $region_id) {
if (self::DEBUG) if (self::DEBUG)
dump(['end'=>'nodes top']); printf(" - RC %d:%d/%d.%d@%s\n",$zo->zone_id,$region_id,0,0,$domain->name);
// Regions $so = $this->system(sprintf('RC %03d:%03d/%03d.0@%s',$zoneid,$region_id,0,$domain->name));
foreach ($hosts as $rid) {
$hostid = $rid;
if (self::DEBUG)
dump(['rid'=>$rid,'hid'=>$hostid,'nid'=>0]);
$so = $this->system(sprintf('Region %03d:%03d/%03d.0@%s',$zoneid,$rid,0,$domain->name));
DB::table('addresses') DB::table('addresses')
->insert([ ->insert([
'zone_id'=>$zo->id, 'zone_id'=>$zo->id,
'active'=>TRUE, 'active'=>TRUE,
'validated'=>TRUE, 'region_id'=>$region_id,
'region_id'=>$rid, 'host_id'=>$region_id,
'host_id'=>$rid,
'node_id'=>0, 'node_id'=>0,
'point_id'=>0, 'point_id'=>0,
'system_id'=>$so->id, 'system_id'=>$so->id,
'role'=>Address::NODE_RC,
'created_at'=>Carbon::now(), 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(), 'updated_at'=>Carbon::now(),
]); ]);
// RC Nodes // RC Nodes
foreach ($nodes as $nid) { foreach ($hubnodes as $hnid) {
if (self::DEBUG) $host_id = $hnid+3;
dump(['rid'=>$rid,'hid'=>$hostid,'nid'=>$nid]);
$so = $this->system(sprintf('RC Node %d/%d',$rid,$nid)); if (self::DEBUG)
printf(" - NODE %d:%d/%d.%d@%s\n",$zo->zone_id,$region_id,$host_id,0,$domain->name);
$so = $this->system(sprintf('RC Node %d/%d',$region_id,$host_id));
DB::table('addresses') DB::table('addresses')
->insert([ ->insert([
'zone_id'=>$zo->id, 'zone_id'=>$zo->id,
'active'=>TRUE, 'active'=>TRUE,
'validated'=>TRUE, 'region_id'=>$region_id,
'region_id'=>$rid, 'host_id'=>$region_id,
'host_id'=>$rid, 'node_id'=>$host_id,
'node_id'=>$nid,
'point_id'=>0, 'point_id'=>0,
'system_id'=>$so->id, 'system_id'=>$so->id,
'role'=>Address::NODE_NN,
'created_at'=>Carbon::now(), 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(), 'updated_at'=>Carbon::now(),
]); ]);
} }
// NC
foreach ($levels as $ncid) {
$net_id = $region_id*10+$ncid-1;
if (self::DEBUG) if (self::DEBUG)
dump(['end'=>'NODES regions']); printf(" - NC %d:%d/%d.%d@%s\n",$zo->zone_id,$net_id,0,0,$domain->name);
// Hosts
foreach ($hosts as $rrid) {
$hostid = $rid*10+$rrid-1;
if (self::DEBUG)
dump(['rid'=>$rid,'hid'=>$hostid,'nid'=>0]);
$so = $this->system(sprintf('Host %d:%d/0 (R%d)',$zoneid,$hostid,$rid));
$so = $this->system(sprintf('NC %d:%d/0 (R%d)',$zo->zone_id,$net_id,$region_id));
DB::table('addresses') DB::table('addresses')
->insert([ ->insert([
'zone_id'=>$zo->id, 'zone_id'=>$zo->id,
'active'=>TRUE, 'active'=>TRUE,
'validated'=>TRUE, 'region_id'=>$region_id,
'region_id'=>$rid, 'host_id'=>$net_id,
'host_id'=>$hostid,
'node_id'=>0, 'node_id'=>0,
'point_id'=>0, 'point_id'=>0,
'system_id'=>$so->id, 'system_id'=>$so->id,
'role'=>Address::NODE_NC,
'created_at'=>Carbon::now(), 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(), 'updated_at'=>Carbon::now(),
]); ]);
// Nodes // NC Nodes
foreach ($nodes as $nid) { foreach ($hubnodes as $hnid) {
if (self::DEBUG) $host_id = $hnid+3;
dump(['rid'=>$rid,'hid'=>$hostid,'nid'=>$nid]);
$so = $this->system(sprintf('Host Node %d/%d (R%d)',$hostid,$nid,$rid)); if (self::DEBUG)
printf(" - NODE %d:%d/%d.%d@%s\n",$zo->zone_id,$net_id,$host_id,0,$domain->name);
$so = $this->system(sprintf('NC Node %d/%d (R%d)',$net_id,$host_id,$region_id));
DB::table('addresses') DB::table('addresses')
->insert([ ->insert([
'zone_id'=>$zo->id, 'zone_id'=>$zo->id,
'active'=>TRUE, 'active'=>TRUE,
'validated'=>TRUE, 'region_id'=>$region_id,
'region_id'=>$rid, 'host_id'=>$net_id,
'host_id'=>$hostid, 'node_id'=>$host_id,
'node_id'=>$nid,
'point_id'=>0, 'point_id'=>0,
'system_id'=>$so->id, 'system_id'=>$so->id,
'role'=>Address::NODE_NN,
'created_at'=>Carbon::now(), 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(), 'updated_at'=>Carbon::now(),
]); ]);
} }
// Hubs // Hubs
foreach ($hubs as $bid) { foreach ($levels as $hbid) {
$so = $this->system(sprintf('HUB %d/%d (R%d)',$hostid,$bid,$rid)); $host_id = $hbid*100;
if (self::DEBUG)
printf(" - HUB %d:%d/%d.%d@%s\n",$zo->zone_id,$net_id,$host_id,0,$domain->name);
$so = $this->system(sprintf('HUB %d/%d (R%d)',$net_id,$host_id,$region_id));
$hub = new Address; $hub = new Address;
$hub->zone_id = $zo->id; $hub->zone_id = $zo->id;
$hub->active = TRUE; $hub->active = TRUE;
$hub->region_id = $rid; $hub->region_id = $region_id;
$hub->host_id = $hostid; $hub->host_id = $net_id;
$hub->node_id = $bid; $hub->node_id = $host_id;
$hub->point_id = 0; $hub->point_id = 0;
$hub->system_id = $so->id; $hub->system_id = $so->id;
$hub->role = Address::NODE_HC;
$hub->created_at = Carbon::now(); $hub->created_at = Carbon::now();
$hub->updated_at = Carbon::now(); $hub->updated_at = Carbon::now();
$hub->save(); $hub->save();
// Nodes // HUB Nodes
foreach ($hubnodes as $nid) { foreach ($hubnodes as $nid) {
$nodeid = $bid+$nid; $host_id = $hub->node_id+$nid;
$so = $this->system(sprintf('Hub Node %d/%d (R%d/H%d)',$hostid,$nodeid,$rid,$hub->node_id));
if (self::DEBUG)
printf(" - NODE %d:%d/%d.%d@%s\n",$zo->zone_id,$net_id,$host_id,0,$domain->name);
$so = $this->system(sprintf('Hub Node %d/%d (R%d/H%d)',$net_id,$host_id,$region_id,$hub->node_id));
DB::table('addresses') DB::table('addresses')
->insert([ ->insert([
'zone_id'=>$zo->id, 'zone_id'=>$zo->id,
'active'=>TRUE, 'active'=>TRUE,
'validated'=>TRUE, 'region_id'=>$region_id,
'region_id'=>$rid, 'host_id'=>$net_id,
'host_id'=>$hostid, 'node_id'=>$host_id,
'node_id'=>$nodeid,
'point_id'=>0, 'point_id'=>0,
'system_id'=>$so->id, 'system_id'=>$so->id,
'hub_id'=>$hub->id, 'hub_id'=>$hub->id,
'role'=>Address::NODE_NN, 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(),
]);
foreach ($hubnodes as $nid) {
$point_id = $nid+3;
if (self::DEBUG)
printf(" - POINT %d:%d/%d.%d@%s\n",$zo->zone_id,$net_id,$host_id,$point_id,$domain->name);
$so = $this->system(sprintf('Node Point %d/%d.%d (R%d/H%d)',$net_id,$host_id,$point_id,$region_id,$hub->node_id));
DB::table('addresses')
->insert([
'zone_id'=>$zo->id,
'active'=>TRUE,
'region_id'=>$region_id,
'host_id'=>$net_id,
'node_id'=>$host_id,
'point_id'=>$point_id,
'system_id'=>$so->id,
'created_at'=>Carbon::now(), 'created_at'=>Carbon::now(),
'updated_at'=>Carbon::now(), 'updated_at'=>Carbon::now(),
]); ]);
} }
} }
} }
if (self::DEBUG)
dump(['end'=>'NODES normal']);
} }
}
if (self::DEBUG)
dump(['end'=>'heirarchy']);
} }
private function system(string $name): System private function system(string $name): System
@ -275,6 +310,7 @@ class TestNodeHierarchy extends Seeder
$o->active = TRUE; $o->active = TRUE;
$o->created_at = Carbon::now(); $o->created_at = Carbon::now();
$o->updated_at = Carbon::now(); $o->updated_at = Carbon::now();
$o->address = 'myhostname';
$o->save(); $o->save();
return $o; return $o;

View File

@ -109,7 +109,7 @@ class PacketTest extends TestCase
$f = $this->mail_file('mail/018A-1702393055-78754407.pkt'); $f = $this->mail_file('mail/018A-1702393055-78754407.pkt');
foreach ($f as $packet) { foreach ($f as $packet) {
$pkt = Packet::process($packet,$x=$f->itemName(),$f->itemSize(),$this->do); $pkt = Packet::process($packet,$x=$f->itemName(),$f->itemSize());
$this->assertInstanceOf(Packet\FSC39::class,$pkt); $this->assertInstanceOf(Packet\FSC39::class,$pkt);
$this->assertEquals('ABCDEFGH',$pkt->password); $this->assertEquals('ABCDEFGH',$pkt->password);
@ -136,7 +136,7 @@ class PacketTest extends TestCase
$f = $this->mail_file('mail/018A-1701955391-71c7a400.pkt'); $f = $this->mail_file('mail/018A-1701955391-71c7a400.pkt');
foreach ($f as $packet) { foreach ($f as $packet) {
$pkt = Packet::process($packet,$x=$f->itemName(),$f->itemSize(),$this->do); $pkt = Packet::process($packet,$x=$f->itemName(),$f->itemSize());
$this->assertInstanceOf(Packet\FSC39::class,$pkt); $this->assertInstanceOf(Packet\FSC39::class,$pkt);
$this->assertEquals('ABCDEFGH',$pkt->password); $this->assertEquals('ABCDEFGH',$pkt->password);
@ -163,7 +163,7 @@ class PacketTest extends TestCase
$f = $this->mail_file('mail/0B39-1701919239-65713a06.pkt'); $f = $this->mail_file('mail/0B39-1701919239-65713a06.pkt');
foreach ($f as $packet) { foreach ($f as $packet) {
$pkt = Packet::process($packet,$x=$f->itemName(),$f->itemSize(),$this->do); $pkt = Packet::process($packet,$x=$f->itemName(),$f->itemSize());
$this->assertInstanceOf(Packet\FSC48::class,$pkt); $this->assertInstanceOf(Packet\FSC48::class,$pkt);
$this->assertEquals('ABCDEFG#',$pkt->password); $this->assertEquals('ABCDEFG#',$pkt->password);
@ -246,7 +246,7 @@ class PacketTest extends TestCase
// This packet has an incorrect zone in the Origin // This packet has an incorrect zone in the Origin
$f = $this->mail_file('mail/test_msgid_origin.pkt'); $f = $this->mail_file('mail/test_msgid_origin.pkt');
foreach ($f as $packet) { foreach ($f as $packet) {
$pkt = Packet::process($packet,$f->itemName(),$f->itemSize(),$this->do); $pkt = Packet::process($packet,$f->itemName(),$f->itemSize());
$this->assertInstanceOf(Packet\FSC39::class,$pkt); $this->assertInstanceOf(Packet\FSC39::class,$pkt);
$this->assertEquals(1,$pkt->count()); $this->assertEquals(1,$pkt->count());
@ -278,7 +278,7 @@ class PacketTest extends TestCase
// This packet has a SOH<char>SOH sequence // This packet has a SOH<char>SOH sequence
$f = $this->mail_file('mail/test_binary_content-2.pkt'); $f = $this->mail_file('mail/test_binary_content-2.pkt');
foreach ($f as $packet) { foreach ($f as $packet) {
$pkt = Packet::process($packet,$f->itemName(),$f->itemSize(),$this->do); $pkt = Packet::process($packet,$f->itemName(),$f->itemSize());
$this->assertEquals(1,$pkt->count()); $this->assertEquals(1,$pkt->count());

View File

@ -5,6 +5,7 @@ namespace Tests\Feature;
use Illuminate\Database\Eloquent\Collection; use Illuminate\Database\Eloquent\Collection;
use Illuminate\Foundation\Testing\DatabaseTransactions; use Illuminate\Foundation\Testing\DatabaseTransactions;
use Illuminate\Support\Facades\Cache; use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Tests\TestCase; use Tests\TestCase;
use App\Models\{Address,Domain,Setup,System}; use App\Models\{Address,Domain,Setup,System};
@ -53,12 +54,17 @@ class RoutingTest extends TestCase
{ {
use DatabaseTransactions; use DatabaseTransactions;
public const ZONE_ADDRS = 4061;
public const REGION_ADDRS = 811;
public const NET_ADDRS = 161;
public const HUB_ADDRS = 31;
public const NODE_ADDRS = 6;
private function zone(): Collection private function zone(): Collection
{ {
//$this->seed(TestNodeHierarchy::class);
$do = Domain::where('name','a')->sole(); $do = Domain::where('name','a')->sole();
$zo = $do->zones->where('zone_id',100)->pop(); $zo = $do->zones->where('zone_id',100)->pop();
return $zo->addresses; return $zo->addresses;
} }
@ -70,19 +76,31 @@ class RoutingTest extends TestCase
private function session_rc(): void private function session_rc(): void
{ {
$ao = Address::findFTN('100:1/0@a'); $ao = Address::findFTN('101:1/0@a');
$ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]); $ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]);
} }
private function session_nc(): void private function session_nc(): void
{ {
$ao = Address::findFTN('100:10/0@a'); $ao = Address::findFTN('101:10/0@a');
$ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]); $ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]);
} }
private function session_hub(): void private function session_hub(): void
{ {
$ao = Address::findFTN('100:10/20@a'); $ao = Address::findFTN('101:10/100@a');
$ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]);
}
private function session_node(): void
{
$ao = Address::findFTN('101:10/101@a');
$ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]);
}
private function session_point(): void
{
$ao = Address::findFTN('101:10/101.1@a');
$ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]); $ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]);
} }
@ -90,14 +108,14 @@ class RoutingTest extends TestCase
public function test_my_addresses() public function test_my_addresses()
{ {
$ftns = our_address(); $ftns = our_address();
$this->assertEquals(1,$ftns->count()); $this->assertEquals(6,$ftns->count());
} }
// Get a list of active addresses in a Zone // Get a list of active addresses in a Zone
public function test_zc_addresses() public function test_zone_addresses()
{ {
$nodes = $this->zone(); $nodes = $this->zone();
$this->assertEquals(936,$nodes->count()); $this->assertEquals(self::ZONE_ADDRS,$nodes->count());
} }
// Get a ZC with no session details, and make sure it has no parent nor children // Get a ZC with no session details, and make sure it has no parent nor children
@ -107,230 +125,302 @@ class RoutingTest extends TestCase
$ao = Address::findFTN('101:0/0@a'); $ao = Address::findFTN('101:0/0@a');
$this->assertEquals($ao->role_id,Address::NODE_ZC); $this->assertEquals($ao->role_id,Address::NODE_ZC);
$this->assertCount(0,$ao->downstream()); $this->assertCount(0,$ao->downlinks());
$this->assertNull($ao->uplink()); $this->assertNull($ao->uplink());
} }
// If we have a ZC, make sure we are routing to all it's children // If we have a ZC, make sure we are routing to all it's children
public function test_zc_session_children() public function test_zc_session_children()
{ {
$this->session_zc();
$ao = Address::findFTN('101:0/0@a'); $ao = Address::findFTN('101:0/0@a');
$this->assertCount(935,$ao->downstream());
}
// An RC's parent should be the ZC, when we have session details with parent // This is a ZC
public function test_zc_rc_node_parent() $this->assertEquals($ao->role_name,'ZC');
{ $this->assertEquals(Address::NODE_ZC,$ao->role_id);
// Children
$this->assertCount(self::ZONE_ADDRS-1,$ao->children());
$this->assertCount(0,$ao->downlinks());
$this->session_zc(); $this->session_zc();
$ao->refresh();
$ao = Address::findFTN('101:1/0@a'); // Children
$this->assertEquals($ao->role_id,Address::NODE_RC); $this->assertCount(self::ZONE_ADDRS,$ao->downlinks());
$this->assertEquals('101:0/0.0@a',$ao->uplink()->ftn); }
// ZC uplink should be null, and the parent should be itself
public function test_zc_parent()
{
$ao = Address::findFTN('101:0/0@a');
// This uplink should also be null
$this->assertNull($ao->uplink()?->ftn);
$this->session_zc();
$ao->refresh();
// This parent should also be null
$this->assertNull($ao->parent()?->ftn);
// This uplink should be itself
$this->assertEquals($ao->ftn,$ao->uplink()?->ftn);
} }
// Get a list of active addresses in a Region
public function test_rc_session_children() public function test_rc_session_children()
{ {
$this->session_rc(); $ao = Address::findFTN('101:1/0@a');
$ao = Address::findFTN('100:1/0@a'); // This is a RC
$this->assertCount(185,$ao->downstream()); $this->assertEquals($ao->role_name,'RC');
$this->assertEquals(Address::NODE_RC,$ao->role_id);
// Children
$this->assertCount(self::REGION_ADDRS-1,$ao->children());
$this->assertCount(0,$ao->downlinks());
$this->session_rc();
$ao->refresh();
// This is a ZC
$this->assertCount(self::REGION_ADDRS,$ao->downlinks());
} }
// An RCs node still collects mail from the RC
public function test_rc_node_rc()
{
$this->session_rc();
// An RCs node should still be the RC
$ao = Address::findFTN('100:1/100@a');
$this->assertEquals($ao->role_id,Address::NODE_NN);
$this->assertEquals('100:1/0.0@a',$ao->uplink()->ftn);
}
// An NC collects mail for its children
public function test_rc_nc_node_rc()
{
$this->session_rc();
// A NCs parent should still be the RC
$ao = Address::findFTN('100:10/0@a');
$this->assertEquals($ao->role_id,Address::NODE_NC);
$this->assertEquals('100:1/0.0@a',$ao->uplink()->ftn);
}
// A Hub still collects mail from NC
public function test_rc_hub_node_nc()
{
$this->session_rc();
// A Hubs parent should still be the NC
$ao = Address::findFTN('100:10/20.0@a');
$this->assertEquals($ao->role_id,Address::NODE_HC);
$this->assertEquals('100:1/0.0@a',$ao->uplink()->ftn);
}
// A Hub's node still collects mail from Hub
public function test_rc_hub_node_hub()
{
$this->session_rc();
// A Hubs node should still be the Hub
$ao = Address::findFTN('100:10/22.0@a');
$this->assertEquals($ao->role_id,Address::NODE_NN);
$this->assertEquals('100:1/0.0@a',$ao->uplink()->ftn);
}
// An RCs parent is us even if we have session details for another RC
public function test_rc_parent() public function test_rc_parent()
{ {
$this->session_rc(); $ao = Address::findFTN('101:1/0@a');
$o = Address::findFTN('101:0/0@a');
$ao = Address::findFTN('100:2/0@a'); // This uplink should also be null
$this->assertNull($ao->uplink()?->ftn); $this->assertNull($ao->uplink()?->ftn);
}
// If we also have session details for an NC, then there are less RC nodes
public function test_rc_nc_session_children()
{
$this->session_rc(); $this->session_rc();
$this->session_nc(); $ao->refresh();
$ao = Address::findFTN('100:1/0@a'); // This parent should also be null
$this->assertCount(185-36,$ao->downstream()); $this->assertEquals($o->ftn,$ao->parent()?->ftn);
// This uplink should be itself
$this->assertEquals($ao->ftn,$ao->uplink()?->ftn);
} }
// If we also have session details for an Hub, then there are less RC nodes public function test_zc_rc_nodes()
public function test_rc_hub_session_children()
{ {
$this->session_zc();
$this->session_rc(); $this->session_rc();
$ao = Address::findFTN('100:10/20@a'); $ao = Address::findFTN('101:0/0@a');
$ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]); $this->assertCount(self::ZONE_ADDRS-self::REGION_ADDRS,$ao->downlinks());
$ao = Address::findFTN('100:1/0@a'); $ao = Address::findFTN('101:1/0@a');
$this->assertCount(185,$ao->downstream()); $this->assertCount(self::REGION_ADDRS,$ao->downlinks());
$ao = Address::findFTN('100:10/22@a');
$this->assertEquals('100:10/20.0@a',$ao->uplink()->ftn);
} }
// If we also have session details for an Hub, then there are less RC nodes
public function test_rc_hub_session_child()
{
$this->session_hub();
$ao = Address::findFTN('100:10/22@a');
$this->assertEquals('100:10/20.0@a',$ao->uplink()->ftn);
}
// When we have an RC with session details, we route to all its children
public function test_nc_session_children() public function test_nc_session_children()
{ {
$this->session_nc(); $ao = Address::findFTN('101:10/0@a');
$ao = Address::findFTN('100:10/0@a'); // This is a NC
$this->assertCount(35,$ao->downstream()); $this->assertEquals($ao->role_name,'NC');
$this->assertEquals(Address::NODE_NC,$ao->role_id);
// Children
$this->assertCount(self::NET_ADDRS-1,$ao->children());
$this->assertCount(0,$ao->downlinks());
$this->session_nc();
$ao->refresh();
// This is a NC
$this->assertCount(self::NET_ADDRS,$ao->downlinks());
} }
public function test_complex_rc_nc_hc() public function test_nc_parent()
{ {
$this->session_rc(); $ao = Address::findFTN('101:10/0@a');
$this->session_nc(); $o = Address::findFTN('101:1/0@a');
$this->session_hub();
$ao = Address::findFTN('100:1/100.0@a'); // This uplink should also be null
$this->assertCount(0,$ao->downstream());
$this->assertEquals('100:1/0.0@a',$ao->uplink()->ftn);
// RC
$ao = Address::findFTN('100:1/0.0@a');
$this->assertCount(186-1-30-6,$ao->downstream());
$ao = Address::findFTN('100:11/0.0@a');
$this->assertEquals('100:1/0.0@a',$ao->uplink()->ftn);
// NC
$ao = Address::findFTN('100:10/0.0@a');
$this->assertCount(36-1-6,$ao->downstream());
$ao = Address::findFTN('100:10/10.0@a');
$this->assertEquals('100:10/0.0@a',$ao->uplink()->ftn);
// HC
$ao = Address::findFTN('100:10/20.0@a');
$this->assertCount(6-1,$ao->downstream());
$ao = Address::findFTN('100:10/22.0@a');
$this->assertEquals('100:10/20.0@a',$ao->uplink()->ftn);
}
public function test_complex_rc_nc_hc_us()
{
Cache::forget('so');
$setup = Setup::findOrFail(config('app.id'));
$ao = Address::findFTN('100:10/0.0@a');
$setup->system_id = $ao->system_id;
$setup->save();
$this->assertEquals('100:10/0.0@a',our_address($ao)?->ftn);
$this->session_rc();
//$this->session_nc();
$this->session_hub();
$ao = Address::findFTN('100:11/0.0');
$ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]);
$ao = Address::findFTN('100:1/100.0@a');
$this->assertCount(0,$ao->downstream());
$this->assertEquals('100:1/0.0@a',$ao->uplink()?->ftn);
// RC
$ao = Address::findFTN('100:1/0.0@a');
$this->assertCount(186-36-36-1,$ao->downstream());
$ao = Address::findFTN('100:11/0.0@a');
$this->assertEquals('100:11/0.0@a',$ao->uplink()->ftn);
// NC
$ao = Address::findFTN('100:10/0.0@a');
$this->assertCount(36-6-1,$ao->downstream());
$ao = Address::findFTN('100:10/10.0@a');
$this->assertNull($ao->uplink()?->ftn); $this->assertNull($ao->uplink()?->ftn);
// HC $this->session_nc();
$ao = Address::findFTN('100:10/20.0@a'); $ao->refresh();
$this->assertCount(6-1,$ao->downstream());
$ao = Address::findFTN('100:10/22.0@a'); // This parent should also be null
$this->assertEquals('100:10/20.0@a',$ao->uplink()->ftn); $this->assertEquals($o->ftn,$ao->parent()?->ftn);
Cache::forget('so');
// This uplink should be itself
$this->assertEquals($ao->ftn,$ao->uplink()?->ftn);
} }
// A points parent is the node, if we have traffic for a point and we have session details for the node public function test_zc_rc_nc_nodes()
public function test_point_session_node()
{ {
//$this->session_hub(); $this->session_zc();
$this->session_rc();
$this->session_nc();
$so = new System; $ao = Address::findFTN('101:0/0@a');
$so->name = 'Point System'; $this->assertCount(self::ZONE_ADDRS-self::REGION_ADDRS,$ao->downlinks());
$so->sysop = 'Point Sysop';
$so->location = 'Melbourne, AU';
$so->active = TRUE;
$so->save();
// Create a child $ao = Address::findFTN('101:1/0@a');
$ao = Address::createFTN('100:10/21.2@a',$so); $this->assertCount(self::REGION_ADDRS-self::NET_ADDRS,$ao->downlinks());
$ao = Address::findFTN('100:10/21.0@a'); $ao = Address::findFTN('101:10/0@a');
$ao->system->sessions()->attach([$ao->zone_id=>['sespass'=>'ABCD']]); $this->assertCount(self::NET_ADDRS,$ao->downlinks());
}
$ao = Address::findFTN('100:10/21.2@a'); public function test_hub_session_children()
$this->assertEquals('100:10/21.0@a',$ao->uplink()?->ftn); {
$ao = Address::findFTN('101:10/100@a');
$ao = Address::findFTN('100:10/21@a'); // This is a HUB
$this->assertCount(1,$ao->downstream()); $this->assertEquals($ao->role_name,'HUB');
$this->assertEquals(Address::NODE_HC,$ao->role_id);
// Children
$this->assertCount(self::HUB_ADDRS-1,$ao->children());
$this->assertCount(0,$ao->downlinks());
$this->session_hub();
$ao->refresh()->unsetRelations();
// This is a NC
$this->assertCount(self::HUB_ADDRS,$ao->downlinks());
}
public function test_hub_parent()
{
$ao = Address::findFTN('101:10/100@a');
$o = Address::findFTN('101:10/0@a');
// This uplink should also be null
$this->assertNull($ao->uplink()?->ftn);
$this->session_hub();
$ao->refresh();
// This parent should also be null
$this->assertEquals($o->ftn,$ao->parent()?->ftn);
// This uplink should be itself
$this->assertEquals($ao->ftn,$ao->uplink()?->ftn);
}
public function test_zc_rc_nc_hub_nodes()
{
$this->session_zc();
$this->session_rc();
$this->session_nc();
$this->session_hub();
$ao = Address::findFTN('101:0/0@a');
$this->assertCount(self::ZONE_ADDRS-self::REGION_ADDRS,$ao->downlinks());
$ao = Address::findFTN('101:1/0@a');
$this->assertCount(self::REGION_ADDRS-self::NET_ADDRS,$ao->downlinks());
$ao = Address::findFTN('101:10/0@a');
$this->assertCount(self::NET_ADDRS-self::HUB_ADDRS,$ao->downlinks());
$ao = Address::findFTN('101:10/100@a');
$this->assertCount(self::HUB_ADDRS,$ao->downlinks());
}
public function test_node_session_children()
{
$ao = Address::findFTN('101:10/101@a');
// This is a NC
$this->assertEquals($ao->role_name,'NODE');
$this->assertEquals(Address::NODE_NN,$ao->role_id);
// Children
$this->assertCount(self::NODE_ADDRS-1,$ao->children());
$this->assertCount(0,$ao->downlinks());
$this->session_node();
$ao->refresh();
// This is a NC
$this->assertCount(self::NODE_ADDRS,$ao->downlinks());
}
public function test_node_parent()
{
$ao = Address::findFTN('101:10/101@a');
$o = Address::findFTN('101:10/100@a');
// This uplink should also be null
$this->assertNull($ao->uplink()?->ftn);
$this->session_node();
$ao->refresh();
// This parent should also be null
$this->assertEquals($o->ftn,$ao->parent()?->ftn);
// This uplink should be itself
$this->assertEquals($ao->ftn,$ao->uplink()?->ftn);
}
public function test_zc_rc_nc_hub_node_nodes()
{
$this->session_zc();
$this->session_rc();
$this->session_nc();
$this->session_hub();
$this->session_node();
$ao = Address::findFTN('101:0/0@a');
$this->assertCount(self::ZONE_ADDRS-self::REGION_ADDRS,$ao->downlinks());
$ao = Address::findFTN('101:1/0@a');
$this->assertCount(self::REGION_ADDRS-self::NET_ADDRS,$ao->downlinks());
$ao = Address::findFTN('101:10/0@a');
$this->assertCount(self::NET_ADDRS-self::HUB_ADDRS,$ao->downlinks());
$ao = Address::findFTN('101:10/100@a');
$this->assertCount(self::HUB_ADDRS-self::NODE_ADDRS,$ao->downlinks());
$ao = Address::findFTN('101:10/101@a');
$this->assertCount(self::NODE_ADDRS,$ao->downlinks());
}
public function test_point_session_children()
{
$ao = Address::findFTN('101:10/101.1@a');
// This is a NC
$this->assertEquals($ao->role_name,'POINT');
$this->assertEquals(Address::NODE_POINT,$ao->role_id);
// Children
$this->assertCount(0,$ao->children());
$this->assertCount(0,$ao->downlinks());
$this->session_point();
$ao->refresh();
// This is a NC
$this->assertCount(1,$ao->downlinks());
}
public function test_point_parent()
{
$ao = Address::findFTN('101:10/101.1@a');
$o = Address::findFTN('101:10/101@a');
// This uplink should also be null
$this->assertNull($ao->uplink()?->ftn);
$this->session_point();
$ao->refresh();
// This parent should also be null
$this->assertEquals($o->ftn,$ao->parent()?->ftn);
// This uplink should be itself
$this->assertEquals($ao->ftn,$ao->uplink()?->ftn);
} }
} }

View File

@ -131,7 +131,7 @@ class TicProcessingTest extends TestCase
$file->refresh(); $file->refresh();
$this->assertEquals('100:1/0',$file->fftn->ftn3d); $this->assertEquals('100:1/0',$file->fftn->ftn3d);
$this->assertEquals('100:10/11',$file->origin->ftn3d); $this->assertEquals('100:10/11',$file->origin->ftn3d);
$this->assertCount(12,$file->seenby); $this->assertCount(7,$file->seenby);
$this->assertCount(4,$file->path); $this->assertCount(4,$file->path);
} }
} }