simple DSPAM search

diff --git a/lib/APKPM/DSLAM.pm b/lib/APKPM/DSLAM.pm
new file mode 100644 (file)
index 0000000..2e9c3cb
--- /dev/null
+++ b/lib/APKPM/DSLAM.pm
@@ -0,0 +1,56 @@
+package APKPM::DSLAM;
+
+use base qw(Gearman::Driver::Worker);
+use Moose;
+use Time::HiRes;
+use Data::Dump qw(dump);
+
+with 'APKPM::Config';
+with 'APKPM::Gearman';
+
+require RPC::XML;
+require RPC::XML::Client;
+use Encode;
+
+#$RPC::XML::ENCODING = "utf-8"; # FIXME really used?
+
+sub prefix { 'DSLAM_' }
+
+sub process_name {
+       my ( $self, $orig, $job_name ) = @_;
+       warn "# process_name $orig $job_name\n";
+       return "$orig ($job_name)";
+}
+
+sub begin {
+       my ( $self, $job, $workload ) = @_;
+       warn "# begin ", dump( $workload );
+}
+
+sub search : Job : Encode(e_json_encode) {
+       my ( $self, $job, $workload ) = @_;
+       warn "# search ",dump($workload);
+
+       my ($field,$value);
+
+       if ( $workload =~ m/[:=]/ ) {
+               ($field,$value) = split(/[:=]/,$workload,2)
+       } else {
+               return { error => 'invalid workload', expected => 'OPT_82:%' };
+       }
+
+       my $cli = RPC::XML::Client->new($self->config('crmxml'));
+       warn "RPC::XML $field $value";
+       my $resp = $cli->send_request('ports',RPC::XML::array->new( $field => $value ));
+       return ref $resp ? $resp->value->[0] : { error => $resp };
+}
+
+sub e_json_encode {
+       my ($self,$data) = @_;
+       my $json = $self->e_json($data);
+       $json = Encode::decode('utf-8', $json);
+       Encode::from_to($json,'cp1250', 'utf-8');
+       return $json;
+}
+
+1;

diff --git a/t/DSLAM.t b/t/DSLAM.t
new file mode 100755 (executable)
index 0000000..2048779
--- /dev/null
+++ b/t/DSLAM.t
@@ -0,0 +1,15 @@
+#!/usr/bin/perl
+use strict;
+use warnings;
+
+use Test::More tests => 3;
+use Data::Dump qw(dump);
+
+use lib 'lib';
+
+use_ok 'APKPM::DSLAM';
+
+ok my $o = APKPM::DSLAM->new, 'new';
+
+ok my $r = $o->search( 'job' => shift @ARGV || 'OPT_82:%' ), 'search';
+diag dump($r);