diff --git a/gso/services/provisioning_proxy.py b/gso/services/provisioning_proxy.py index 9ba2862475a544a840740d6f14b64bdcd87bdf3a..2b7c98bdfc863fe691a3652b808d64a3eb01f7fa 100644 --- a/gso/services/provisioning_proxy.py +++ b/gso/services/provisioning_proxy.py @@ -36,29 +36,29 @@ def _send_request(endpoint: str, parameters: dict, process_id: UUIDstr): raise AssertionError(post_request.text) -def _provision_service( - endpoint: str, +def provision_device( subscription: SubscriptionModel, process_id: UUIDstr, - dry_run: bool): + dry_run: bool = True): parameters = { 'dry_run': dry_run, 'subscription': json.loads(json_dumps(subscription)) } - _send_request(endpoint, parameters, process_id) - - -def provision_device(subscription: DeviceProvisioning, - process_id: UUIDstr, - dry_run: bool = True): - _provision_service('device', subscription, process_id, dry_run) + _send_request('device', parameters, process_id) def provision_ip_trunk(subscription: IptrunkProvisioning, process_id: UUIDstr, dry_run: bool = True): - _provision_service('ip_trunk', subscription, process_id, dry_run) + parameters = { + 'subscription': json.loads(json_dumps(subscription)), + 'dry_run': dry_run, + 'verb': '', # FIXME + 'object': '' # FIXME + } + + _send_request('ip_trunk', parameters, process_id) @inputstep('Await provisioning proxy results', assignee=Assignee('SYSTEM'))