Changeset 10144 for trunk/Padre-Plugin-Swarm/t/06_service.t

Timestamp:

01/18/10 01:38:23 (2 years ago)

Author:

submersible_toaster

Message:

doom lots of swarm code. remove IO::Interface, use wx event to notify components of swarm message arrival.

File:

• trunk/Padre-Plugin-Swarm/t/06_service.t (modified) (2 diffs)

trunk/Padre-Plugin-Swarm/t/06_service.t

@@ -1 @@
-use Test::More skip_all => 'needs better Taskmanager harness';
-
+use Test::More skip_all => 'Still trouble driving padre in testing';
 use JSON::XS;
 use t::lib::Demo;
-    use threads;
-    use threads::shared;
-BEGIN {
-use_ok( 'Padre::TaskManager' );
-use_ok( 'Padre::Swarm::Service::Chat' );
-use_ok( 'Padre::Swarm::Transport::Multicast' );
-use_ok( 'Padre::Swarm::Message' );
-}
 
+use threads;         # need to be loaded before Padre
+use threads::shared; # need to be loaded before Padre
+use Padre;
+use Padre::Swarm::Message;
+use Padre::Swarm::Service;
+use IO::Socket::Multicast;
+use Data::Dumper;
 my $app = Padre->new;
 isa_ok($app, 'Padre');
-my $tm = Padre::TaskManager->new;
 
-#Padre::Util::set_logging( 1 );
-#Padre::Util::set_tracing( 1 );
-my $chat = Padre::Swarm::Service::Chat->new(
-    use_transport => {
-        'Padre::Swarm::Transport::Multicast' => {},
-    }
-);
+
+my $chat = Padre::Swarm::Service->new;
 $chat->schedule;
+my $socket = IO::Socket::Multicast->new;
 
-my $got_loopback : shared = 0 ;
+my $got_loopback = 0; 
 Wx::Event::EVT_COMMAND( $app->wx->main , -1 , $chat->event,
  sub { diag "LOOPBACK!" ; $got_loopback = 1 }
@@ -31 +24 @@
 diag( "WX event is " . $chat->event );
 
-$chat->queue->enqueue(
-    Padre::Swarm::Message->new(
+
+$socket->mcast_send(
+        JSON::XS::encode_json( {
         from => getlogin(),
         type =>'chat',
         body => 'test',
-    )
+    }) ,
+    '239.255.255.1:12000',
 );
 
-sleep 5;
 
 ok( $got_loopback , 'got service event' );
 
-$chat->queue->enqueue('HANGUP');
 $chat->shutdown;
-$tm->cleanup;
-#ok( $chat->start, 'Started chat' );
-#ok( $chat->shutdown , 'Chat shutdown' );