views.py 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825
  1. from __future__ import unicode_literals
  2. from django_tables2 import RequestConfig
  3. import netaddr
  4. from django.conf import settings
  5. from django.contrib.auth.mixins import PermissionRequiredMixin
  6. from django.db.models import Count, Q
  7. from django.shortcuts import get_object_or_404, render
  8. from django.urls import reverse
  9. from django.views.generic import View
  10. from dcim.models import Device
  11. from utilities.paginator import EnhancedPaginator
  12. from utilities.views import (
  13. BulkCreateView, BulkDeleteView, BulkEditView, BulkImportView, ObjectDeleteView, ObjectEditView, ObjectListView,
  14. )
  15. from . import filters, forms, tables
  16. from .models import (
  17. Aggregate, IPAddress, PREFIX_STATUS_ACTIVE, PREFIX_STATUS_DEPRECATED, PREFIX_STATUS_RESERVED, Prefix, RIR, Role,
  18. Service, VLAN, VLANGroup, VRF,
  19. )
  20. def add_available_prefixes(parent, prefix_list):
  21. """
  22. Create fake Prefix objects for all unallocated space within a prefix.
  23. """
  24. # Find all unallocated space
  25. available_prefixes = netaddr.IPSet(parent) ^ netaddr.IPSet([p.prefix for p in prefix_list])
  26. available_prefixes = [Prefix(prefix=p) for p in available_prefixes.iter_cidrs()]
  27. # Concatenate and sort complete list of children
  28. prefix_list = list(prefix_list) + available_prefixes
  29. prefix_list.sort(key=lambda p: p.prefix)
  30. return prefix_list
  31. def add_available_ipaddresses(prefix, ipaddress_list, is_pool=False):
  32. """
  33. Annotate ranges of available IP addresses within a given prefix. If is_pool is True, the first and last IP will be
  34. considered usable (regardless of mask length).
  35. """
  36. output = []
  37. prev_ip = None
  38. # Ignore the network and broadcast addresses for non-pool IPv4 prefixes larger than /31.
  39. if prefix.version == 4 and prefix.prefixlen < 31 and not is_pool:
  40. first_ip_in_prefix = netaddr.IPAddress(prefix.first + 1)
  41. last_ip_in_prefix = netaddr.IPAddress(prefix.last - 1)
  42. else:
  43. first_ip_in_prefix = netaddr.IPAddress(prefix.first)
  44. last_ip_in_prefix = netaddr.IPAddress(prefix.last)
  45. if not ipaddress_list:
  46. return [(
  47. int(last_ip_in_prefix - first_ip_in_prefix + 1),
  48. '{}/{}'.format(first_ip_in_prefix, prefix.prefixlen)
  49. )]
  50. # Account for any available IPs before the first real IP
  51. if ipaddress_list[0].address.ip > first_ip_in_prefix:
  52. skipped_count = int(ipaddress_list[0].address.ip - first_ip_in_prefix)
  53. first_skipped = '{}/{}'.format(first_ip_in_prefix, prefix.prefixlen)
  54. output.append((skipped_count, first_skipped))
  55. # Iterate through existing IPs and annotate free ranges
  56. for ip in ipaddress_list:
  57. if prev_ip:
  58. diff = int(ip.address.ip - prev_ip.address.ip)
  59. if diff > 1:
  60. first_skipped = '{}/{}'.format(prev_ip.address.ip + 1, prefix.prefixlen)
  61. output.append((diff - 1, first_skipped))
  62. output.append(ip)
  63. prev_ip = ip
  64. # Include any remaining available IPs
  65. if prev_ip.address.ip < last_ip_in_prefix:
  66. skipped_count = int(last_ip_in_prefix - prev_ip.address.ip)
  67. first_skipped = '{}/{}'.format(prev_ip.address.ip + 1, prefix.prefixlen)
  68. output.append((skipped_count, first_skipped))
  69. return output
  70. #
  71. # VRFs
  72. #
  73. class VRFListView(ObjectListView):
  74. queryset = VRF.objects.select_related('tenant')
  75. filter = filters.VRFFilter
  76. filter_form = forms.VRFFilterForm
  77. table = tables.VRFTable
  78. template_name = 'ipam/vrf_list.html'
  79. class VRFView(View):
  80. def get(self, request, pk):
  81. vrf = get_object_or_404(VRF.objects.all(), pk=pk)
  82. prefix_table = tables.PrefixBriefTable(
  83. list(Prefix.objects.filter(vrf=vrf).select_related('site', 'role'))
  84. )
  85. prefix_table.exclude = ('vrf',)
  86. return render(request, 'ipam/vrf.html', {
  87. 'vrf': vrf,
  88. 'prefix_table': prefix_table,
  89. })
  90. class VRFCreateView(PermissionRequiredMixin, ObjectEditView):
  91. permission_required = 'ipam.add_vrf'
  92. model = VRF
  93. form_class = forms.VRFForm
  94. template_name = 'ipam/vrf_edit.html'
  95. default_return_url = 'ipam:vrf_list'
  96. class VRFEditView(VRFCreateView):
  97. permission_required = 'ipam.change_vrf'
  98. class VRFDeleteView(PermissionRequiredMixin, ObjectDeleteView):
  99. permission_required = 'ipam.delete_vrf'
  100. model = VRF
  101. default_return_url = 'ipam:vrf_list'
  102. class VRFBulkImportView(PermissionRequiredMixin, BulkImportView):
  103. permission_required = 'ipam.add_vrf'
  104. model_form = forms.VRFCSVForm
  105. table = tables.VRFTable
  106. default_return_url = 'ipam:vrf_list'
  107. class VRFBulkEditView(PermissionRequiredMixin, BulkEditView):
  108. permission_required = 'ipam.change_vrf'
  109. cls = VRF
  110. filter = filters.VRFFilter
  111. form = forms.VRFBulkEditForm
  112. template_name = 'ipam/vrf_bulk_edit.html'
  113. default_return_url = 'ipam:vrf_list'
  114. class VRFBulkDeleteView(PermissionRequiredMixin, BulkDeleteView):
  115. permission_required = 'ipam.delete_vrf'
  116. cls = VRF
  117. filter = filters.VRFFilter
  118. default_return_url = 'ipam:vrf_list'
  119. #
  120. # RIRs
  121. #
  122. class RIRListView(ObjectListView):
  123. queryset = RIR.objects.annotate(aggregate_count=Count('aggregates'))
  124. filter = filters.RIRFilter
  125. filter_form = forms.RIRFilterForm
  126. table = tables.RIRTable
  127. template_name = 'ipam/rir_list.html'
  128. def alter_queryset(self, request):
  129. if request.GET.get('family') == '6':
  130. family = 6
  131. denominator = 2 ** 64 # Count /64s for IPv6 rather than individual IPs
  132. else:
  133. family = 4
  134. denominator = 1
  135. rirs = []
  136. for rir in self.queryset:
  137. stats = {
  138. 'total': 0,
  139. 'active': 0,
  140. 'reserved': 0,
  141. 'deprecated': 0,
  142. 'available': 0,
  143. }
  144. aggregate_list = Aggregate.objects.filter(family=family, rir=rir)
  145. for aggregate in aggregate_list:
  146. queryset = Prefix.objects.filter(prefix__net_contained_or_equal=str(aggregate.prefix))
  147. # Find all consumed space for each prefix status (we ignore containers for this purpose).
  148. active_prefixes = netaddr.cidr_merge([p.prefix for p in queryset.filter(status=PREFIX_STATUS_ACTIVE)])
  149. reserved_prefixes = netaddr.cidr_merge([p.prefix for p in queryset.filter(status=PREFIX_STATUS_RESERVED)])
  150. deprecated_prefixes = netaddr.cidr_merge([p.prefix for p in queryset.filter(status=PREFIX_STATUS_DEPRECATED)])
  151. # Find all available prefixes by subtracting each of the existing prefix sets from the aggregate prefix.
  152. available_prefixes = (
  153. netaddr.IPSet([aggregate.prefix]) -
  154. netaddr.IPSet(active_prefixes) -
  155. netaddr.IPSet(reserved_prefixes) -
  156. netaddr.IPSet(deprecated_prefixes)
  157. )
  158. # Add the size of each metric to the RIR total.
  159. stats['total'] += aggregate.prefix.size / denominator
  160. stats['active'] += netaddr.IPSet(active_prefixes).size / denominator
  161. stats['reserved'] += netaddr.IPSet(reserved_prefixes).size / denominator
  162. stats['deprecated'] += netaddr.IPSet(deprecated_prefixes).size / denominator
  163. stats['available'] += available_prefixes.size / denominator
  164. # Calculate the percentage of total space for each prefix status.
  165. total = float(stats['total'])
  166. stats['percentages'] = {
  167. 'active': float('{:.2f}'.format(stats['active'] / total * 100)) if total else 0,
  168. 'reserved': float('{:.2f}'.format(stats['reserved'] / total * 100)) if total else 0,
  169. 'deprecated': float('{:.2f}'.format(stats['deprecated'] / total * 100)) if total else 0,
  170. }
  171. stats['percentages']['available'] = (
  172. 100 -
  173. stats['percentages']['active'] -
  174. stats['percentages']['reserved'] -
  175. stats['percentages']['deprecated']
  176. )
  177. rir.stats = stats
  178. rirs.append(rir)
  179. return rirs
  180. def extra_context(self):
  181. totals = {
  182. 'total': sum([rir.stats['total'] for rir in self.queryset]),
  183. 'active': sum([rir.stats['active'] for rir in self.queryset]),
  184. 'reserved': sum([rir.stats['reserved'] for rir in self.queryset]),
  185. 'deprecated': sum([rir.stats['deprecated'] for rir in self.queryset]),
  186. 'available': sum([rir.stats['available'] for rir in self.queryset]),
  187. }
  188. return {
  189. 'totals': totals,
  190. }
  191. class RIRCreateView(PermissionRequiredMixin, ObjectEditView):
  192. permission_required = 'ipam.add_rir'
  193. model = RIR
  194. form_class = forms.RIRForm
  195. def get_return_url(self, request, obj):
  196. return reverse('ipam:rir_list')
  197. class RIREditView(RIRCreateView):
  198. permission_required = 'ipam.change_rir'
  199. class RIRBulkDeleteView(PermissionRequiredMixin, BulkDeleteView):
  200. permission_required = 'ipam.delete_rir'
  201. cls = RIR
  202. filter = filters.RIRFilter
  203. default_return_url = 'ipam:rir_list'
  204. #
  205. # Aggregates
  206. #
  207. class AggregateListView(ObjectListView):
  208. queryset = Aggregate.objects.select_related('rir').extra(select={
  209. 'child_count': 'SELECT COUNT(*) FROM ipam_prefix WHERE ipam_prefix.prefix <<= ipam_aggregate.prefix',
  210. })
  211. filter = filters.AggregateFilter
  212. filter_form = forms.AggregateFilterForm
  213. table = tables.AggregateTable
  214. template_name = 'ipam/aggregate_list.html'
  215. def extra_context(self):
  216. ipv4_total = 0
  217. ipv6_total = 0
  218. for a in self.queryset:
  219. if a.prefix.version == 4:
  220. ipv4_total += a.prefix.size
  221. elif a.prefix.version == 6:
  222. ipv6_total += a.prefix.size / 2 ** 64
  223. return {
  224. 'ipv4_total': ipv4_total,
  225. 'ipv6_total': ipv6_total,
  226. }
  227. class AggregateView(View):
  228. def get(self, request, pk):
  229. aggregate = get_object_or_404(Aggregate, pk=pk)
  230. # Find all child prefixes contained by this aggregate
  231. child_prefixes = Prefix.objects.filter(
  232. prefix__net_contained_or_equal=str(aggregate.prefix)
  233. ).select_related(
  234. 'site', 'role'
  235. ).annotate_depth(
  236. limit=0
  237. )
  238. child_prefixes = add_available_prefixes(aggregate.prefix, child_prefixes)
  239. prefix_table = tables.PrefixTable(child_prefixes)
  240. if request.user.has_perm('ipam.change_prefix') or request.user.has_perm('ipam.delete_prefix'):
  241. prefix_table.base_columns['pk'].visible = True
  242. paginate = {
  243. 'klass': EnhancedPaginator,
  244. 'per_page': request.GET.get('per_page', settings.PAGINATE_COUNT)
  245. }
  246. RequestConfig(request, paginate).configure(prefix_table)
  247. # Compile permissions list for rendering the object table
  248. permissions = {
  249. 'add': request.user.has_perm('ipam.add_prefix'),
  250. 'change': request.user.has_perm('ipam.change_prefix'),
  251. 'delete': request.user.has_perm('ipam.delete_prefix'),
  252. }
  253. return render(request, 'ipam/aggregate.html', {
  254. 'aggregate': aggregate,
  255. 'prefix_table': prefix_table,
  256. 'permissions': permissions,
  257. })
  258. class AggregateCreateView(PermissionRequiredMixin, ObjectEditView):
  259. permission_required = 'ipam.add_aggregate'
  260. model = Aggregate
  261. form_class = forms.AggregateForm
  262. template_name = 'ipam/aggregate_edit.html'
  263. default_return_url = 'ipam:aggregate_list'
  264. class AggregateEditView(AggregateCreateView):
  265. permission_required = 'ipam.change_aggregate'
  266. class AggregateDeleteView(PermissionRequiredMixin, ObjectDeleteView):
  267. permission_required = 'ipam.delete_aggregate'
  268. model = Aggregate
  269. default_return_url = 'ipam:aggregate_list'
  270. class AggregateBulkImportView(PermissionRequiredMixin, BulkImportView):
  271. permission_required = 'ipam.add_aggregate'
  272. model_form = forms.AggregateCSVForm
  273. table = tables.AggregateTable
  274. default_return_url = 'ipam:aggregate_list'
  275. class AggregateBulkEditView(PermissionRequiredMixin, BulkEditView):
  276. permission_required = 'ipam.change_aggregate'
  277. cls = Aggregate
  278. filter = filters.AggregateFilter
  279. form = forms.AggregateBulkEditForm
  280. template_name = 'ipam/aggregate_bulk_edit.html'
  281. default_return_url = 'ipam:aggregate_list'
  282. class AggregateBulkDeleteView(PermissionRequiredMixin, BulkDeleteView):
  283. permission_required = 'ipam.delete_aggregate'
  284. cls = Aggregate
  285. filter = filters.AggregateFilter
  286. default_return_url = 'ipam:aggregate_list'
  287. #
  288. # Prefix/VLAN roles
  289. #
  290. class RoleListView(ObjectListView):
  291. queryset = Role.objects.all()
  292. table = tables.RoleTable
  293. template_name = 'ipam/role_list.html'
  294. class RoleCreateView(PermissionRequiredMixin, ObjectEditView):
  295. permission_required = 'ipam.add_role'
  296. model = Role
  297. form_class = forms.RoleForm
  298. def get_return_url(self, request, obj):
  299. return reverse('ipam:role_list')
  300. class RoleEditView(RoleCreateView):
  301. permission_required = 'ipam.change_role'
  302. class RoleBulkDeleteView(PermissionRequiredMixin, BulkDeleteView):
  303. permission_required = 'ipam.delete_role'
  304. cls = Role
  305. default_return_url = 'ipam:role_list'
  306. #
  307. # Prefixes
  308. #
  309. class PrefixListView(ObjectListView):
  310. queryset = Prefix.objects.select_related('site', 'vrf__tenant', 'tenant', 'vlan', 'role')
  311. filter = filters.PrefixFilter
  312. filter_form = forms.PrefixFilterForm
  313. table = tables.PrefixTable
  314. template_name = 'ipam/prefix_list.html'
  315. def alter_queryset(self, request):
  316. # Show only top-level prefixes by default (unless searching)
  317. limit = None if request.GET.get('expand') or request.GET.get('q') else 0
  318. return self.queryset.annotate_depth(limit=limit)
  319. class PrefixView(View):
  320. def get(self, request, pk):
  321. prefix = get_object_or_404(Prefix.objects.select_related(
  322. 'vrf', 'site__region', 'tenant__group', 'vlan__group', 'role'
  323. ), pk=pk)
  324. try:
  325. aggregate = Aggregate.objects.get(prefix__net_contains_or_equals=str(prefix.prefix))
  326. except Aggregate.DoesNotExist:
  327. aggregate = None
  328. # Count child IP addresses
  329. ipaddress_count = IPAddress.objects.filter(
  330. vrf=prefix.vrf, address__net_host_contained=str(prefix.prefix)
  331. ).count()
  332. # Parent prefixes table
  333. parent_prefixes = Prefix.objects.filter(
  334. Q(vrf=prefix.vrf) | Q(vrf__isnull=True)
  335. ).filter(
  336. prefix__net_contains=str(prefix.prefix)
  337. ).select_related(
  338. 'site', 'role'
  339. ).annotate_depth()
  340. parent_prefix_table = tables.PrefixBriefTable(parent_prefixes)
  341. parent_prefix_table.exclude = ('vrf',)
  342. # Duplicate prefixes table
  343. duplicate_prefixes = Prefix.objects.filter(
  344. vrf=prefix.vrf, prefix=str(prefix.prefix)
  345. ).exclude(
  346. pk=prefix.pk
  347. ).select_related(
  348. 'site', 'role'
  349. )
  350. duplicate_prefix_table = tables.PrefixBriefTable(list(duplicate_prefixes))
  351. duplicate_prefix_table.exclude = ('vrf',)
  352. # Child prefixes table
  353. child_prefixes = Prefix.objects.filter(
  354. vrf=prefix.vrf, prefix__net_contained=str(prefix.prefix)
  355. ).select_related(
  356. 'site', 'role'
  357. ).annotate_depth(limit=0)
  358. if child_prefixes:
  359. child_prefixes = add_available_prefixes(prefix.prefix, child_prefixes)
  360. child_prefix_table = tables.PrefixTable(child_prefixes)
  361. if request.user.has_perm('ipam.change_prefix') or request.user.has_perm('ipam.delete_prefix'):
  362. child_prefix_table.base_columns['pk'].visible = True
  363. paginate = {
  364. 'klass': EnhancedPaginator,
  365. 'per_page': request.GET.get('per_page', settings.PAGINATE_COUNT)
  366. }
  367. RequestConfig(request, paginate).configure(child_prefix_table)
  368. # Compile permissions list for rendering the object table
  369. permissions = {
  370. 'add': request.user.has_perm('ipam.add_prefix'),
  371. 'change': request.user.has_perm('ipam.change_prefix'),
  372. 'delete': request.user.has_perm('ipam.delete_prefix'),
  373. }
  374. return render(request, 'ipam/prefix.html', {
  375. 'prefix': prefix,
  376. 'aggregate': aggregate,
  377. 'ipaddress_count': ipaddress_count,
  378. 'parent_prefix_table': parent_prefix_table,
  379. 'child_prefix_table': child_prefix_table,
  380. 'duplicate_prefix_table': duplicate_prefix_table,
  381. 'permissions': permissions,
  382. 'return_url': prefix.get_absolute_url(),
  383. })
  384. class PrefixIPAddressesView(View):
  385. def get(self, request, pk):
  386. prefix = get_object_or_404(Prefix.objects.all(), pk=pk)
  387. # Find all IPAddresses belonging to this Prefix
  388. ipaddresses = IPAddress.objects.filter(
  389. vrf=prefix.vrf, address__net_host_contained=str(prefix.prefix)
  390. ).select_related(
  391. 'vrf', 'interface__device', 'primary_ip4_for', 'primary_ip6_for'
  392. )
  393. ipaddresses = add_available_ipaddresses(prefix.prefix, ipaddresses, prefix.is_pool)
  394. ip_table = tables.IPAddressTable(ipaddresses)
  395. if request.user.has_perm('ipam.change_ipaddress') or request.user.has_perm('ipam.delete_ipaddress'):
  396. ip_table.base_columns['pk'].visible = True
  397. paginate = {
  398. 'klass': EnhancedPaginator,
  399. 'per_page': request.GET.get('per_page', settings.PAGINATE_COUNT)
  400. }
  401. RequestConfig(request, paginate).configure(ip_table)
  402. # Compile permissions list for rendering the object table
  403. permissions = {
  404. 'add': request.user.has_perm('ipam.add_ipaddress'),
  405. 'change': request.user.has_perm('ipam.change_ipaddress'),
  406. 'delete': request.user.has_perm('ipam.delete_ipaddress'),
  407. }
  408. return render(request, 'ipam/prefix_ipaddresses.html', {
  409. 'prefix': prefix,
  410. 'ip_table': ip_table,
  411. 'permissions': permissions,
  412. 'bulk_querystring': 'vrf_id={}&parent={}'.format(prefix.vrf or '0', prefix.prefix),
  413. })
  414. class PrefixCreateView(PermissionRequiredMixin, ObjectEditView):
  415. permission_required = 'ipam.add_prefix'
  416. model = Prefix
  417. form_class = forms.PrefixForm
  418. template_name = 'ipam/prefix_edit.html'
  419. default_return_url = 'ipam:prefix_list'
  420. class PrefixEditView(PrefixCreateView):
  421. permission_required = 'ipam.change_prefix'
  422. class PrefixDeleteView(PermissionRequiredMixin, ObjectDeleteView):
  423. permission_required = 'ipam.delete_prefix'
  424. model = Prefix
  425. template_name = 'ipam/prefix_delete.html'
  426. default_return_url = 'ipam:prefix_list'
  427. class PrefixBulkImportView(PermissionRequiredMixin, BulkImportView):
  428. permission_required = 'ipam.add_prefix'
  429. model_form = forms.PrefixCSVForm
  430. table = tables.PrefixTable
  431. default_return_url = 'ipam:prefix_list'
  432. class PrefixBulkEditView(PermissionRequiredMixin, BulkEditView):
  433. permission_required = 'ipam.change_prefix'
  434. cls = Prefix
  435. filter = filters.PrefixFilter
  436. form = forms.PrefixBulkEditForm
  437. template_name = 'ipam/prefix_bulk_edit.html'
  438. default_return_url = 'ipam:prefix_list'
  439. class PrefixBulkDeleteView(PermissionRequiredMixin, BulkDeleteView):
  440. permission_required = 'ipam.delete_prefix'
  441. cls = Prefix
  442. filter = filters.PrefixFilter
  443. default_return_url = 'ipam:prefix_list'
  444. #
  445. # IP addresses
  446. #
  447. class IPAddressListView(ObjectListView):
  448. queryset = IPAddress.objects.select_related('vrf__tenant', 'tenant', 'interface__device', 'nat_inside')
  449. filter = filters.IPAddressFilter
  450. filter_form = forms.IPAddressFilterForm
  451. table = tables.IPAddressTable
  452. template_name = 'ipam/ipaddress_list.html'
  453. class IPAddressView(View):
  454. def get(self, request, pk):
  455. ipaddress = get_object_or_404(IPAddress.objects.select_related('interface__device'), pk=pk)
  456. # Parent prefixes table
  457. parent_prefixes = Prefix.objects.filter(
  458. vrf=ipaddress.vrf, prefix__net_contains=str(ipaddress.address.ip)
  459. ).select_related(
  460. 'site', 'role'
  461. )
  462. parent_prefixes_table = tables.PrefixBriefTable(list(parent_prefixes))
  463. parent_prefixes_table.exclude = ('vrf',)
  464. # Duplicate IPs table
  465. duplicate_ips = IPAddress.objects.filter(
  466. vrf=ipaddress.vrf, address=str(ipaddress.address)
  467. ).exclude(
  468. pk=ipaddress.pk
  469. ).select_related(
  470. 'interface__device', 'nat_inside'
  471. )
  472. duplicate_ips_table = tables.IPAddressBriefTable(list(duplicate_ips))
  473. # Related IP table
  474. related_ips = IPAddress.objects.select_related(
  475. 'interface__device'
  476. ).exclude(
  477. address=str(ipaddress.address)
  478. ).filter(
  479. vrf=ipaddress.vrf, address__net_contained_or_equal=str(ipaddress.address)
  480. )
  481. related_ips_table = tables.IPAddressBriefTable(list(related_ips))
  482. return render(request, 'ipam/ipaddress.html', {
  483. 'ipaddress': ipaddress,
  484. 'parent_prefixes_table': parent_prefixes_table,
  485. 'duplicate_ips_table': duplicate_ips_table,
  486. 'related_ips_table': related_ips_table,
  487. })
  488. class IPAddressCreateView(PermissionRequiredMixin, ObjectEditView):
  489. permission_required = 'ipam.add_ipaddress'
  490. model = IPAddress
  491. form_class = forms.IPAddressForm
  492. template_name = 'ipam/ipaddress_edit.html'
  493. default_return_url = 'ipam:ipaddress_list'
  494. class IPAddressEditView(IPAddressCreateView):
  495. permission_required = 'ipam.change_ipaddress'
  496. class IPAddressDeleteView(PermissionRequiredMixin, ObjectDeleteView):
  497. permission_required = 'ipam.delete_ipaddress'
  498. model = IPAddress
  499. default_return_url = 'ipam:ipaddress_list'
  500. class IPAddressBulkCreateView(PermissionRequiredMixin, BulkCreateView):
  501. permission_required = 'ipam.add_ipaddress'
  502. pattern_form = forms.IPAddressPatternForm
  503. model_form = forms.IPAddressBulkAddForm
  504. pattern_target = 'address'
  505. template_name = 'ipam/ipaddress_bulk_add.html'
  506. default_return_url = 'ipam:ipaddress_list'
  507. class IPAddressBulkImportView(PermissionRequiredMixin, BulkImportView):
  508. permission_required = 'ipam.add_ipaddress'
  509. model_form = forms.IPAddressCSVForm
  510. table = tables.IPAddressTable
  511. default_return_url = 'ipam:ipaddress_list'
  512. def save_obj(self, obj):
  513. obj.save()
  514. # Update primary IP for device if needed. The Device must be updated directly in the database; otherwise we risk
  515. # overwriting a previous IP assignment from the same import (see #861).
  516. try:
  517. if obj.family == 4 and obj.primary_ip4_for:
  518. Device.objects.filter(pk=obj.primary_ip4_for.pk).update(primary_ip4=obj)
  519. elif obj.family == 6 and obj.primary_ip6_for:
  520. Device.objects.filter(pk=obj.primary_ip6_for.pk).update(primary_ip6=obj)
  521. except Device.DoesNotExist:
  522. pass
  523. class IPAddressBulkEditView(PermissionRequiredMixin, BulkEditView):
  524. permission_required = 'ipam.change_ipaddress'
  525. cls = IPAddress
  526. filter = filters.IPAddressFilter
  527. form = forms.IPAddressBulkEditForm
  528. template_name = 'ipam/ipaddress_bulk_edit.html'
  529. default_return_url = 'ipam:ipaddress_list'
  530. class IPAddressBulkDeleteView(PermissionRequiredMixin, BulkDeleteView):
  531. permission_required = 'ipam.delete_ipaddress'
  532. cls = IPAddress
  533. filter = filters.IPAddressFilter
  534. default_return_url = 'ipam:ipaddress_list'
  535. #
  536. # VLAN groups
  537. #
  538. class VLANGroupListView(ObjectListView):
  539. queryset = VLANGroup.objects.select_related('site').annotate(vlan_count=Count('vlans'))
  540. filter = filters.VLANGroupFilter
  541. filter_form = forms.VLANGroupFilterForm
  542. table = tables.VLANGroupTable
  543. template_name = 'ipam/vlangroup_list.html'
  544. class VLANGroupCreateView(PermissionRequiredMixin, ObjectEditView):
  545. permission_required = 'ipam.add_vlangroup'
  546. model = VLANGroup
  547. form_class = forms.VLANGroupForm
  548. def get_return_url(self, request, obj):
  549. return reverse('ipam:vlangroup_list')
  550. class VLANGroupEditView(VLANGroupCreateView):
  551. permission_required = 'ipam.change_vlangroup'
  552. class VLANGroupBulkDeleteView(PermissionRequiredMixin, BulkDeleteView):
  553. permission_required = 'ipam.delete_vlangroup'
  554. cls = VLANGroup
  555. filter = filters.VLANGroupFilter
  556. default_return_url = 'ipam:vlangroup_list'
  557. #
  558. # VLANs
  559. #
  560. class VLANListView(ObjectListView):
  561. queryset = VLAN.objects.select_related('site', 'group', 'tenant', 'role').prefetch_related('prefixes')
  562. filter = filters.VLANFilter
  563. filter_form = forms.VLANFilterForm
  564. table = tables.VLANTable
  565. template_name = 'ipam/vlan_list.html'
  566. class VLANView(View):
  567. def get(self, request, pk):
  568. vlan = get_object_or_404(VLAN.objects.select_related(
  569. 'site__region', 'tenant__group', 'role'
  570. ), pk=pk)
  571. prefixes = Prefix.objects.filter(vlan=vlan).select_related('vrf', 'site', 'role')
  572. prefix_table = tables.PrefixBriefTable(list(prefixes))
  573. prefix_table.exclude = ('vlan',)
  574. return render(request, 'ipam/vlan.html', {
  575. 'vlan': vlan,
  576. 'prefix_table': prefix_table,
  577. })
  578. class VLANCreateView(PermissionRequiredMixin, ObjectEditView):
  579. permission_required = 'ipam.add_vlan'
  580. model = VLAN
  581. form_class = forms.VLANForm
  582. template_name = 'ipam/vlan_edit.html'
  583. default_return_url = 'ipam:vlan_list'
  584. class VLANEditView(VLANCreateView):
  585. permission_required = 'ipam.change_vlan'
  586. class VLANDeleteView(PermissionRequiredMixin, ObjectDeleteView):
  587. permission_required = 'ipam.delete_vlan'
  588. model = VLAN
  589. default_return_url = 'ipam:vlan_list'
  590. class VLANBulkImportView(PermissionRequiredMixin, BulkImportView):
  591. permission_required = 'ipam.add_vlan'
  592. model_form = forms.VLANCSVForm
  593. table = tables.VLANTable
  594. default_return_url = 'ipam:vlan_list'
  595. class VLANBulkEditView(PermissionRequiredMixin, BulkEditView):
  596. permission_required = 'ipam.change_vlan'
  597. cls = VLAN
  598. filter = filters.VLANFilter
  599. form = forms.VLANBulkEditForm
  600. template_name = 'ipam/vlan_bulk_edit.html'
  601. default_return_url = 'ipam:vlan_list'
  602. class VLANBulkDeleteView(PermissionRequiredMixin, BulkDeleteView):
  603. permission_required = 'ipam.delete_vlan'
  604. cls = VLAN
  605. filter = filters.VLANFilter
  606. default_return_url = 'ipam:vlan_list'
  607. #
  608. # Services
  609. #
  610. class ServiceCreateView(PermissionRequiredMixin, ObjectEditView):
  611. permission_required = 'ipam.add_service'
  612. model = Service
  613. form_class = forms.ServiceForm
  614. template_name = 'ipam/service_edit.html'
  615. def alter_obj(self, obj, request, url_args, url_kwargs):
  616. if 'device' in url_kwargs:
  617. obj.device = get_object_or_404(Device, pk=url_kwargs['device'])
  618. return obj
  619. def get_return_url(self, request, obj):
  620. return obj.device.get_absolute_url()
  621. class ServiceEditView(ServiceCreateView):
  622. permission_required = 'ipam.change_service'
  623. class ServiceDeleteView(PermissionRequiredMixin, ObjectDeleteView):
  624. permission_required = 'ipam.delete_service'
  625. model = Service