Initial revision
[OpenSRF.git] / 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