modify schema for new CPE stats

[APKPM.git] / lib / APKPM.pm

diff --git a/lib/APKPM.pm b/lib/APKPM.pm
index e87da68..05f5c6b 100644 (file)
--- a/lib/APKPM.pm
+++ b/lib/APKPM.pm
@@ -8,6 +8,9 @@ use Data::Dump qw(dump);
 
 our $VERSION = '0.00';
 
+with 'APKPM::Gearman';
+with 'APKPM::Gearman::Client';
+
 sub prefix { '' }
 
 sub process_name {
@@ -16,21 +19,23 @@ sub process_name {
        return "$orig ($job_name)";
 }
 
-sub poll : Job : MinProcesses(1) : MaxProcesses(5) : Encode : Decode {
+sub search : Job : Encode(e_json) : MinProcesses(0) {
        my ( $self, $job, $workload ) = @_;
-       warn "# poll $job ", dump($workload);
-}
-
-sub encode {
-       my ( $self, $result ) = @_;
-       warn "# encode ",dump $result;
-       return JSON::XS::encode_json($result);
+       warn "# search $job ", dump($workload);
+
+       my $res = { workload => $workload };
+
+       my $taskset = $self->gc->new_task_set;
+       $taskset->add_task('LDAP_search', $workload, {
+               on_complete => sub { $res->{ldap} = $self->d_json( ${$_[0]} ) }
+       });
+       $taskset->add_task('CRM_search', $workload, {
+               on_complete => sub { $res->{crm} = $self->d_json( ${$_[0]} ) }
+       });
+       warn "# wait";
+       $taskset->wait;
+       return $res;
 }
 
-sub decode {
-       my ( $self, $workload ) = @_;
-       warn "# decode ", dump $workload;
-       return JSON::XS::decode_json($workload);
-}
 
 1;