forms.py 54 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277
  1. import re
  2. from django import forms
  3. from django.core.exceptions import ValidationError
  4. from django.db.models import Count, Q
  5. from extras.forms import CustomFieldForm, CustomFieldBulkEditForm, CustomFieldFilterForm
  6. from ipam.models import IPAddress
  7. from tenancy.models import Tenant
  8. from utilities.forms import (
  9. APISelect, add_blank_choice, BootstrapMixin, BulkEditForm, BulkImportForm, CommentField, CSVDataField,
  10. ExpandableNameField, FilterChoiceField, FlexibleModelChoiceField, Livesearch, SelectWithDisabled, SmallTextarea,
  11. SlugField,
  12. )
  13. from .models import (
  14. DeviceBay, DeviceBayTemplate, CONNECTION_STATUS_CHOICES, CONNECTION_STATUS_PLANNED, CONNECTION_STATUS_CONNECTED,
  15. ConsolePort, ConsolePortTemplate, ConsoleServerPort, ConsoleServerPortTemplate, Device, DeviceRole, DeviceType,
  16. Interface, IFACE_FF_CHOICES, IFACE_FF_VIRTUAL, InterfaceConnection, InterfaceTemplate, Manufacturer, Module,
  17. Platform, PowerOutlet, PowerOutletTemplate, PowerPort, PowerPortTemplate, RACK_TYPE_CHOICES, RACK_WIDTH_CHOICES,
  18. Rack, RackGroup, RackRole, Site, STATUS_CHOICES, SUBDEVICE_ROLE_CHILD
  19. )
  20. FORM_STATUS_CHOICES = [
  21. ['', '---------'],
  22. ]
  23. FORM_STATUS_CHOICES += STATUS_CHOICES
  24. DEVICE_BY_PK_RE = '{\d+\}'
  25. def get_device_by_name_or_pk(name):
  26. """
  27. Attempt to retrieve a device by either its name or primary key ('{pk}').
  28. """
  29. if re.match(DEVICE_BY_PK_RE, name):
  30. pk = name.strip('{}')
  31. device = Device.objects.get(pk=pk)
  32. else:
  33. device = Device.objects.get(name=name)
  34. return device
  35. def validate_connection_status(value):
  36. """
  37. Custom validator for connection statuses. value must be either "planned" or "connected" (case-insensitive).
  38. """
  39. if value.lower() not in ['planned', 'connected']:
  40. raise ValidationError('Invalid connection status ({}); must be either "planned" or "connected".'.format(value))
  41. #
  42. # Sites
  43. #
  44. class SiteForm(BootstrapMixin, CustomFieldForm):
  45. slug = SlugField()
  46. comments = CommentField()
  47. class Meta:
  48. model = Site
  49. fields = ['name', 'slug', 'tenant', 'facility', 'asn', 'physical_address', 'shipping_address', 'comments']
  50. widgets = {
  51. 'physical_address': SmallTextarea(attrs={'rows': 3}),
  52. 'shipping_address': SmallTextarea(attrs={'rows': 3}),
  53. }
  54. help_texts = {
  55. 'name': "Full name of the site",
  56. 'facility': "Data center provider and facility (e.g. Equinix NY7)",
  57. 'asn': "BGP autonomous system number",
  58. 'physical_address': "Physical location of the building (e.g. for GPS)",
  59. 'shipping_address': "If different from the physical address"
  60. }
  61. class SiteFromCSVForm(forms.ModelForm):
  62. tenant = forms.ModelChoiceField(Tenant.objects.all(), to_field_name='name', required=False,
  63. error_messages={'invalid_choice': 'Tenant not found.'})
  64. class Meta:
  65. model = Site
  66. fields = ['name', 'slug', 'tenant', 'facility', 'asn']
  67. class SiteImportForm(BulkImportForm, BootstrapMixin):
  68. csv = CSVDataField(csv_form=SiteFromCSVForm)
  69. class SiteBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  70. pk = forms.ModelMultipleChoiceField(queryset=Site.objects.all(), widget=forms.MultipleHiddenInput)
  71. tenant = forms.ModelChoiceField(queryset=Tenant.objects.all(), required=False)
  72. class Meta:
  73. nullable_fields = ['tenant']
  74. class SiteFilterForm(BootstrapMixin, CustomFieldFilterForm):
  75. model = Site
  76. tenant = FilterChoiceField(queryset=Tenant.objects.annotate(filter_count=Count('sites')), to_field_name='slug',
  77. null_option=(0, 'None'))
  78. #
  79. # Rack groups
  80. #
  81. class RackGroupForm(forms.ModelForm, BootstrapMixin):
  82. slug = SlugField()
  83. class Meta:
  84. model = RackGroup
  85. fields = ['site', 'name', 'slug']
  86. class RackGroupFilterForm(forms.Form, BootstrapMixin):
  87. site = FilterChoiceField(queryset=Site.objects.annotate(filter_count=Count('rack_groups')), to_field_name='slug')
  88. #
  89. # Rack roles
  90. #
  91. class RackRoleForm(forms.ModelForm, BootstrapMixin):
  92. slug = SlugField()
  93. class Meta:
  94. model = RackRole
  95. fields = ['name', 'slug', 'color']
  96. #
  97. # Racks
  98. #
  99. class RackForm(BootstrapMixin, CustomFieldForm):
  100. group = forms.ModelChoiceField(queryset=RackGroup.objects.all(), required=False, label='Group', widget=APISelect(
  101. api_url='/api/dcim/rack-groups/?site_id={{site}}',
  102. ))
  103. comments = CommentField()
  104. class Meta:
  105. model = Rack
  106. fields = ['site', 'group', 'name', 'facility_id', 'tenant', 'role', 'type', 'width', 'u_height', 'desc_units',
  107. 'comments']
  108. help_texts = {
  109. 'site': "The site at which the rack exists",
  110. 'name': "Organizational rack name",
  111. 'facility_id': "The unique rack ID assigned by the facility",
  112. 'u_height': "Height in rack units",
  113. }
  114. widgets = {
  115. 'site': forms.Select(attrs={'filter-for': 'group'}),
  116. }
  117. def __init__(self, *args, **kwargs):
  118. super(RackForm, self).__init__(*args, **kwargs)
  119. # Limit rack group choices
  120. if self.is_bound and self.data.get('site'):
  121. self.fields['group'].queryset = RackGroup.objects.filter(site__pk=self.data['site'])
  122. elif self.initial.get('site'):
  123. self.fields['group'].queryset = RackGroup.objects.filter(site=self.initial['site'])
  124. else:
  125. self.fields['group'].choices = []
  126. class RackFromCSVForm(forms.ModelForm):
  127. site = forms.ModelChoiceField(queryset=Site.objects.all(), to_field_name='name',
  128. error_messages={'invalid_choice': 'Site not found.'})
  129. group_name = forms.CharField(required=False)
  130. tenant = forms.ModelChoiceField(Tenant.objects.all(), to_field_name='name', required=False,
  131. error_messages={'invalid_choice': 'Tenant not found.'})
  132. role = forms.ModelChoiceField(RackRole.objects.all(), to_field_name='name', required=False,
  133. error_messages={'invalid_choice': 'Role not found.'})
  134. type = forms.CharField(required=False)
  135. class Meta:
  136. model = Rack
  137. fields = ['site', 'group_name', 'name', 'facility_id', 'tenant', 'role', 'type', 'width', 'u_height',
  138. 'desc_units']
  139. def clean(self):
  140. site = self.cleaned_data.get('site')
  141. group = self.cleaned_data.get('group_name')
  142. # Validate rack group
  143. if site and group:
  144. try:
  145. self.instance.group = RackGroup.objects.get(site=site, name=group)
  146. except RackGroup.DoesNotExist:
  147. self.add_error('group_name', "Invalid rack group ({})".format(group))
  148. def clean_type(self):
  149. rack_type = self.cleaned_data['type']
  150. if not rack_type:
  151. return None
  152. try:
  153. choices = {v.lower(): k for k, v in RACK_TYPE_CHOICES}
  154. return choices[rack_type.lower()]
  155. except KeyError:
  156. raise forms.ValidationError('Invalid rack type ({}). Valid choices are: {}.'.format(
  157. rack_type,
  158. ', '.join({v: k for k, v in RACK_TYPE_CHOICES}),
  159. ))
  160. class RackImportForm(BulkImportForm, BootstrapMixin):
  161. csv = CSVDataField(csv_form=RackFromCSVForm)
  162. class RackBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  163. pk = forms.ModelMultipleChoiceField(queryset=Rack.objects.all(), widget=forms.MultipleHiddenInput)
  164. site = forms.ModelChoiceField(queryset=Site.objects.all(), required=False, label='Site')
  165. group = forms.ModelChoiceField(queryset=RackGroup.objects.all(), required=False, label='Group')
  166. tenant = forms.ModelChoiceField(queryset=Tenant.objects.all(), required=False)
  167. role = forms.ModelChoiceField(queryset=RackRole.objects.all(), required=False)
  168. type = forms.ChoiceField(choices=add_blank_choice(RACK_TYPE_CHOICES), required=False, label='Type')
  169. width = forms.ChoiceField(choices=add_blank_choice(RACK_WIDTH_CHOICES), required=False, label='Width')
  170. u_height = forms.IntegerField(required=False, label='Height (U)')
  171. comments = CommentField(widget=SmallTextarea)
  172. class Meta:
  173. nullable_fields = ['group', 'tenant', 'role', 'comments']
  174. class RackFilterForm(BootstrapMixin, CustomFieldFilterForm):
  175. model = Rack
  176. site = FilterChoiceField(queryset=Site.objects.annotate(filter_count=Count('racks')), to_field_name='slug')
  177. group_id = FilterChoiceField(queryset=RackGroup.objects.select_related('site')
  178. .annotate(filter_count=Count('racks')), label='Rack group', null_option=(0, 'None'))
  179. tenant = FilterChoiceField(queryset=Tenant.objects.annotate(filter_count=Count('racks')), to_field_name='slug',
  180. null_option=(0, 'None'))
  181. role = FilterChoiceField(queryset=RackRole.objects.annotate(filter_count=Count('racks')), to_field_name='slug',
  182. null_option=(0, 'None'))
  183. #
  184. # Manufacturers
  185. #
  186. class ManufacturerForm(forms.ModelForm, BootstrapMixin):
  187. slug = SlugField()
  188. class Meta:
  189. model = Manufacturer
  190. fields = ['name', 'slug']
  191. #
  192. # Device types
  193. #
  194. class DeviceTypeForm(forms.ModelForm, BootstrapMixin):
  195. slug = SlugField(slug_source='model')
  196. class Meta:
  197. model = DeviceType
  198. fields = ['manufacturer', 'model', 'slug', 'part_number', 'u_height', 'is_full_depth', 'is_console_server',
  199. 'is_pdu', 'is_network_device', 'subdevice_role']
  200. class DeviceTypeBulkEditForm(BulkEditForm, BootstrapMixin):
  201. pk = forms.ModelMultipleChoiceField(queryset=DeviceType.objects.all(), widget=forms.MultipleHiddenInput)
  202. manufacturer = forms.ModelChoiceField(queryset=Manufacturer.objects.all(), required=False)
  203. u_height = forms.IntegerField(min_value=1, required=False)
  204. class Meta:
  205. nullable_fields = []
  206. class DeviceTypeFilterForm(forms.Form, BootstrapMixin):
  207. manufacturer = FilterChoiceField(queryset=Manufacturer.objects.annotate(filter_count=Count('device_types')),
  208. to_field_name='slug')
  209. #
  210. # Device component templates
  211. #
  212. class ConsolePortTemplateForm(forms.ModelForm, BootstrapMixin):
  213. name_pattern = ExpandableNameField(label='Name')
  214. class Meta:
  215. model = ConsolePortTemplate
  216. fields = ['name_pattern']
  217. class ConsoleServerPortTemplateForm(forms.ModelForm, BootstrapMixin):
  218. name_pattern = ExpandableNameField(label='Name')
  219. class Meta:
  220. model = ConsoleServerPortTemplate
  221. fields = ['name_pattern']
  222. class PowerPortTemplateForm(forms.ModelForm, BootstrapMixin):
  223. name_pattern = ExpandableNameField(label='Name')
  224. class Meta:
  225. model = PowerPortTemplate
  226. fields = ['name_pattern']
  227. class PowerOutletTemplateForm(forms.ModelForm, BootstrapMixin):
  228. name_pattern = ExpandableNameField(label='Name')
  229. class Meta:
  230. model = PowerOutletTemplate
  231. fields = ['name_pattern']
  232. class InterfaceTemplateForm(forms.ModelForm, BootstrapMixin):
  233. name_pattern = ExpandableNameField(label='Name')
  234. class Meta:
  235. model = InterfaceTemplate
  236. fields = ['name_pattern', 'form_factor', 'mgmt_only']
  237. class InterfaceTemplateBulkEditForm(BootstrapMixin, BulkEditForm):
  238. pk = forms.ModelMultipleChoiceField(queryset=InterfaceTemplate.objects.all(), widget=forms.MultipleHiddenInput)
  239. form_factor = forms.ChoiceField(choices=add_blank_choice(IFACE_FF_CHOICES), required=False)
  240. class Meta:
  241. nullable_fields = []
  242. class DeviceBayTemplateForm(forms.ModelForm, BootstrapMixin):
  243. name_pattern = ExpandableNameField(label='Name')
  244. class Meta:
  245. model = DeviceBayTemplate
  246. fields = ['name_pattern']
  247. #
  248. # Device roles
  249. #
  250. class DeviceRoleForm(forms.ModelForm, BootstrapMixin):
  251. slug = SlugField()
  252. class Meta:
  253. model = DeviceRole
  254. fields = ['name', 'slug', 'color']
  255. #
  256. # Platforms
  257. #
  258. class PlatformForm(forms.ModelForm, BootstrapMixin):
  259. slug = SlugField()
  260. class Meta:
  261. model = Platform
  262. fields = ['name', 'slug']
  263. #
  264. # Devices
  265. #
  266. class DeviceForm(BootstrapMixin, CustomFieldForm):
  267. site = forms.ModelChoiceField(queryset=Site.objects.all(), widget=forms.Select(attrs={'filter-for': 'rack'}))
  268. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), widget=APISelect(
  269. api_url='/api/dcim/racks/?site_id={{site}}',
  270. display_field='display_name',
  271. attrs={'filter-for': 'position'}
  272. ))
  273. position = forms.TypedChoiceField(required=False, empty_value=None,
  274. help_text="The lowest-numbered unit occupied by the device",
  275. widget=APISelect(api_url='/api/dcim/racks/{{rack}}/rack-units/?face={{face}}',
  276. disabled_indicator='device'))
  277. manufacturer = forms.ModelChoiceField(queryset=Manufacturer.objects.all(),
  278. widget=forms.Select(attrs={'filter-for': 'device_type'}))
  279. device_type = forms.ModelChoiceField(queryset=DeviceType.objects.all(), label='Device type', widget=APISelect(
  280. api_url='/api/dcim/device-types/?manufacturer_id={{manufacturer}}',
  281. display_field='model'
  282. ))
  283. comments = CommentField()
  284. class Meta:
  285. model = Device
  286. fields = ['name', 'device_role', 'tenant', 'device_type', 'serial', 'asset_tag', 'site', 'rack', 'position',
  287. 'face', 'status', 'platform', 'primary_ip4', 'primary_ip6', 'comments']
  288. help_texts = {
  289. 'device_role': "The function this device serves",
  290. 'serial': "Chassis serial number",
  291. }
  292. widgets = {
  293. 'face': forms.Select(attrs={'filter-for': 'position'}),
  294. 'manufacturer': forms.Select(attrs={'filter-for': 'device_type'}),
  295. }
  296. def __init__(self, *args, **kwargs):
  297. super(DeviceForm, self).__init__(*args, **kwargs)
  298. if self.instance.pk:
  299. # Initialize helper selections
  300. self.initial['site'] = self.instance.rack.site
  301. self.initial['manufacturer'] = self.instance.device_type.manufacturer
  302. # Compile list of choices for primary IPv4 and IPv6 addresses
  303. for family in [4, 6]:
  304. ip_choices = []
  305. interface_ips = IPAddress.objects.filter(family=family, interface__device=self.instance)
  306. ip_choices += [(ip.id, u'{} ({})'.format(ip.address, ip.interface)) for ip in interface_ips]
  307. nat_ips = IPAddress.objects.filter(family=family, nat_inside__interface__device=self.instance)\
  308. .select_related('nat_inside__interface')
  309. ip_choices += [(ip.id, u'{} ({} NAT)'.format(ip.address, ip.nat_inside.interface)) for ip in nat_ips]
  310. self.fields['primary_ip{}'.format(family)].choices = [(None, '---------')] + ip_choices
  311. else:
  312. # An object that doesn't exist yet can't have any IPs assigned to it
  313. self.fields['primary_ip4'].choices = []
  314. self.fields['primary_ip4'].widget.attrs['readonly'] = True
  315. self.fields['primary_ip6'].choices = []
  316. self.fields['primary_ip6'].widget.attrs['readonly'] = True
  317. # Limit rack choices
  318. if self.is_bound and self.data.get('site'):
  319. self.fields['rack'].queryset = Rack.objects.filter(site__pk=self.data['site'])
  320. elif self.initial.get('site'):
  321. self.fields['rack'].queryset = Rack.objects.filter(site=self.initial['site'])
  322. else:
  323. self.fields['rack'].choices = []
  324. # Rack position
  325. pk = self.instance.pk if self.instance.pk else None
  326. try:
  327. if self.is_bound and self.data.get('rack') and str(self.data.get('face')):
  328. position_choices = Rack.objects.get(pk=self.data['rack'])\
  329. .get_rack_units(face=self.data.get('face'), exclude=pk)
  330. elif self.initial.get('rack') and str(self.initial.get('face')):
  331. position_choices = Rack.objects.get(pk=self.initial['rack'])\
  332. .get_rack_units(face=self.initial.get('face'), exclude=pk)
  333. else:
  334. position_choices = []
  335. except Rack.DoesNotExist:
  336. position_choices = []
  337. self.fields['position'].choices = [('', '---------')] + [
  338. (p['id'], {
  339. 'label': p['name'],
  340. 'disabled': bool(p['device'] and p['id'] != self.initial.get('position')),
  341. }) for p in position_choices
  342. ]
  343. # Limit device_type choices
  344. if self.is_bound:
  345. self.fields['device_type'].queryset = DeviceType.objects.filter(manufacturer__pk=self.data['manufacturer'])\
  346. .select_related('manufacturer')
  347. elif self.initial.get('manufacturer'):
  348. self.fields['device_type'].queryset = DeviceType.objects.filter(manufacturer=self.initial['manufacturer'])\
  349. .select_related('manufacturer')
  350. else:
  351. self.fields['device_type'].choices = []
  352. # Disable rack assignment if this is a child device installed in a parent device
  353. if pk and self.instance.device_type.is_child_device and hasattr(self.instance, 'parent_bay'):
  354. self.fields['site'].disabled = True
  355. self.fields['rack'].disabled = True
  356. self.initial['site'] = self.instance.parent_bay.device.rack.site_id
  357. self.initial['rack'] = self.instance.parent_bay.device.rack_id
  358. class BaseDeviceFromCSVForm(forms.ModelForm):
  359. device_role = forms.ModelChoiceField(queryset=DeviceRole.objects.all(), to_field_name='name',
  360. error_messages={'invalid_choice': 'Invalid device role.'})
  361. tenant = forms.ModelChoiceField(Tenant.objects.all(), to_field_name='name', required=False,
  362. error_messages={'invalid_choice': 'Tenant not found.'})
  363. manufacturer = forms.ModelChoiceField(queryset=Manufacturer.objects.all(), to_field_name='name',
  364. error_messages={'invalid_choice': 'Invalid manufacturer.'})
  365. model_name = forms.CharField()
  366. platform = forms.ModelChoiceField(queryset=Platform.objects.all(), required=False, to_field_name='name',
  367. error_messages={'invalid_choice': 'Invalid platform.'})
  368. class Meta:
  369. fields = []
  370. model = Device
  371. def clean(self):
  372. manufacturer = self.cleaned_data.get('manufacturer')
  373. model_name = self.cleaned_data.get('model_name')
  374. # Validate device type
  375. if manufacturer and model_name:
  376. try:
  377. self.instance.device_type = DeviceType.objects.get(manufacturer=manufacturer, model=model_name)
  378. except DeviceType.DoesNotExist:
  379. self.add_error('model_name', "Invalid device type ({} {})".format(manufacturer, model_name))
  380. class DeviceFromCSVForm(BaseDeviceFromCSVForm):
  381. site = forms.ModelChoiceField(queryset=Site.objects.all(), to_field_name='name', error_messages={
  382. 'invalid_choice': 'Invalid site name.',
  383. })
  384. rack_name = forms.CharField()
  385. face = forms.CharField(required=False)
  386. class Meta(BaseDeviceFromCSVForm.Meta):
  387. fields = ['name', 'device_role', 'tenant', 'manufacturer', 'model_name', 'platform', 'serial', 'asset_tag',
  388. 'site', 'rack_name', 'position', 'face']
  389. def clean(self):
  390. super(DeviceFromCSVForm, self).clean()
  391. site = self.cleaned_data.get('site')
  392. rack_name = self.cleaned_data.get('rack_name')
  393. # Validate rack
  394. if site and rack_name:
  395. try:
  396. self.instance.rack = Rack.objects.get(site=site, name=rack_name)
  397. except Rack.DoesNotExist:
  398. self.add_error('rack_name', "Invalid rack ({})".format(rack_name))
  399. def clean_face(self):
  400. face = self.cleaned_data['face']
  401. if not face:
  402. return None
  403. try:
  404. return {
  405. 'front': 0,
  406. 'rear': 1,
  407. }[face.lower()]
  408. except KeyError:
  409. raise forms.ValidationError('Invalid rack face ({}); must be "front" or "rear".'.format(face))
  410. class ChildDeviceFromCSVForm(BaseDeviceFromCSVForm):
  411. parent = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name', required=False,
  412. error_messages={'invalid_choice': 'Parent device not found.'})
  413. device_bay_name = forms.CharField(required=False)
  414. class Meta(BaseDeviceFromCSVForm.Meta):
  415. fields = ['name', 'device_role', 'tenant', 'manufacturer', 'model_name', 'platform', 'serial', 'asset_tag',
  416. 'parent', 'device_bay_name']
  417. def clean(self):
  418. super(ChildDeviceFromCSVForm, self).clean()
  419. parent = self.cleaned_data.get('parent')
  420. device_bay_name = self.cleaned_data.get('device_bay_name')
  421. # Validate device bay
  422. if parent and device_bay_name:
  423. try:
  424. device_bay = DeviceBay.objects.get(device=parent, name=device_bay_name)
  425. if device_bay.installed_device:
  426. self.add_error('device_bay_name',
  427. "Device bay ({} {}) is already occupied".format(parent, device_bay_name))
  428. else:
  429. self.instance.parent_bay = device_bay
  430. except DeviceBay.DoesNotExist:
  431. self.add_error('device_bay_name', "Parent device/bay ({} {}) not found".format(parent, device_bay_name))
  432. class DeviceImportForm(BulkImportForm, BootstrapMixin):
  433. csv = CSVDataField(csv_form=DeviceFromCSVForm)
  434. class ChildDeviceImportForm(BulkImportForm, BootstrapMixin):
  435. csv = CSVDataField(csv_form=ChildDeviceFromCSVForm)
  436. class DeviceBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  437. pk = forms.ModelMultipleChoiceField(queryset=Device.objects.all(), widget=forms.MultipleHiddenInput)
  438. device_type = forms.ModelChoiceField(queryset=DeviceType.objects.all(), required=False, label='Type')
  439. device_role = forms.ModelChoiceField(queryset=DeviceRole.objects.all(), required=False, label='Role')
  440. tenant = forms.ModelChoiceField(queryset=Tenant.objects.all(), required=False)
  441. platform = forms.ModelChoiceField(queryset=Platform.objects.all(), required=False)
  442. status = forms.ChoiceField(choices=FORM_STATUS_CHOICES, required=False, initial='', label='Status')
  443. serial = forms.CharField(max_length=50, required=False, label='Serial Number')
  444. class Meta:
  445. nullable_fields = ['tenant', 'platform']
  446. class DeviceBulkAddComponentForm(forms.Form, BootstrapMixin):
  447. pk = forms.ModelMultipleChoiceField(queryset=Device.objects.all(), widget=forms.MultipleHiddenInput)
  448. name_pattern = ExpandableNameField(label='Name')
  449. class DeviceBulkAddInterfaceForm(forms.ModelForm, DeviceBulkAddComponentForm):
  450. class Meta:
  451. model = Interface
  452. fields = ['name_pattern', 'form_factor', 'mgmt_only', 'description']
  453. class DeviceFilterForm(BootstrapMixin, CustomFieldFilterForm):
  454. model = Device
  455. site = FilterChoiceField(queryset=Site.objects.annotate(filter_count=Count('racks__devices')), to_field_name='slug')
  456. rack_group_id = FilterChoiceField(queryset=RackGroup.objects.annotate(filter_count=Count('racks__devices')),
  457. label='Rack Group')
  458. role = FilterChoiceField(queryset=DeviceRole.objects.annotate(filter_count=Count('devices')), to_field_name='slug')
  459. tenant = FilterChoiceField(queryset=Tenant.objects.annotate(filter_count=Count('devices')), to_field_name='slug',
  460. null_option=(0, 'None'))
  461. device_type_id = FilterChoiceField(queryset=DeviceType.objects.select_related('manufacturer')
  462. .annotate(filter_count=Count('instances')), label='Type')
  463. platform = FilterChoiceField(queryset=Platform.objects.annotate(filter_count=Count('devices')),
  464. to_field_name='slug', null_option=(0, 'None'))
  465. status = forms.NullBooleanField(required=False, widget=forms.Select(choices=FORM_STATUS_CHOICES))
  466. mac_address = forms.CharField(required=False, label='MAC address')
  467. #
  468. # Console ports
  469. #
  470. class ConsolePortForm(forms.ModelForm, BootstrapMixin):
  471. class Meta:
  472. model = ConsolePort
  473. fields = ['device', 'name']
  474. widgets = {
  475. 'device': forms.HiddenInput(),
  476. }
  477. class ConsolePortCreateForm(forms.Form, BootstrapMixin):
  478. name_pattern = ExpandableNameField(label='Name')
  479. class ConsoleConnectionCSVForm(forms.Form):
  480. console_server = FlexibleModelChoiceField(queryset=Device.objects.filter(device_type__is_console_server=True),
  481. to_field_name='name',
  482. error_messages={'invalid_choice': 'Console server not found'})
  483. cs_port = forms.CharField()
  484. device = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name',
  485. error_messages={'invalid_choice': 'Device not found'})
  486. console_port = forms.CharField()
  487. status = forms.CharField(validators=[validate_connection_status])
  488. def clean(self):
  489. # Validate console server port
  490. if self.cleaned_data.get('console_server'):
  491. try:
  492. cs_port = ConsoleServerPort.objects.get(device=self.cleaned_data['console_server'],
  493. name=self.cleaned_data['cs_port'])
  494. if ConsolePort.objects.filter(cs_port=cs_port):
  495. raise forms.ValidationError("Console server port is already occupied (by {} {})"
  496. .format(cs_port.connected_console.device, cs_port.connected_console))
  497. except ConsoleServerPort.DoesNotExist:
  498. raise forms.ValidationError("Invalid console server port ({} {})"
  499. .format(self.cleaned_data['console_server'], self.cleaned_data['cs_port']))
  500. # Validate console port
  501. if self.cleaned_data.get('device'):
  502. try:
  503. console_port = ConsolePort.objects.get(device=self.cleaned_data['device'],
  504. name=self.cleaned_data['console_port'])
  505. if console_port.cs_port:
  506. raise forms.ValidationError("Console port is already connected (to {} {})"
  507. .format(console_port.cs_port.device, console_port.cs_port))
  508. except ConsolePort.DoesNotExist:
  509. raise forms.ValidationError("Invalid console port ({} {})"
  510. .format(self.cleaned_data['device'], self.cleaned_data['console_port']))
  511. class ConsoleConnectionImportForm(BulkImportForm, BootstrapMixin):
  512. csv = CSVDataField(csv_form=ConsoleConnectionCSVForm)
  513. def clean(self):
  514. records = self.cleaned_data.get('csv')
  515. if not records:
  516. return
  517. connection_list = []
  518. for i, record in enumerate(records, start=1):
  519. form = self.fields['csv'].csv_form(data=record)
  520. if form.is_valid():
  521. console_port = ConsolePort.objects.get(device=form.cleaned_data['device'],
  522. name=form.cleaned_data['console_port'])
  523. console_port.cs_port = ConsoleServerPort.objects.get(device=form.cleaned_data['console_server'],
  524. name=form.cleaned_data['cs_port'])
  525. if form.cleaned_data['status'] == 'planned':
  526. console_port.connection_status = CONNECTION_STATUS_PLANNED
  527. else:
  528. console_port.connection_status = CONNECTION_STATUS_CONNECTED
  529. connection_list.append(console_port)
  530. else:
  531. for field, errors in form.errors.items():
  532. for e in errors:
  533. self.add_error('csv', "Record {} {}: {}".format(i, field, e))
  534. self.cleaned_data['csv'] = connection_list
  535. class ConsolePortConnectionForm(forms.ModelForm, BootstrapMixin):
  536. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  537. widget=forms.Select(attrs={'filter-for': 'console_server'}))
  538. console_server = forms.ModelChoiceField(queryset=Device.objects.all(), label='Console Server', required=False,
  539. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack}}&is_console_server=True',
  540. display_field='display_name',
  541. attrs={'filter-for': 'cs_port'}))
  542. livesearch = forms.CharField(required=False, label='Console Server', widget=Livesearch(
  543. query_key='q', query_url='dcim-api:device_list', field_to_update='console_server')
  544. )
  545. cs_port = forms.ModelChoiceField(queryset=ConsoleServerPort.objects.all(), label='Port',
  546. widget=APISelect(api_url='/api/dcim/devices/{{console_server}}/console-server-ports/',
  547. disabled_indicator='connected_console'))
  548. class Meta:
  549. model = ConsolePort
  550. fields = ['rack', 'console_server', 'livesearch', 'cs_port', 'connection_status']
  551. labels = {
  552. 'cs_port': 'Port',
  553. 'connection_status': 'Status',
  554. }
  555. def __init__(self, *args, **kwargs):
  556. super(ConsolePortConnectionForm, self).__init__(*args, **kwargs)
  557. if not self.instance.pk:
  558. raise RuntimeError("ConsolePortConnectionForm must be initialized with an existing ConsolePort instance.")
  559. self.fields['rack'].queryset = Rack.objects.filter(site=self.instance.device.rack.site)
  560. self.fields['cs_port'].required = True
  561. self.fields['connection_status'].choices = CONNECTION_STATUS_CHOICES
  562. # Initialize console server choices
  563. if self.is_bound and self.data.get('rack'):
  564. self.fields['console_server'].queryset = Device.objects.filter(rack=self.data['rack'], device_type__is_console_server=True)
  565. elif self.initial.get('rack'):
  566. self.fields['console_server'].queryset = Device.objects.filter(rack=self.initial['rack'], device_type__is_console_server=True)
  567. else:
  568. self.fields['console_server'].choices = []
  569. # Initialize CS port choices
  570. if self.is_bound:
  571. self.fields['cs_port'].queryset = ConsoleServerPort.objects.filter(device__pk=self.data['console_server'])
  572. elif self.initial.get('console_server', None):
  573. self.fields['cs_port'].queryset = ConsoleServerPort.objects.filter(device__pk=self.initial['console_server'])
  574. else:
  575. self.fields['cs_port'].choices = []
  576. #
  577. # Console server ports
  578. #
  579. class ConsoleServerPortForm(forms.ModelForm, BootstrapMixin):
  580. class Meta:
  581. model = ConsoleServerPort
  582. fields = ['device', 'name']
  583. widgets = {
  584. 'device': forms.HiddenInput(),
  585. }
  586. class ConsoleServerPortCreateForm(forms.Form, BootstrapMixin):
  587. name_pattern = ExpandableNameField(label='Name')
  588. class ConsoleServerPortConnectionForm(forms.Form, BootstrapMixin):
  589. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  590. widget=forms.Select(attrs={'filter-for': 'device'}))
  591. device = forms.ModelChoiceField(queryset=Device.objects.all(), label='Device', required=False,
  592. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack}}',
  593. display_field='display_name', attrs={'filter-for': 'port'}))
  594. livesearch = forms.CharField(required=False, label='Device', widget=Livesearch(
  595. query_key='q', query_url='dcim-api:device_list', field_to_update='device')
  596. )
  597. port = forms.ModelChoiceField(queryset=ConsolePort.objects.all(), label='Port',
  598. widget=APISelect(api_url='/api/dcim/devices/{{device}}/console-ports/',
  599. disabled_indicator='cs_port'))
  600. connection_status = forms.BooleanField(required=False, initial=CONNECTION_STATUS_CONNECTED, label='Status',
  601. widget=forms.Select(choices=CONNECTION_STATUS_CHOICES))
  602. class Meta:
  603. fields = ['rack', 'device', 'livesearch', 'port', 'connection_status']
  604. labels = {
  605. 'connection_status': 'Status',
  606. }
  607. def __init__(self, consoleserverport, *args, **kwargs):
  608. super(ConsoleServerPortConnectionForm, self).__init__(*args, **kwargs)
  609. self.fields['rack'].queryset = Rack.objects.filter(site=consoleserverport.device.rack.site)
  610. # Initialize device choices
  611. if self.is_bound and self.data.get('rack'):
  612. self.fields['device'].queryset = Device.objects.filter(rack=self.data['rack'])
  613. elif self.initial.get('rack', None):
  614. self.fields['device'].queryset = Device.objects.filter(rack=self.initial['rack'])
  615. else:
  616. self.fields['device'].choices = []
  617. # Initialize port choices
  618. if self.is_bound:
  619. self.fields['port'].queryset = ConsolePort.objects.filter(device__pk=self.data['device'])
  620. elif self.initial.get('device', None):
  621. self.fields['port'].queryset = ConsolePort.objects.filter(device_pk=self.initial['device'])
  622. else:
  623. self.fields['port'].choices = []
  624. #
  625. # Power ports
  626. #
  627. class PowerPortForm(forms.ModelForm, BootstrapMixin):
  628. class Meta:
  629. model = PowerPort
  630. fields = ['device', 'name']
  631. widgets = {
  632. 'device': forms.HiddenInput(),
  633. }
  634. class PowerPortCreateForm(forms.Form, BootstrapMixin):
  635. name_pattern = ExpandableNameField(label='Name')
  636. class PowerConnectionCSVForm(forms.Form):
  637. pdu = FlexibleModelChoiceField(queryset=Device.objects.filter(device_type__is_pdu=True), to_field_name='name',
  638. error_messages={'invalid_choice': 'PDU not found.'})
  639. power_outlet = forms.CharField()
  640. device = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name',
  641. error_messages={'invalid_choice': 'Device not found'})
  642. power_port = forms.CharField()
  643. status = forms.CharField(validators=[validate_connection_status])
  644. def clean(self):
  645. # Validate power outlet
  646. if self.cleaned_data.get('pdu'):
  647. try:
  648. power_outlet = PowerOutlet.objects.get(device=self.cleaned_data['pdu'],
  649. name=self.cleaned_data['power_outlet'])
  650. if PowerPort.objects.filter(power_outlet=power_outlet):
  651. raise forms.ValidationError("Power outlet is already occupied (by {} {})"
  652. .format(power_outlet.connected_port.device,
  653. power_outlet.connected_port))
  654. except PowerOutlet.DoesNotExist:
  655. raise forms.ValidationError("Invalid PDU port ({} {})"
  656. .format(self.cleaned_data['pdu'], self.cleaned_data['power_outlet']))
  657. # Validate power port
  658. if self.cleaned_data.get('device'):
  659. try:
  660. power_port = PowerPort.objects.get(device=self.cleaned_data['device'],
  661. name=self.cleaned_data['power_port'])
  662. if power_port.power_outlet:
  663. raise forms.ValidationError("Power port is already connected (to {} {})"
  664. .format(power_port.power_outlet.device, power_port.power_outlet))
  665. except PowerPort.DoesNotExist:
  666. raise forms.ValidationError("Invalid power port ({} {})"
  667. .format(self.cleaned_data['device'], self.cleaned_data['power_port']))
  668. class PowerConnectionImportForm(BulkImportForm, BootstrapMixin):
  669. csv = CSVDataField(csv_form=PowerConnectionCSVForm)
  670. def clean(self):
  671. records = self.cleaned_data.get('csv')
  672. if not records:
  673. return
  674. connection_list = []
  675. for i, record in enumerate(records, start=1):
  676. form = self.fields['csv'].csv_form(data=record)
  677. if form.is_valid():
  678. power_port = PowerPort.objects.get(device=form.cleaned_data['device'],
  679. name=form.cleaned_data['power_port'])
  680. power_port.power_outlet = PowerOutlet.objects.get(device=form.cleaned_data['pdu'],
  681. name=form.cleaned_data['power_outlet'])
  682. if form.cleaned_data['status'] == 'planned':
  683. power_port.connection_status = CONNECTION_STATUS_PLANNED
  684. else:
  685. power_port.connection_status = CONNECTION_STATUS_CONNECTED
  686. connection_list.append(power_port)
  687. else:
  688. for field, errors in form.errors.items():
  689. for e in errors:
  690. self.add_error('csv', "Record {} {}: {}".format(i, field, e))
  691. self.cleaned_data['csv'] = connection_list
  692. class PowerPortConnectionForm(forms.ModelForm, BootstrapMixin):
  693. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  694. widget=forms.Select(attrs={'filter-for': 'pdu'}))
  695. pdu = forms.ModelChoiceField(queryset=Device.objects.all(), label='PDU', required=False,
  696. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack}}&is_pdu=True',
  697. display_field='display_name', attrs={'filter-for': 'power_outlet'}))
  698. livesearch = forms.CharField(required=False, label='PDU', widget=Livesearch(
  699. query_key='q', query_url='dcim-api:device_list', field_to_update='pdu')
  700. )
  701. power_outlet = forms.ModelChoiceField(queryset=PowerOutlet.objects.all(), label='Outlet',
  702. widget=APISelect(api_url='/api/dcim/devices/{{pdu}}/power-outlets/',
  703. disabled_indicator='connected_port'))
  704. class Meta:
  705. model = PowerPort
  706. fields = ['rack', 'pdu', 'livesearch', 'power_outlet', 'connection_status']
  707. labels = {
  708. 'power_outlet': 'Outlet',
  709. 'connection_status': 'Status',
  710. }
  711. def __init__(self, *args, **kwargs):
  712. super(PowerPortConnectionForm, self).__init__(*args, **kwargs)
  713. if not self.instance.pk:
  714. raise RuntimeError("PowerPortConnectionForm must be initialized with an existing PowerPort instance.")
  715. self.fields['rack'].queryset = Rack.objects.filter(site=self.instance.device.rack.site)
  716. self.fields['power_outlet'].required = True
  717. self.fields['connection_status'].choices = CONNECTION_STATUS_CHOICES
  718. # Initialize PDU choices
  719. if self.is_bound and self.data.get('rack'):
  720. self.fields['pdu'].queryset = Device.objects.filter(rack=self.data['rack'], device_type__is_pdu=True)
  721. elif self.initial.get('rack', None):
  722. self.fields['pdu'].queryset = Device.objects.filter(rack=self.initial['rack'], device_type__is_pdu=True)
  723. else:
  724. self.fields['pdu'].choices = []
  725. # Initialize power outlet choices
  726. if self.is_bound:
  727. self.fields['power_outlet'].queryset = PowerOutlet.objects.filter(device__pk=self.data['pdu'])
  728. elif self.initial.get('pdu', None):
  729. self.fields['power_outlet'].queryset = PowerOutlet.objects.filter(device__pk=self.initial['pdu'])
  730. else:
  731. self.fields['power_outlet'].choices = []
  732. #
  733. # Power outlets
  734. #
  735. class PowerOutletForm(forms.ModelForm, BootstrapMixin):
  736. class Meta:
  737. model = PowerOutlet
  738. fields = ['device', 'name']
  739. widgets = {
  740. 'device': forms.HiddenInput(),
  741. }
  742. class PowerOutletCreateForm(forms.Form, BootstrapMixin):
  743. name_pattern = ExpandableNameField(label='Name')
  744. class PowerOutletConnectionForm(forms.Form, BootstrapMixin):
  745. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  746. widget=forms.Select(attrs={'filter-for': 'device'}))
  747. device = forms.ModelChoiceField(queryset=Device.objects.all(), label='Device', required=False,
  748. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack}}',
  749. display_field='display_name', attrs={'filter-for': 'port'}))
  750. livesearch = forms.CharField(required=False, label='Device', widget=Livesearch(
  751. query_key='q', query_url='dcim-api:device_list', field_to_update='device')
  752. )
  753. port = forms.ModelChoiceField(queryset=PowerPort.objects.all(), label='Port',
  754. widget=APISelect(api_url='/api/dcim/devices/{{device}}/power-ports/',
  755. disabled_indicator='power_outlet'))
  756. connection_status = forms.BooleanField(required=False, initial=CONNECTION_STATUS_CONNECTED, label='Status',
  757. widget=forms.Select(choices=CONNECTION_STATUS_CHOICES))
  758. class Meta:
  759. fields = ['rack', 'device', 'livesearch', 'port', 'connection_status']
  760. labels = {
  761. 'connection_status': 'Status',
  762. }
  763. def __init__(self, poweroutlet, *args, **kwargs):
  764. super(PowerOutletConnectionForm, self).__init__(*args, **kwargs)
  765. self.fields['rack'].queryset = Rack.objects.filter(site=poweroutlet.device.rack.site)
  766. # Initialize device choices
  767. if self.is_bound and self.data.get('rack'):
  768. self.fields['device'].queryset = Device.objects.filter(rack=self.data['rack'])
  769. elif self.initial.get('rack', None):
  770. self.fields['device'].queryset = Device.objects.filter(rack=self.initial['rack'])
  771. else:
  772. self.fields['device'].choices = []
  773. # Initialize port choices
  774. if self.is_bound:
  775. self.fields['port'].queryset = PowerPort.objects.filter(device__pk=self.data['device'])
  776. elif self.initial.get('device', None):
  777. self.fields['port'].queryset = PowerPort.objects.filter(device_pk=self.initial['device'])
  778. else:
  779. self.fields['port'].choices = []
  780. #
  781. # Interfaces
  782. #
  783. class InterfaceForm(forms.ModelForm, BootstrapMixin):
  784. class Meta:
  785. model = Interface
  786. fields = ['device', 'name', 'form_factor', 'mac_address', 'mgmt_only', 'description']
  787. widgets = {
  788. 'device': forms.HiddenInput(),
  789. }
  790. class InterfaceCreateForm(forms.ModelForm, BootstrapMixin):
  791. name_pattern = ExpandableNameField(label='Name')
  792. class Meta:
  793. model = Interface
  794. fields = ['name_pattern', 'form_factor', 'mac_address', 'mgmt_only', 'description']
  795. class InterfaceBulkEditForm(BootstrapMixin, BulkEditForm):
  796. pk = forms.ModelMultipleChoiceField(queryset=Interface.objects.all(), widget=forms.MultipleHiddenInput)
  797. form_factor = forms.ChoiceField(choices=add_blank_choice(IFACE_FF_CHOICES), required=False)
  798. description = forms.CharField(max_length=100, required=False)
  799. class Meta:
  800. nullable_fields = ['description']
  801. #
  802. # Interface connections
  803. #
  804. class InterfaceConnectionForm(forms.ModelForm, BootstrapMixin):
  805. interface_a = forms.ChoiceField(choices=[], widget=SelectWithDisabled, label='Interface')
  806. rack_b = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  807. widget=forms.Select(attrs={'filter-for': 'device_b'}))
  808. device_b = forms.ModelChoiceField(queryset=Device.objects.all(), label='Device', required=False,
  809. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack_b}}',
  810. display_field='display_name',
  811. attrs={'filter-for': 'interface_b'}))
  812. livesearch = forms.CharField(required=False, label='Device', widget=Livesearch(
  813. query_key='q', query_url='dcim-api:device_list', field_to_update='device_b')
  814. )
  815. interface_b = forms.ModelChoiceField(queryset=Interface.objects.all(), label='Interface',
  816. widget=APISelect(api_url='/api/dcim/devices/{{device_b}}/interfaces/?type=physical',
  817. disabled_indicator='is_connected'))
  818. class Meta:
  819. model = InterfaceConnection
  820. fields = ['interface_a', 'rack_b', 'device_b', 'interface_b', 'livesearch', 'connection_status']
  821. def __init__(self, device_a, *args, **kwargs):
  822. super(InterfaceConnectionForm, self).__init__(*args, **kwargs)
  823. self.fields['rack_b'].queryset = Rack.objects.filter(site=device_a.rack.site)
  824. # Initialize interface A choices
  825. device_a_interfaces = Interface.objects.filter(device=device_a).exclude(form_factor=IFACE_FF_VIRTUAL) \
  826. .select_related('circuit', 'connected_as_a', 'connected_as_b')
  827. self.fields['interface_a'].choices = [
  828. (iface.id, {'label': iface.name, 'disabled': iface.is_connected}) for iface in device_a_interfaces
  829. ]
  830. # Initialize device_b choices if rack_b is set
  831. if self.is_bound and self.data.get('rack_b'):
  832. self.fields['device_b'].queryset = Device.objects.filter(rack__pk=self.data['rack_b'])
  833. elif self.initial.get('rack_b'):
  834. self.fields['device_b'].queryset = Device.objects.filter(rack=self.initial['rack_b'])
  835. else:
  836. self.fields['device_b'].choices = []
  837. # Initialize interface_b choices if device_b is set
  838. if self.is_bound:
  839. device_b_interfaces = Interface.objects.filter(device=self.data['device_b']) \
  840. .exclude(form_factor=IFACE_FF_VIRTUAL).select_related('circuit', 'connected_as_a', 'connected_as_b')
  841. elif self.initial.get('device_b'):
  842. device_b_interfaces = Interface.objects.filter(device=self.initial['device_b']) \
  843. .exclude(form_factor=IFACE_FF_VIRTUAL).select_related('circuit', 'connected_as_a', 'connected_as_b')
  844. else:
  845. device_b_interfaces = []
  846. self.fields['interface_b'].choices = [
  847. (iface.id, {'label': iface.name, 'disabled': iface.is_connected}) for iface in device_b_interfaces
  848. ]
  849. class InterfaceConnectionCSVForm(forms.Form):
  850. device_a = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name',
  851. error_messages={'invalid_choice': 'Device A not found.'})
  852. interface_a = forms.CharField()
  853. device_b = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name',
  854. error_messages={'invalid_choice': 'Device B not found.'})
  855. interface_b = forms.CharField()
  856. status = forms.CharField(validators=[validate_connection_status])
  857. def clean(self):
  858. # Validate interface A
  859. if self.cleaned_data.get('device_a'):
  860. try:
  861. interface_a = Interface.objects.get(device=self.cleaned_data['device_a'],
  862. name=self.cleaned_data['interface_a'])
  863. except Interface.DoesNotExist:
  864. raise forms.ValidationError("Invalid interface ({} {})"
  865. .format(self.cleaned_data['device_a'], self.cleaned_data['interface_a']))
  866. try:
  867. InterfaceConnection.objects.get(Q(interface_a=interface_a) | Q(interface_b=interface_a))
  868. raise forms.ValidationError("{} {} is already connected"
  869. .format(self.cleaned_data['device_a'], self.cleaned_data['interface_a']))
  870. except InterfaceConnection.DoesNotExist:
  871. pass
  872. # Validate interface B
  873. if self.cleaned_data.get('device_b'):
  874. try:
  875. interface_b = Interface.objects.get(device=self.cleaned_data['device_b'],
  876. name=self.cleaned_data['interface_b'])
  877. except Interface.DoesNotExist:
  878. raise forms.ValidationError("Invalid interface ({} {})"
  879. .format(self.cleaned_data['device_b'], self.cleaned_data['interface_b']))
  880. try:
  881. InterfaceConnection.objects.get(Q(interface_a=interface_b) | Q(interface_b=interface_b))
  882. raise forms.ValidationError("{} {} is already connected"
  883. .format(self.cleaned_data['device_b'], self.cleaned_data['interface_b']))
  884. except InterfaceConnection.DoesNotExist:
  885. pass
  886. class InterfaceConnectionImportForm(BulkImportForm, BootstrapMixin):
  887. csv = CSVDataField(csv_form=InterfaceConnectionCSVForm)
  888. def clean(self):
  889. records = self.cleaned_data.get('csv')
  890. if not records:
  891. return
  892. connection_list = []
  893. occupied_interfaces = []
  894. for i, record in enumerate(records, start=1):
  895. form = self.fields['csv'].csv_form(data=record)
  896. if form.is_valid():
  897. interface_a = Interface.objects.get(device=form.cleaned_data['device_a'],
  898. name=form.cleaned_data['interface_a'])
  899. if interface_a in occupied_interfaces:
  900. raise forms.ValidationError("{} {} found in multiple connections"
  901. .format(interface_a.device.name, interface_a.name))
  902. interface_b = Interface.objects.get(device=form.cleaned_data['device_b'],
  903. name=form.cleaned_data['interface_b'])
  904. if interface_b in occupied_interfaces:
  905. raise forms.ValidationError("{} {} found in multiple connections"
  906. .format(interface_b.device.name, interface_b.name))
  907. connection = InterfaceConnection(interface_a=interface_a, interface_b=interface_b)
  908. if form.cleaned_data['status'] == 'planned':
  909. connection.connection_status = CONNECTION_STATUS_PLANNED
  910. else:
  911. connection.connection_status = CONNECTION_STATUS_CONNECTED
  912. connection_list.append(connection)
  913. occupied_interfaces.append(interface_a)
  914. occupied_interfaces.append(interface_b)
  915. else:
  916. for field, errors in form.errors.items():
  917. for e in errors:
  918. self.add_error('csv', "Record {} {}: {}".format(i, field, e))
  919. self.cleaned_data['csv'] = connection_list
  920. class InterfaceConnectionDeletionForm(forms.Form, BootstrapMixin):
  921. confirm = forms.BooleanField(required=True)
  922. # Used for HTTP redirect upon successful deletion
  923. device = forms.ModelChoiceField(queryset=Device.objects.all(), widget=forms.HiddenInput(), required=False)
  924. #
  925. # Device bays
  926. #
  927. class DeviceBayForm(forms.ModelForm, BootstrapMixin):
  928. class Meta:
  929. model = DeviceBay
  930. fields = ['device', 'name']
  931. widgets = {
  932. 'device': forms.HiddenInput(),
  933. }
  934. class DeviceBayCreateForm(forms.Form, BootstrapMixin):
  935. name_pattern = ExpandableNameField(label='Name')
  936. class PopulateDeviceBayForm(forms.Form, BootstrapMixin):
  937. installed_device = forms.ModelChoiceField(queryset=Device.objects.all(), label='Child Device',
  938. help_text="Child devices must first be created within the rack occupied "
  939. "by the parent device. Then they can be assigned to a bay.")
  940. def __init__(self, device_bay, *args, **kwargs):
  941. super(PopulateDeviceBayForm, self).__init__(*args, **kwargs)
  942. children_queryset = Device.objects.filter(rack=device_bay.device.rack,
  943. parent_bay__isnull=True,
  944. device_type__u_height=0,
  945. device_type__subdevice_role=SUBDEVICE_ROLE_CHILD)\
  946. .exclude(pk=device_bay.device.pk)
  947. self.fields['installed_device'].queryset = children_queryset
  948. #
  949. # Connections
  950. #
  951. class ConsoleConnectionFilterForm(forms.Form, BootstrapMixin):
  952. site = forms.ModelChoiceField(required=False, queryset=Site.objects.all(), to_field_name='slug')
  953. class PowerConnectionFilterForm(forms.Form, BootstrapMixin):
  954. site = forms.ModelChoiceField(required=False, queryset=Site.objects.all(), to_field_name='slug')
  955. class InterfaceConnectionFilterForm(forms.Form, BootstrapMixin):
  956. site = forms.ModelChoiceField(required=False, queryset=Site.objects.all(), to_field_name='slug')
  957. #
  958. # IP addresses
  959. #
  960. class IPAddressForm(BootstrapMixin, CustomFieldForm):
  961. set_as_primary = forms.BooleanField(label='Set as primary IP for device', required=False)
  962. class Meta:
  963. model = IPAddress
  964. fields = ['address', 'vrf', 'tenant', 'status', 'interface', 'description']
  965. def __init__(self, device, *args, **kwargs):
  966. super(IPAddressForm, self).__init__(*args, **kwargs)
  967. self.fields['vrf'].empty_label = 'Global'
  968. interfaces = device.interfaces.all()
  969. self.fields['interface'].queryset = interfaces
  970. self.fields['interface'].required = True
  971. # If this device has only one interface, select it by default.
  972. if len(interfaces) == 1:
  973. self.fields['interface'].initial = interfaces[0]
  974. # If this device does not have any IP addresses assigned, default to setting the first IP as its primary.
  975. if not IPAddress.objects.filter(interface__device=device).count():
  976. self.fields['set_as_primary'].initial = True
  977. #
  978. # Modules
  979. #
  980. class ModuleForm(forms.ModelForm, BootstrapMixin):
  981. class Meta:
  982. model = Module
  983. fields = ['name', 'manufacturer', 'part_id', 'serial']