view release on metacpan or  search on metacpan

lib/App/Standby/Service.pm  view on Meta::CPAN

package App::Standby::Service;
$App::Standby::Service::VERSION = '0.04';
BEGIN {
  $App::Standby::Service::AUTHORITY = 'cpan:TEX';
}
# ABSTRACT: Service Plugin baseclass

use 5.010_000;
use mro 'c3';
use feature ':5.10';

use Moose;
use namespace::autoclean;

# use IO::Handle;
# use autodie;
# use MooseX::Params::Validate;
# use Carp;
# use English qw( -no_match_vars );
# use Try::Tiny;

# extends ...
extends 'App::Standby';
# has ...
has 'name' => (
    'is'    => 'ro',
    'isa'   => 'Str',
    'required' => 1,
);

has 'description' => (
    'is'        => 'rw',
    'isa'       => 'Str',
    'required'  => 0,
);

has 'group_id' => (
    'is'    => 'ro',
    'isa'   => 'Int',
    'required' => 1,
);
# with ...
# initializers ...

# your code here ...
sub update {
    my $self = shift;
    my $user_ref = shift;

    # this base class does nothing here
    # subclasses should override this method
    # and update their services here ...
    my $new_user_ref = $self->_inject_per_user_config($user_ref);

    return $self->_update($new_user_ref);
}

sub _update {
    my $self = shift;
    my $user_ref = shift;
    # this base class does nothing here
    # subclasses should override this method
    # and update their services here ...
    return;
}

sub _inject_per_user_config {
    my $self = shift;
    my $user_ref = shift;

    my $sql = 'SELECT id,key,value FROM config_contacts WHERE contact_id = ?';
    my $sth = $self->dbh()->prepare($sql);
    if(!$sth) {
        $self->logger()->log( message => 'Failed to prepare SQL '.$sql.' w/ error: '.$self->dbh()->errstr, level => 'error', );
        return;
    }

    my @new_users = ();

    foreach my $user (@{$user_ref}) {
        if(!$sth->execute($user->{'id'})) {
            $self->logger()->log( message => 'Failed to execute stmt w/ error: '.$sth->errstr, level => 'error', );
        }

        # copy existing values
        my $new_user = {};
        foreach my $key (keys %{$user}) {
            $new_user->{$key} = $user->{$key};
        }
        # add new values
        while(my ($cconfig_id,$cconfig_key,$cconfig_value) = $sth->fetchrow_array()) {
            my $service_name = $self->name();
            # only use config items for this service
            next unless $cconfig_key =~ m/^${service_name}_/;
            # strip leading serice name prefix
            $cconfig_key =~ s/^${service_name}_//i;
            if($new_user->{$cconfig_key}) {
                $self->logger()->log( message => 'Per-user config item '.$cconfig_key.' collides w/ existing value. Overwriting global item with per-user item', level => 'warning', );
            }
            $new_user->{$cconfig_key} = $cconfig_value;
        }

        push(@new_users,$new_user);
    }

    $sth->finish();