make feed example auto-reconnect forever

cpan-testers · Dec 24, 2016 · b03c76f · b03c76f
1 parent 63bff23
commit b03c76f
Showing 1 changed file with 22 additions and 16 deletions.
diff --git a/eg/feed.pl b/eg/feed.pl
@@ -24,22 +24,28 @@ =head1 SEE ALSO
 use Mojo::UserAgent;
 
 my $topic = $ARGV[0] || 'http://api.cpantesters.org/v1/upload';
-my $ua = Mojo::UserAgent->new(
-    inactivity_timeout => 60000,
-);
-$ua->websocket( $topic => sub( $ua, $tx ) {
-    say 'WebSocket handshake failed!' and return unless $tx->is_websocket;
-    say sprintf "[%s] Connected", scalar localtime;
-    $tx->on( json => sub( $tx, $upload ) {
-        say sprintf qq{[%s] Got upload: %s (%s) by %s},
-            scalar localtime, $upload->@{qw( dist version author )};
-    } );
-    $tx->on( finish => sub( $tx, $code ) {
-        say sprintf "[%s] Connection closed: %s",
-            scalar localtime, $code;
-        Mojo::IOLoop->stop;
+
+sub open_socket {
+    state $ua = Mojo::UserAgent->new(
+        inactivity_timeout => 60000,
+    );
+    $ua->websocket( $topic => sub( $ua, $tx ) {
+        say 'WebSocket handshake failed: ' . $tx->error->{message} and return unless $tx->is_websocket;
+        say sprintf "[%s] Connected", scalar localtime;
+        $tx->on( json => sub( $tx, $upload ) {
+            say sprintf qq{[%s] Got upload: %s (%s) by %s},
+                scalar localtime, $upload->@{qw( dist version author )};
+        } );
+        $tx->on( finish => sub( $tx, $code ) {
+            say sprintf "[%s] Connection closed: %s",
+                scalar localtime, $code;
+            Mojo::IOLoop->stop;
+        } );
     } );
-} );
+}
 
-Mojo::IOLoop->start unless Mojo::IOLoop->is_running;
+while ( 1 ) {
+    open_socket() && Mojo::IOLoop->start;
+    sleep 1;
+}