You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
ngcp-panel/lib/NGCP/Panel/Controller/Sound.pm

701 lines
26 KiB

package NGCP::Panel::Controller::Sound;
use Sipwise::Base;
BEGIN { extends 'Catalyst::Controller'; }
use NGCP::Panel::Form::Sound::AdminSet;
use NGCP::Panel::Form::Sound::ResellerSet;
use NGCP::Panel::Form::Sound::CustomerSet;
use NGCP::Panel::Form::Sound::File;
use File::Type;
use NGCP::Panel::Utils::XMLDispatcher;
use NGCP::Panel::Utils::Sounds;
use NGCP::Panel::Utils::Navigation;
use NGCP::Panel::Utils::Sems;
sub auto :Private {
my ($self, $c) = @_;
$c->log->debug(__PACKAGE__ . '::auto');
NGCP::Panel::Utils::Navigation::check_redirect_chain(c => $c);
# only allow access to admin/reseller if cloudpbx is not enabled
if(!$c->config->{features}->{cloudpbx} &&
$c->user->roles ne "admin" &&
$c->user->roles ne "reseller") {
$c->detach('/denied_page');
}
# even for pbx, it's only for admin/reseller/subscriberadmins
if($c->user->roles eq "subscriber") {
$c->detach('/denied_page');
}
# and then again, it's only for subscriberadmins with pbxaccount product
if($c->user->roles eq "subscriberadmin") {
my $contract_id = $c->user->account_id;
my $contract_select_rs = NGCP::Panel::Utils::Contract::get_contract_rs(
schema => $c->model('DB'));
$contract_select_rs = $contract_select_rs->search({ 'me.id' => $contract_id });
my $product_id = $contract_select_rs->first->get_column('product_id');
unless($product_id) {
NGCP::Panel::Utils::Message->error(
c => $c,
error => "No product for customer contract id $contract_id found",
desc => "No product for this customer contract found.",
);
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
my $product = $c->model('DB')->resultset('products')->find({
id => $product_id, class => 'pbxaccount'
});
unless($product) {
$c->detach('/denied_page');
}
$c->stash->{contract_rs} = $contract_select_rs;
}
return 1;
}
sub sets_list :Chained('/') :PathPart('sound') :CaptureArgs(0) {
my ( $self, $c ) = @_;
if($c->stash->{contract_rs}) {
NGCP::Panel::Utils::Sounds::stash_soundset_list(
c => $c,
contract => $c->stash->{contract_rs}->first
);
} else {
NGCP::Panel::Utils::Sounds::stash_soundset_list(c => $c);
}
$c->stash(template => 'sound/list.tt');
}
sub contract_sets_list :Chained('/') :PathPart('sound/contract') :CaptureArgs(1) {
my ( $self, $c, $contract_id ) = @_;
unless($contract_id && $contract_id->is_int) {
NGCP::Panel::Utils::Message->error(
c => $c,
error => "Invalid contract id $contract_id found",
desc => "Invalid contract id found",
);
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
if($c->user->roles eq "subscriberadmin" && $c->user->account_id != $contract_id) {
NGCP::Panel::Utils::Message->error(
c => $c,
error => "access violatio, subscriberadmin ".$c->user->uuid." with contract id ".$c->user->account_id." tries to access foreign contract id $contract_id",
desc => "Invalid contract id found",
);
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
my $contract = $c->model('DB')->resultset('contracts')->find($contract_id);
unless($contract) {
NGCP::Panel::Utils::Message->error(
c => $c,
error => "Contract id $contract_id not found",
desc => "Invalid contract id detected",
);
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
NGCP::Panel::Utils::Sounds::stash_soundset_list(
c => $c,
contract => $contract,
);
$c->stash(template => 'sound/list.tt');
}
sub root :Chained('sets_list') :PathPart('') :Args(0) {
my ($self, $c) = @_;
}
sub ajax :Chained('sets_list') :PathPart('ajax') :Args(0) {
my ($self, $c) = @_;
my $resultset = $c->stash->{sets_rs};
NGCP::Panel::Utils::Datatables::process($c, $resultset, $c->stash->{soundset_dt_columns});
$c->detach( $c->view("JSON") );
}
sub contract_ajax :Chained('contract_sets_list') :PathPart('ajax') :Args(0) {
my ($self, $c) = @_;
my $resultset = $c->stash->{sets_rs};
NGCP::Panel::Utils::Datatables::process($c, $resultset, $c->stash->{soundset_dt_columns});
$c->detach( $c->view("JSON") );
}
sub base :Chained('sets_list') :PathPart('') :CaptureArgs(1) {
my ($self, $c, $set_id) = @_;
unless($set_id && $set_id->is_integer) {
$c->flash(messages => [{type => 'error', text => 'Invalid sound set id detected'}]);
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
my $res = $c->stash->{sets_rs}->find($set_id);
unless(defined($res)) {
$c->flash(messages => [{type => 'error', text => 'Sound set does not exist'}]);
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
$c->stash(set_result => $res);
}
sub edit :Chained('base') :PathPart('edit') {
my ($self, $c) = @_;
my $posted = ($c->request->method eq 'POST');
my $form;
my $params = { $c->stash->{set_result}->get_inflated_columns };
$params->{reseller}{id} = delete $params->{reseller_id};
$params->{contract}{id} = delete $params->{contract_id};
$params = $params->merge($c->session->{created_objects});
if($c->user->roles eq "admin") {
$form = NGCP::Panel::Form::Sound::AdminSet->new;
} elsif($c->user->roles eq "reseller") {
$form = NGCP::Panel::Form::Sound::ResellerSet->new;
} else {
$form = NGCP::Panel::Form::Sound::CustomerSet->new;
}
$form->process(
posted => $posted,
params => $c->request->params,
item => $params,
);
NGCP::Panel::Utils::Navigation::check_form_buttons(
c => $c,
form => $form,
fields => {
'reseller.create' => $c->uri_for('/reseller/create'),
},
back_uri => $c->req->uri,
);
if($posted && $form->validated) {
try {
if($c->user->roles eq "admin") {
$form->values->{reseller_id} = $form->values->{reseller}{id};
$form->values->{contract_id} = $form->values->{contract}{id} // undef;
if(defined $form->values->{contract_id}) {
$form->values->{contract_default} //= 0;
} else {
$form->values->{contract_default} = 0;
}
} elsif($c->user->roles eq "reseller") {
if(defined $c->stash->{set_result}->contract_id) {
$form->values->{contract_default} //= 0;
} else {
$form->values->{contract_default} = 0;
}
} else {
$form->values->{contract_default} //= 0;
}
delete $form->values->{reseller};
delete $form->values->{contract};
$c->model('DB')->txn_do(sub {
# if contract default is set, clear old ones first
if($c->stash->{set_result}->contract_id && $form->values->{contract_default} == 1) {
$c->stash->{sets_rs}->search({
reseller_id => $c->stash->{set_result}->reseller_id,
contract_id => $c->stash->{set_result}->contract_id,
contract_default => 1,
})->update_all({ contract_default => 0 });
}
my $old_contract_default = $c->stash->{set_result}->contract_default;
$c->stash->{set_result}->update($form->values);
if($c->stash->{set_result}->contract &&
$c->stash->{set_result}->contract_default == 1 && $old_contract_default != 1) {
# go over each subscriber in the contract and set the contract_sound_set
# preference if it doesn't have one set yet
my $contract = $c->stash->{set_result}->contract;
foreach my $bill_subscriber($contract->voip_subscribers->all) {
my $prov_subscriber = $bill_subscriber->provisioning_voip_subscriber;
if($prov_subscriber) {
my $pref_rs = NGCP::Panel::Utils::Preferences::get_usr_preference_rs(
c => $c, prov_subscriber => $prov_subscriber, attribute => 'contract_sound_set',
);
unless($pref_rs->first) {
$pref_rs->create({ value => $c->stash->{set_result}->id });
}
}
}
}
});
delete $c->session->{created_objects}->{reseller};
delete $c->session->{created_objects}->{contract};
$c->flash(messages => [{type => 'success', text => 'Sound set successfully updated'}]);
} catch($e) {
$c->log->error("failed to update sound set: $e");
$c->flash(messages => [{type => 'error', text => 'Sound set successfully updated'}]);
};
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
$c->stash(
form => $form,
edit_flag => 1,
);
}
sub delete :Chained('base') :PathPart('delete') {
my ($self, $c) = @_;
try {
my $schema = $c->model('DB');
$schema->txn_do(sub {
# remove all usr_preferenes where this set is assigned
my $pref_rs = NGCP::Panel::Utils::Preferences::get_usr_preference_rs(
c => $c, attribute => 'contract_sound_set',
);
$pref_rs->search({ value => $c->stash->{set_result}->id })
->delete_all;
# TODO: what about normal sound_sets for usr/dom/peer?
$c->stash->{set_result}->delete;
});
$c->flash(messages => [{type => 'success', text => 'Sound set successfully deleted'}]);
} catch($e) {
$c->log->error("failed to delete sound set: $e");
$c->flash(messages => [{type => 'error', text => 'Delete failed.'}]);
};
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
sub create :Chained('sets_list') :PathPart('create') :Args() {
my ($self, $c, $contract_id) = @_;
my $posted = ($c->request->method eq 'POST');
my $form;
my $params = {};
$params = $params->merge($c->session->{created_objects});
if($c->user->roles eq "admin") {
$form = NGCP::Panel::Form::Sound::AdminSet->new;
if($contract_id) {
my $contract = $c->model('DB')->resultset('contracts')->find($contract_id);
if($contract) {
$params->{contract}{id} = $contract->id;
$params->{reseller}{id} = $contract->contact->reseller_id;
}
}
} elsif($c->user->roles eq "reseller") {
$form = NGCP::Panel::Form::Sound::ResellerSet->new;
if($contract_id) {
my $contract = $c->model('DB')->resultset('contracts')->find($contract_id);
if($contract && $contract->contact->reseller_id == $c->user->reseller_id) {
$params->{contract}{id} = $contract->id;
}
}
} else {
$form = NGCP::Panel::Form::Sound::CustomerSet->new;
}
$form->process(
posted => $posted,
params => $c->request->params,
item => $params,
);
NGCP::Panel::Utils::Navigation::check_form_buttons(
c => $c,
form => $form,
fields => {
'reseller.create' => $c->uri_for('/reseller/create'),
'contract.create' => $c->uri_for_action('/customer/create'),
},
back_uri => $c->req->uri,
);
if($posted && $form->validated) {
try {
if($c->user->roles eq "admin") {
$form->values->{reseller_id} = $form->values->{reseller}{id};
$form->values->{contract_id} = $form->values->{contract}{id} // undef;
if(defined $form->values->{contract_id}) {
$form->values->{contract_default} //= 0;
} else {
$form->values->{contract_default} = 0;
}
} elsif($c->user->roles eq "reseller") {
$form->values->{reseller_id} = $c->user->reseller_id;
$form->values->{contract_id} = $form->values->{contract}{id} // undef;
if(defined $form->values->{contract_id}) {
$form->values->{contract_default} //= 0;
} else {
$form->values->{contract_default} = 0;
}
} else {
$form->values->{reseller_id} = $c->user->contract->contact->reseller_id;
$form->values->{contract_id} = $c->user->account_id;
$form->values->{contract_default} //= 0;
}
delete $form->values->{reseller};
delete $form->values->{contract};
my $schema = $c->model('DB');
$schema->txn_do(sub {
# if a new contract default is set, clear old ones first
if($form->values->{contract_id} && $form->values->{contract_default} == 1) {
$c->stash->{sets_rs}->search({
reseller_id => $form->values->{reseller_id},
contract_id => $form->values->{contract_id},
contract_default => 1,
})->update_all({ contract_default => 0 });
}
my $set = $c->stash->{sets_rs}->create($form->values);
if($set->contract && $set->contract_default == 1) {
# go over each subscriber in the contract and set the contract_sound_set
# preference if it doesn't have one set yet
my $contract = $set->contract;
foreach my $bill_subscriber($contract->voip_subscribers->all) {
my $prov_subscriber = $bill_subscriber->provisioning_voip_subscriber;
if($prov_subscriber) {
my $pref_rs = NGCP::Panel::Utils::Preferences::get_usr_preference_rs(
c => $c, prov_subscriber => $prov_subscriber, attribute => 'contract_sound_set',
);
unless($pref_rs->first) {
$pref_rs->create({ value => $set->id });
}
}
}
}
});
delete $c->session->{created_objects}->{reseller};
$c->flash(messages => [{type => 'success', text => 'Sound set successfully created'}]);
} catch($e) {
$c->log->error("failed to create sound set: $e");
$c->flash(messages => [{type => 'error', text => 'Failed to create sound set'}]);
}
NGCP::Panel::Utils::Navigation::back_or($c, $c->uri_for('/sound'));
}
$c->stash(
form => $form,
create_flag => 1,
);
}
sub handles_list :Chained('base') :PathPart('handles') :CaptureArgs(0) {
my ( $self, $c ) = @_;
my $files_rs = $c->stash->{set_result}->voip_sound_files;
$c->stash(files_rs => $files_rs);
$c->stash(handles_base_uri =>
$c->uri_for_action("/sound/handles_root", [$c->req->captures->[0]]));
my $handles_rs = $c->model('DB')->resultset('voip_sound_groups')
->search({
},{
select => ['groups.name', \'handles.name', \'handles.id', 'files.filename', 'files.loopplay', 'files.codec'],
as => [ 'groupname', 'handlename', 'handleid', 'filename', 'loopplay', 'codec'],
alias => 'groups',
from => [
{ groups => 'provisioning.voip_sound_groups' },
[
{ handles => 'provisioning.voip_sound_handles', -join_type=>'left'},
{ 'groups.id' => 'handles.group_id'},
],
[
{ files => 'provisioning.voip_sound_files', -join_type => 'left'},
{ 'handles.id' => { '=' => \'files.handle_id'}, 'files.set_id' => $c->stash->{set_result}->id},
],
],
});
if($c->stash->{set_result}->contract_id) {
$handles_rs = $handles_rs->search({ 'groups.name' => { '-in' => ['pbx', 'music_on_hold'] } });
} else {
$handles_rs = $handles_rs->search({ 'groups.name' => { '!=' => 'pbx' } });
}
unless($c->config->{features}->{cloudpbx}) {
$handles_rs = $handles_rs->search({ 'groups.name' => { '!=' => 'pbx' } });
}
unless($c->config->{features}->{musiconhold}) {
$handles_rs = $handles_rs->search({ 'groups.name' => { '!=' => 'music_on_hold' } });
}
unless($c->config->{features}->{callingcard}) {
$handles_rs = $handles_rs->search({ 'groups.name' => { '!=' => 'calling_card' } });
}
unless($c->config->{features}->{mobilepush}) {
$handles_rs = $handles_rs->search({ 'groups.name' => { '!=' => 'mobile_push' } });
}
my @rows = $handles_rs->all;
my %groups;
for my $handle (@rows) {
$groups{ $handle->get_column('groupname') } = []
unless exists $groups{ $handle->get_column('groupname') };
push $groups{ $handle->get_column('groupname') }, $handle;
}
$c->stash(sound_groups => \%groups);
$c->stash(handles_rs => $handles_rs);
$c->stash(has_edit => 1);
$c->stash(has_delete => 1);
$c->stash(template => 'sound/handles_list.tt');
}
sub handles_root :Chained('handles_list') :PathPart('') :Args(0) {
my ($self, $c) = @_;
}
sub handles_base :Chained('handles_list') :PathPart('') :CaptureArgs(1) {
my ($self, $c, $handle_id) = @_;
unless($handle_id && $handle_id->is_integer) {
$c->flash(messages => [{type => 'error', text => 'Invalid sound handle id detected'}]);
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
my @tmph = $c->stash->{handles_rs}->all;
unless($c->stash->{handles_rs}->find({ 'handles.id' => $handle_id })) {
$c->flash(messages => [{type => 'error', text => 'Sound handle id does not exist'}]);
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
my $res = $c->stash->{files_rs}->find_or_create(handle_id => $handle_id);
unless(defined $res ) {
$c->flash(messages => [{type => 'error', text => 'Sound handle not found'}]);
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
$c->stash(file_result => $res);
}
sub handles_edit :Chained('handles_base') :PathPart('edit') {
my ($self, $c) = @_;
my $posted = ($c->request->method eq 'POST');
my $upload = $c->req->upload('soundfile');
my %params = (
%{ $c->request->params },
soundfile => $posted ? $upload : undef,
);
my $file_result = $c->stash->{file_result};
my $form = NGCP::Panel::Form::Sound::File->new;
$form->process(
posted => $posted,
params => \%params,
item => $file_result,
);
NGCP::Panel::Utils::Navigation::check_form_buttons(
c => $c,
form => $form,
fields => {},
back_uri => $c->req->uri,
);
if($posted && $form->validated) {
if (defined $upload) {
my $soundfile = eval { $upload->slurp };
my $filename = eval { $upload->filename };
my $ft = File::Type->new();
unless ($ft->checktype_contents($soundfile) eq 'audio/x-wav') {
$c->flash(messages => [{type => 'error', text => 'Invalid file type detected, only WAV supported'}]);
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
my $target_codec = 'WAV';
if($file_result->handle->group->name eq 'calling_card') {
try {
NGCP::Panel::Utils::Sems::clear_audio_cache("appserver", $file_result->set_id, $file_result->handle->name);
if($c->config->{features}->{cloudpbx}) {
NGCP::Panel::Utils::Sems::clear_audio_cache("pbx", $file_result->set_id, $file_result->handle->name);
}
} catch ($e) {
$c->flash(messages => [{type => 'error', text => 'Failed to clear audio cache'}]);
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
}
if ($file_result->handle->name eq 'music_on_hold' && !$file_result->set->contract_id) {
$target_codec = 'PCMA';
$filename =~ s/\.[^.]+$/.pcma/;
}
try {
$soundfile = NGCP::Panel::Utils::Sounds::transcode_file(
$upload->tempname, 'WAV', $target_codec);
} catch ($e) {
$c->flash(messages => [{type => 'error', text => 'Transcoding audio file failed'}]);
$c->log->error("failed to transcode audio file: $e");
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
try {
$file_result->update({
loopplay => $form->values->{loopplay},
filename => $filename,
data => $soundfile,
codec => $target_codec,
});
$c->flash(messages => [{type => 'success', text => 'Sound handle successfully uploaded'}]);
} catch($e) {
$c->log->error("failed to update sound handle with data: $e");
$c->flash(messages => [{type => 'error', text => 'Failed to update sound handle upload'}]);
}
} else {
try {
$file_result->update({
loopplay => $form->values->{loopplay},
});
$c->flash(messages => [{type => 'success', text => 'Sound handle successfully updated'}]);
} catch($e) {
$c->log->error("failed to update sound handle: $e");
$c->flash(messages => [{type => 'error', text => 'Failed to update sound handle'}]);
}
}
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
$c->stash(form => $form);
$c->stash(edit_flag => 1);
}
sub handles_delete :Chained('handles_base') :PathPart('delete') {
my ($self, $c) = @_;
try {
$c->stash->{file_result}->delete;
$c->flash(messages => [{type => 'success', text => 'Sound handle successfully deleted'}]);
} catch($e) {
$c->log->error("failed to delete sound handle: $e");
$c->flash(messages => [{type => 'error', text => 'Failed to delete sound handle'}]);
};
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
sub handles_download :Chained('handles_base') :PathPart('download') :Args(0) {
my ($self, $c) = @_;
my $file = $c->stash->{file_result};
my $filename = $file->filename;
$filename =~ s/\.\w+$/.wav/;
my $data;
if($file->codec ne 'WAV') {
try {
$data = NGCP::Panel::Utils::Sounds::transcode_data(
$file->data, $file->codec, 'WAV');
} catch($e) {
$c->log->error("failed to transcode audio file: $e");
$c->flash(messages => [{type => 'error', text => 'Failed to transcode audio file'}]);
NGCP::Panel::Utils::Navigation::back_or($c, $c->stash->{handles_base_uri});
}
} else {
$data = $file->data;
}
$c->response->header ('Content-Disposition' => 'attachment; filename="' . $filename . '"');
$c->response->content_type('audio/x-wav');
$c->response->body($data);
}
__PACKAGE__->meta->make_immutable;
1;
=head1 NAME
NGCP::Panel::Controller::Sound - Manage Sounds
=head1 DESCRIPTION
Show/Edit/Create/Delete Sound Sets.
Show/Upload Sound Files in Sound Sets.
=head1 METHODS
=head2 auto
Grants access to admin and reseller role.
=head2 sets_list
Basis for provisioning.voip_sound_sets.
Provides sets_rs in stash.
=head2 root
Display Sound Sets through F<sound/list.tt> template.
=head2 ajax
Get provisioning.voip_sound_sets from db and output them as JSON.
The format is meant for parsing with datatables.
=head2 base
Fetch a provisioning.voip_sound_sets row from the database by its id.
The resultset is exported to stash as "set_result".
=head2 edit
Show a modal to edit the Sound Set determined by L</base> using the form
L<NGCP::Panel::Form::SoundSet>.
=head2 delete
Delete the Sound Set determined by L</base>.
=head2 create
Show modal to create a new Sound Set using the form
L<NGCP::Panel::Form::SoundSet>.
=head2 handles_list
Basis for provisioning.voip_sound_handles grouped by voip_sound_groups with
the actual data in voip_sound_files.
Stashes:
* handles_base_uri: To show L</pattern_root>
* files_rs: Resultset of voip_sound_files in the current voip_sound_group
* sound_groups: Hashref of sound_goups with handles JOIN files inside
(used in the template F<sound/handles_list.tt>)
=head2 handles_root
Display Sound Files through F<sound/handles_list.tt> template accordion
grouped by sound_groups.
=head2 handles_base
Fetch a provisioning.voip_sound_files row from the database by the id
of the according voip_sound_handle. Create a new one if it doesn't exist but
do not immediately update the db.
The ResultClass is exported to stash as "file_result".
=head2 handles_edit
Show a modal to upload a file or set/unset loopplay using the form
L<NGCP::Panel::Form::SoundFile>.
=head2 handles_delete
Delete the Sound File determined by L</base>.
=head1 AUTHOR
Gerhard Jungwirth C<< <gjungwirth@sipwise.com> >>
=head1 LICENSE
This library is free software. You can redistribute it and/or modify
it under the same terms as Perl itself.
=cut
# vim: set tabstop=4 expandtab: