/[notice-sender]/trunk/Nos.pm

This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!

Diff of /trunk/Nos.pm

Parent Directory | Revision Log | View Patch Patch

-revision 74 by dpavlin,
Wed Aug 24 17:19:16 2005 UTC
+revision 76 by dpavlin,
Wed Aug 24 22:11:00 2005 UTC
 Line 16 
 our @EXPORT_OK = ( @{ $EXPORT_TAGS{'all'
  our @EXPORT = qw(
  );
- our $VERSION = '0.7';
+ our $VERSION = '0.8';
  use Class::DBI::Loader;
  use Email::Valid;
 Line 116 
 sub new {
          $self->{'hash_len'} ||= 8;
+         $self->{'loader'}->find_class('received')->set_sql(
+                 'received' => qq{
+                         select
+                                 received.id as id,
+                                 lists.name as list,
+                                 users.ext_id as ext_id,
+                                 users.email as email,
+                                 bounced,received.date as date
+                         from received
+                         join lists on lists.id = list_id
+                         join users on users.id = user_id
+                 },
+         );
          $self ? return $self : return undef;
  }
-Line 475 
 Send e-mail using SMTP server at 127.0.0
+Line 489 
 Send e-mail using SMTP server at 127.0.0
  =back
+ Any other driver name will try to use C<Email::Send::that_driver> module.
  Default sleep wait between two messages is 3 seconds.
+ This method will return number of succesfully sent messages.
  =cut
  sub send_queued_messages {
-Line 489 
 sub send_queued_messages {
+Line 507 
 sub send_queued_messages {
          my $sleep = $arg->{'sleep'};
          $sleep ||= 3 unless defined($sleep);
+         # number of messages sent o.k.
+         my $ok = 0;
          my $email_send_driver = 'Email::Send::IO';
          my @email_send_options;
          if (lc($driver) eq 'smtp') {
                  $email_send_driver = 'Email::Send::SMTP';
                  @email_send_options = ['127.0.0.1'];
+         } elsif ($driver && $driver ne '') {
+                 $email_send_driver = 'Email::Send::' . $driver;
          } else {
                  warn "dumping all messages to STDERR\n";
          }
-Line 564 
 sub send_queued_messages {
+Line 587 
 sub send_queued_messages {
                                  }
                                  croak "can't send e-mail: $sent_status\n\nOriginal e-mail follows:\n".$m_obj->as_string unless ($sent_status);
-                                 my @bad = @{ $sent_status->prop('bad') };
+                                 my @bad;
+                                 @bad = @{ $sent_status->prop('bad') } if (eval { $sent_status->can('prop') });
                                  croak "failed sending to ",join(",",@bad) if (@bad);
                                  if ($sent_status) {
-Line 578 
 sub send_queued_messages {
+Line 602 
 sub send_queued_messages {
                                          print " - $sent_status\n";
+                                         $ok++;
                                  } else {
                                          warn "ERROR: $sent_status\n";
                                  }
-Line 593 
 sub send_queued_messages {
+Line 618 
 sub send_queued_messages {
                  $m->dbi_commit;
          }
+         return $ok;
  }
  =head2 inbox_message
-Line 691 
 sub inbox_message {
+Line 718 
 sub inbox_message {
  #       print "message_id: ",($message_id || "not found")," -- $is_bounce\n";
  }
+ =head2 received_messages
+ Returns all received messages for given list or user.
+  my @received = $nos->received_message(
+         list => 'My list',
+         email => "john.doe@example.com",
+  );
+ Each element in returned array will have following structure:
+  {
+         id => 42,                       # unique ID of received message
+         list => 'My list',              # useful only of filtering by email
+         ext_id => 9999,                 # ext_id from message user
+         email => 'jdoe@example.com',    # e-mail of user
+         bounced => 0,                   # true value if message is bounce
+         date => '2005-08-24 18:57:24',  # date of recival in ISO format
+  }
+ =cut
+ sub received_messages {
+         my $self = shift;
+         my $arg = {@_};
+         croak "need list name or email" unless ($arg->{'list'} || $arg->{'email'});
+         $arg->{'list'} = lc($arg->{'list'});
+         $arg->{'email'} = lc($arg->{'email'});
+         my @out;
+         my $sth = $self->{'loader'}->find_class('received')->sql_received;
+         $sth->execute();
+         return $sth->fetchall_hash;
+ }
  =head1 INTERNAL METHODS
-Line 923 
 Create new SOAP object
+Line 990 
 Create new SOAP object
          aliases => '/etc/aliases',
   );
+ If you are writing SOAP server (like C<soap.cgi> example), you will need to
+ call this method once to make new instance of Nos::SOAP and specify C<dsn>
+ and options for it.
  =cut
  sub new {
-Line 1093 
 This is a stub for documentation of unim
+Line 1164 
 This is a stub for documentation of unim
  You can specify just C<list> or C<email> or any combination of those.
- It will return array of hashes with following structure:
+ For format of returned array element see C<received_messages>.
-  {
-         id => 42,                       # unique ID of received message
-         list => 'My list',              # useful only of filtering by email
-         ext_id => 9999,                 # ext_id from message user
-         email => 'jdoe@example.com',    # e-mail of user
-         bounced => 0,                   # true value if message is bounce
-         date => '2005-08-24 18:57:24',  # date of recival in ISO format
-  }
  =head2 MessagesReceivedByDate

 Legend:



Removed from v.74
 


changed lines


 
Added in v.76
 Legend:



Removed from v.74
 


changed lines


 
Added in v.76
-Removed from v.74
+Added in v.76

	ViewVC Help
Powered by ViewVC 1.1.26