/[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!
ViewVC logotype

Diff of /trunk/Nos.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 21 by dpavlin, Sun May 15 21:35:15 2005 UTC revision 23 by dpavlin, Sun May 15 22:12:31 2005 UTC
# Line 57  sub new { Line 57  sub new {
57          my $self = {@_};          my $self = {@_};
58          bless($self, $class);          bless($self, $class);
59    
60            croak "need at least dsn" unless ($self->{'dsn'});
61    
62          $self->{'loader'} = Class::DBI::Loader->new(          $self->{'loader'} = Class::DBI::Loader->new(
63                  debug           => $self->{'debug'},                  debug           => $self->{'debug'},
64                  dsn             => $self->{'dsn'},                  dsn             => $self->{'dsn'},
# Line 66  sub new { Line 68  sub new {
68  #               additional_classes      => qw/Class::DBI::AbstractSearch/,  #               additional_classes      => qw/Class::DBI::AbstractSearch/,
69  #               additional_base_classes => qw/My::Stuff/,  #               additional_base_classes => qw/My::Stuff/,
70                  relationships   => 1,                  relationships   => 1,
71          );          ) || croak "can't init Class::DBI::Loader";
72    
73          $self ? return $self : return undef;          $self ? return $self : return undef;
74  }  }
75    
76  =head2 update_list_email  =head2 add_member_to_list
77    
78    Add new member to list
79    
80     $nos->add_member_to_list(
81            list => "My list",
82            email => "john.doe@example.com",
83            name => "John A. Doe",
84     );
85    
86  Update list e-mail address  C<name> parametar is optional.
87    
88   $noc->update_list_email($list, 'foobar@example.com');  Return true if user is added.
89    
90  =cut  =cut
91    
92  sub update_list_email {  sub add_member_to_list {
93          my $self = shift;          my $self = shift;
94    
95            my $arg = {@_};
96    
97            my $email = $arg->{'email'} || confess "can't add user without e-mail";
98            my $name = $arg->{'name'} || '';
99            confess "need list name" unless ($arg->{'list'});
100    
101            if (! Email::Valid->address($email)) {
102                    warn "SKIPPING $name <$email>";
103                    return 0;
104            }
105    
106            print "# $name <$email>\n";
107    
108            my $lists = $self->{'loader'}->find_class('lists');
109            my $users = $self->{'loader'}->find_class('users');
110            my $user_list = $self->{'loader'}->find_class('user_list');
111    
112            my $list = $lists->find_or_create({
113                    name => $arg->{'list'},
114            }) || croak "can't add list ",$arg->{'list'},"\n";
115            
116            my $this_user = $users->find_or_create({
117                    email => $email,
118                    full_name => $name,
119            }) || croak "can't find or create member\n";
120    
121            my $user_on_list = $user_list->find_or_create({
122                    user_id => $this_user->id,
123                    list_id => $list->id,
124            }) || croak "can't add user to list";
125    
126            $list->dbi_commit;
127            $this_user->dbi_commit;
128            $user_on_list->dbi_commit;
129    
130            return 1;
131  }  }
132    
133  =head2 send  =head2 send_queued_messages
134    
135  Send a message using configured mailer.  Send queued messages or just ones for selected list
136    
137   $nos->send("message with headers");   $noc->send_queued_messages("my list");
138    
139  =cut  =cut
140    
141  sub send_email {  sub send_queued_messages {
142          my $self = shift;          my $self = shift;
143    
144          my $message = shift || return;          my $list_name = shift;
145    
146            my $lists = $self->{'loader'}->find_class('lists');
147            my $queue = $self->{'loader'}->find_class('queue');
148            my $user_list = $self->{'loader'}->find_class('user_list');
149            my $sent = $self->{'loader'}->find_class('sent');
150    
151            my $my_q;
152            if ($list_name ne '') {
153                    my $l_id = $lists->search_like( name => $list_name )->first ||
154                            croak "can't find list $list_name";
155                    $my_q = $queue->search_like( list_id => $l_id ) ||
156                            croak "can't find list $list_name";
157            } else {
158                    $my_q = $queue->retrieve_all;
159            }
160    
161            while (my $m = $my_q->next) {
162                    next if ($m->all_sent);
163    
164                    print "sending message ",$m->message_id," enqueued on ",$m->date," to list ",$m->list_id->name,"\n";
165                    my $msg = $m->message_id->message;
166    
167                    foreach my $u ($user_list->search(list_id => $m->list_id)) {
168    
169                            if ($sent->search( message_id => $m->message_id, user_id => $u->user_id )) {
170                                    print "SKIP ",$u->user_id->email," message allready sent\n";
171                            } else {
172                                    print "\t",$u->user_id->email,"\n";
173    
174                                    my $hdr = "From: " . $u->list_id->name . " <" . $u->list_id->email . ">\n" .
175                                            "To: " . $u->user_id->full_name . " <". $u->user_id->email. ">\n";
176    
177                                    # FIXME do real sending :-)
178                                    send IO => "$hdr\n$msg";
179    
180                                    $sent->create({
181                                            message_id => $m->message_id,
182                                            user_id => $u->user_id,
183                                    });
184                                    $sent->dbi_commit;
185                            }
186                    }
187                    $m->all_sent(1);
188                    $m->update;
189                    $m->dbi_commit;
190            }
191    
         send IO => $message;  
192  }  }
193    
194  =head2 EXPORT  =head2 EXPORT
Legend:
Removed from v.21  
changed lines
  Added in v.23
  ViewVC Help
Powered by ViewVC 1.1.26