lib/Tak.pm

   1 package Tak;
   2
   3 use Tak::Loop;
   4 use strictures 1;
   5
   6 our $VERSION = '0.001004'; # 0.1.4
   7
   8 our ($loop, $did_upgrade);
   9
  10 sub loop { $loop ||= Tak::Loop->new }
  11
  12 sub loop_upgrade {
  13   return if $did_upgrade;
  14   require IO::Async::Loop;
  15   my $new_loop = IO::Async::Loop->new;
  16   $loop->pass_watches_to($new_loop) if $loop;
  17   $loop = $new_loop;
  18   $did_upgrade = 1;
  19 }
  20
  21 sub loop_until {
  22   my ($class, $done) = @_;
  23   return if $done;
  24   $class->loop->loop_once until $_[1];
  25 }
  26
  27 sub await_all {
  28   my ($class, @requests) = @_;
  29   @requests = grep !$_->is_done, @requests;
  30   return unless @requests;
  31   my %req = map +("$_" => "$_"), @requests;
  32   my $done;
  33   my %on_r = map {
  34     my $orig = $_->{on_result};
  35     my $tag = $req{$_};
  36     ($_ => sub { delete $req{$tag}; $orig->(@_); $done = 1 unless keys %req; })
  37   } @requests;
  38   my $call = sub { $class->loop_until($done) };
  39   foreach (@requests) {
  40     my $req = $_;
  41     my $inner = $call;
  42     $call = sub { local $req->{on_result} = $on_r{$req}; $inner->() };
  43   }
  44   $call->();
  45   return;
  46 }
  47
  48 1;
  49
  50 =head1 NAME
  51
  52 Tak - Multi host remote control over ssh (then I wrote Object::Remote)
  53
  54 =head1 SYNOPSIS
  55
  56   # Curse at mst for doing it again under a different name
  57   # Curse at mst some more
  58   $ cpanm Object::Remote
  59   # Now go use that
  60
  61 (sorry, I should've done a tombstone release ages back)
  62
  63   bin/tak -h user1@host1 -h user2@host2 exec cat /etc/hostname
  64
  65 or
  66
  67   in Takfile:
  68
  69   package Tak::MyScript;
  70
  71   use Tak::Takfile;
  72   use Tak::ObjectClient;
  73
  74   sub each_get_homedir {
  75     my ($self, $remote) = @_;
  76     my $oc = Tak::ObjectClient->new(remote => $remote);
  77     my $home = $oc->new_object('Path::Class::Dir')->absolute->stringify;
  78     $self->stdout->print(
  79       $remote->host.': '.$home."\n"
  80     );
  81   }
  82
  83   1;
  84
  85 then
  86
  87   tak -h something get-homedir
  88
  89 =head1 WHERE'S THE REST?
  90
  91 A drink leaked in my bag on the way back from LPW. My laptop is finally
  92 alive again though so I'll try and turn my slides into a vague attempt
  93 at documentation while I'm traveling to/from christmas things.
  94
  95 =head1 Example
  96
  97 $ cat Takfile
  98 package Tak::MyScript;
  99
 100 use strict;
 101 use warnings;
 102
 103 use Tak::Takfile;
 104 use Tak::ObjectClient;
 105 use lib "./lib";
 106
 107 sub each_host {
 108     my ($self, $remote) = @_;
 109
 110     my $oc = Tak::ObjectClient->new(remote => $remote);
 111     my $name = $oc->new_object('My::Hostname');
 112     print "Connected to hostname: " . $name . "\n";
 113     }
 114
 115 1;
 116
 117 -----
 118
 119 $cat ./lib/My/Hostname
 120 package My::Hostname;
 121
 122 use Sys::Hostname;
 123
 124 sub new {
 125     my ($self) = @_;
 126     my $name = hostname;
 127     return $name;
 128     }
 129
 130 1;
 131
 132 =head1 AUTHOR
 133
 134 mst - Matt S. Trout (cpan:MSTROUT) <mst@shadowcat.co.uk>
 135
 136 =head1 CONTRIBUTORS
 137
 138 None required yet. Maybe this module is perfect (hahahahaha ...).
 139
 140 =head1 COPYRIGHT
 141
 142 Copyright (c) 2011 the Tak L</AUTHOR> and L</CONTRIBUTORS>
 143 as listed above.
 144
 145 =head1 LICENSE
 146
 147 This library is free software and may be distributed under the same terms
 148 as perl itself.
 149
 150 =cut