+
+ # banner
+ my ($year) = (gmtime)[5];
+ $year += 1900;
+ LogDbg('cluster', "DXSpider v$version build $build (git: $gitbranch/$gitversion) using perl $^V on $^O started");
+ LogDbg('cluster', "Copyright (c) 1998-$year Dirk Koopman G1TLH");
+ LogDbg('cluster', "Capabilities: ve7cc rbn");
+
+ # prime some signals
+ unless ($DB::VERSION) {
+ $SIG{INT} = $SIG{TERM} = sub { $ending = 10; };
+ }
+
+
+ # setup location of motd & issue
+ localdata_mv($motd);
+ $motd = localdata($motd);
+ localdata_mv("issue");
+
+
+ # try to load XML::Simple
+ DXXml::init();
+
+
+ # load Prefixes
+ dbg("loading prefixes ...");
+ dbg(USDB::init());
+ my $r = Prefix::init();
+ confess $r if $r;
+
+ # load band data
+ dbg("loading band data ...");
+ Bands::load();
+
+ # initialise User file system
+ dbg("loading user file system ...");
+ DXUser::init(4); # version 4 == json format
+
+ Filter::init(); # doesn't do much, but has to be done
+
+
+ # look for the sysop and the alias user and complain if they aren't there
+ {
+ die "\$myalias \& \$mycall are the same ($mycall)!, they must be different (hint: make \$mycall = '${mycall}-2';). Oh and don't forget to rerun create_sysop.pl!" if $mycall eq $myalias;
+ my $ref = DXUser::get($mycall);
+ die "\$mycall missing, run the create_sysop.pl script and please RTFM" unless $ref && $ref->priv == 9;
+ my $oldsort = $ref->sort;
+ if ($oldsort ne 'S') {
+ $ref->sort('S');
+ dbg("Resetting node type from $oldsort -> DXSpider ('S')");
+ }
+ $ref = DXUser::get($myalias);
+ die "\$myalias missing, run the create_sysop.pl script and please RTFM" unless $ref && $ref->priv == 9;
+ $oldsort = $ref->sort;
+ if ($oldsort ne 'U') {
+ $ref->sort('U');
+ dbg("Resetting sysop user type from $oldsort -> User ('U')");
+ }
+ }
+
+ # make sure that mycall, myalias and homenode are upper case;
+ my $flag = 0;
+ if ($mycall =~ /[a-z]/) {
+ LogDbg('err', "\$mycall '$mycall' contains lower case letters, correcting");
+ $mycall = uc $mycall;
+ ++$flag;
+ }
+ if ($myalias =~ /[a-z]/) {
+ LogDbg('err', "\$myalias '$myalias' contains lower case letters, correcting");
+ $myalias = uc $myalias;
+ ++$flag;
+ }
+ if ($flag) {
+ LogDbg('err', "DXVars.pm has $flag errors. See above. Please edit DXVars.pm to correct");
+ sleep 10;
+ }
+
+ # read any route cache there might be
+ Route::read_cache() if $save_route_cache;
+
+ # start listening for incoming messages/connects
+ dbg("starting listeners ...");
+ my $conn = IntMsg->new_server($clusteraddr, $clusterport, \&login);
+ $conn->conns("Server $clusteraddr/$clusterport using IntMsg");
+ push @listeners, $conn;
+ dbg("Internal port: $clusteraddr $clusterport using IntMsg");
+ foreach my $l (@main::listen) {
+ no strict 'refs';
+ my $pkg = $l->[2] || 'ExtMsg';
+ my $login = $l->[3] || 'login';
+
+ $conn = $pkg->new_server($l->[0], $l->[1], \&{"${pkg}::${login}"});
+ $conn->conns("Server $l->[0]/$l->[1] using ${pkg}::${login}");
+ push @listeners, $conn;
+ dbg("External Port: $l->[0] $l->[1] using ${pkg}::${login}");
+ }
+
+
+ dbg("AGW Listener") if $AGWMsg::enable;
+ AGWrestart();
+
+ dbg("BPQ Listener") if $BPQMsg::enable;
+ BPQMsg::init(\&new_channel);
+
+ dbg("UDP Listener") if $UDPMsg::enable;
+ UDPMsg::init(\&new_channel);
+
+ # start dupe system
+ dbg("Starting Dupe system");
+ DXDupe::init();
+
+ # read in system messages
+ dbg("Read in Messages");
+ DXM->init();
+
+ # read in command aliases
+ dbg("Read in Aliases");
+ CmdAlias->init();
+
+ # initialise the protocol engine
+ dbg("Start Protocol Engines ...");
+ DXProt->init();
+
+ # read startup script
+ my $script = new Script "startup";
+ $script->run($main::me) if $script;
+
+
+ # initialise the Geomagnetic data engine
+ dbg("Start WWV system");
+ Geomag->init();
+ dbg("Start WCY system");
+ WCY->init();
+ dbg("Start Announce and Talk system");
+ AnnTalk::init(); # initialise announce cache
+
+
+ # put in a DXCluster node for us here so we can add users and take them away
+ $routeroot = Route::Node->new($mycall, $version*100+5300, Route::here($main::me->here)|Route::conf($main::me->conf));
+ $routeroot->do_pc9x(1);
+ $routeroot->via_pc92(1);
+
+ # make sure that there is a routing OUTPUT node default file
+ #unless (Filter::read_in('route', 'node_default', 0)) {
+ # my $dxcc = $main::me->dxcc;
+ # $Route::filterdef->cmd($main::me, 'route', 'accept', "node_default call $mycall" );
+ #}
+
+ # initial the Spot stuff
+ dbg("Starting DX Spot system");
+ Spot->init();
+
+ # try to load the spot database if present
+ if (DXSql::init($dsn)) {
+ $dbh = DXSql->new($dsn);
+ $dbh = $dbh->connect($dsn, $dbuser, $dbpass) if $dbh;
+ }
+
+
+ # read in any existing message headers and clean out old crap
+ dbg("Reading existing Message/Bulletine headers ...");
+ DXMsg->init();
+ DXMsg::clean_old();
+
+ # read in any cron jobs
+ dbg("Reading cron jobs ...");
+ DXCron->init();
+
+ # read in database desriptors
+ dbg("Reading database descriptors ...");
+ DXDb::load();
+
+ dbg("Rtarting RBN ...");
+ RBN::init();
+
+ # starting local stuff
+ dbg("Starting DXQsl system");
+ QSL::init(1);
+
+ # load bad words
+ BadWords::load();
+
+ # get any bad IPs
+ DXCIDR::init();
+
+
+ dbg("Ooing local initialisations ...");
+ if (defined &Local::init) {
+ eval {
+ Local::init();
+ };
+ dbg("Local::init error $@") if $@;
+ }
+
+
+ # this, such as it is, is the main loop!
+ dbg("Orft we jolly well go ...");
+
+ #open(DB::OUT, "|tee /tmp/aa");
+}
+
+our $io_disconnected;
+
+sub idle_loop
+{
+ BPQMsg::process();
+# DXCommandmode::process(); # process ongoing command mode stuff
+# DXProt::process(); # process ongoing ak1a pcxx stuff
+