File Coverage

blib/lib/Net/Async/WebSearch/Provider/Serper.pm

Criterion	Covered	Total	%
statement	24	54	44.4
branch	0	20	0.0
condition	0	11	0.0
subroutine	8	13	61.5
pod	3	3	100.0
total	35	101	34.6

package Net::Async::WebSearch::Provider::Serper;
our $VERSION = '0.002';
# ABSTRACT: Serper.dev Google Search API provider
use strict;
use warnings;
use parent 'Net::Async::WebSearch::Provider';

use Carp qw( croak );
use Future;
use JSON::MaybeXS qw( encode_json decode_json );
use HTTP::Request ();
use Net::Async::WebSearch::Result;

sub _init {
  my ( $self ) = @_;
  croak "Serper provider requires 'api_key'" unless $self->{api_key};
  $self->{endpoint} ||= 'https://google.serper.dev/search';
  $self->{name}     ||= 'serper';
}

sub endpoint { $_[0]->{endpoint} }
sub api_key  { $_[0]->{api_key} }

sub search {
  my ( $self, $http, $query, $opts ) = @_;
  $opts ||= {};
  my $limit = $opts->{limit} || 10;

  my %body = ( q => $query, num => $limit );
  $body{gl}  = $opts->{region}   if defined $opts->{region};
  $body{hl}  = $opts->{language} if defined $opts->{language};
  $body{tbs} = $opts->{tbs}      if defined $opts->{tbs};

  my $req = HTTP::Request->new(
    POST => $self->endpoint,
    [
      'X-API-KEY'     => $self->api_key,
      'Content-Type'  => 'application/json',
      'Accept'        => 'application/json',
      'User-Agent'    => $self->user_agent_string,
    ],
    encode_json(\%body),
  );

  return $http->do_request( request => $req )->then(sub {
    my ( $resp ) = @_;
    unless ( $resp->is_success ) {
      return Future->fail(
        $self->name.": HTTP ".$resp->status_line, 'websearch', $self->name,
      );
    }
    my $data = eval { decode_json( $resp->decoded_content ) };
    if ( my $e = $@ ) {
      return Future->fail( $self->name.": invalid JSON: $e", 'websearch', $self->name );
    }
    my @out;
    my $rank = 0;
    for my $r ( @{ $data->{organic} || [] } ) {
      $rank++;
      push @out, Net::Async::WebSearch::Result->new(
        url          => $r->{link},
        title        => $r->{title},
        snippet      => $r->{snippet},
        provider     => $self->name,
        rank         => $r->{position} // $rank,
        published_at => $r->{date},
        raw          => $r,
        extra        => {
          ( defined $r->{sitelinks} ? ( sitelinks => $r->{sitelinks} ) : () ),
          ( defined $r->{imageUrl}  ? ( imageUrl  => $r->{imageUrl} )  : () ),
        },
      );
      last if $rank >= $limit;
    }
    return Future->done(\@out);
  });
}

1;

__END__