mirror of
https://github.com/netbox-community/netbox.git
synced 2024-05-10 07:54:54 +00:00
Initial work on JSON/YAML-based DeviceType import
This commit is contained in:
@ -6,8 +6,7 @@ from io import StringIO
|
||||
from django import forms
|
||||
from django.conf import settings
|
||||
from django.contrib.postgres.forms.jsonb import JSONField as _JSONField, InvalidJSONInput
|
||||
from django.db.models import Count
|
||||
from django.urls import reverse_lazy
|
||||
from django.utils.html import mark_safe
|
||||
from mptt.forms import TreeNodeMultipleChoiceField
|
||||
|
||||
from .constants import *
|
||||
@ -554,6 +553,24 @@ class SlugField(forms.SlugField):
|
||||
self.widget.attrs['slug-source'] = slug_source
|
||||
|
||||
|
||||
class MultiObjectField(forms.Field):
|
||||
"""
|
||||
Use this field to relay data to another form for validation. Useful when importing data via JSON/YAML.
|
||||
"""
|
||||
def __init__(self, form, *args, **kwargs):
|
||||
self.form = form
|
||||
super().__init__(*args, **kwargs)
|
||||
|
||||
def clean(self, value):
|
||||
|
||||
for obj in value:
|
||||
subform = self.form(obj)
|
||||
if not subform.is_valid():
|
||||
raise forms.ValidationError(mark_safe(subform.errors.items()))
|
||||
|
||||
return value
|
||||
|
||||
|
||||
class FilterChoiceIterator(forms.models.ModelChoiceIterator):
|
||||
|
||||
def __iter__(self):
|
||||
@ -721,3 +738,19 @@ class BulkEditForm(forms.Form):
|
||||
# Copy any nullable fields defined in Meta
|
||||
if hasattr(self.Meta, 'nullable_fields'):
|
||||
self.nullable_fields = self.Meta.nullable_fields
|
||||
|
||||
|
||||
class ImportForm(BootstrapMixin, forms.Form):
|
||||
"""
|
||||
Generic form for creating an object from JSON/YAML data
|
||||
"""
|
||||
data = forms.CharField(
|
||||
widget=forms.Textarea
|
||||
)
|
||||
format = forms.ChoiceField(
|
||||
choices=(
|
||||
('json', 'JSON'),
|
||||
('yaml', 'YAML')
|
||||
),
|
||||
initial='yaml'
|
||||
)
|
||||
|
@ -1,4 +1,6 @@
|
||||
import json
|
||||
import sys
|
||||
import yaml
|
||||
from copy import deepcopy
|
||||
|
||||
from django.conf import settings
|
||||
@ -26,7 +28,7 @@ from extras.querysets import CustomFieldQueryset
|
||||
from utilities.forms import BootstrapMixin, CSVDataField
|
||||
from utilities.utils import csv_format
|
||||
from .error_handlers import handle_protectederror
|
||||
from .forms import ConfirmationForm
|
||||
from .forms import ConfirmationForm, ImportForm
|
||||
from .paginator import EnhancedPaginator
|
||||
|
||||
|
||||
@ -393,6 +395,62 @@ class BulkCreateView(GetReturnURLMixin, View):
|
||||
})
|
||||
|
||||
|
||||
class ObjectImportView(GetReturnURLMixin, View):
|
||||
"""
|
||||
Import a single object (YAML or JSON format).
|
||||
"""
|
||||
model = None
|
||||
model_form = None
|
||||
template_name = 'utilities/obj_import.html'
|
||||
|
||||
def create_object(self, data):
|
||||
raise NotImplementedError("View must implement object creation logic")
|
||||
|
||||
def get(self, request):
|
||||
|
||||
form = ImportForm()
|
||||
|
||||
return render(request, self.template_name, {
|
||||
'form': form,
|
||||
'obj_type': self.model._meta.verbose_name,
|
||||
'return_url': self.get_return_url(request),
|
||||
})
|
||||
|
||||
def post(self, request):
|
||||
|
||||
form = ImportForm(request.POST)
|
||||
|
||||
if form.is_valid():
|
||||
|
||||
# Process object data
|
||||
if form.cleaned_data['format'] == 'json':
|
||||
data = json.loads(form.cleaned_data['data'])
|
||||
else:
|
||||
data = yaml.load(form.cleaned_data['data'])
|
||||
|
||||
# Initialize model form
|
||||
model_form = self.model_form(data)
|
||||
|
||||
if model_form.is_valid():
|
||||
|
||||
obj = model_form.save(commit=False)
|
||||
# assert False, model_form.cleaned_data['interfaces']
|
||||
|
||||
messages.success(request, "Imported object: {}".format(obj))
|
||||
return redirect(self.get_return_url(request))
|
||||
|
||||
else:
|
||||
# Replicate model form errors for display
|
||||
for field, err in model_form.errors.items():
|
||||
form.add_error(None, "{}: {}".format(field, err))
|
||||
|
||||
return render(request, self.template_name, {
|
||||
'form': form,
|
||||
'obj_type': self.model._meta.verbose_name,
|
||||
'return_url': self.get_return_url(request),
|
||||
})
|
||||
|
||||
|
||||
class BulkImportView(GetReturnURLMixin, View):
|
||||
"""
|
||||
Import objects in bulk (CSV format).
|
||||
@ -404,7 +462,7 @@ class BulkImportView(GetReturnURLMixin, View):
|
||||
"""
|
||||
model_form = None
|
||||
table = None
|
||||
template_name = 'utilities/obj_import.html'
|
||||
template_name = 'utilities/obj_bulk_import.html'
|
||||
widget_attrs = {}
|
||||
|
||||
def _import_form(self, *args, **kwargs):
|
||||
|
Reference in New Issue
Block a user