Allow reading files/URIs from STDIN

[Fey] / lib / App / Fey.pm

diff --git a/lib/App/Fey.pm b/lib/App/Fey.pm
index c0778ab2ede342c99b79f96f124388ab303f3310..8b802a0d70e7a1881af2e3bcf1baae2a074a7051 100644 (file)
--- a/lib/App/Fey.pm
+++ b/lib/App/Fey.pm
@@ -27,9 +27,18 @@ sub launch {
     my $self = shift;
     my $options = ref $_[0] ? shift : {};
 
+    if (!(-t STDIN)) {
+        _read_stdin(\@_);
+    }
+    if (!@_ || $options->{interactive}) {
+        open STDIN, '<', '/dev/tty'; 
+        _read_stdin(\@_);
+    }
     die "No files or URIs specified.\n" unless @_;
 
-    if ($options->{single}) {
+    if ($options->{group}) {
+        $self->_launch_group($options, @_);
+    } elsif ($options->{single}) {
         $self->_launch_single($options, @_);
     } else {
         $self->_launch($options, @_);
@@ -45,18 +54,49 @@ sub _launch {
             my $pid = fork;
             next if $pid;
 
-            my $handler = $self->_get_handler($file_or_uri);
+            my $handler = $self->_get_handler($options, $file_or_uri);
             $handler->($file_or_uri) if $handler;
             return;
         }
     } else {
         for my $file_or_uri (@_) {
-            my $handler = $self->_get_handler($file_or_uri);
+            my $handler = $self->_get_handler($options, $file_or_uri);
             $handler->($file_or_uri) if $handler;
         }
     }
 }
 
+sub _launch_group {
+    my $self = shift;
+    my $options = shift;
+
+    my ($groups, $handlers) = ({}, {});
+    for my $file_or_uri (@_) {
+        my $handler = $self->_get_handler($options, $file_or_uri);
+        if ($handler) {
+            $groups->{"$handler"} //= [];
+            push @{ $groups->{"$handler"} }, $file_or_uri;
+            $handlers->{"$handler"} = $handler;
+        }
+    }
+
+    if ($options->{fork}) {
+        for my $group (keys %{ $groups }) {
+            if ($options->{fork}) {
+                my $pid = fork;
+                next if $pid;
+            }
+
+            $handlers->{$group}->(@{ $groups->{$group} });
+            return;
+        }
+    } else {
+        for my $group (keys %{ $groups }) {
+            $handlers->{$group}->(@{ $groups->{$group} });
+        }
+    }
+}
+
 sub _launch_single {
     my $self = shift;
     my $options = shift;
@@ -66,12 +106,13 @@ sub _launch_single {
         return if $pid;
     }
 
-    my $handler = $self->_get_handler($_[0]);
+    my $handler = $self->_get_handler($options, $_[0]);
     $handler->(@_) if $handler;
 }
 
 sub _get_handler {
     my $self = shift;
+    my $options = shift;
     
     my $file_or_uri = $_[0] =~ m|^file://(.+)| ? $1 : $_[0];
     my $mime_or_uri = -e $file_or_uri ? $self->{mime_query}->($file_or_uri) : $file_or_uri;
@@ -80,6 +121,11 @@ sub _get_handler {
         for my $pattern (@{ $target->{patterns} }) {
             if ($mime_or_uri =~ /$pattern/) {
                 my $associations = $target->{associations};
+
+                my $context = $options->{context};
+                my $handler = $associations->{$context} if $context;
+                return $handler if defined $handler;
+
                 for my $context (keys %{ $associations }) {
                     if ($self->{contexts}->{$context}->()) {
                         return $associations->{$context};
@@ -90,6 +136,13 @@ sub _get_handler {
     }
 }
 
+sub _read_stdin {
+    for my $file_or_uri (<STDIN>) {
+        chomp $file_or_uri;
+        push @{ $_[0] }, $file_or_uri;
+    }
+}
+
 sub fey {
     App::Fey->new(ref $_[0] ? $_[0] : {})->launch(@_);
 }