X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXUser.pm;h=ad1b890cb7e7bbf34cabb150a3dffcd2fa51fc5a;hb=080a66c38925314321249190eb5a4dc572636d4b;hp=63dad4f3a0fbe50721fa3213bb33810a2cfd5d2f;hpb=fe78618f23392a6ae58542b78cc4c8dbc84e71c5;p=spider.git

diff --git a/perl/DXUser.pm b/perl/DXUser.pm
index 63dad4f3..ad1b890c 100644
--- a/perl/DXUser.pm
+++ b/perl/DXUser.pm
@@ -15,14 +15,17 @@ use DXLog;
 use DB_File;
 use Data::Dumper;
 use Fcntl;
-use Carp;
+use IO::File;
+use DXDebug;
 
 use strict;
-use vars qw(%u $dbm $filename %valid);
+use vars qw(%u $dbm $filename %valid $lastoperinterval $lasttime);
 
 %u = ();
 $dbm = undef;
 $filename = undef;
+$lastoperinterval = 30*24*60*60;
+$lasttime = 0;
 
 # hash of valid elements and a simple prompt
 %valid = (
@@ -54,12 +57,17 @@ $filename = undef;
 		  wantbeep => '0,Rec Beep,yesno',
 		  wantann => '0,Rec Announce,yesno',
 		  wantwwv => '0,Rec WWV,yesno',
+		  wantwcy => '0,Rec WCY,yesno',
+		  wantecho => '0,Rec Echo,yesno',
 		  wanttalk => '0,Rec Talk,yesno',
 		  wantwx => '0,Rec WX,yesno',
 		  wantdx => '0,Rec DX Spots,yesno',
+		  pagelth => '0,Current Pagelth',
 		  pingint => '9,Node Ping interval',
 		  nopings => '9,Ping Obs Count',
 		  wantlogininfo => '9,Login info req,yesno',
+	          wantgrid => '0,DX Grid Info,yesno',
+		  lastoper => '9,Last for/oper,cldatetime',
 		 );
 
 no strict;
@@ -98,6 +106,17 @@ sub init
 
 use strict;
 
+#
+# periodic processing
+#
+sub process
+{
+	if ($main::systime > $lasttime + 15) {
+		$dbm->sync;
+		$lasttime = $main::systime;
+	}
+}
+
 #
 # close the system
 #
@@ -123,9 +142,6 @@ sub new
 	my $self = bless {}, $pkg;
 	$self->{call} = $call;
 	$self->{'sort'} = 'U';
-	$self->{dxok} = '1';
-	$self->{annok} = '1';
-	$self->{lang} = $main::lang;
 	$self->put;
 	return $self;
 }
@@ -169,8 +185,7 @@ sub get_current
   
 	my $dxchan = DXChannel->get($call);
 	return $dxchan->user if $dxchan;
-	my $s = $u{$call};
-	return $s ? decode($s) : undef;
+	return get($pkg, $call);
 }
 
 #
@@ -182,6 +197,12 @@ sub put
 	my $self = shift;
 	confess "Trying to put nothing!" unless $self && ref $self;
 	my $call = $self->{call};
+	# delete all instances of this 
+	for ($dbm->get_dup($call)) {
+		$dbm->del_dup($call, $_);
+	}
+	delete $self->{annok} if $self->{annok};
+	delete $self->{dxok} if $self->{dxok};
 	$u{$call} = $self->encode();
 }
 
@@ -220,7 +241,10 @@ sub del
 {
 	my $self = shift;
 	my $call = $self->{call};
-	delete $u{$call};
+	# delete all instances of this 
+	for ($dbm->get_dup($call)) {
+		$dbm->del_dup($call, $_);
+	}
 }
 
 #
@@ -234,6 +258,15 @@ sub close
 	$self->put();
 }
 
+#
+# sync the database
+#
+
+sub sync
+{
+	$dbm->sync;
+}
+
 #
 # return a list of valid elements 
 # 
@@ -243,6 +276,52 @@ sub fields
 	return keys(%valid);
 }
 
+
+#
+# export the database to an ascii file
+#
+
+sub export
+{
+	my $fn = shift;
+	
+	# save old ones
+        rename "$fn.oooo", "$fn.ooooo" if -e "$fn.oooo";
+        rename "$fn.ooo", "$fn.oooo" if -e "$fn.ooo";
+        rename "$fn.oo", "$fn.ooo" if -e "$fn.oo";
+        rename "$fn.o", "$fn.oo" if -e "$fn.o";
+        rename "$fn", "$fn.o" if -e "$fn";
+
+	my $count = 0;
+	my $fh = new IO::File ">$fn" or return "cannot open $fn ($!)";
+	if ($fh) {
+		my $ref;
+		my $key;
+		my $action;
+		my $t = scalar localtime;
+		print $fh "#!/usr/bin/perl
+#
+# The exported userfile for a DXSpider System
+#
+# Input file: $filename
+#       Time: $t
+#
+
+package DXUser;
+
+%u = (
+";
+
+		for ($action = R_FIRST; !$dbm->seq($key, $ref, $action); $action = R_NEXT) {
+			print $fh "'$key' => $ref,\n";
+			++$count;
+		} 
+		print $fh ");\n#\n# there were $count records\n#\n";
+		$fh->close;
+	} 
+	return $count;
+}
+
 #
 # group handling
 #
@@ -347,6 +426,16 @@ sub wantwwv
 	return _want('wwv', @_);
 }
 
+sub wantwcy
+{
+	return _want('wcy', @_);
+}
+
+sub wantecho
+{
+	return _want('echo', @_);
+}
+
 sub wantwx
 {
 	return _want('wx', @_);
@@ -362,6 +451,11 @@ sub wanttalk
 	return _want('talk', @_);
 }
 
+sub wantgrid
+{
+	return _want('grid', @_);
+}
+
 sub wantlogininfo
 {
 	my $self = shift;
@@ -370,5 +464,57 @@ sub wantlogininfo
 	return exists $self->{wantlogininfo} ? $self->{wantlogininfo} : 0;
 }
 
+sub is_node
+{
+	my $self = shift;
+	return $self->{sort} =~ /[ACRSX]/;
+}
+
+sub is_user
+{
+	my $self = shift;
+	return $self->{sort} eq 'U';
+}
+
+sub is_bbs
+{
+	my $self = shift;
+	return $self->{sort} eq 'B';
+}
+
+sub is_spider
+{
+	my $self = shift;
+	return $self->{sort} eq 'S';
+}
+
+sub is_clx
+{
+	my $self = shift;
+	return $self->{sort} eq 'C';
+}
+
+sub is_dxnet
+{
+	my $self = shift;
+	return $self->{sort} eq 'X';
+}
+
+sub is_arcluster
+{
+	my $self = shift;
+	return $self->{sort} eq 'R';
+}
+
+sub is_ak1a
+{
+	my $self = shift;
+	return $self->{sort} eq 'A';
+}
 1;
 __END__
+
+
+
+
+