File Coverage

blib/lib/Flower/Rest.pm

Criterion	Covered	Total	%
statement	29	81	35.8
branch	0	6	0.0
condition	0	2	0.0
subroutine	9	14	64.2
pod	0	5	0.0
total	38	108	35.1

package Flower::Rest;



use strict;
use warnings;
use feature qw(say switch);
use Data::Printer;
use Mojo::Base 'Mojolicious::Controller';
use JSON::XS;
use Number::Format qw/format_bytes/;
use Data::FreqConvert;
my $json    = JSON::XS->new->allow_nonref;

#my $json    = JSON::XS->new->allow_nonref();
# respond to a ping
sub ping {
  my $self   = shift;
  my $config = $self->config;
  my $nodes  = $self->req->json;

  # Add all the nodes that have been advertised to us by the pinger.
  foreach (@$nodes) {

    # add nodes that have a UUID
    $config->{nodes}->add_if_necessary($_)
      if ( $_->{uuid} );
  }

  $self->render(
    json => { result => 'ok', 'uuid' => $config->{nodes}->self->uuid } );
}

# list my files
sub files {
  my $self   = shift;
  my $config = $self->config;

  my $files_hashref = $config->{nodes}->self->files->as_hashref;
  $self->render( json => { result => 'ok', files => $files_hashref } );
}



# list my files
sub query {
  my $self   = shift;
  my $config = $self->config;
  my $type = $self->param('type') || "class";


  $self->ua->get('http://localhost:9200/_search?size=10000000&pretty=1' => sub {
    my ($ua, $tx) = @_;
    my $hits = $tx->res->json->{hits}{hits};
    my $h = {};
    my @freq = ();


    for my $hit (@$hits) {

      #$hit->{_source}{name}=~ s/\W//g;
      push @freq,$hit->{_source}{$type} unless !$hit->{_source}{$type};

    }

    my $data =  Data::FreqConvert->new;
    $h = $data->freq(\@freq);

    $self->render("interface/root",set  => $h);


    });
}

# all files we know about
sub files_all {
  my $self   = shift;
  my $config = $self->config;
  my $stats  = {};

  my @all_files = ();
  foreach my $node ( $config->{nodes}->list ) {
    $stats->{total_nodes}++;
    push @all_files, @{ $node->files->as_hashref };
  }

  $stats->{total_files} = scalar @all_files;
  $stats->{total_bytes} += $_->{size} foreach @all_files;

  $stats->{$_} = format_bytes( $stats->{$_} )
    foreach (qw/total_files total_bytes/);

  # sort for presentation
  # newest at the top
  @all_files = sort { $b->{mtime} <=> $a->{mtime} } @all_files;

  $self->render(
    json => {
      result => 'ok',
      files  => \@all_files,
      stats  => $stats
    }
  );

}
sub file_get_by_uuid {

 my $self   = shift;
  my $config = $self->config;
  my $stats  = {};
  my @user_files = ();
  my @all_files = ();
  foreach my $node ( $config->{nodes}->list ) {
    $stats->{total_nodes}++;
    push @all_files, @{ $node->files->as_hashref };
  }




  $stats->{total_files} = 0;
  #scalar @all_files;

  foreach(@all_files){

  next unless $config->{nodes}->self->uuid =~ $_->{uuid};
  $stats->{total_files}++;
  $stats->{total_bytes} += $_->{size};
  push @user_files ,$_ ;
  }
  $stats->{$_} = format_bytes( $stats->{$_} )
  foreach (qw/total_files total_bytes/);

  # sort for presentation
  # newest at the top
  @all_files = sort { $b->{mtime} <=> $a->{mtime} } @user_files;


  p $config;

  $self->render(
    json => {
      result => 'ok',
      files  => \@all_files,
      stats  => $stats
    }
  );

}
1;

__DATA__