src/perlmods/OpenSRF/Transport/SlimJabber/PeerConnection.pm

   1 package OpenSRF::Transport::SlimJabber::PeerConnection;
   2 use strict;
   3 use base qw/OpenSRF::Transport::SlimJabber::Client/;
   4 use OpenSRF::Utils::Config;
   5 use OpenSRF::Utils::Logger qw(:level);
   6 use OpenSRF::EX qw/:try/;
   7
   8 =head1 Description
   9
  10 Represents a single connection to a remote peer.  The
  11 Jabber values are loaded from the config file.
  12
  13 Subclasses OpenSRF::Transport::SlimJabber::Client.
  14
  15 =cut
  16
  17 =head2 new()
  18
  19         new( $appname );
  20
  21         The $appname parameter tells this class how to find the correct
  22         Jabber username, password, etc to connect to the server.
  23
  24 =cut
  25
  26 our %apps_hash;
  27
  28 sub retrieve {
  29         my( $class, $app ) = @_;
  30         my @keys = keys %apps_hash;
  31         OpenSRF::Utils::Logger->transport(
  32                         "Requesting peer for $app and we have @keys", INTERNAL );
  33         return $apps_hash{$app};
  34 }
  35
  36
  37
  38 sub new {
  39         my( $class, $app ) = @_;
  40         my $config = OpenSRF::Utils::Config->current;
  41
  42         if( ! $config ) {
  43                 throw OpenSRF::EX::Config( "No suitable config found" );
  44         }
  45
  46         my $app_stat    = $app . "_peer";
  47         my $username    = $config->transport->users->$app;
  48         my $password    = $config->transport->auth->password;
  49         my $resource    = $config->env->hostname . "_$$";
  50
  51         OpenSRF::EX::Config->throw( "JPeer could not load all necesarry values from config" )
  52                 unless ( $username and $password and $resource );
  53
  54
  55         my $self = __PACKAGE__->SUPER::new(
  56                 username                => $username,
  57                 resource                => $resource,
  58                 password                => $password,
  59                 );
  60
  61         bless( $self, $class );
  62
  63         $self->app($app);
  64
  65         $apps_hash{$app} = $self;
  66         return $apps_hash{$app};
  67 }
  68
  69 sub process {
  70         my $self = shift;
  71         my $val = $self->SUPER::process(@_);
  72         return 0 unless $val;
  73         OpenSRF::Utils::Logger->transport( "Calling transport handler for ".$self->app." with: $val", INTERNAL );
  74         my $t;
  75 #try {
  76         $t = OpenSRF::Transport->handler($self->app, $val);
  77
  78 #       } catch OpenSRF::EX with {
  79 #               my $e = shift;
  80 #               $e->throw();
  81
  82 #       } catch Error with { return undef; }
  83
  84         return $t;
  85 }
  86
  87 sub app {
  88         my $self = shift;
  89         my $app = shift;
  90         if( $app ) {
  91                 OpenSRF::Utils::Logger->transport( "PEER changing app to $app: ".$self->jid, INTERNAL );
  92         }
  93
  94         $self->{app} = $app if ($app);
  95         return $self->{app};
  96 }
  97
  98 1;
  99