File Coverage

blib/lib/Net/MQTT/TopicStore.pm

Criterion	Covered	Total	%
statement	34	36	94.4
branch	8	10	80.0
condition			n/a
subroutine	6	7	85.7
pod	4	4	100.0
total	52	57	91.2

use strict;
use warnings;
package Net::MQTT::TopicStore;
$Net::MQTT::TopicStore::VERSION = '1.163170';
# ABSTRACT: Perl module to represent MQTT topic store


sub new {
  my $pkg = shift;
  my $self = bless { topics => { } }, $pkg;
  $self->add($_) foreach (@_);
  $self
}


sub add {
  my ($self, $topic_pattern) = @_;
  unless (exists $self->{topics}->{$topic_pattern}) {
    $self->{topics}->{$topic_pattern} = _topic_to_regexp($topic_pattern);
  }
  $topic_pattern
}


sub delete {
  my ($self, $topic) = @_;
  delete $self->{topics}->{$topic};
}


sub values {
  my ($self, $topic) = @_;
  my @res = ();
  foreach my $t (keys %{$self->{topics}}) {
    my $re = $self->{topics}->{$t};
    next unless (defined $re ? $topic =~ $re : $topic eq $t);
    push @res, $t;
  }
  return \@res;
}

sub _topic_to_regexp {
  my $topic = shift;
  my $c;
  $topic = quotemeta $topic;
  $c += ($topic =~ s!\\/\\\+!\\/[^/]*!g);
  $c += ($topic =~ s!\\/\\#$!(?:\$|/.*)!);
  $c += ($topic =~ s!^\\\+\\/![^/]*\\/!g);
  $c += ($topic =~ s!^\\\+$![^/]*!g);
  $c += ($topic =~ s!^\\#$!.*!);
  $topic .= '$' unless ($topic =~ m!\$$!);
  unless ($c) {
    return;
  }
  qr/^$topic/
}

1;

__END__