156 |
my $list_name = $args->{'list'} || confess "need list name"; |
my $list_name = $args->{'list'} || confess "need list name"; |
157 |
my $message_text = $args->{'message'} || croak "need message"; |
my $message_text = $args->{'message'} || croak "need message"; |
158 |
|
|
|
warn Dumper($message_text); |
|
|
|
|
159 |
my $m = Email::Simple->new($message_text) || croak "can't parse message"; |
my $m = Email::Simple->new($message_text) || croak "can't parse message"; |
160 |
|
|
161 |
croak "message doesn't have Subject header\n" unless( $m->header('Subject') ); |
unless( $m->header('Subject') ) { |
162 |
|
warn "message doesn't have Subject header\n"; |
163 |
|
return; |
164 |
|
} |
165 |
|
|
166 |
my $lists = $self->{'loader'}->find_class('lists'); |
my $lists = $self->{'loader'}->find_class('lists'); |
167 |
|
|
224 |
print "sending message ",$m->message_id," enqueued on ",$m->date," to list ",$m->list_id->name,"\n"; |
print "sending message ",$m->message_id," enqueued on ",$m->date," to list ",$m->list_id->name,"\n"; |
225 |
my $msg = $m->message_id->message; |
my $msg = $m->message_id->message; |
226 |
|
|
|
my $auth = Email::Auth::AddressHash->new( |
|
|
$m->list_id->name, # secret |
|
|
10, # hashlen |
|
|
); |
|
|
|
|
227 |
foreach my $u ($user_list->search(list_id => $m->list_id)) { |
foreach my $u ($user_list->search(list_id => $m->list_id)) { |
228 |
|
|
229 |
my $to_email = $u->user_id->email; |
my $to_email = $u->user_id->email; |
230 |
|
|
231 |
|
my ($from,$domain) = split(/@/, $u->list_id->email, 2); |
232 |
|
|
233 |
if ($sent->search( message_id => $m->message_id, user_id => $u->user_id )) { |
if ($sent->search( message_id => $m->message_id, user_id => $u->user_id )) { |
234 |
print "SKIP $to_email message allready sent\n"; |
print "SKIP $to_email message allready sent\n"; |
235 |
} else { |
} else { |
236 |
print "\t$to_email\n"; |
print "=> $to_email\n"; |
237 |
|
|
238 |
|
my $secret = $m->list_id->name . " " . $u->user_id->email . " " . $m->message_id; |
239 |
|
my $auth = Email::Auth::AddressHash->new( $secret, 10 ); |
240 |
|
|
241 |
my $hash = $auth->generate_hash( $to_email ); |
my $hash = $auth->generate_hash( $to_email ); |
242 |
|
|
243 |
my $from = $u->list_id->name . " <" . $u->list_id->email . "+" . $hash . ">"; |
my $from = $u->list_id->name . " <" . $from . "+" . $hash . ( $domain ? "@" . $domain : '' ). ">"; |
244 |
my $to = $u->user_id->full_name . " <$to_email>"; |
my $to = $u->user_id->full_name . " <$to_email>"; |
245 |
|
|
246 |
my $m = Email::Simple->new($msg) || croak "can't parse message"; |
my $m_obj = Email::Simple->new($msg) || croak "can't parse message"; |
|
|
|
|
print Dumper($m); |
|
247 |
|
|
248 |
$m->header_set('From', $from) || croak "can't set From: header"; |
$m_obj->header_set('From', $from) || croak "can't set From: header"; |
249 |
$m->header_set('To', $to) || croak "can't set To: header"; |
$m_obj->header_set('To', $to) || croak "can't set To: header"; |
250 |
|
|
251 |
# FIXME do real sending :-) |
# FIXME do real sending :-) |
252 |
send IO => $m->as_string; |
send IO => $m_obj->as_string; |
253 |
|
|
254 |
$sent->create({ |
$sent->create({ |
255 |
message_id => $m->message_id, |
message_id => $m->message_id, |