--- trunk/Nos.pm 2005/05/15 22:12:31 23 +++ trunk/Nos.pm 2005/05/15 22:30:54 24 @@ -130,11 +130,63 @@ return 1; } +=head2 add_message_to_queue + +Adds message to one list's queue for later sending. + + $nos->add_message_to_queue( + list => 'My list', + message => 'From: My list + To: John A. Doe + + This is example message + ', + ); + +On success returns ID of newly created (or existing) message. + +=cut + +sub add_message_to_queue { + my $self = shift; + + my $args = {@_}; + + my $list_name = $args->{'list'} || confess "need list name"; + my $message_text = $args->{'message'} || croak "need message"; + + my $lists = $self->{'loader'}->find_class('lists'); + + my $this_list = $lists->search( + name => $list_name, + )->first || croak "can't find list $list_name"; + + my $messages = $self->{'loader'}->find_class('messages'); + + my $this_message = $messages->find_or_create({ + message => $message_text + }) || croak "can't insert message"; + + $this_message->dbi_commit() || croak "can't add message"; + + my $queue = $self->{'loader'}->find_class('queue'); + + $queue->find_or_create({ + message_id => $this_message->id, + list_id => $this_list->id, + }) || croak "can't add message ",$this_message->id," to list ",$this_list->id, ": ",$this_list->name; + + $queue->dbi_commit || croak "can't add message to list ",$this_list->name; + + return $this_message->id; +} + + =head2 send_queued_messages Send queued messages or just ones for selected list - $noc->send_queued_messages("my list"); + $nos->send_queued_messages("My list"); =cut