File Coverage

blib/lib/Sphinx/Log/Parser.pm

Criterion	Covered	Total	%
statement	48	55	87.2
branch	9	16	56.2
condition			n/a
subroutine	9	9	100.0
pod	0	2	0.0
total	66	82	80.4

package Sphinx::Log::Parser;

BEGIN {
    $Sphinx::Log::Parser::VERSION = '0.03';
}

use strict;
use warnings;

# ABSTRACT: parse Sphinx searchd log

use Carp;
use IO::File;
use IO::Handle;

sub new {
    my ( $class, $file ) = @_;

    my %data;
    if ( UNIVERSAL::isa( $file, 'IO::Handle' ) ) {
        $data{file} = $file;
    }
    elsif ( UNIVERSAL::isa( $file, 'File::Tail' ) ) {
        $data{file}     = $file;
        $data{filetail} = 1;
    }
    elsif ( !ref $file ) {
        if ( $file eq '-' ) {
            my $io = new IO::Handle;
            $data{file} = $io->fdopen( fileno(STDIN), "r" );
        }
        else {
            $data{file} = new IO::File( $file, "<" );
            defined $data{file} or croak "can't open $file: $!";
        }
    }
    else {
        croak
"argument must be either a file-name or an IO::Handle/File::Tail object.";
    }

    return bless \%data, $class;
}

sub _next_line {
    my $self = shift;
    my $f    = $self->{file};
    if ( defined $self->{filetail} ) {
        return $f->read;
    }
    else {
        return $f->getline;
    }
}

sub next {
    my ($self) = @_;

    while ( defined( my $str = $self->_next_line ) ) {

# 0.9.9
# [query-date] query-time multiquery-factor [match-mode/filters-count/sort-mode total-matches (offset,limit) @groupby-attr]  [index-name] [performances-counters] [query-comment] query
# optionals: multiquery-factor, @groupby-attr, performances-counters, query-comment

        # '[Mon Sep 20 06:25:29.979 2010] '
        # '0.005 sec x20 '
        # '[ext/3/ext 163 (0,100) @perf_id] '
        # '[index1 index2] '
        # '[ios=5 kb=45.6 ioms=65.57 cpums=2.5] '
        # '[query comment] '
        # '@author  (Days Gracie) '

        $str =~ /^
                 \[(\w{3}\s+\w{3}\s+\d{1,2}\s+\d{2}:\d{2}:\d{2}\.\d{3}\s+\d{4})\]\s+
                 ([\d\.]+)\s+sec\s+(x[\d]+)?\s?
                 \[(\w+)\/(\d+)\/([\w\-\+]+)\s(\d+)\s\((\d+)\,(\d+)\)\s*\@?(\S+)?\]\s+
                 \[([\w\s\;]+)\]\s+
                 (\[ios\=[\d\.]+\s+kb\=[\d\.]+\s+ioms\=[\d\.]+[\s+cpums\=[\d\.]+]?\])?\s?
                 (\[.*\])?\s?
                 (.*)
                $/x;

        my $query_date            = $1;
        my $query_time            = $2;
        my $multiquery_factor     = $3;
        my $match_mode            = $4;
        my $filter_count          = $5;
        my $sort_mode             = $6;
        my $total_matches         = $7;
        my $offset                = $8;
        my $limit                 = $9;
        my $groupby_attr          = $10;
        my $index_name            = $11;
        my $performances_counters = $12;
        my $query_comment         = $13;
        my $query                 = $14;

        $performances_counters =~ s/\[(.*)\]/$1/ if $performances_counters;
        $query_comment         =~ s/\[(.*)\]/$1/ if $query_comment;

        return {
            query_date            => $query_date,
            multiquery_factor     => $multiquery_factor,
            query_time            => $query_time,
            match_mode            => $match_mode,
            filter_count          => $filter_count,
            sort_mode             => $sort_mode,
            total_matches         => $total_matches,
            offset                => $offset,
            limit                 => $limit,
            groupby_attr          => $groupby_attr,
            index_name            => $index_name,
            performances_counters => $performances_counters,
            query_comment         => $query_comment,
            query                 => $query
        };
    }
    return;
}

1;

__END__