Changeset 5602

Timestamp:

06/26/09 09:48:38 (3 years ago)

Author:

submersible_toaster

Message:

chat from ./announcer.pl to listener.pl and also running padre instance Swarm -Chat window

Location:

trunk/Padre-Plugin-Swarm

Files:

• announcer.pl (added)
• lib/Padre/Plugin/Swarm.pm (modified) (6 diffs)
• lib/Padre/Swarm/Service/Chat.pm (modified) (1 diff)
• lib/Padre/Wx (added)
• lib/Padre/Wx/Swarm (added)
• lib/Padre/Wx/Swarm/Chat.pm (added)
• listener.pl (modified) (1 diff)

trunk/Padre-Plugin-Swarm/lib/Padre/Plugin/Swarm.pm

@@ -9 +9 @@
 use Padre::Wx::Icon ();
 use Padre::Swarm::Service::Chat ();
+use Padre::Wx::Swarm::Chat ();
 use File::Spec      ();
 
@@ -15 +16 @@
         get_config => 'config',
         get_services => 'services',
+        # 
+        get_chat => 'chat',
     }
     ,
@@ -20 +23 @@
         set_config => 'config',
         set_services=>'services',
+        set_chat => 'chat',
     };
 
@@ -73 +77 @@
     my $config = $self->config_read;
     $self->set_config( $config );
-    
+
     $self->_load_everything;
     $self->_start_services;
@@ -83 +87 @@
     my $self = shift;
     $self->_shutdown_services;
+    $self->_destroy_ui;
 }
 
@@ -127 +132 @@
     );
     
-
-}
-
-sub _start_transports {
-    my $self = shift;
-    my $transports = $self->get_transports;
-    while ( my ($name,$transport) = each %$transports ) {
-        $transport->start;
-    }
-}
-
-sub _shutdown_transports {
-    my $self = shift;
-    my $transports = $self->get_transports;
-    while ( my ($name,$transport) = each %$transports ) {
-        $transport->shutdown;
-    }
-}
+    my $chatframe = Padre::Wx::Swarm::Chat->new($self->main);
+    
+    $self->set_chat( $chatframe );
+    $chatframe->enable;
+}
+
+sub _destroy_ui {
+    my $self = shift;
+    if ( my $chat = $self->get_chat ) {
+        $chat->disable;
+    }
+    $self->set_chat(undef);
+
+}
+
+#sub _start_transports {
+#   my $self = shift;
+#   my $transports = $self->get_transports;
+#   while ( my ($name,$transport) = each %$transports ) {
+#       $transport->start;
+#   }
+#}
+#
+#sub _shutdown_transports {
+#   my $self = shift;
+#   my $transports = $self->get_transports;
+#   while ( my ($name,$transport) = each %$transports ) {
+#       $transport->shutdown;
+#   }
+#}
 
 sub _start_services {

trunk/Padre-Plugin-Swarm/lib/Padre/Swarm/Service/Chat.pm

@@ -66 +66 @@
 }
 
+sub receive {
+    my $self = shift;
+    my $t = $self->get_transport;
+    if ( $t->poll(0) ) {
+        my ($channel,$client,$payload) = $t->receive_from( 12000 );
+        my $message = eval { JSON::XS::decode_json( $payload ); } ;
+        if ($@) {
+            warn "cannot decode message from [$client], $@. Client said\t$message";
+            return;
+        }
+        return $message;
+    }
+    return;
+}
+
 1;

trunk/Padre-Plugin-Swarm/listener.pl

@@ -12 +12 @@
     my $buffer;
     my ($channel,$client,$payload) = $mc->receive_from( 12000 );
-    print "[$client], $payload";
+    print "[$client], $payload",$\;
 }