Skip to content
Snippets Groups Projects
Commit e84daf32 authored by Simone Spinelli's avatar Simone Spinelli
Browse files

Commenting out the whole insert_in_ibgp since should not have been here

parent 3fb88e49
No related branches found
No related tags found
1 merge request!55Feature/nat 230 add isis and ping checks to create iptrunk workflow
Pipeline #83792 failed
Stage: tox
Stage: documentation
This commit is part of merge request !55. Comments created here will be created in the context of that merge request.
Hide whitespace changes
Inline Side-by-side
gso/workflows/device/insert_in_ibgp.py
+ 84
− 84
View file @ e84daf32
import ipaddress #import ipaddress
import re #import re
from uuid import uuid4 #from uuid import uuid4
#
from orchestrator.db.models import ProductTable, SubscriptionTable #from orchestrator.db.models import ProductTable, SubscriptionTable
#
# noinspection PyProtectedMember ## noinspection PyProtectedMember
from orchestrator.forms import FormPage #from orchestrator.forms import FormPage
from orchestrator.forms.validators import Choice #from orchestrator.forms.validators import Choice
from orchestrator.targets import Target #from orchestrator.targets import Target
from orchestrator.types import FormGenerator, State #from orchestrator.types import FormGenerator, State
from orchestrator.types import SubscriptionLifecycle, UUIDstr #from orchestrator.types import SubscriptionLifecycle, UUIDstr
from orchestrator.workflow import done, init, step, workflow #from orchestrator.workflow import done, init, step, workflow
from orchestrator.workflows.steps import resync, store_process_subscription, unsync #from orchestrator.workflows.steps import resync, store_process_subscription, unsync
#
from orchestrator.workflows.utils import wrap_modify_initial_input_form #from orchestrator.workflows.utils import wrap_modify_initial_input_form
from gso.products.product_blocks import device as device_pb #from gso.products.product_blocks import device as device_pb
from gso.products.product_types import device #from gso.products.product_types import device
from gso.products.product_types.device import ( #from gso.products.product_types.device import (
Device, # Device,
) #)
from gso.products.product_types.site import Site #from gso.products.product_types.site import Site
from gso.services import _ipam #from gso.services import _ipam
#
def initial_input_form_generator(subscription_id: UUIDstr) -> FormGenerator: #def initial_input_form_generator(subscription_id: UUIDstr) -> FormGenerator:
subscription = Device.from_subscription(subscription_id) # subscription = Device.from_subscription(subscription_id)
#
class SimoneDeviceForm(FormPage): # class SimoneDeviceForm(FormPage):
class Config: # class Config:
random_input: str # random_input: str
#
user_input = yield SimoneDeviceForm # user_input = yield SimoneDeviceForm
#
return user_input.dict() # return user_input.dict()
#
@step("Show the devices") #@step("Show the devices")
def display_devices() -> State: #def display_devices() -> State:
devices = [] # devices = []
for subscription_id in ( # for subscription_id in (
SubscriptionTable.query.join(ProductTable) # SubscriptionTable.query.join(ProductTable)
.filter( # .filter(
ProductTable.product_type == "Device", # ProductTable.product_type == "Device",
SubscriptionTable.status == "active", # SubscriptionTable.status == "active",
) # )
.with_entities( # .with_entities(
SubscriptionTable.subscription_id, # SubscriptionTable.subscription_id,
) # )
.all() # .all()
): # ):
devices.append(Device.from_subscription(subscription_id)) # devices.append(Device.from_subscription(subscription_id))
#
pe_devices = [] # pe_devices = []
p_devices = [] # p_devices = []
#
for device in devices : # for device in devices :
if device.device.device_access_via_ts == False : # if device.device.device_access_via_ts == False :
if device.device.device_role == "p": # if device.device.device_role == "p":
p_devices.append(device) # p_devices.append(device)
if device.device.device_role == "pe": # if device.device.device_role == "pe":
pe_devices.append(device) # pe_devices.append(device)
#
return { # return {
"pe_devices": pe_devices, # "pe_devices": pe_devices,
"p_devices": p_devices, # "p_devices": p_devices,
} # }
#
#
@workflow( #@workflow(
"Add node to iBGP", # "Add node to iBGP",
initial_input_form=wrap_modify_initial_input_form( # initial_input_form=wrap_modify_initial_input_form(
initial_input_form_generator # initial_input_form_generator
), # ),
target=Target.MODIFY, # target=Target.MODIFY,
) #)
#
def insert_in_ibgp(): #def insert_in_ibgp():
return ( # return (
init # init
>> store_process_subscription(Target.MODIFY) # >> store_process_subscription(Target.MODIFY)
>> unsync # >> unsync
>> display_devices # >> display_devices
>> resync # >> resync
>> done # >> done
) # )
\ No newline at end of file
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment