Enabled plugin_debug effect Pipeline; Added send_event() method for i…

…njecting events in the event handling system.
bingos · Oct 17, 2006 · fc975b6 · fc975b6
1 parent 21c4d4f
commit fc975b6
Show file tree

Hide file tree

Showing 3 changed files with 30 additions and 6 deletions.
diff --git a/Changes b/Changes
@@ -1,5 +1,10 @@
 Revision history for Perl extension POE::Component::IRC.
 
+5.07  Tue Oct 17 11:37:28 BST 2006
+    - Enabled plugin_debug effect Pipeline.
+    - Added send_event() method for injecting events in the event
+      handling system.
+
 5.06  Thu Oct 12 12:45:06 BST 2006
     - Adjusted load() in PlugMan, suggested by Stefan Schwarzkopf.
 

diff --git a/lib/POE/Component/IRC.pm b/lib/POE/Component/IRC.pm
@@ -32,7 +32,7 @@ use vars qw($VERSION $REVISION $GOT_SSL $GOT_CLIENT_DNS);
 # Load the plugin stuff
 use POE::Component::IRC::Plugin qw( :ALL );
 
-$VERSION = '5.06';
+$VERSION = '5.07';
 $REVISION = do {my@r=(q$Revision$=~/\d+/g);sprintf"%d"."%04d"x$#r,@r};
 
 # BINGOS: I have bundled up all the stuff that needs changing for inherited classes
@@ -503,14 +503,18 @@ sub _parseline {
   undef;
 }
 
+sub send_event {
+  my $self = shift;
+  $poe_kernel->call( $self->{SESSION_ID}, '__send_event', @_ );
+  return 1;
+}
 
 # Hack to make plugin_add/del send events from OUR session
 sub __send_event {
-	my( $self, $event, @args ) = @_[ OBJECT, ARG0, ARG1 .. $#_ ];
-
-	# Actually send the event...
-	$self->_send_event( $event, @args );
-	return 1;
+  my( $self, $event, @args ) = @_[ OBJECT, ARG0, ARG1 .. $#_ ];
+  # Actually send the event...
+  $self->_send_event( $event, @args );
+  return 1;
 }
 
 # Sends an event to all interested sessions. This is a separate sub
@@ -2354,6 +2358,11 @@ created by the component.
 
 Returns a reference to the L<POE::Component::IRC::Pipeline> object used by the plugin system.
 
+=item send_event
+
+Sends an event through the components event handling system. These will get processed by 
+plugins then by registered sessions. First argument is the event name, followed by any parameters for that event.
+
 =back
 
 =head1 INPUT

diff --git a/lib/POE/Component/IRC/Pipeline.pm b/lib/POE/Component/IRC/Pipeline.pm
@@ -14,6 +14,7 @@ sub new {
     PIPELINE => [],
     HANDLES => {},
     IRC => $irc,
+    DEBUG => $irc->{plugin_debug},
   }, $class;
 }
 
@@ -26,6 +27,7 @@ sub push {
   my $return;
 
   eval { $return = $plug->PCI_register($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
 
   if ($return) {
     push @{ $self->{PIPELINE} }, $plug;
@@ -49,6 +51,7 @@ sub pop {
   delete $self->{HANDLES}{$plug};
 
   eval { $plug->PCI_unregister($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
   $self->{IRC}->yield(__send_event => irc_plugin_del => $alias, $plug);
 
   return wantarray() ? ($plug, $alias) : $plug;
@@ -63,6 +66,7 @@ sub unshift {
   my $return;
 
   eval { $return = $plug->PCI_register($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
 
   if ($return) {
     unshift @{ $self->{PIPELINE} }, $plug;
@@ -88,6 +92,7 @@ sub shift {
   delete $self->{HANDLES}{$plug};
 
   eval { $plug->PCI_unregister($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
   $self->{IRC}->yield(__send_event => irc_plugin_del => $alias, $plug);
 
   return wantarray() ? ($plug, $alias) : $plug;
@@ -107,6 +112,7 @@ sub replace {
   delete $self->{PLUGS}{$old_a};
   delete $self->{HANDLES}{$old_p};
   eval { $old_p->PCI_unregister($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
   $self->{IRC}->yield(__send_event => irc_plugin_del => $old_a, $old_p);
 
   $@ = "Plugin named '$new_a' already exists ($self->{PLUGS}{$new_a}", return
@@ -115,6 +121,7 @@ sub replace {
   my $return;
 
   eval { $return = $new_p->PCI_register($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
 
   if ($return) {
     $self->{PLUGS}{$new_p} = $new_a;
@@ -152,6 +159,7 @@ sub remove {
   }
 
   eval { $old_p->PCI_unregister($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
   $self->{IRC}->yield(__send_event => irc_plugin_del => $old_a, $old_p);
 
   return wantarray ? ($old_p, $old_a) : $old_p;
@@ -203,6 +211,7 @@ sub insert_before {
   my $return;
 
   eval { $return = $new_p->PCI_register($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
 
   if ($return) {
     $self->{PLUGS}{$new_p} = $new_a;
@@ -237,6 +246,7 @@ sub insert_after {
   my $return;
 
   eval { $return = $new_p->PCI_register($self->{IRC}) };
+  warn "$@\n" if $@ and $self->{DEBUG};
 
   if ($return) {
     $self->{PLUGS}{$new_p} = $new_a;