view release on metacpan or  search on metacpan

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

    'required' => 1,
);

has 'name' => (
    'is'    => 'ro',
    'isa'   => 'Str',
    'required' => 1,
);
# with ...
# initializers ...
sub _init_services {
    my $self = shift;

    my %want_sv;
    my %has_sv;
    my $sql = 'SELECT id,name,class,desc FROM group_services WHERE group_id = ?';
    my $sth = $self->dbh()->prepexec($sql,$self->group_id());
    if(!$sth) {
        $self->logger()->log( message => 'Failed to get required services from DB due to SQL error: '.$self->dbh()->errstr, level => 'error', );
        return \%has_sv;
    }
    while( my ($sv_id, $sv_name, $sv_class, $sv_desc) = $sth->fetchrow_array()) {
        $want_sv{$sv_name}->{'id'} = $sv_id;
        $want_sv{$sv_name}->{'class'} = 'App::Standby::Service::'.$sv_class;
        $want_sv{$sv_name}->{'desc'} = $sv_desc;
    }
    $sth->finish();

    # try to load each requested service
    foreach my $sv_name ( sort keys %want_sv) {
        my $sv_class = $want_sv{$sv_name}->{'class'};
        my $sv_desc  = $want_sv{$sv_name}->{'desc'};
        my $load_result = $self->_load_class($sv_class);
        if($load_result ne $sv_class) {
            $self->logger()->log( message => 'Failed to load required class: '.$sv_class.' w/ error: '.$load_result, level => 'error', );
            next;
        }
        try {
            my $Service = $sv_class->new({
                'name'      => $sv_name,
                'description' => $sv_desc,
                'group_id'  => $self->group_id(),
                'dbh'       => $self->dbh(),
                'logger'    => $self->logger(),
            });
            $has_sv{$sv_name} = $Service;
            $self->logger()->log( message => "Initialized $sv_name service for ".$self->name().' ('.$self->group_id().')', level => 'debug', );
        } catch {
            $self->logger()->log( message => "Failed to init $sv_name service for ".$self->name().' ('.$self->group_id().'):'.$_, level => 'warning', );
        };
    }

    return \%has_sv;;
}

# your code here ...
sub _config_values {
    my $self = shift;
    my $key = shift;

    return $self->SUPER::_config_values($key, $self->group_id());
}

sub _update_services {
    my $self = shift;
    my $contact_ref = shift;

    my $count = 0;
    foreach my $name (sort keys %{$self->services()}) {
        my $service = $self->services()->{$name};
        $self->logger()->log( message => "Service: ".$name.' starting ...', level => 'debug', );
        try {
            if($service->update($contact_ref)) {
                $self->logger()->log( message => "Updated service ".$name, level => 'debug', );
                $count++;
            } else {
                $self->logger()->log( message => "Failed to update service ".$name, level => 'warning', );
            }
        } catch {
            $self->logger()->log( message => "Failed to update service ".$name.'. Error: '.$_, level => 'warning', );
        };
        $self->logger()->log( message => "Service: ".$name.' done.', level => 'debug', );
    }

    return $count;
}

sub set_janitor {
    my $self = shift;
    my $contact_id = shift;

    my $contact_ref = $self->get_contacts();
    # set the last janitor as the last person in the list, so the chances of being notified
    # are the least for the last janitor
    push @$contact_ref, shift @$contact_ref;
    # put the new janitor on the first place, leave everything else as it was before
    # This didn't work: my @new_users = (grep { $_->{'id'} == $contact_id } @$contact_ref, grep { $_->{'id'} != $contact_id } @$contact_ref);
    my @l1 = grep { $_->{'id'} == $contact_id } @$contact_ref;
    my @l2 = grep { $_->{'id'} != $contact_id } @$contact_ref;
    my @new_contacts = (@l1, @l2);
    #$self->logger()->log( message => "New Ordering: ".Dumper(\@new_users), level => 'debug', );

    # Example:
    # Current queue: Jim (on duty), Jon, Paul, Dave
    # Paul wants to be the new janitor
    # Push Jim to the last position:
    # Jon, Paul, Dave, Jim
    # Push Paul to the first position:
    # Paul, Jon, Dave, Jim

    if($self->_update_services($self->_set_ordering(\@new_contacts))) {
        $self->logger()->log( message => "Updated all services", level => 'debug', );
    } else {
        $self->logger()->log( message => "Failed to update all services", level => 'debug', );
    }

    return \@new_contacts;
}

sub _set_ordering {
    my $self = shift;