#!/usr/bin/perl

use strict;
use lib "$ENV{HOME}/hack/Data-ObjectDriver/lib";
use lib "$ENV{HOME}/hack/TheSchwartz/lib";
use lib "$ENV{HOME}/hack/gearman/api/perl/Gearman/lib";
use lib "$ENV{HOME}/cvs/Data-ObjectDriver/lib";
use lib "$ENV{HOME}/cvs/TheSchwartz/lib";
use lib "$ENV{HOME}/cvs/gearman/api/perl/Gearman/lib";

use Gearman::Worker;
use TheSchwartz;
use JSON::Any;

my $j = JSON::Any->new;

my $ts = TheSchwartz->new(
    databases => [
        {   dsn  => "dbi:mysql:database=t_sch_unnamed",
            user => "root",
            pass => "",
        }
    ]
);

# FIXME: use embedded gearman server, and workers be child processes

my $worker = Gearman::Worker->new;
$worker->job_servers('127.0.0.1:7003');

$worker->register_function( "insert_job" => handler( \&insert_job ) );
$worker->work while 1;

############################################################################

sub handler {
    my ($code) = @_;
    return sub {
        my $job  = shift;
        my $arg  = $job->arg;
        my $jreq = eval { $j->jsonToObj( $job->arg ) };
        unless ($jreq) {
            die "not a valid JSON request";
        }
        return $code->( $job, $jreq );
    };
}

sub insert_job {
    my ( $job, $json ) = @_;
    my $funcname = $json->{funcname} or die "No funcname";
    my $job = TheSchwartz::Job->new(
        funcname => $json->{funcname},
        arg      => $json->{arg},
        uniqkey  => $json->{uniqkey},
        coalesce => $json->{coalesce},
    );
    my $h = $ts->insert($job)
        or die "insert_failure\n";
    return $h->as_string;
}