File Coverage

blib/lib/Net/Ethereum/Swarm.pm

Criterion	Covered	Total	%
statement	20	51	39.2
branch			n/a
condition			n/a
subroutine	7	14	50.0
pod	2	2	100.0
total	29	67	43.2

package Net::Ethereum::Swarm;

use 5.020002;
use strict;
use warnings;

use LWP::UserAgent;
use File::Slurp;
use HTTP::Request ();
use JSON;


our $VERSION = '0.04';



=pod

=encoding utf8

=head1 NAME

  Net::Ethereum::Swarm - Perl Framework for a distributed storage platform and content distribution service Ethereum Swarm.

=head1 SYNOPSIS


# Upload text file to Ethereum Swarm

  use Net::Ethereum::Swarm;
  my $uploaded_file_path = $ARGV[0];
  my $sw_node = Net::Ethereum::Swarm->new('http://localhost:8500/');
  my $rc = $sw_node->_swarp_node_upload_text_file($uploaded_file_path, 'plain/text; charset=UTF-8');
  print Dumper($rc), "\n";


# Upload binary file to Ethereum Swarm

  use Net::Ethereum::Swarm;
  my $uploaded_file_path = $ARGV[0];
  my $sw_node = Net::Ethereum::Swarm->new('http://localhost:8500/');
  my $rc = $sw_node->_swarp_node_upload_binary_file($uploaded_file_path, 'image/jpeg');
  print Dumper($rc), "\n";


# Get manifest by manifest id

  use Net::Ethereum::Swarm;
  my $manifest_id = $ARGV[0];
  my $sw_node = Net::Ethereum::Swarm->new('http://localhost:8500/');
  my $rc = $sw_node->_swarp_node_get_manifest($manifest_id);
  print Dumper($rc), "\n";


# Get file from Ethereum Swarm

  use Net::Ethereum::Swarm;
  my $manifest_id = $ARGV[0];
  my $file_path_to_save = $ARGV[1];
  my $sw_node = Net::Ethereum::Swarm->new('http://localhost:8500/');
  my $rc = $sw_node->_swarp_node_get_file($manifest_id, $file_path_to_save, 'plain/text; charset=UTF-8');
  print Dumper($rc), "\n";



=head1 DESCRIPTION

  Net::Ethereum::Swarm - Perl Framework for a distributed storage platform and content distribution service Ethereum Swarm.

=head1 FUNCTIONS



=head2 new()

  my $sw_node = Net::Ethereum::Swarm->new('http://localhost:8500/');

=cut

sub new
{
  my ($this, $swarm_api_url) = @_;
  my $self = {};
  bless( $self, $this );

  $self->{api_url} = $swarm_api_url;
  $self->{debug} = 0;

  return $self;
}

=pod

=head2 _swarp_node_get_manifest

  Get manifest by manifest id
  my $rc = $sw_node->_swarp_node_get_manifest($manifest_id);

=cut

sub _swarp_node_get_manifest()
{
  my ($this, $manifest_id) = @_;
  my $header = ['Content-Type' => 'plain/text'];
  my $rc = $this->_swarp_node_request('GET', 'bzz-list:/'.$manifest_id.'/', $header, '');
  my $manifest = JSON::decode_json($rc);
  return $manifest;
}


=pod

=head2 _swarp_node_get_file

  Get file from Ethereum Swarm
  my $rc = $sw_node->_swarp_node_get_file($manifest_id, $file_path_to_save, 'plain/text; charset=UTF-8');

=cut

sub _swarp_node_get_file()
{
  my ($this, $manifest_id, $content_type, $path) = @_;
  my $header = ['Content-Type' => $content_type];
  my $file_content = $this->_swarp_node_request('GET', 'bzz:/'.$manifest_id.'/'.$path, $header, '');
  return $file_content;
}


=pod

=head2 _swarp_node_upload_text_file

  Upload text file to Ethereum Swarm

  my $rc = $sw_node->_swarp_node_upload_text_file($uploaded_file_path, 'plain/text; charset=UTF-8');

=cut


sub _swarp_node_upload_text_file()
{
  my ($this, $uploaded_file_path, $content_type) = @_;

  my $file_content = read_file( $uploaded_file_path, scalar_ref => 1);
#  my $header = ['Content-Type' => 'plain/text; charset=UTF-8'];
  my $header = ['Content-Type' => $content_type];
  my $ua_rc = $this->_swarp_node_request('POST', 'bzz:/', $header, $file_content);
  return $ua_rc;
}


=pod

=head2 _swarp_node_upload_binary_file

  Upload binary file to Ethereum Swarm

  my $rc = $sw_node->_swarp_node_upload_binary_file($uploaded_file_path, 'image/jpeg');

=cut


sub _swarp_node_upload_binary_file()
{
  my ($this, $uploaded_file_path, $content_type) = @_;

  my $file_content = read_file( $uploaded_file_path , binmode => ':raw' , scalar_ref => 1 );
#  my $header = ['Content-Type' => 'image/jpeg'];
  my $header = ['Content-Type' => $content_type];
  my $ua_rc = $this->_swarp_node_request('POST', 'bzz:/', $header, $file_content);
  return $ua_rc;
}


=pod

=head2 _swarp_node_request

  Internal method.
  Send request to Ethereum Swarm

  my $ua_rc = $this->_swarp_node_request('POST', 'bzz:/', $header, $file_content);

=cut


sub _swarp_node_request()
{
  my ($this, $rq_type, $bzz_protocol, $header, $content) = @_;
  my $req = HTTP::Request->new($rq_type, $this->{api_url}.$bzz_protocol, $header, $content);
  my $ua = LWP::UserAgent->new;
  return $ua->request($req)->{ _content };
}



=pod

=head2 set_debug_mode

  Set dubug mode. Debug info printed to console.
  $node->set_debug_mode($mode);

  $mode: 1 - debug on, 0 - debug off.

=cut

sub set_debug_mode()
{
  my ($this, $debug_mode) = @_;
  $this->{debug} = $debug_mode;
}



1;
__END__