forms.py 53 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268
  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()
  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 DeviceTypeFilterForm(forms.Form, BootstrapMixin):
  205. manufacturer = FilterChoiceField(queryset=Manufacturer.objects.annotate(filter_count=Count('device_types')),
  206. to_field_name='slug')
  207. #
  208. # Device component templates
  209. #
  210. class ConsolePortTemplateForm(forms.ModelForm, BootstrapMixin):
  211. name_pattern = ExpandableNameField(label='Name')
  212. class Meta:
  213. model = ConsolePortTemplate
  214. fields = ['name_pattern']
  215. class ConsoleServerPortTemplateForm(forms.ModelForm, BootstrapMixin):
  216. name_pattern = ExpandableNameField(label='Name')
  217. class Meta:
  218. model = ConsoleServerPortTemplate
  219. fields = ['name_pattern']
  220. class PowerPortTemplateForm(forms.ModelForm, BootstrapMixin):
  221. name_pattern = ExpandableNameField(label='Name')
  222. class Meta:
  223. model = PowerPortTemplate
  224. fields = ['name_pattern']
  225. class PowerOutletTemplateForm(forms.ModelForm, BootstrapMixin):
  226. name_pattern = ExpandableNameField(label='Name')
  227. class Meta:
  228. model = PowerOutletTemplate
  229. fields = ['name_pattern']
  230. class InterfaceTemplateForm(forms.ModelForm, BootstrapMixin):
  231. name_pattern = ExpandableNameField(label='Name')
  232. class Meta:
  233. model = InterfaceTemplate
  234. fields = ['name_pattern', 'form_factor', 'mgmt_only']
  235. class InterfaceTemplateBulkEditForm(BootstrapMixin, BulkEditForm):
  236. pk = forms.ModelMultipleChoiceField(queryset=InterfaceTemplate.objects.all(), widget=forms.MultipleHiddenInput)
  237. form_factor = forms.ChoiceField(choices=add_blank_choice(IFACE_FF_CHOICES), required=False)
  238. class Meta:
  239. nullable_fields = []
  240. class DeviceBayTemplateForm(forms.ModelForm, BootstrapMixin):
  241. name_pattern = ExpandableNameField(label='Name')
  242. class Meta:
  243. model = DeviceBayTemplate
  244. fields = ['name_pattern']
  245. #
  246. # Device roles
  247. #
  248. class DeviceRoleForm(forms.ModelForm, BootstrapMixin):
  249. slug = SlugField()
  250. class Meta:
  251. model = DeviceRole
  252. fields = ['name', 'slug', 'color']
  253. #
  254. # Platforms
  255. #
  256. class PlatformForm(forms.ModelForm, BootstrapMixin):
  257. slug = SlugField()
  258. class Meta:
  259. model = Platform
  260. fields = ['name', 'slug']
  261. #
  262. # Devices
  263. #
  264. class DeviceForm(BootstrapMixin, CustomFieldForm):
  265. site = forms.ModelChoiceField(queryset=Site.objects.all(), widget=forms.Select(attrs={'filter-for': 'rack'}))
  266. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), widget=APISelect(
  267. api_url='/api/dcim/racks/?site_id={{site}}',
  268. display_field='display_name',
  269. attrs={'filter-for': 'position'}
  270. ))
  271. position = forms.TypedChoiceField(required=False, empty_value=None,
  272. help_text="The lowest-numbered unit occupied by the device",
  273. widget=APISelect(api_url='/api/dcim/racks/{{rack}}/rack-units/?face={{face}}',
  274. disabled_indicator='device'))
  275. manufacturer = forms.ModelChoiceField(queryset=Manufacturer.objects.all(),
  276. widget=forms.Select(attrs={'filter-for': 'device_type'}))
  277. device_type = forms.ModelChoiceField(queryset=DeviceType.objects.all(), label='Device type', widget=APISelect(
  278. api_url='/api/dcim/device-types/?manufacturer_id={{manufacturer}}',
  279. display_field='model'
  280. ))
  281. comments = CommentField()
  282. class Meta:
  283. model = Device
  284. fields = ['name', 'device_role', 'tenant', 'device_type', 'serial', 'asset_tag', 'site', 'rack', 'position',
  285. 'face', 'status', 'platform', 'primary_ip4', 'primary_ip6', 'comments']
  286. help_texts = {
  287. 'device_role': "The function this device serves",
  288. 'serial': "Chassis serial number",
  289. }
  290. widgets = {
  291. 'face': forms.Select(attrs={'filter-for': 'position'}),
  292. 'manufacturer': forms.Select(attrs={'filter-for': 'device_type'}),
  293. }
  294. def __init__(self, *args, **kwargs):
  295. super(DeviceForm, self).__init__(*args, **kwargs)
  296. if self.instance.pk:
  297. # Initialize helper selections
  298. self.initial['site'] = self.instance.rack.site
  299. self.initial['manufacturer'] = self.instance.device_type.manufacturer
  300. # Compile list of choices for primary IPv4 and IPv6 addresses
  301. for family in [4, 6]:
  302. ip_choices = []
  303. interface_ips = IPAddress.objects.filter(family=family, interface__device=self.instance)
  304. ip_choices += [(ip.id, u'{} ({})'.format(ip.address, ip.interface)) for ip in interface_ips]
  305. nat_ips = IPAddress.objects.filter(family=family, nat_inside__interface__device=self.instance)\
  306. .select_related('nat_inside__interface')
  307. ip_choices += [(ip.id, u'{} ({} NAT)'.format(ip.address, ip.nat_inside.interface)) for ip in nat_ips]
  308. self.fields['primary_ip{}'.format(family)].choices = [(None, '---------')] + ip_choices
  309. else:
  310. # An object that doesn't exist yet can't have any IPs assigned to it
  311. self.fields['primary_ip4'].choices = []
  312. self.fields['primary_ip4'].widget.attrs['readonly'] = True
  313. self.fields['primary_ip6'].choices = []
  314. self.fields['primary_ip6'].widget.attrs['readonly'] = True
  315. # Limit rack choices
  316. if self.is_bound and self.data.get('site'):
  317. self.fields['rack'].queryset = Rack.objects.filter(site__pk=self.data['site'])
  318. elif self.initial.get('site'):
  319. self.fields['rack'].queryset = Rack.objects.filter(site=self.initial['site'])
  320. else:
  321. self.fields['rack'].choices = []
  322. # Rack position
  323. pk = self.instance.pk if self.instance.pk else None
  324. try:
  325. if self.is_bound and self.data.get('rack') and str(self.data.get('face')):
  326. position_choices = Rack.objects.get(pk=self.data['rack'])\
  327. .get_rack_units(face=self.data.get('face'), exclude=pk)
  328. elif self.initial.get('rack') and str(self.initial.get('face')):
  329. position_choices = Rack.objects.get(pk=self.initial['rack'])\
  330. .get_rack_units(face=self.initial.get('face'), exclude=pk)
  331. else:
  332. position_choices = []
  333. except Rack.DoesNotExist:
  334. position_choices = []
  335. self.fields['position'].choices = [('', '---------')] + [
  336. (p['id'], {
  337. 'label': p['name'],
  338. 'disabled': bool(p['device'] and p['id'] != self.initial.get('position')),
  339. }) for p in position_choices
  340. ]
  341. # Limit device_type choices
  342. if self.is_bound:
  343. self.fields['device_type'].queryset = DeviceType.objects.filter(manufacturer__pk=self.data['manufacturer'])\
  344. .select_related('manufacturer')
  345. elif self.initial.get('manufacturer'):
  346. self.fields['device_type'].queryset = DeviceType.objects.filter(manufacturer=self.initial['manufacturer'])\
  347. .select_related('manufacturer')
  348. else:
  349. self.fields['device_type'].choices = []
  350. # Disable rack assignment if this is a child device installed in a parent device
  351. if pk and self.instance.device_type.is_child_device and hasattr(self.instance, 'parent_bay'):
  352. self.fields['site'].disabled = True
  353. self.fields['rack'].disabled = True
  354. self.initial['site'] = self.instance.parent_bay.device.rack.site_id
  355. self.initial['rack'] = self.instance.parent_bay.device.rack_id
  356. class BaseDeviceFromCSVForm(forms.ModelForm):
  357. device_role = forms.ModelChoiceField(queryset=DeviceRole.objects.all(), to_field_name='name',
  358. error_messages={'invalid_choice': 'Invalid device role.'})
  359. tenant = forms.ModelChoiceField(Tenant.objects.all(), to_field_name='name', required=False,
  360. error_messages={'invalid_choice': 'Tenant not found.'})
  361. manufacturer = forms.ModelChoiceField(queryset=Manufacturer.objects.all(), to_field_name='name',
  362. error_messages={'invalid_choice': 'Invalid manufacturer.'})
  363. model_name = forms.CharField()
  364. platform = forms.ModelChoiceField(queryset=Platform.objects.all(), required=False, to_field_name='name',
  365. error_messages={'invalid_choice': 'Invalid platform.'})
  366. class Meta:
  367. fields = []
  368. model = Device
  369. def clean(self):
  370. manufacturer = self.cleaned_data.get('manufacturer')
  371. model_name = self.cleaned_data.get('model_name')
  372. # Validate device type
  373. if manufacturer and model_name:
  374. try:
  375. self.instance.device_type = DeviceType.objects.get(manufacturer=manufacturer, model=model_name)
  376. except DeviceType.DoesNotExist:
  377. self.add_error('model_name', "Invalid device type ({} {})".format(manufacturer, model_name))
  378. class DeviceFromCSVForm(BaseDeviceFromCSVForm):
  379. site = forms.ModelChoiceField(queryset=Site.objects.all(), to_field_name='name', error_messages={
  380. 'invalid_choice': 'Invalid site name.',
  381. })
  382. rack_name = forms.CharField()
  383. face = forms.CharField(required=False)
  384. class Meta(BaseDeviceFromCSVForm.Meta):
  385. fields = ['name', 'device_role', 'tenant', 'manufacturer', 'model_name', 'platform', 'serial', 'asset_tag',
  386. 'site', 'rack_name', 'position', 'face']
  387. def clean(self):
  388. super(DeviceFromCSVForm, self).clean()
  389. site = self.cleaned_data.get('site')
  390. rack_name = self.cleaned_data.get('rack_name')
  391. # Validate rack
  392. if site and rack_name:
  393. try:
  394. self.instance.rack = Rack.objects.get(site=site, name=rack_name)
  395. except Rack.DoesNotExist:
  396. self.add_error('rack_name', "Invalid rack ({})".format(rack_name))
  397. def clean_face(self):
  398. face = self.cleaned_data['face']
  399. if not face:
  400. return None
  401. try:
  402. return {
  403. 'front': 0,
  404. 'rear': 1,
  405. }[face.lower()]
  406. except KeyError:
  407. raise forms.ValidationError('Invalid rack face ({}); must be "front" or "rear".'.format(face))
  408. class ChildDeviceFromCSVForm(BaseDeviceFromCSVForm):
  409. parent = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name', required=False,
  410. error_messages={'invalid_choice': 'Parent device not found.'})
  411. device_bay_name = forms.CharField(required=False)
  412. class Meta(BaseDeviceFromCSVForm.Meta):
  413. fields = ['name', 'device_role', 'tenant', 'manufacturer', 'model_name', 'platform', 'serial', 'asset_tag',
  414. 'parent', 'device_bay_name']
  415. def clean(self):
  416. super(ChildDeviceFromCSVForm, self).clean()
  417. parent = self.cleaned_data.get('parent')
  418. device_bay_name = self.cleaned_data.get('device_bay_name')
  419. # Validate device bay
  420. if parent and device_bay_name:
  421. try:
  422. device_bay = DeviceBay.objects.get(device=parent, name=device_bay_name)
  423. if device_bay.installed_device:
  424. self.add_error('device_bay_name',
  425. "Device bay ({} {}) is already occupied".format(parent, device_bay_name))
  426. else:
  427. self.instance.parent_bay = device_bay
  428. except DeviceBay.DoesNotExist:
  429. self.add_error('device_bay_name', "Parent device/bay ({} {}) not found".format(parent, device_bay_name))
  430. class DeviceImportForm(BulkImportForm, BootstrapMixin):
  431. csv = CSVDataField(csv_form=DeviceFromCSVForm)
  432. class ChildDeviceImportForm(BulkImportForm, BootstrapMixin):
  433. csv = CSVDataField(csv_form=ChildDeviceFromCSVForm)
  434. class DeviceBulkEditForm(BootstrapMixin, CustomFieldBulkEditForm):
  435. pk = forms.ModelMultipleChoiceField(queryset=Device.objects.all(), widget=forms.MultipleHiddenInput)
  436. device_type = forms.ModelChoiceField(queryset=DeviceType.objects.all(), required=False, label='Type')
  437. device_role = forms.ModelChoiceField(queryset=DeviceRole.objects.all(), required=False, label='Role')
  438. tenant = forms.ModelChoiceField(queryset=Tenant.objects.all(), required=False)
  439. platform = forms.ModelChoiceField(queryset=Platform.objects.all(), required=False)
  440. status = forms.ChoiceField(choices=FORM_STATUS_CHOICES, required=False, initial='', label='Status')
  441. serial = forms.CharField(max_length=50, required=False, label='Serial Number')
  442. class Meta:
  443. nullable_fields = ['tenant', 'platform']
  444. class DeviceBulkAddComponentForm(forms.Form, BootstrapMixin):
  445. pk = forms.ModelMultipleChoiceField(queryset=Device.objects.all(), widget=forms.MultipleHiddenInput)
  446. name_pattern = ExpandableNameField(label='Name')
  447. class DeviceBulkAddInterfaceForm(forms.ModelForm, DeviceBulkAddComponentForm):
  448. class Meta:
  449. model = Interface
  450. fields = ['name_pattern', 'form_factor', 'mgmt_only', 'description']
  451. class DeviceFilterForm(BootstrapMixin, CustomFieldFilterForm):
  452. model = Device
  453. site = FilterChoiceField(queryset=Site.objects.annotate(filter_count=Count('racks__devices')), to_field_name='slug')
  454. rack_group_id = FilterChoiceField(queryset=RackGroup.objects.annotate(filter_count=Count('racks__devices')),
  455. label='Rack Group')
  456. role = FilterChoiceField(queryset=DeviceRole.objects.annotate(filter_count=Count('devices')), to_field_name='slug')
  457. tenant = FilterChoiceField(queryset=Tenant.objects.annotate(filter_count=Count('devices')), to_field_name='slug',
  458. null_option=(0, 'None'))
  459. device_type_id = FilterChoiceField(queryset=DeviceType.objects.select_related('manufacturer')
  460. .annotate(filter_count=Count('instances')), label='Type')
  461. platform = FilterChoiceField(queryset=Platform.objects.annotate(filter_count=Count('devices')),
  462. to_field_name='slug', null_option=(0, 'None'))
  463. status = forms.NullBooleanField(required=False, widget=forms.Select(choices=FORM_STATUS_CHOICES))
  464. #
  465. # Console ports
  466. #
  467. class ConsolePortForm(forms.ModelForm, BootstrapMixin):
  468. class Meta:
  469. model = ConsolePort
  470. fields = ['device', 'name']
  471. widgets = {
  472. 'device': forms.HiddenInput(),
  473. }
  474. class ConsolePortCreateForm(forms.Form, BootstrapMixin):
  475. name_pattern = ExpandableNameField(label='Name')
  476. class ConsoleConnectionCSVForm(forms.Form):
  477. console_server = FlexibleModelChoiceField(queryset=Device.objects.filter(device_type__is_console_server=True),
  478. to_field_name='name',
  479. error_messages={'invalid_choice': 'Console server not found'})
  480. cs_port = forms.CharField()
  481. device = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name',
  482. error_messages={'invalid_choice': 'Device not found'})
  483. console_port = forms.CharField()
  484. status = forms.CharField(validators=[validate_connection_status])
  485. def clean(self):
  486. # Validate console server port
  487. if self.cleaned_data.get('console_server'):
  488. try:
  489. cs_port = ConsoleServerPort.objects.get(device=self.cleaned_data['console_server'],
  490. name=self.cleaned_data['cs_port'])
  491. if ConsolePort.objects.filter(cs_port=cs_port):
  492. raise forms.ValidationError("Console server port is already occupied (by {} {})"
  493. .format(cs_port.connected_console.device, cs_port.connected_console))
  494. except ConsoleServerPort.DoesNotExist:
  495. raise forms.ValidationError("Invalid console server port ({} {})"
  496. .format(self.cleaned_data['console_server'], self.cleaned_data['cs_port']))
  497. # Validate console port
  498. if self.cleaned_data.get('device'):
  499. try:
  500. console_port = ConsolePort.objects.get(device=self.cleaned_data['device'],
  501. name=self.cleaned_data['console_port'])
  502. if console_port.cs_port:
  503. raise forms.ValidationError("Console port is already connected (to {} {})"
  504. .format(console_port.cs_port.device, console_port.cs_port))
  505. except ConsolePort.DoesNotExist:
  506. raise forms.ValidationError("Invalid console port ({} {})"
  507. .format(self.cleaned_data['device'], self.cleaned_data['console_port']))
  508. class ConsoleConnectionImportForm(BulkImportForm, BootstrapMixin):
  509. csv = CSVDataField(csv_form=ConsoleConnectionCSVForm)
  510. def clean(self):
  511. records = self.cleaned_data.get('csv')
  512. if not records:
  513. return
  514. connection_list = []
  515. for i, record in enumerate(records, start=1):
  516. form = self.fields['csv'].csv_form(data=record)
  517. if form.is_valid():
  518. console_port = ConsolePort.objects.get(device=form.cleaned_data['device'],
  519. name=form.cleaned_data['console_port'])
  520. console_port.cs_port = ConsoleServerPort.objects.get(device=form.cleaned_data['console_server'],
  521. name=form.cleaned_data['cs_port'])
  522. if form.cleaned_data['status'] == 'planned':
  523. console_port.connection_status = CONNECTION_STATUS_PLANNED
  524. else:
  525. console_port.connection_status = CONNECTION_STATUS_CONNECTED
  526. connection_list.append(console_port)
  527. else:
  528. for field, errors in form.errors.items():
  529. for e in errors:
  530. self.add_error('csv', "Record {} {}: {}".format(i, field, e))
  531. self.cleaned_data['csv'] = connection_list
  532. class ConsolePortConnectionForm(forms.ModelForm, BootstrapMixin):
  533. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  534. widget=forms.Select(attrs={'filter-for': 'console_server'}))
  535. console_server = forms.ModelChoiceField(queryset=Device.objects.all(), label='Console Server', required=False,
  536. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack}}&is_console_server=True',
  537. display_field='display_name',
  538. attrs={'filter-for': 'cs_port'}))
  539. livesearch = forms.CharField(required=False, label='Console Server', widget=Livesearch(
  540. query_key='q', query_url='dcim-api:device_list', field_to_update='console_server')
  541. )
  542. cs_port = forms.ModelChoiceField(queryset=ConsoleServerPort.objects.all(), label='Port',
  543. widget=APISelect(api_url='/api/dcim/devices/{{console_server}}/console-server-ports/',
  544. disabled_indicator='connected_console'))
  545. class Meta:
  546. model = ConsolePort
  547. fields = ['rack', 'console_server', 'livesearch', 'cs_port', 'connection_status']
  548. labels = {
  549. 'cs_port': 'Port',
  550. 'connection_status': 'Status',
  551. }
  552. def __init__(self, *args, **kwargs):
  553. super(ConsolePortConnectionForm, self).__init__(*args, **kwargs)
  554. if not self.instance.pk:
  555. raise RuntimeError("ConsolePortConnectionForm must be initialized with an existing ConsolePort instance.")
  556. self.fields['rack'].queryset = Rack.objects.filter(site=self.instance.device.rack.site)
  557. self.fields['cs_port'].required = True
  558. self.fields['connection_status'].choices = CONNECTION_STATUS_CHOICES
  559. # Initialize console server choices
  560. if self.is_bound and self.data.get('rack'):
  561. self.fields['console_server'].queryset = Device.objects.filter(rack=self.data['rack'], device_type__is_console_server=True)
  562. elif self.initial.get('rack'):
  563. self.fields['console_server'].queryset = Device.objects.filter(rack=self.initial['rack'], device_type__is_console_server=True)
  564. else:
  565. self.fields['console_server'].choices = []
  566. # Initialize CS port choices
  567. if self.is_bound:
  568. self.fields['cs_port'].queryset = ConsoleServerPort.objects.filter(device__pk=self.data['console_server'])
  569. elif self.initial.get('console_server', None):
  570. self.fields['cs_port'].queryset = ConsoleServerPort.objects.filter(device__pk=self.initial['console_server'])
  571. else:
  572. self.fields['cs_port'].choices = []
  573. #
  574. # Console server ports
  575. #
  576. class ConsoleServerPortForm(forms.ModelForm, BootstrapMixin):
  577. class Meta:
  578. model = ConsoleServerPort
  579. fields = ['device', 'name']
  580. widgets = {
  581. 'device': forms.HiddenInput(),
  582. }
  583. class ConsoleServerPortCreateForm(forms.Form, BootstrapMixin):
  584. name_pattern = ExpandableNameField(label='Name')
  585. class ConsoleServerPortConnectionForm(forms.Form, BootstrapMixin):
  586. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  587. widget=forms.Select(attrs={'filter-for': 'device'}))
  588. device = forms.ModelChoiceField(queryset=Device.objects.all(), label='Device', required=False,
  589. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack}}',
  590. display_field='display_name', attrs={'filter-for': 'port'}))
  591. livesearch = forms.CharField(required=False, label='Device', widget=Livesearch(
  592. query_key='q', query_url='dcim-api:device_list', field_to_update='device')
  593. )
  594. port = forms.ModelChoiceField(queryset=ConsolePort.objects.all(), label='Port',
  595. widget=APISelect(api_url='/api/dcim/devices/{{device}}/console-ports/',
  596. disabled_indicator='cs_port'))
  597. connection_status = forms.BooleanField(required=False, initial=CONNECTION_STATUS_CONNECTED, label='Status',
  598. widget=forms.Select(choices=CONNECTION_STATUS_CHOICES))
  599. class Meta:
  600. fields = ['rack', 'device', 'livesearch', 'port', 'connection_status']
  601. labels = {
  602. 'connection_status': 'Status',
  603. }
  604. def __init__(self, consoleserverport, *args, **kwargs):
  605. super(ConsoleServerPortConnectionForm, self).__init__(*args, **kwargs)
  606. self.fields['rack'].queryset = Rack.objects.filter(site=consoleserverport.device.rack.site)
  607. # Initialize device choices
  608. if self.is_bound and self.data.get('rack'):
  609. self.fields['device'].queryset = Device.objects.filter(rack=self.data['rack'])
  610. elif self.initial.get('rack', None):
  611. self.fields['device'].queryset = Device.objects.filter(rack=self.initial['rack'])
  612. else:
  613. self.fields['device'].choices = []
  614. # Initialize port choices
  615. if self.is_bound:
  616. self.fields['port'].queryset = ConsolePort.objects.filter(device__pk=self.data['device'])
  617. elif self.initial.get('device', None):
  618. self.fields['port'].queryset = ConsolePort.objects.filter(device_pk=self.initial['device'])
  619. else:
  620. self.fields['port'].choices = []
  621. #
  622. # Power ports
  623. #
  624. class PowerPortForm(forms.ModelForm, BootstrapMixin):
  625. class Meta:
  626. model = PowerPort
  627. fields = ['device', 'name']
  628. widgets = {
  629. 'device': forms.HiddenInput(),
  630. }
  631. class PowerPortCreateForm(forms.Form, BootstrapMixin):
  632. name_pattern = ExpandableNameField(label='Name')
  633. class PowerConnectionCSVForm(forms.Form):
  634. pdu = FlexibleModelChoiceField(queryset=Device.objects.filter(device_type__is_pdu=True), to_field_name='name',
  635. error_messages={'invalid_choice': 'PDU not found.'})
  636. power_outlet = forms.CharField()
  637. device = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name',
  638. error_messages={'invalid_choice': 'Device not found'})
  639. power_port = forms.CharField()
  640. status = forms.CharField(validators=[validate_connection_status])
  641. def clean(self):
  642. # Validate power outlet
  643. if self.cleaned_data.get('pdu'):
  644. try:
  645. power_outlet = PowerOutlet.objects.get(device=self.cleaned_data['pdu'],
  646. name=self.cleaned_data['power_outlet'])
  647. if PowerPort.objects.filter(power_outlet=power_outlet):
  648. raise forms.ValidationError("Power outlet is already occupied (by {} {})"
  649. .format(power_outlet.connected_port.device,
  650. power_outlet.connected_port))
  651. except PowerOutlet.DoesNotExist:
  652. raise forms.ValidationError("Invalid PDU port ({} {})"
  653. .format(self.cleaned_data['pdu'], self.cleaned_data['power_outlet']))
  654. # Validate power port
  655. if self.cleaned_data.get('device'):
  656. try:
  657. power_port = PowerPort.objects.get(device=self.cleaned_data['device'],
  658. name=self.cleaned_data['power_port'])
  659. if power_port.power_outlet:
  660. raise forms.ValidationError("Power port is already connected (to {} {})"
  661. .format(power_port.power_outlet.device, power_port.power_outlet))
  662. except PowerPort.DoesNotExist:
  663. raise forms.ValidationError("Invalid power port ({} {})"
  664. .format(self.cleaned_data['device'], self.cleaned_data['power_port']))
  665. class PowerConnectionImportForm(BulkImportForm, BootstrapMixin):
  666. csv = CSVDataField(csv_form=PowerConnectionCSVForm)
  667. def clean(self):
  668. records = self.cleaned_data.get('csv')
  669. if not records:
  670. return
  671. connection_list = []
  672. for i, record in enumerate(records, start=1):
  673. form = self.fields['csv'].csv_form(data=record)
  674. if form.is_valid():
  675. power_port = PowerPort.objects.get(device=form.cleaned_data['device'],
  676. name=form.cleaned_data['power_port'])
  677. power_port.power_outlet = PowerOutlet.objects.get(device=form.cleaned_data['pdu'],
  678. name=form.cleaned_data['power_outlet'])
  679. if form.cleaned_data['status'] == 'planned':
  680. power_port.connection_status = CONNECTION_STATUS_PLANNED
  681. else:
  682. power_port.connection_status = CONNECTION_STATUS_CONNECTED
  683. connection_list.append(power_port)
  684. else:
  685. for field, errors in form.errors.items():
  686. for e in errors:
  687. self.add_error('csv', "Record {} {}: {}".format(i, field, e))
  688. self.cleaned_data['csv'] = connection_list
  689. class PowerPortConnectionForm(forms.ModelForm, BootstrapMixin):
  690. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  691. widget=forms.Select(attrs={'filter-for': 'pdu'}))
  692. pdu = forms.ModelChoiceField(queryset=Device.objects.all(), label='PDU', required=False,
  693. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack}}&is_pdu=True',
  694. display_field='display_name', attrs={'filter-for': 'power_outlet'}))
  695. livesearch = forms.CharField(required=False, label='PDU', widget=Livesearch(
  696. query_key='q', query_url='dcim-api:device_list', field_to_update='pdu')
  697. )
  698. power_outlet = forms.ModelChoiceField(queryset=PowerOutlet.objects.all(), label='Outlet',
  699. widget=APISelect(api_url='/api/dcim/devices/{{pdu}}/power-outlets/',
  700. disabled_indicator='connected_port'))
  701. class Meta:
  702. model = PowerPort
  703. fields = ['rack', 'pdu', 'livesearch', 'power_outlet', 'connection_status']
  704. labels = {
  705. 'power_outlet': 'Outlet',
  706. 'connection_status': 'Status',
  707. }
  708. def __init__(self, *args, **kwargs):
  709. super(PowerPortConnectionForm, self).__init__(*args, **kwargs)
  710. if not self.instance.pk:
  711. raise RuntimeError("PowerPortConnectionForm must be initialized with an existing PowerPort instance.")
  712. self.fields['rack'].queryset = Rack.objects.filter(site=self.instance.device.rack.site)
  713. self.fields['power_outlet'].required = True
  714. self.fields['connection_status'].choices = CONNECTION_STATUS_CHOICES
  715. # Initialize PDU choices
  716. if self.is_bound and self.data.get('rack'):
  717. self.fields['pdu'].queryset = Device.objects.filter(rack=self.data['rack'], device_type__is_pdu=True)
  718. elif self.initial.get('rack', None):
  719. self.fields['pdu'].queryset = Device.objects.filter(rack=self.initial['rack'], device_type__is_pdu=True)
  720. else:
  721. self.fields['pdu'].choices = []
  722. # Initialize power outlet choices
  723. if self.is_bound:
  724. self.fields['power_outlet'].queryset = PowerOutlet.objects.filter(device__pk=self.data['pdu'])
  725. elif self.initial.get('pdu', None):
  726. self.fields['power_outlet'].queryset = PowerOutlet.objects.filter(device__pk=self.initial['pdu'])
  727. else:
  728. self.fields['power_outlet'].choices = []
  729. #
  730. # Power outlets
  731. #
  732. class PowerOutletForm(forms.ModelForm, BootstrapMixin):
  733. class Meta:
  734. model = PowerOutlet
  735. fields = ['device', 'name']
  736. widgets = {
  737. 'device': forms.HiddenInput(),
  738. }
  739. class PowerOutletCreateForm(forms.Form, BootstrapMixin):
  740. name_pattern = ExpandableNameField(label='Name')
  741. class PowerOutletConnectionForm(forms.Form, BootstrapMixin):
  742. rack = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  743. widget=forms.Select(attrs={'filter-for': 'device'}))
  744. device = forms.ModelChoiceField(queryset=Device.objects.all(), label='Device', required=False,
  745. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack}}',
  746. display_field='display_name', attrs={'filter-for': 'port'}))
  747. livesearch = forms.CharField(required=False, label='Device', widget=Livesearch(
  748. query_key='q', query_url='dcim-api:device_list', field_to_update='device')
  749. )
  750. port = forms.ModelChoiceField(queryset=PowerPort.objects.all(), label='Port',
  751. widget=APISelect(api_url='/api/dcim/devices/{{device}}/power-ports/',
  752. disabled_indicator='power_outlet'))
  753. connection_status = forms.BooleanField(required=False, initial=CONNECTION_STATUS_CONNECTED, label='Status',
  754. widget=forms.Select(choices=CONNECTION_STATUS_CHOICES))
  755. class Meta:
  756. fields = ['rack', 'device', 'livesearch', 'port', 'connection_status']
  757. labels = {
  758. 'connection_status': 'Status',
  759. }
  760. def __init__(self, poweroutlet, *args, **kwargs):
  761. super(PowerOutletConnectionForm, self).__init__(*args, **kwargs)
  762. self.fields['rack'].queryset = Rack.objects.filter(site=poweroutlet.device.rack.site)
  763. # Initialize device choices
  764. if self.is_bound and self.data.get('rack'):
  765. self.fields['device'].queryset = Device.objects.filter(rack=self.data['rack'])
  766. elif self.initial.get('rack', None):
  767. self.fields['device'].queryset = Device.objects.filter(rack=self.initial['rack'])
  768. else:
  769. self.fields['device'].choices = []
  770. # Initialize port choices
  771. if self.is_bound:
  772. self.fields['port'].queryset = PowerPort.objects.filter(device__pk=self.data['device'])
  773. elif self.initial.get('device', None):
  774. self.fields['port'].queryset = PowerPort.objects.filter(device_pk=self.initial['device'])
  775. else:
  776. self.fields['port'].choices = []
  777. #
  778. # Interfaces
  779. #
  780. class InterfaceForm(forms.ModelForm, BootstrapMixin):
  781. class Meta:
  782. model = Interface
  783. fields = ['device', 'name', 'form_factor', 'mac_address', 'mgmt_only', 'description']
  784. widgets = {
  785. 'device': forms.HiddenInput(),
  786. }
  787. class InterfaceCreateForm(forms.ModelForm, BootstrapMixin):
  788. name_pattern = ExpandableNameField(label='Name')
  789. class Meta:
  790. model = Interface
  791. fields = ['name_pattern', 'form_factor', 'mac_address', 'mgmt_only', 'description']
  792. class InterfaceBulkEditForm(BootstrapMixin, BulkEditForm):
  793. pk = forms.ModelMultipleChoiceField(queryset=Interface.objects.all(), widget=forms.MultipleHiddenInput)
  794. form_factor = forms.ChoiceField(choices=add_blank_choice(IFACE_FF_CHOICES), required=False)
  795. description = forms.CharField(max_length=100, required=False)
  796. class Meta:
  797. nullable_fields = ['description']
  798. #
  799. # Interface connections
  800. #
  801. class InterfaceConnectionForm(forms.ModelForm, BootstrapMixin):
  802. interface_a = forms.ChoiceField(choices=[], widget=SelectWithDisabled, label='Interface')
  803. rack_b = forms.ModelChoiceField(queryset=Rack.objects.all(), label='Rack', required=False,
  804. widget=forms.Select(attrs={'filter-for': 'device_b'}))
  805. device_b = forms.ModelChoiceField(queryset=Device.objects.all(), label='Device', required=False,
  806. widget=APISelect(api_url='/api/dcim/devices/?rack_id={{rack_b}}',
  807. display_field='display_name',
  808. attrs={'filter-for': 'interface_b'}))
  809. livesearch = forms.CharField(required=False, label='Device', widget=Livesearch(
  810. query_key='q', query_url='dcim-api:device_list', field_to_update='device_b')
  811. )
  812. interface_b = forms.ModelChoiceField(queryset=Interface.objects.all(), label='Interface',
  813. widget=APISelect(api_url='/api/dcim/devices/{{device_b}}/interfaces/?type=physical',
  814. disabled_indicator='is_connected'))
  815. class Meta:
  816. model = InterfaceConnection
  817. fields = ['interface_a', 'rack_b', 'device_b', 'interface_b', 'livesearch', 'connection_status']
  818. def __init__(self, device_a, *args, **kwargs):
  819. super(InterfaceConnectionForm, self).__init__(*args, **kwargs)
  820. self.fields['rack_b'].queryset = Rack.objects.filter(site=device_a.rack.site)
  821. # Initialize interface A choices
  822. device_a_interfaces = Interface.objects.filter(device=device_a).exclude(form_factor=IFACE_FF_VIRTUAL) \
  823. .select_related('circuit', 'connected_as_a', 'connected_as_b')
  824. self.fields['interface_a'].choices = [
  825. (iface.id, {'label': iface.name, 'disabled': iface.is_connected}) for iface in device_a_interfaces
  826. ]
  827. # Initialize device_b choices if rack_b is set
  828. if self.is_bound and self.data.get('rack_b'):
  829. self.fields['device_b'].queryset = Device.objects.filter(rack__pk=self.data['rack_b'])
  830. elif self.initial.get('rack_b'):
  831. self.fields['device_b'].queryset = Device.objects.filter(rack=self.initial['rack_b'])
  832. else:
  833. self.fields['device_b'].choices = []
  834. # Initialize interface_b choices if device_b is set
  835. if self.is_bound:
  836. device_b_interfaces = Interface.objects.filter(device=self.data['device_b']) \
  837. .exclude(form_factor=IFACE_FF_VIRTUAL).select_related('circuit', 'connected_as_a', 'connected_as_b')
  838. elif self.initial.get('device_b'):
  839. device_b_interfaces = Interface.objects.filter(device=self.initial['device_b']) \
  840. .exclude(form_factor=IFACE_FF_VIRTUAL).select_related('circuit', 'connected_as_a', 'connected_as_b')
  841. else:
  842. device_b_interfaces = []
  843. self.fields['interface_b'].choices = [
  844. (iface.id, {'label': iface.name, 'disabled': iface.is_connected}) for iface in device_b_interfaces
  845. ]
  846. class InterfaceConnectionCSVForm(forms.Form):
  847. device_a = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name',
  848. error_messages={'invalid_choice': 'Device A not found.'})
  849. interface_a = forms.CharField()
  850. device_b = FlexibleModelChoiceField(queryset=Device.objects.all(), to_field_name='name',
  851. error_messages={'invalid_choice': 'Device B not found.'})
  852. interface_b = forms.CharField()
  853. status = forms.CharField(validators=[validate_connection_status])
  854. def clean(self):
  855. # Validate interface A
  856. if self.cleaned_data.get('device_a'):
  857. try:
  858. interface_a = Interface.objects.get(device=self.cleaned_data['device_a'],
  859. name=self.cleaned_data['interface_a'])
  860. except Interface.DoesNotExist:
  861. raise forms.ValidationError("Invalid interface ({} {})"
  862. .format(self.cleaned_data['device_a'], self.cleaned_data['interface_a']))
  863. try:
  864. InterfaceConnection.objects.get(Q(interface_a=interface_a) | Q(interface_b=interface_a))
  865. raise forms.ValidationError("{} {} is already connected"
  866. .format(self.cleaned_data['device_a'], self.cleaned_data['interface_a']))
  867. except InterfaceConnection.DoesNotExist:
  868. pass
  869. # Validate interface B
  870. if self.cleaned_data.get('device_b'):
  871. try:
  872. interface_b = Interface.objects.get(device=self.cleaned_data['device_b'],
  873. name=self.cleaned_data['interface_b'])
  874. except Interface.DoesNotExist:
  875. raise forms.ValidationError("Invalid interface ({} {})"
  876. .format(self.cleaned_data['device_b'], self.cleaned_data['interface_b']))
  877. try:
  878. InterfaceConnection.objects.get(Q(interface_a=interface_b) | Q(interface_b=interface_b))
  879. raise forms.ValidationError("{} {} is already connected"
  880. .format(self.cleaned_data['device_b'], self.cleaned_data['interface_b']))
  881. except InterfaceConnection.DoesNotExist:
  882. pass
  883. class InterfaceConnectionImportForm(BulkImportForm, BootstrapMixin):
  884. csv = CSVDataField(csv_form=InterfaceConnectionCSVForm)
  885. def clean(self):
  886. records = self.cleaned_data.get('csv')
  887. if not records:
  888. return
  889. connection_list = []
  890. occupied_interfaces = []
  891. for i, record in enumerate(records, start=1):
  892. form = self.fields['csv'].csv_form(data=record)
  893. if form.is_valid():
  894. interface_a = Interface.objects.get(device=form.cleaned_data['device_a'],
  895. name=form.cleaned_data['interface_a'])
  896. if interface_a in occupied_interfaces:
  897. raise forms.ValidationError("{} {} found in multiple connections"
  898. .format(interface_a.device.name, interface_a.name))
  899. interface_b = Interface.objects.get(device=form.cleaned_data['device_b'],
  900. name=form.cleaned_data['interface_b'])
  901. if interface_b in occupied_interfaces:
  902. raise forms.ValidationError("{} {} found in multiple connections"
  903. .format(interface_b.device.name, interface_b.name))
  904. connection = InterfaceConnection(interface_a=interface_a, interface_b=interface_b)
  905. if form.cleaned_data['status'] == 'planned':
  906. connection.connection_status = CONNECTION_STATUS_PLANNED
  907. else:
  908. connection.connection_status = CONNECTION_STATUS_CONNECTED
  909. connection_list.append(connection)
  910. occupied_interfaces.append(interface_a)
  911. occupied_interfaces.append(interface_b)
  912. else:
  913. for field, errors in form.errors.items():
  914. for e in errors:
  915. self.add_error('csv', "Record {} {}: {}".format(i, field, e))
  916. self.cleaned_data['csv'] = connection_list
  917. class InterfaceConnectionDeletionForm(forms.Form, BootstrapMixin):
  918. confirm = forms.BooleanField(required=True)
  919. # Used for HTTP redirect upon successful deletion
  920. device = forms.ModelChoiceField(queryset=Device.objects.all(), widget=forms.HiddenInput(), required=False)
  921. #
  922. # Device bays
  923. #
  924. class DeviceBayForm(forms.ModelForm, BootstrapMixin):
  925. class Meta:
  926. model = DeviceBay
  927. fields = ['device', 'name']
  928. widgets = {
  929. 'device': forms.HiddenInput(),
  930. }
  931. class DeviceBayCreateForm(forms.Form, BootstrapMixin):
  932. name_pattern = ExpandableNameField(label='Name')
  933. class PopulateDeviceBayForm(forms.Form, BootstrapMixin):
  934. installed_device = forms.ModelChoiceField(queryset=Device.objects.all(), label='Child Device',
  935. help_text="Child devices must first be created within the rack occupied "
  936. "by the parent device. Then they can be assigned to a bay.")
  937. def __init__(self, device_bay, *args, **kwargs):
  938. super(PopulateDeviceBayForm, self).__init__(*args, **kwargs)
  939. children_queryset = Device.objects.filter(rack=device_bay.device.rack,
  940. parent_bay__isnull=True,
  941. device_type__u_height=0,
  942. device_type__subdevice_role=SUBDEVICE_ROLE_CHILD)\
  943. .exclude(pk=device_bay.device.pk)
  944. self.fields['installed_device'].queryset = children_queryset
  945. #
  946. # Connections
  947. #
  948. class ConsoleConnectionFilterForm(forms.Form, BootstrapMixin):
  949. site = forms.ModelChoiceField(required=False, queryset=Site.objects.all(), to_field_name='slug')
  950. class PowerConnectionFilterForm(forms.Form, BootstrapMixin):
  951. site = forms.ModelChoiceField(required=False, queryset=Site.objects.all(), to_field_name='slug')
  952. class InterfaceConnectionFilterForm(forms.Form, BootstrapMixin):
  953. site = forms.ModelChoiceField(required=False, queryset=Site.objects.all(), to_field_name='slug')
  954. #
  955. # IP addresses
  956. #
  957. class IPAddressForm(BootstrapMixin, CustomFieldForm):
  958. set_as_primary = forms.BooleanField(label='Set as primary IP for device', required=False)
  959. class Meta:
  960. model = IPAddress
  961. fields = ['address', 'vrf', 'tenant', 'status', 'interface', 'description']
  962. def __init__(self, device, *args, **kwargs):
  963. super(IPAddressForm, self).__init__(*args, **kwargs)
  964. self.fields['vrf'].empty_label = 'Global'
  965. self.fields['interface'].queryset = device.interfaces.all()
  966. self.fields['interface'].required = True
  967. # If this device does not have any IP addresses assigned, default to setting the first IP as its primary
  968. if not IPAddress.objects.filter(interface__device=device).count():
  969. self.fields['set_as_primary'].initial = True
  970. #
  971. # Modules
  972. #
  973. class ModuleForm(forms.ModelForm, BootstrapMixin):
  974. class Meta:
  975. model = Module
  976. fields = ['name', 'manufacturer', 'part_id', 'serial']