App-RecordStream

 view release on metacpan or  search on metacpan

META.json  view on Meta::CPAN

                  "Net::FTPServer::XferLog" : "0"
               }
            }
         }
      },
      "recs-fromxml and recs-fromatomfeeds" : {
         "description" : "XML/Atom sources",
         "prereqs" : {
            "runtime" : {
               "requires" : {
                  "HTTP::Request" : "0",
                  "LWP::UserAgent" : "0",
                  "List::MoreUtils" : "0",
                  "XML::Twig" : "0"
               }
            }
         }
      },
      "recs-togdgraph" : {
         "description" : "GD graph output",
         "prereqs" : {

META.yml  view on Meta::CPAN

      NetPacket::IP: '0'
      NetPacket::TCP: '0'
      NetPacket::UDP: '0'
  recs-fromxferlog:
    description: 'Transfer (xfer) log parsing'
    requires:
      Net::FTPServer::XferLog: '0'
  'recs-fromxml and recs-fromatomfeeds':
    description: 'XML/Atom sources'
    requires:
      HTTP::Request: '0'
      LWP::UserAgent: '0'
      List::MoreUtils: '0'
      XML::Twig: '0'
  recs-togdgraph:
    description: 'GD graph output'
    requires:
      GD::Graph: '0'
      GD::Graph::bars: '0'
      GD::Graph::lines: '0'
      GD::Graph::points: '0'

cpanfile  view on Meta::CPAN

        requires 'NetPacket::UDP';
        requires 'Net::Pcap';
    };
}

feature 'recs-fromxferlog', 'Transfer (xfer) log parsing' => sub {
    requires 'Net::FTPServer::XferLog';
};

feature 'recs-fromxml and recs-fromatomfeeds', 'XML/Atom sources' => sub {
    requires 'HTTP::Request';
    requires 'List::MoreUtils';
    requires 'LWP::UserAgent';
    requires 'XML::Twig';
};

feature 'recs-togdgraph', 'GD graph output' => sub {
    requires 'GD::Graph';
    requires "GD::Graph::$_"
        for qw(lines bars points);
};

lib/App/RecordStream/Operation/fromatomfeed.pm  view on Meta::CPAN

{
  return 0;
}

sub stream_done
{
  my ($this) = @_;

  my $ua = $this->make_user_agent();

  my $request = HTTP::Request->new();
  $request->method('GET');

  my $twig_roots = { '/*/entry' => sub { $this->handle_entry_elem( @_ ) } };

  if ( $this->{'FOLLOW'} ) {
    $twig_roots->{ '/*/link[ @rel="next" and @href ]' } = sub { $this->handle_link_elem( @_ ) };
  }

  my $twig = XML::Twig->new(twig_roots => $twig_roots);

lib/App/RecordStream/Operation/fromxml.pm  view on Meta::CPAN

our $VERSION = "4.0.25";

use strict;
use warnings;

use base qw(App::RecordStream::Operation);

use App::RecordStream::Record;

use App::RecordStream::OptionalRequire 'HTTP::Request';
use App::RecordStream::OptionalRequire 'LWP::UserAgent';
use App::RecordStream::OptionalRequire 'List::MoreUtils', qw(uniq);
use App::RecordStream::OptionalRequire 'XML::Twig';
BEGIN { App::RecordStream::OptionalRequire::require_done() }

sub init {
  my $this = shift;
  my $args = shift;

  my @elements;

lib/App/RecordStream/Operation/fromxml.pm  view on Meta::CPAN

    $contents = <STDIN>;
  }

  return $contents;
}

sub get_request {
  my $this = shift;
  my $uri  = shift;

  my $request = HTTP::Request->new();
  $request->method('GET');
  $request->uri($uri);

  return $request;
}

sub make_user_agent {
  return LWP::UserAgent->new();
}