[SCM] libmessage-passing-perl Debian packaging branch, master, updated. debian/0.111-3-14-g44f6e88

[Tomas Doran]

The following commit has been merged in the master branch:
commit abfdd7a3f3304346a2ff1bda938abf2b75fa7c21
Author: Tomas Doran <bobtfish at bobtfish.net>
Date:   Fri Jun 15 16:28:01 2012 -0500

    Add Gzip and Bzip2 encoders and decoders

diff --git a/Changes b/Changes
index bf2e36b..6f9875d 100644
--- a/Changes
+++ b/Changes
@@ -1,3 +1,5 @@
+  - Add Gzip and Bzip2 encoders and decoders.
+
 0.009
   - Add Message::Passing::Manual::Components.
 
diff --git a/Makefile.PL b/Makefile.PL
index 00be1d4..62e2138 100644
--- a/Makefile.PL
+++ b/Makefile.PL
@@ -36,6 +36,8 @@ author_requires(
     'Pod::Coverage' => '0.19',
     'Pod::Coverage::TrustPod' => '0',
     'Test::Spelling' => '0',
+    'Compress::Zlib' => '0',
+    'Compress::Bzip2' => '0',
 );
 
 author_tests 't/author';
diff --git a/lib/Message/Passing/Filter/Decoder/Bzip2.pm b/lib/Message/Passing/Filter/Decoder/Bzip2.pm
new file mode 100644
index 0000000..856dc09
--- /dev/null
+++ b/lib/Message/Passing/Filter/Decoder/Bzip2.pm
@@ -0,0 +1,15 @@
+package Message::Passing::Filter::Decoder::Bzip2;
+use Moose;
+use Compress::Bzip2;
+use namespace::autoclean;
+
+with 'Message::Passing::Role::Filter';
+
+sub filter {
+    my ($self, $message) = @_;
+    Compress::Bzip2::memBunzip($message);
+}
+
+__PACKAGE__->meta->make_immutable;
+1;
+
diff --git a/lib/Message/Passing/Filter/Decoder/Gzip.pm b/lib/Message/Passing/Filter/Decoder/Gzip.pm
new file mode 100644
index 0000000..455d8d6
--- /dev/null
+++ b/lib/Message/Passing/Filter/Decoder/Gzip.pm
@@ -0,0 +1,15 @@
+package Message::Passing::Filter::Decoder::Gzip;
+use Moose;
+use Compress::Zlib;
+use namespace::autoclean;
+
+with 'Message::Passing::Role::Filter';
+
+sub filter {
+    my ($self, $message) = @_;
+    Compress::Zlib::memGunzip($message);
+}
+
+__PACKAGE__->meta->make_immutable;
+1;
+
diff --git a/lib/Message/Passing/Filter/Encoder/Bzip2.pm b/lib/Message/Passing/Filter/Encoder/Bzip2.pm
new file mode 100644
index 0000000..29f5fd0
--- /dev/null
+++ b/lib/Message/Passing/Filter/Encoder/Bzip2.pm
@@ -0,0 +1,15 @@
+package Message::Passing::Filter::Encoder::Bzip2;
+use Moose;
+use Compress::Bzip2;
+use namespace::autoclean;
+
+with 'Message::Passing::Role::Filter';
+
+sub filter {
+    my ($self, $message) = @_;
+    Compress::Bzip2::memBzip($message);
+}
+
+__PACKAGE__->meta->make_immutable;
+1;
+
diff --git a/lib/Message/Passing/Filter/Encoder/Gzip.pm b/lib/Message/Passing/Filter/Encoder/Gzip.pm
new file mode 100644
index 0000000..3b4b430
--- /dev/null
+++ b/lib/Message/Passing/Filter/Encoder/Gzip.pm
@@ -0,0 +1,15 @@
+package Message::Passing::Filter::Encoder::Gzip;
+use Moose;
+use Compress::Zlib;
+use namespace::autoclean;
+
+with 'Message::Passing::Role::Filter';
+
+sub filter {
+    my ($self, $message) = @_;
+    Compress::Zlib::memGzip($message);
+}
+
+__PACKAGE__->meta->make_immutable;
+1;
+
diff --git a/t/compress.t b/t/compress.t
new file mode 100644
index 0000000..7311449
--- /dev/null
+++ b/t/compress.t
@@ -0,0 +1,43 @@
+use strict;
+use warnings;
+use Test::More;
+use Try::Tiny;
+use Message::Passing::Input::Null;
+use Message::Passing::Output::Test;
+
+plan skip_all => "No IO::Compress"
+    unless try { require Message::Passing::Filter::Decoder::Bzip2; require Message::Passing::Filter::Encoder::Gzip };
+
+use_ok 'Message::Passing::Filter::Decoder::Bzip2';
+use_ok 'Message::Passing::Filter::Encoder::Bzip2';
+use_ok 'Message::Passing::Filter::Encoder::Gzip';
+use_ok 'Message::Passing::Filter::Decoder::Gzip';
+
+my $gzt = Message::Passing::Output::Test->new;
+my $gz = Message::Passing::Input::Null->new(
+    output_to => Message::Passing::Filter::Encoder::Gzip->new(
+        output_to => Message::Passing::Filter::Decoder::Gzip->new(
+            output_to => $gzt,
+        ),
+    ),
+);
+
+$gz->output_to->consume('test');
+is $gzt->message_count, 1;
+is_deeply [$gzt->messages], ['test'];
+
+my $bzt = Message::Passing::Output::Test->new;
+my $bz = Message::Passing::Input::Null->new(
+    output_to => Message::Passing::Filter::Encoder::Gzip->new(
+        output_to => Message::Passing::Filter::Decoder::Gzip->new(
+            output_to => $bzt,
+        ),
+    ),
+);
+
+$bz->output_to->consume('test');
+is $bzt->message_count, 1;
+is_deeply [$bzt->messages], ['test'];
+
+done_testing;
+

-- 
libmessage-passing-perl Debian packaging