Skip to content
Snippets Groups Projects

Add sites, and add integration of IPtrunks and routers with LSO deployment

Merged Karel van Klink requested to merge feature/new_device_model_and_sites_and_orgs into develop
2 files
+ 18
13
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -4,6 +4,7 @@ import logging
import requests
from orchestrator import inputstep
from orchestrator.config.assignee import Assignee
from orchestrator.domain.lifecycle import SubscriptionModel
from orchestrator.forms import FormPage, ReadOnlyField
from orchestrator.forms.validators import Accept, Label, LongText
from orchestrator.types import UUIDstr, State
@@ -15,24 +16,16 @@ from gso.products.product_types.device import DeviceProvisioning
logger = logging.getLogger(__name__)
def provision_node(
node_subscription_params: DeviceProvisioning,
process_id: UUIDstr,
dry_run: bool = True):
def _send_request(parameters: dict, process_id: UUIDstr):
oss = settings.load_oss_params()
pp_params = oss.PROVISIONING_PROXY
assert pp_params
device_params = node_subscription_params.device
callback_url = f'{settings.load_oss_params().GENERAL.public_hostname}' \
f'/api/processes/{process_id}/resume'
logger.debug(f'[disabled] provisioning node {device_params}')
logger.debug(f'[provisioning proxy] provisioning for process {process_id}')
parameters = {
'callback': callback_url,
'dry_run': dry_run,
'device': json.loads(json_dumps(node_subscription_params))
}
parameters.update({'callback': callback_url})
post_request = requests.post(
f'{pp_params.scheme}://{pp_params.api_base}/api/device',
@@ -42,6 +35,18 @@ def provision_node(
raise AssertionError(post_request.text)
def provision_service(
subscription: SubscriptionModel,
process_id: UUIDstr,
dry_run: bool = True):
parameters = {
'dry_run': dry_run,
'subscription': json.loads(json_dumps(subscription))
}
_send_request(parameters, process_id)
@inputstep('Await provisioning proxy results', assignee=Assignee('SYSTEM'))
def await_pp_results() -> State:
class ProvisioningResultPage(FormPage):
Loading