X-Git-Url: http://www.dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXMsg.pm;h=6a6f104aa346073dc0a6eb5e979b7beee023ed72;hb=cef696652d16bbeec53aca45234ea0b64f3496d3;hp=e9097d9ca4f8fa159b2ecce5092e08689a8d8a3f;hpb=b5b58db69484da5554b4f7e10b813d13e8cf16cb;p=spider.git

diff --git a/perl/DXMsg.pm b/perl/DXMsg.pm
index e9097d9c..6a6f104a 100644
--- a/perl/DXMsg.pm
+++ b/perl/DXMsg.pm
@@ -19,6 +19,7 @@ use DXCluster;
 use DXProtVars;
 use DXProtout;
 use DXDebug;
+use DXLog;
 use FileHandle;
 use Carp;
 
@@ -167,6 +168,8 @@ sub process
 	      push @{$ref->{gotit}}, $f[2];           # mark this up as being received
 		  $ref->store($ref->{lines});
 		  add_dir($ref);
+		  my $dxchan = DXChannel->get($ref->{to});
+		  $dxchan->send("New mail has arrived for you") if $dxchan;
 		}
 		$ref->stop_msg($self);
 		queue_msg();
@@ -266,6 +269,7 @@ sub store
 	  }
 	  $fh->close;
 	  dbg('msg', "file $ref->{to} stored\n");
+	  Log('msg', "file $ref->{to} from $ref->{from} stored" );
     } else {
       confess "can't open file $ref->{to} $!";  
     }
@@ -292,6 +296,7 @@ sub store
 	  }
 	  $fh->close;
 	  dbg('msg', "msg $ref->{msgno} stored\n");
+	  Log('msg', "msg $ref->{msgno} from $ref->{from} to $ref->{to} stored" );
     } else {
       confess "can't open msg file $fn $!";  
     }
@@ -633,6 +638,8 @@ sub do_send_stuff
 		  $ref->add_dir();
 		  #push @out, $self->msg('sendsent', $to);
 		  push @out, "msgno $ref->{msgno} sent to $to";
+		  my $dxchan = DXChannel->get(uc $to);
+		  $dxchan->send("New mail has arrived for you") if $dxchan;
 	    }
 	  }
 	  delete $loc->{lines};
@@ -658,6 +665,15 @@ sub do_send_stuff
   return (1, @out);
 }
 
+# return the standard directory line for this ref 
+sub dir
+{
+  my $ref = shift;
+  return sprintf "%6d%s%s%5d %8.8s %8.8s %-6.6s %5.5s %-30.30s", 
+    $ref->msgno, $ref->read ? '-' : ' ', $ref->private ? 'p' : ' ', $ref->size,
+	$ref->to, $ref->from, cldate($ref->t), ztime($ref->t), $ref->subject;
+}
+
 no strict;
 sub AUTOLOAD
 {