forms.py 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945
  1. from __future__ import unicode_literals
  2. from django import forms
  3. from django.core.exceptions import MultipleObjectsReturned
  4. from django.db.models import Count
  5. from dcim.models import Site, Rack, Device, Interface
  6. from extras.forms import CustomFieldForm, CustomFieldBulkEditForm, CustomFieldFilterForm
  7. from tenancy.forms import TenancyForm
  8. from tenancy.models import Tenant
  9. from utilities.forms import (
  10. APISelect, BootstrapMixin, BulkEditNullBooleanSelect, ChainedModelChoiceField, CSVChoiceField,
  11. ExpandableIPAddressField, FilterChoiceField, FlexibleModelChoiceField, Livesearch, ReturnURLForm, SlugField,
  12. add_blank_choice,
  13. )
  14. from virtualization.models import VirtualMachine
  15. from .models import (
  16. Aggregate, IPAddress, IPADDRESS_ROLE_CHOICES, IPADDRESS_STATUS_CHOICES, Prefix, PREFIX_STATUS_CHOICES, RIR, Role,
  17. Service, VLAN, VLANGroup, VLAN_STATUS_CHOICES, VRF,
  18. )
  19. IP_FAMILY_CHOICES = [
  20. ('', 'All'),
  21. (4, 'IPv4'),
  22. (6, 'IPv6'),
  23. ]
  24. PREFIX_MASK_LENGTH_CHOICES = add_blank_choice([(i, i) for i in range(1, 128)])
  25. IPADDRESS_MASK_LENGTH_CHOICES = add_blank_choice([(i, i) for i in range(1, 129)])
  26. #
  27. # VRFs
  28. #
  29. class VRFForm(BootstrapMixin, TenancyForm, CustomFieldForm):
  30. class Meta:
  31. model = VRF
  32. fields = ['name', 'rd', 'enforce_unique', 'description', 'tenant_group', 'tenant']
  33. labels = {
  34. 'rd': "RD",
  35. }
  36. help_texts = {
  37. 'rd': "Route distinguisher in any format",
  38. }
  39. class VRFCSVForm(forms.ModelForm):
  40. tenant = forms.ModelChoiceField(
  41. queryset=Tenant.objects.all(),
  42. required=False,
  43. to_field_name='name',
  44. help_text='Name of assigned tenant',
  45. error_messages={
  46. 'invalid_choice': 'Tenant not found.',
  47. }
  48. )
  49. class Meta:
  50. model = VRF
  51. fields = ['name', 'rd', 'tenant', 'enforce_unique', 'description']
  52. help_texts = {
  53. 'name': 'VRF name',
  54. }
  55. class VRFBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  56. pk = forms.ModelMultipleChoiceField(queryset=VRF.objects.all(), widget=forms.MultipleHiddenInput)
  57. tenant = forms.ModelChoiceField(queryset=Tenant.objects.all(), required=False)
  58. enforce_unique = forms.NullBooleanField(
  59. required=False, widget=BulkEditNullBooleanSelect, label='Enforce unique space'
  60. )
  61. description = forms.CharField(max_length=100, required=False)
  62. class Meta:
  63. nullable_fields = ['tenant', 'description']
  64. class VRFFilterForm(BootstrapMixin, CustomFieldFilterForm):
  65. model = VRF
  66. q = forms.CharField(required=False, label='Search')
  67. tenant = FilterChoiceField(queryset=Tenant.objects.annotate(filter_count=Count('vrfs')), to_field_name='slug',
  68. null_option=(0, None))
  69. #
  70. # RIRs
  71. #
  72. class RIRForm(BootstrapMixin, forms.ModelForm):
  73. slug = SlugField()
  74. class Meta:
  75. model = RIR
  76. fields = ['name', 'slug', 'is_private']
  77. class RIRCSVForm(forms.ModelForm):
  78. slug = SlugField()
  79. class Meta:
  80. model = RIR
  81. fields = ['name', 'slug', 'is_private']
  82. help_texts = {
  83. 'name': 'RIR name',
  84. }
  85. class RIRFilterForm(BootstrapMixin, forms.Form):
  86. is_private = forms.NullBooleanField(required=False, label='Private', widget=forms.Select(choices=[
  87. ('', '---------'),
  88. ('True', 'Yes'),
  89. ('False', 'No'),
  90. ]))
  91. #
  92. # Aggregates
  93. #
  94. class AggregateForm(BootstrapMixin, CustomFieldForm):
  95. class Meta:
  96. model = Aggregate
  97. fields = ['prefix', 'rir', 'date_added', 'description']
  98. help_texts = {
  99. 'prefix': "IPv4 or IPv6 network",
  100. 'rir': "Regional Internet Registry responsible for this prefix",
  101. 'date_added': "Format: YYYY-MM-DD",
  102. }
  103. class AggregateCSVForm(forms.ModelForm):
  104. rir = forms.ModelChoiceField(
  105. queryset=RIR.objects.all(),
  106. to_field_name='name',
  107. help_text='Name of parent RIR',
  108. error_messages={
  109. 'invalid_choice': 'RIR not found.',
  110. }
  111. )
  112. class Meta:
  113. model = Aggregate
  114. fields = ['prefix', 'rir', 'date_added', 'description']
  115. class AggregateBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  116. pk = forms.ModelMultipleChoiceField(queryset=Aggregate.objects.all(), widget=forms.MultipleHiddenInput)
  117. rir = forms.ModelChoiceField(queryset=RIR.objects.all(), required=False, label='RIR')
  118. date_added = forms.DateField(required=False)
  119. description = forms.CharField(max_length=100, required=False)
  120. class Meta:
  121. nullable_fields = ['date_added', 'description']
  122. class AggregateFilterForm(BootstrapMixin, CustomFieldFilterForm):
  123. model = Aggregate
  124. q = forms.CharField(required=False, label='Search')
  125. family = forms.ChoiceField(required=False, choices=IP_FAMILY_CHOICES, label='Address Family')
  126. rir = FilterChoiceField(
  127. queryset=RIR.objects.annotate(filter_count=Count('aggregates')),
  128. to_field_name='slug',
  129. label='RIR'
  130. )
  131. #
  132. # Roles
  133. #
  134. class RoleForm(BootstrapMixin, forms.ModelForm):
  135. slug = SlugField()
  136. class Meta:
  137. model = Role
  138. fields = ['name', 'slug']
  139. class RoleCSVForm(forms.ModelForm):
  140. slug = SlugField()
  141. class Meta:
  142. model = Role
  143. fields = ['name', 'slug']
  144. help_texts = {
  145. 'name': 'Role name',
  146. }
  147. #
  148. # Prefixes
  149. #
  150. class PrefixForm(BootstrapMixin, TenancyForm, CustomFieldForm):
  151. site = forms.ModelChoiceField(
  152. queryset=Site.objects.all(),
  153. required=False,
  154. label='Site',
  155. widget=forms.Select(
  156. attrs={'filter-for': 'vlan_group', 'nullable': 'true'}
  157. )
  158. )
  159. vlan_group = ChainedModelChoiceField(
  160. queryset=VLANGroup.objects.all(),
  161. chains=(
  162. ('site', 'site'),
  163. ),
  164. required=False,
  165. label='VLAN group',
  166. widget=APISelect(
  167. api_url='/api/ipam/vlan-groups/?site_id={{site}}',
  168. attrs={'filter-for': 'vlan', 'nullable': 'true'}
  169. )
  170. )
  171. vlan = ChainedModelChoiceField(
  172. queryset=VLAN.objects.all(),
  173. chains=(
  174. ('site', 'site'),
  175. ('group', 'vlan_group'),
  176. ),
  177. required=False,
  178. label='VLAN',
  179. widget=APISelect(
  180. api_url='/api/ipam/vlans/?site_id={{site}}&group_id={{vlan_group}}', display_field='display_name'
  181. )
  182. )
  183. class Meta:
  184. model = Prefix
  185. fields = ['prefix', 'vrf', 'site', 'vlan', 'status', 'role', 'is_pool', 'description', 'tenant_group', 'tenant']
  186. def __init__(self, *args, **kwargs):
  187. # Initialize helper selectors
  188. instance = kwargs.get('instance')
  189. initial = kwargs.get('initial', {}).copy()
  190. if instance and instance.vlan is not None:
  191. initial['vlan_group'] = instance.vlan.group
  192. kwargs['initial'] = initial
  193. super(PrefixForm, self).__init__(*args, **kwargs)
  194. self.fields['vrf'].empty_label = 'Global'
  195. class PrefixCSVForm(forms.ModelForm):
  196. vrf = forms.ModelChoiceField(
  197. queryset=VRF.objects.all(),
  198. required=False,
  199. to_field_name='rd',
  200. help_text='Route distinguisher of parent VRF',
  201. error_messages={
  202. 'invalid_choice': 'VRF not found.',
  203. }
  204. )
  205. tenant = forms.ModelChoiceField(
  206. queryset=Tenant.objects.all(),
  207. required=False,
  208. to_field_name='name',
  209. help_text='Name of assigned tenant',
  210. error_messages={
  211. 'invalid_choice': 'Tenant not found.',
  212. }
  213. )
  214. site = forms.ModelChoiceField(
  215. queryset=Site.objects.all(),
  216. required=False,
  217. to_field_name='name',
  218. help_text='Name of parent site',
  219. error_messages={
  220. 'invalid_choice': 'Site not found.',
  221. }
  222. )
  223. vlan_group = forms.CharField(
  224. help_text='Group name of assigned VLAN',
  225. required=False
  226. )
  227. vlan_vid = forms.IntegerField(
  228. help_text='Numeric ID of assigned VLAN',
  229. required=False
  230. )
  231. status = CSVChoiceField(
  232. choices=PREFIX_STATUS_CHOICES,
  233. help_text='Operational status'
  234. )
  235. role = forms.ModelChoiceField(
  236. queryset=Role.objects.all(),
  237. required=False,
  238. to_field_name='name',
  239. help_text='Functional role',
  240. error_messages={
  241. 'invalid_choice': 'Invalid role.',
  242. }
  243. )
  244. class Meta:
  245. model = Prefix
  246. fields = [
  247. 'prefix', 'vrf', 'tenant', 'site', 'vlan_group', 'vlan_vid', 'status', 'role', 'is_pool', 'description',
  248. ]
  249. def clean(self):
  250. super(PrefixCSVForm, self).clean()
  251. site = self.cleaned_data.get('site')
  252. vlan_group = self.cleaned_data.get('vlan_group')
  253. vlan_vid = self.cleaned_data.get('vlan_vid')
  254. # Validate VLAN
  255. if vlan_group and vlan_vid:
  256. try:
  257. self.instance.vlan = VLAN.objects.get(site=site, group__name=vlan_group, vid=vlan_vid)
  258. except VLAN.DoesNotExist:
  259. if site:
  260. raise forms.ValidationError("VLAN {} not found in site {} group {}".format(
  261. vlan_vid, site, vlan_group
  262. ))
  263. else:
  264. raise forms.ValidationError("Global VLAN {} not found in group {}".format(vlan_vid, vlan_group))
  265. except MultipleObjectsReturned:
  266. raise forms.ValidationError(
  267. "Multiple VLANs with VID {} found in group {}".format(vlan_vid, vlan_group)
  268. )
  269. elif vlan_vid:
  270. try:
  271. self.instance.vlan = VLAN.objects.get(site=site, group__isnull=True, vid=vlan_vid)
  272. except VLAN.DoesNotExist:
  273. if site:
  274. raise forms.ValidationError("VLAN {} not found in site {}".format(vlan_vid, site))
  275. else:
  276. raise forms.ValidationError("Global VLAN {} not found".format(vlan_vid))
  277. except MultipleObjectsReturned:
  278. raise forms.ValidationError("Multiple VLANs with VID {} found".format(vlan_vid))
  279. class PrefixBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  280. pk = forms.ModelMultipleChoiceField(queryset=Prefix.objects.all(), widget=forms.MultipleHiddenInput)
  281. site = forms.ModelChoiceField(queryset=Site.objects.all(), required=False)
  282. vrf = forms.ModelChoiceField(queryset=VRF.objects.all(), required=False, label='VRF')
  283. tenant = forms.ModelChoiceField(queryset=Tenant.objects.all(), required=False)
  284. status = forms.ChoiceField(choices=add_blank_choice(PREFIX_STATUS_CHOICES), required=False)
  285. role = forms.ModelChoiceField(queryset=Role.objects.all(), required=False)
  286. is_pool = forms.NullBooleanField(required=False, widget=BulkEditNullBooleanSelect, label='Is a pool')
  287. description = forms.CharField(max_length=100, required=False)
  288. class Meta:
  289. nullable_fields = ['site', 'vrf', 'tenant', 'role', 'description']
  290. def prefix_status_choices():
  291. status_counts = {}
  292. for status in Prefix.objects.values('status').annotate(count=Count('status')).order_by('status'):
  293. status_counts[status['status']] = status['count']
  294. return [(s[0], '{} ({})'.format(s[1], status_counts.get(s[0], 0))) for s in PREFIX_STATUS_CHOICES]
  295. class PrefixFilterForm(BootstrapMixin, CustomFieldFilterForm):
  296. model = Prefix
  297. q = forms.CharField(required=False, label='Search')
  298. within_include = forms.CharField(required=False, label='Search within', widget=forms.TextInput(attrs={
  299. 'placeholder': 'Prefix',
  300. }))
  301. family = forms.ChoiceField(required=False, choices=IP_FAMILY_CHOICES, label='Address family')
  302. mask_length = forms.ChoiceField(required=False, choices=PREFIX_MASK_LENGTH_CHOICES, label='Mask length')
  303. vrf = FilterChoiceField(
  304. queryset=VRF.objects.annotate(filter_count=Count('prefixes')),
  305. to_field_name='rd',
  306. label='VRF',
  307. null_option=(0, 'Global')
  308. )
  309. tenant = FilterChoiceField(
  310. queryset=Tenant.objects.annotate(filter_count=Count('prefixes')),
  311. to_field_name='slug',
  312. null_option=(0, 'None')
  313. )
  314. status = forms.MultipleChoiceField(choices=prefix_status_choices, required=False)
  315. site = FilterChoiceField(
  316. queryset=Site.objects.annotate(filter_count=Count('prefixes')),
  317. to_field_name='slug',
  318. null_option=(0, 'None')
  319. )
  320. role = FilterChoiceField(
  321. queryset=Role.objects.annotate(filter_count=Count('prefixes')),
  322. to_field_name='slug',
  323. null_option=(0, 'None')
  324. )
  325. expand = forms.BooleanField(required=False, label='Expand prefix hierarchy')
  326. #
  327. # IP addresses
  328. #
  329. class IPAddressForm(BootstrapMixin, TenancyForm, ReturnURLForm, CustomFieldForm):
  330. interface = forms.ModelChoiceField(
  331. queryset=Interface.objects.all(),
  332. required=False
  333. )
  334. nat_site = forms.ModelChoiceField(
  335. queryset=Site.objects.all(),
  336. required=False,
  337. label='Site',
  338. widget=forms.Select(
  339. attrs={'filter-for': 'nat_rack'}
  340. )
  341. )
  342. nat_rack = ChainedModelChoiceField(
  343. queryset=Rack.objects.all(),
  344. chains=(
  345. ('site', 'nat_site'),
  346. ),
  347. required=False,
  348. label='Rack',
  349. widget=APISelect(
  350. api_url='/api/dcim/racks/?site_id={{nat_site}}',
  351. display_field='display_name',
  352. attrs={'filter-for': 'nat_device', 'nullable': 'true'}
  353. )
  354. )
  355. nat_device = ChainedModelChoiceField(
  356. queryset=Device.objects.all(),
  357. chains=(
  358. ('site', 'nat_site'),
  359. ('rack', 'nat_rack'),
  360. ),
  361. required=False,
  362. label='Device',
  363. widget=APISelect(
  364. api_url='/api/dcim/devices/?site_id={{nat_site}}&rack_id={{nat_rack}}',
  365. display_field='display_name',
  366. attrs={'filter-for': 'nat_inside'}
  367. )
  368. )
  369. nat_inside = ChainedModelChoiceField(
  370. queryset=IPAddress.objects.all(),
  371. chains=(
  372. ('interface__device', 'nat_device'),
  373. ),
  374. required=False,
  375. label='IP Address',
  376. widget=APISelect(
  377. api_url='/api/ipam/ip-addresses/?device_id={{nat_device}}',
  378. display_field='address'
  379. )
  380. )
  381. livesearch = forms.CharField(
  382. required=False,
  383. label='Search',
  384. widget=Livesearch(
  385. query_key='q',
  386. query_url='ipam-api:ipaddress-list',
  387. field_to_update='nat_inside',
  388. obj_label='address'
  389. )
  390. )
  391. primary_for_parent = forms.BooleanField(required=False, label='Make this the primary IP for the device/VM')
  392. class Meta:
  393. model = IPAddress
  394. fields = [
  395. 'address', 'vrf', 'status', 'role', 'description', 'interface', 'primary_for_parent', 'nat_site',
  396. 'nat_rack', 'nat_inside', 'tenant_group', 'tenant',
  397. ]
  398. def __init__(self, *args, **kwargs):
  399. # Initialize helper selectors
  400. instance = kwargs.get('instance')
  401. initial = kwargs.get('initial', {}).copy()
  402. if instance and instance.nat_inside and instance.nat_inside.device is not None:
  403. initial['nat_site'] = instance.nat_inside.device.site
  404. initial['nat_rack'] = instance.nat_inside.device.rack
  405. initial['nat_device'] = instance.nat_inside.device
  406. kwargs['initial'] = initial
  407. super(IPAddressForm, self).__init__(*args, **kwargs)
  408. self.fields['vrf'].empty_label = 'Global'
  409. # Limit interface selections to those belonging to the parent device/VM
  410. if self.instance and self.instance.interface:
  411. self.fields['interface'].queryset = Interface.objects.filter(
  412. device=self.instance.interface.device, virtual_machine=self.instance.interface.virtual_machine
  413. )
  414. else:
  415. self.fields['interface'].choices = []
  416. # Initialize primary_for_parent if IP address is already assigned
  417. if self.instance.pk and self.instance.interface is not None:
  418. parent = self.instance.interface.parent
  419. if (
  420. self.instance.address.version == 4 and parent.primary_ip4_id == self.instance.pk or
  421. self.instance.address.version == 6 and parent.primary_ip6_id == self.instance.pk
  422. ):
  423. self.initial['primary_for_parent'] = True
  424. def clean(self):
  425. super(IPAddressForm, self).clean()
  426. # Primary IP assignment is only available if an interface has been assigned.
  427. if self.cleaned_data.get('primary_for_parent') and not self.cleaned_data.get('interface'):
  428. self.add_error(
  429. 'primary_for_parent', "Only IP addresses assigned to an interface can be designated as primary IPs."
  430. )
  431. def save(self, *args, **kwargs):
  432. ipaddress = super(IPAddressForm, self).save(*args, **kwargs)
  433. # Assign this IPAddress as the primary for the associated Device.
  434. if self.cleaned_data['primary_for_parent']:
  435. parent = self.cleaned_data['interface'].parent
  436. if ipaddress.address.version == 4:
  437. parent.primary_ip4 = ipaddress
  438. else:
  439. parent.primary_ip6 = ipaddress
  440. parent.save()
  441. # Clear assignment as primary for device if set.
  442. else:
  443. try:
  444. if ipaddress.address.version == 4:
  445. device = ipaddress.primary_ip4_for
  446. device.primary_ip4 = None
  447. else:
  448. device = ipaddress.primary_ip6_for
  449. device.primary_ip6 = None
  450. device.save()
  451. except Device.DoesNotExist:
  452. pass
  453. return ipaddress
  454. class IPAddressBulkCreateForm(BootstrapMixin, forms.Form):
  455. pattern = ExpandableIPAddressField(label='Address pattern')
  456. class IPAddressBulkAddForm(BootstrapMixin, TenancyForm, CustomFieldForm):
  457. class Meta:
  458. model = IPAddress
  459. fields = ['address', 'vrf', 'status', 'role', 'description', 'tenant_group', 'tenant']
  460. def __init__(self, *args, **kwargs):
  461. super(IPAddressBulkAddForm, self).__init__(*args, **kwargs)
  462. self.fields['vrf'].empty_label = 'Global'
  463. class IPAddressCSVForm(forms.ModelForm):
  464. vrf = forms.ModelChoiceField(
  465. queryset=VRF.objects.all(),
  466. required=False,
  467. to_field_name='rd',
  468. help_text='Route distinguisher of the assigned VRF',
  469. error_messages={
  470. 'invalid_choice': 'VRF not found.',
  471. }
  472. )
  473. tenant = forms.ModelChoiceField(
  474. queryset=Tenant.objects.all(),
  475. to_field_name='name',
  476. required=False,
  477. help_text='Name of the assigned tenant',
  478. error_messages={
  479. 'invalid_choice': 'Tenant not found.',
  480. }
  481. )
  482. status = CSVChoiceField(
  483. choices=IPADDRESS_STATUS_CHOICES,
  484. help_text='Operational status'
  485. )
  486. role = CSVChoiceField(
  487. choices=IPADDRESS_ROLE_CHOICES,
  488. required=False,
  489. help_text='Functional role'
  490. )
  491. device = FlexibleModelChoiceField(
  492. queryset=Device.objects.all(),
  493. required=False,
  494. to_field_name='name',
  495. help_text='Name or ID of assigned device',
  496. error_messages={
  497. 'invalid_choice': 'Device not found.',
  498. }
  499. )
  500. virtual_machine = forms.ModelChoiceField(
  501. queryset=VirtualMachine.objects.all(),
  502. required=False,
  503. to_field_name='name',
  504. help_text='Name of assigned virtual machine',
  505. error_messages={
  506. 'invalid_choice': 'Virtual machine not found.',
  507. }
  508. )
  509. interface_name = forms.CharField(
  510. help_text='Name of assigned interface',
  511. required=False
  512. )
  513. is_primary = forms.BooleanField(
  514. help_text='Make this the primary IP for the assigned device',
  515. required=False
  516. )
  517. class Meta:
  518. model = IPAddress
  519. fields = [
  520. 'address', 'vrf', 'tenant', 'status', 'role', 'device', 'virtual_machine', 'interface_name', 'is_primary',
  521. 'description',
  522. ]
  523. def clean(self):
  524. super(IPAddressCSVForm, self).clean()
  525. device = self.cleaned_data.get('device')
  526. virtual_machine = self.cleaned_data.get('virtual_machine')
  527. interface_name = self.cleaned_data.get('interface_name')
  528. is_primary = self.cleaned_data.get('is_primary')
  529. # Validate interface
  530. if interface_name and device:
  531. try:
  532. self.instance.interface = Interface.objects.get(device=device, name=interface_name)
  533. except Interface.DoesNotExist:
  534. raise forms.ValidationError("Invalid interface {} for device {}".format(
  535. interface_name, device
  536. ))
  537. elif interface_name and virtual_machine:
  538. try:
  539. self.instance.interface = Interface.objects.get(virtual_machine=virtual_machine, name=interface_name)
  540. except Interface.DoesNotExist:
  541. raise forms.ValidationError("Invalid interface {} for virtual machine {}".format(
  542. interface_name, virtual_machine
  543. ))
  544. elif interface_name:
  545. raise forms.ValidationError("Interface given ({}) but parent device/virtual machine not specified".format(
  546. interface_name
  547. ))
  548. elif device:
  549. raise forms.ValidationError("Device specified ({}) but interface missing".format(device))
  550. elif virtual_machine:
  551. raise forms.ValidationError("Virtual machine specified ({}) but interface missing".format(virtual_machine))
  552. # Validate is_primary
  553. if is_primary and not device and not virtual_machine:
  554. raise forms.ValidationError("No device or virtual machine specified; cannot set as primary IP")
  555. def save(self, *args, **kwargs):
  556. # Set interface
  557. if self.cleaned_data['device'] and self.cleaned_data['interface_name']:
  558. self.instance.interface = Interface.objects.get(
  559. device=self.cleaned_data['device'],
  560. name=self.cleaned_data['interface_name']
  561. )
  562. elif self.cleaned_data['virtual_machine'] and self.cleaned_data['interface_name']:
  563. self.instance.interface = Interface.objects.get(
  564. virtual_machine=self.cleaned_data['virtual_machine'],
  565. name=self.cleaned_data['interface_name']
  566. )
  567. ipaddress = super(IPAddressCSVForm, self).save(*args, **kwargs)
  568. # Set as primary for device/VM
  569. if self.cleaned_data['is_primary']:
  570. parent = self.cleaned_data['device'] or self.cleaned_data['virtual_machine']
  571. if self.instance.address.version == 4:
  572. parent.primary_ip4 = ipaddress
  573. elif self.instance.address.version == 6:
  574. parent.primary_ip6 = ipaddress
  575. parent.save()
  576. return ipaddress
  577. class IPAddressBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  578. pk = forms.ModelMultipleChoiceField(queryset=IPAddress.objects.all(), widget=forms.MultipleHiddenInput)
  579. vrf = forms.ModelChoiceField(queryset=VRF.objects.all(), required=False, label='VRF')
  580. tenant = forms.ModelChoiceField(queryset=Tenant.objects.all(), required=False)
  581. status = forms.ChoiceField(choices=add_blank_choice(IPADDRESS_STATUS_CHOICES), required=False)
  582. role = forms.ChoiceField(choices=add_blank_choice(IPADDRESS_ROLE_CHOICES), required=False)
  583. description = forms.CharField(max_length=100, required=False)
  584. class Meta:
  585. nullable_fields = ['vrf', 'role', 'tenant', 'description']
  586. def ipaddress_status_choices():
  587. status_counts = {}
  588. for status in IPAddress.objects.values('status').annotate(count=Count('status')).order_by('status'):
  589. status_counts[status['status']] = status['count']
  590. return [(s[0], '{} ({})'.format(s[1], status_counts.get(s[0], 0))) for s in IPADDRESS_STATUS_CHOICES]
  591. def ipaddress_role_choices():
  592. role_counts = {}
  593. for role in IPAddress.objects.values('role').annotate(count=Count('role')).order_by('role'):
  594. role_counts[role['role']] = role['count']
  595. return [(r[0], '{} ({})'.format(r[1], role_counts.get(r[0], 0))) for r in IPADDRESS_ROLE_CHOICES]
  596. class IPAddressFilterForm(BootstrapMixin, CustomFieldFilterForm):
  597. model = IPAddress
  598. q = forms.CharField(required=False, label='Search')
  599. parent = forms.CharField(required=False, label='Parent Prefix', widget=forms.TextInput(attrs={
  600. 'placeholder': 'Prefix',
  601. }))
  602. family = forms.ChoiceField(required=False, choices=IP_FAMILY_CHOICES, label='Address family')
  603. mask_length = forms.ChoiceField(required=False, choices=IPADDRESS_MASK_LENGTH_CHOICES, label='Mask length')
  604. vrf = FilterChoiceField(
  605. queryset=VRF.objects.annotate(filter_count=Count('ip_addresses')),
  606. to_field_name='rd',
  607. label='VRF',
  608. null_option=(0, 'Global')
  609. )
  610. tenant = FilterChoiceField(
  611. queryset=Tenant.objects.annotate(filter_count=Count('ip_addresses')),
  612. to_field_name='slug',
  613. null_option=(0, 'None')
  614. )
  615. status = forms.MultipleChoiceField(choices=ipaddress_status_choices, required=False)
  616. role = forms.MultipleChoiceField(choices=ipaddress_role_choices, required=False)
  617. #
  618. # VLAN groups
  619. #
  620. class VLANGroupForm(BootstrapMixin, forms.ModelForm):
  621. slug = SlugField()
  622. class Meta:
  623. model = VLANGroup
  624. fields = ['site', 'name', 'slug']
  625. class VLANGroupCSVForm(forms.ModelForm):
  626. site = forms.ModelChoiceField(
  627. queryset=Site.objects.all(),
  628. required=False,
  629. to_field_name='name',
  630. help_text='Name of parent site',
  631. error_messages={
  632. 'invalid_choice': 'Site not found.',
  633. }
  634. )
  635. slug = SlugField()
  636. class Meta:
  637. model = VLANGroup
  638. fields = ['site', 'name', 'slug']
  639. help_texts = {
  640. 'name': 'Name of VLAN group',
  641. }
  642. class VLANGroupFilterForm(BootstrapMixin, forms.Form):
  643. site = FilterChoiceField(
  644. queryset=Site.objects.annotate(filter_count=Count('vlan_groups')),
  645. to_field_name='slug',
  646. null_option=(0, 'Global')
  647. )
  648. #
  649. # VLANs
  650. #
  651. class VLANForm(BootstrapMixin, TenancyForm, CustomFieldForm):
  652. site = forms.ModelChoiceField(
  653. queryset=Site.objects.all(),
  654. required=False,
  655. widget=forms.Select(
  656. attrs={'filter-for': 'group', 'nullable': 'true'}
  657. )
  658. )
  659. group = ChainedModelChoiceField(
  660. queryset=VLANGroup.objects.all(),
  661. chains=(
  662. ('site', 'site'),
  663. ),
  664. required=False,
  665. label='Group',
  666. widget=APISelect(
  667. api_url='/api/ipam/vlan-groups/?site_id={{site}}',
  668. )
  669. )
  670. class Meta:
  671. model = VLAN
  672. fields = ['site', 'group', 'vid', 'name', 'status', 'role', 'description', 'tenant_group', 'tenant']
  673. help_texts = {
  674. 'site': "Leave blank if this VLAN spans multiple sites",
  675. 'group': "VLAN group (optional)",
  676. 'vid': "Configured VLAN ID",
  677. 'name': "Configured VLAN name",
  678. 'status': "Operational status of this VLAN",
  679. 'role': "The primary function of this VLAN",
  680. }
  681. class VLANCSVForm(forms.ModelForm):
  682. site = forms.ModelChoiceField(
  683. queryset=Site.objects.all(),
  684. required=False,
  685. to_field_name='name',
  686. help_text='Name of parent site',
  687. error_messages={
  688. 'invalid_choice': 'Site not found.',
  689. }
  690. )
  691. group_name = forms.CharField(
  692. help_text='Name of VLAN group',
  693. required=False
  694. )
  695. tenant = forms.ModelChoiceField(
  696. queryset=Tenant.objects.all(),
  697. to_field_name='name',
  698. required=False,
  699. help_text='Name of assigned tenant',
  700. error_messages={
  701. 'invalid_choice': 'Tenant not found.',
  702. }
  703. )
  704. status = CSVChoiceField(
  705. choices=VLAN_STATUS_CHOICES,
  706. help_text='Operational status'
  707. )
  708. role = forms.ModelChoiceField(
  709. queryset=Role.objects.all(),
  710. required=False,
  711. to_field_name='name',
  712. help_text='Functional role',
  713. error_messages={
  714. 'invalid_choice': 'Invalid role.',
  715. }
  716. )
  717. class Meta:
  718. model = VLAN
  719. fields = ['site', 'group_name', 'vid', 'name', 'tenant', 'status', 'role', 'description']
  720. help_texts = {
  721. 'vid': 'Numeric VLAN ID (1-4095)',
  722. 'name': 'VLAN name',
  723. }
  724. def clean(self):
  725. super(VLANCSVForm, self).clean()
  726. site = self.cleaned_data.get('site')
  727. group_name = self.cleaned_data.get('group_name')
  728. # Validate VLAN group
  729. if group_name:
  730. try:
  731. self.instance.group = VLANGroup.objects.get(site=site, name=group_name)
  732. except VLANGroup.DoesNotExist:
  733. if site:
  734. raise forms.ValidationError("VLAN group {} not found for site {}".format(group_name, site))
  735. else:
  736. raise forms.ValidationError("Global VLAN group {} not found".format(group_name))
  737. class VLANBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  738. pk = forms.ModelMultipleChoiceField(queryset=VLAN.objects.all(), widget=forms.MultipleHiddenInput)
  739. site = forms.ModelChoiceField(queryset=Site.objects.all(), required=False)
  740. group = forms.ModelChoiceField(queryset=VLANGroup.objects.all(), required=False)
  741. tenant = forms.ModelChoiceField(queryset=Tenant.objects.all(), required=False)
  742. status = forms.ChoiceField(choices=add_blank_choice(VLAN_STATUS_CHOICES), required=False)
  743. role = forms.ModelChoiceField(queryset=Role.objects.all(), required=False)
  744. description = forms.CharField(max_length=100, required=False)
  745. class Meta:
  746. nullable_fields = ['site', 'group', 'tenant', 'role', 'description']
  747. def vlan_status_choices():
  748. status_counts = {}
  749. for status in VLAN.objects.values('status').annotate(count=Count('status')).order_by('status'):
  750. status_counts[status['status']] = status['count']
  751. return [(s[0], '{} ({})'.format(s[1], status_counts.get(s[0], 0))) for s in VLAN_STATUS_CHOICES]
  752. class VLANFilterForm(BootstrapMixin, CustomFieldFilterForm):
  753. model = VLAN
  754. q = forms.CharField(required=False, label='Search')
  755. site = FilterChoiceField(
  756. queryset=Site.objects.annotate(filter_count=Count('vlans')),
  757. to_field_name='slug',
  758. null_option=(0, 'Global')
  759. )
  760. group_id = FilterChoiceField(
  761. queryset=VLANGroup.objects.annotate(filter_count=Count('vlans')),
  762. label='VLAN group',
  763. null_option=(0, 'None')
  764. )
  765. tenant = FilterChoiceField(
  766. queryset=Tenant.objects.annotate(filter_count=Count('vlans')),
  767. to_field_name='slug',
  768. null_option=(0, 'None')
  769. )
  770. status = forms.MultipleChoiceField(choices=vlan_status_choices, required=False)
  771. role = FilterChoiceField(
  772. queryset=Role.objects.annotate(filter_count=Count('vlans')),
  773. to_field_name='slug',
  774. null_option=(0, 'None')
  775. )
  776. #
  777. # Services
  778. #
  779. class ServiceForm(BootstrapMixin, forms.ModelForm):
  780. class Meta:
  781. model = Service
  782. fields = ['name', 'protocol', 'port', 'ipaddresses', 'description']
  783. help_texts = {
  784. 'ipaddresses': "IP address assignment is optional. If no IPs are selected, the service is assumed to be "
  785. "reachable via all IPs assigned to the device.",
  786. }
  787. def __init__(self, *args, **kwargs):
  788. super(ServiceForm, self).__init__(*args, **kwargs)
  789. # Limit IP address choices to those assigned to interfaces of the parent device/VM
  790. if self.instance.device:
  791. self.fields['ipaddresses'].queryset = IPAddress.objects.filter(
  792. interface__device=self.instance.device
  793. )
  794. elif self.instance.virtual_machine:
  795. self.fields['ipaddresses'].queryset = IPAddress.objects.filter(
  796. interface__virtual_machine=self.instance.virtual_machine
  797. )
  798. else:
  799. self.fields['ipaddresses'].choices = []