#!/usr/bin/perl

#
# USAGE:
#   jabber-send <jid> <password> [<host> <port>]
#
# STDIN usage:
#   First line: space divided list of recipients
#   Next lines: message text in UTF-8
#

use strict;
use open ":utf8";
use AnyEvent;
use AnyEvent::XMPP::IM::Connection;

binmode STDOUT, ":utf8";
binmode STDIN, ":utf8";

my $DEBUG   = 0;  # set to 1 if you want to see a protocol dump
my $TIMEOUT = 600; # timeout the whole program after $TIMEOUT seconds

my ($jid, $pass, $host, $port) = @ARGV;

my $j = AnyEvent->condvar;
my $session_ready = AnyEvent->condvar;

my $con;
if(defined $host)
{
    $con =
	AnyEvent::XMPP::IM::Connection->new (
    	    jid              => $jid,
    	    password         => $pass,
	    resource	     => "jabber bot",
    	    initial_presence => -5,
    	    override_host => $host,
    	    override_port => $port);
   shift @ARGV;
   shift @ARGV;
   shift @ARGV;
   shift @ARGV;
}
else
{
    $con =
	AnyEvent::XMPP::IM::Connection->new (
    	    jid              => $jid,
    	    password         => $pass,
	    resource	     => "jabber bot",
    	    initial_presence => -5);
   shift @ARGV;
   shift @ARGV;
}

my $timer =
   AnyEvent->timer (
      after => 30, cb => sub { warn "got timeout, exiting..."; $j->broadcast }
   );

my @tos=split /\s+/, <>;
my $body = "";
while(<>)
{
    $body .= $_;
}

$con->reg_cb (
   session_ready => sub {
      my ($con) = @_;
      $session_ready->broadcast;
      print "session ready\n";
   },
   error => sub {
      my ($con, $error) = @_;
      warn "error: " . $error->string . "\n";
   },
   disconnect => sub {
      my ($con, $host, $port, $message) = @_;
      warn "disconnected from $host:$port: $message\n";
      $j->broadcast;
   },
);

$con->connect;
$session_ready->wait;

my $to;
foreach $to (@tos)
{
    chomp $to;
    print "sending to $to\n";
    my $r = AnyEvent::XMPP::IM::Message->new(connection => $con, body => $body, to => $to, from => $jid);
    $r->send;
}

$j->wait;