TT#132650 run provisioningtemplate from api

provisioning templates with their dynamic forms
can be executed by a entityitem POST request, ie.

POST /api/provicioningtemplates/<reseller>/<template>

or

POST /api/provisioningtemplates/<readonly template>

Change-Id: I77f6c9d42e1afdb49635d3f11e4d73bcf6269605
mr10.2
Rene Krenn 4 years ago
parent b199ad3e1e
commit 4c47920f2e

@ -20,6 +20,15 @@ sub api_description {
return 'Manage "provisioning templates" for creating subscribers with batch provisioning.';
};
sub order_by_cols {
my ($self, $c) = @_;
my $cols = {
'name' => 'name',
'lang' => 'lang',
};
return $cols;
}
sub query_params {
return [
{

@ -11,6 +11,8 @@ require Catalyst::ActionRole::ACL;
require NGCP::Panel::Role::HTTPMethods;
require Catalyst::ActionRole::RequireSSL;
use Scalar::Util qw/blessed/;
use NGCP::Panel::Utils::ProvisioningTemplates qw();
use NGCP::Panel::Role::API::Subscribers qw();
sub allowed_methods{
return [qw/GET OPTIONS HEAD PATCH PUT DELETE/];
@ -100,6 +102,15 @@ __PACKAGE__->set_config({
AllowedRole => [qw/admin reseller ccareadmin ccare/],
Does => [qw(ACL RequireSSL)]
},
item_post => {
Chained => 'item_base',
PathPart => '',
Args => 0,
Method => 'POST',
ACLDetachTo => '/api/root/invalid_user',
AllowedRole => [qw/admin reseller ccareadmin ccare/],
Does => [qw(ACL RequireSSL)]
},
item_get_reseller => {
Chained => 'item_base',
@ -155,6 +166,15 @@ __PACKAGE__->set_config({
AllowedRole => [qw/admin reseller ccareadmin ccare/],
Does => [qw(ACL RequireSSL)]
},
item_post_reseller => {
Chained => 'item_base',
PathPart => '',
Args => 1,
Method => 'POST',
ACLDetachTo => '/api/root/invalid_user',
AllowedRole => [qw/admin reseller ccareadmin ccare/],
Does => [qw(ACL RequireSSL)]
},
}
});
@ -251,6 +271,20 @@ sub item_delete_reseller {
}
sub item_post {
my ($self,$c) = @_;
#$c->log->debug((caller(0))[3] . ": " . $c->stash->{id});
return $self->post($c,$c->stash->{id});
}
sub item_post_reseller {
my ($self,$c,$name) = @_;
$c->stash->{id} = $self->get_id($c->stash->{id},$name);
#$c->log->debug((caller(0))[3] . ": " . $c->stash->{id});
return $self->post($c,$c->stash->{id});
}
sub update_item_model {
my($self, $c, $item, $old_resource, $resource, $form, $process_extras) = @_;
@ -285,5 +319,75 @@ sub delete_item {
}
sub post {
my ($self,$c,$id) = @_;
my $template = $self->item_by_id_valid($c, $id);
last unless $template;
my ($form) = $self->get_form($c, 'form', $id);
my ($action) = reverse split(/::/,(caller(1))[3],-1);
my $method_config = $self->get_config('action')->{$action};
my ($resource, $data, $non_json_data) = $self->get_valid_data(
c => $c,
method => 'POST',
media_type => $method_config->{ContentType} // 'application/json',
uploads => $method_config->{Uploads} // [] ,
form => $form,
resource_media_type => $method_config->{ResourceContentType},
);
return unless $resource;
if (!$non_json_data || !$data) {
my $context;
try {
$context = NGCP::Panel::Utils::ProvisioningTemplates::provision_begin(
c => $c,
);
NGCP::Panel::Utils::ProvisioningTemplates::provision_commit_row(
c => $c,
context => $context,
'values' => $resource,
);
NGCP::Panel::Utils::ProvisioningTemplates::provision_finish(
c => $c,
context => $context,
);
$c->log->debug(sprintf("Provisioning template '%s' done: subscriber %s created",
$id,
$context->{subscriber}->{username} . '@' . $context->{domain}->{domain}
));
$c->response->header(Location => sprintf('%s%d', NGCP::Panel::Role::API::Subscribers::dispatch_path(), $context->{subscriber}->{id}));
} catch($e) {
NGCP::Panel::Utils::ProvisioningTemplates::provision_cleanup($c, $context);
$c->log->error(sprintf("Provisioning template '%s' failed: %s",
$id,
$e,
));
$self->error($c, HTTP_INTERNAL_SERVER_ERROR, $e);
return;
}
} else {
#try {
# #$processed_ok(array), $processed_failed(array), $info, $error
# $data_processed_result = $self->process_data(
# c => $c,
# data => \$data,
# resource => $resource,
# form => $form,
# process_extras => $process_extras,
# );
#} catch($e) {
# $c->log->error("failed to process non json data: $e");
# $self->error($c, HTTP_INTERNAL_SERVER_ERROR, "Internal Server Error");
# last;
#};
}
$self->return_representation_post($c);
return;
}
1;

@ -97,11 +97,19 @@ sub valid_id {
sub get_form {
my ($self, $c) = @_;
if ($c->user->is_superuser) {
return NGCP::Panel::Form::get("NGCP::Panel::Form::ProvisioningTemplate::AdminAPI", $c);
my ($self, $c, $type, $id) = @_;
if ($type and 'form' eq lc($type)) {
unless ($c->stash->{provisioning_templates}) {
NGCP::Panel::Utils::ProvisioningTemplates::load_template_map($c);
}
$c->stash->{provisioning_template_name} = $id;
return NGCP::Panel::Utils::ProvisioningTemplates::get_provisioning_template_form($c);
} else {
return NGCP::Panel::Form::get("NGCP::Panel::Form::ProvisioningTemplate::ResellerAPI", $c);
if ($c->user->is_superuser) {
return NGCP::Panel::Form::get("NGCP::Panel::Form::ProvisioningTemplate::AdminAPI", $c);
} else {
return NGCP::Panel::Form::get("NGCP::Panel::Form::ProvisioningTemplate::ResellerAPI", $c);
}
}
}

@ -193,6 +193,19 @@ sub parse_template {
}
sub get_provisioning_template_form {
my ($c,$fields) = @_;
$fields //= get_fields($c,0);
my $form = NGCP::Panel::Form::ProvisioningTemplate::ProvisioningTemplate->new({
ctx => $c,
fields_config => [ values %$fields ],
});
$form->create_structure([ keys %$fields ]);
return $form;
}
sub create_provisioning_template_form {
my %params = @_;
@ -208,11 +221,7 @@ sub create_provisioning_template_form {
my $form;
try {
$form = NGCP::Panel::Form::ProvisioningTemplate::ProvisioningTemplate->new({
ctx => $c,
fields_config => [ values %$fields ],
});
$form->create_structure([ keys %$fields ]);
$form = get_provisioning_template_form($c,$fields);
} catch($e) {
NGCP::Panel::Utils::Message::error(
c => $c,
@ -260,7 +269,7 @@ sub create_provisioning_template_form {
desc => $c->loc("Provisioning template '[_1]' done: subscriber [_2] created", $template, $context->{subscriber}->{username} . '@' . $context->{domain}->{domain}),
);
} catch($e) {
_provision_cleanup($c, $context);
provision_cleanup($c, $context);
NGCP::Panel::Utils::Message::error(
c => $c,
error => $e,
@ -652,7 +661,7 @@ sub provision_finish {
context
/};
_provision_cleanup($c, $context);
provision_cleanup($c, $context);
if (exists $context->{_dfrd}->{kamailio_trusted_reload}
and $context->{_dfrd}->{kamailio_trusted_reload} > 0) {
@ -668,7 +677,7 @@ sub provision_finish {
}
sub _provision_cleanup {
sub provision_cleanup {
my ($c, $context) = @_;

@ -1413,7 +1413,7 @@ sub update_subscriber_numbers {
domain_id => $prov_subs->domain->id,
is_primary => 1,
});
}
}
}
if(defined $acli_pref) {
$acli_pref->search({ value => $old_cli })->delete if($old_cli);

Loading…
Cancel
Save