Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

16145 Use module.ScriptName to call Script API instead of PK #16170

Merged
merged 5 commits into from
May 22, 2024
Merged
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
21 changes: 17 additions & 4 deletions netbox/extras/api/views.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
from django.http import Http404
from django.shortcuts import get_object_or_404
from django_rq.queues import get_connection
from rest_framework import status
Expand All @@ -13,7 +14,7 @@
from core.models import Job, ObjectType
from extras import filtersets
from extras.models import *
from extras.scripts import run_script
from extras.scripts import get_module_and_script, run_script
from netbox.api.authentication import IsAuthenticatedOrLoginNotRequired
from netbox.api.features import SyncedDataMixin
from netbox.api.metadata import ContentTypeMetadata
Expand Down Expand Up @@ -215,21 +216,33 @@ class ScriptViewSet(ModelViewSet):
_ignore_model_permissions = True
lookup_value_regex = '[^/]+' # Allow dots

def _get_script(self, pk):
try:
module_name, script_name = pk.split('.', maxsplit=1)
except ValueError:
raise Http404

module, script = get_module_and_script(module_name, script_name)
if script is None:
raise Http404

return module, script

def retrieve(self, request, pk):
script = get_object_or_404(self.queryset, pk=pk)
module, script = self._get_script(pk)
serializer = serializers.ScriptDetailSerializer(script, context={'request': request})

return Response(serializer.data)

def post(self, request, pk):
"""
Run a Script identified by the id and return the pending Job as the result
Run a Script identified by the name and return the pending Job as the result
"""

if not request.user.has_perm('extras.run_script'):
raise PermissionDenied("This user does not have permission to run scripts.")

script = get_object_or_404(self.queryset, pk=pk)
module, script = self._get_script(pk)
input_serializer = serializers.ScriptInputSerializer(
data=request.data,
context={'script': script}
Expand Down
16 changes: 12 additions & 4 deletions netbox/extras/tests/test_api.py
Original file line number Diff line number Diff line change
Expand Up @@ -777,23 +777,31 @@ def setUpTestData(cls):
is_executable=True,
)

def python_class(self):
return self.TestScriptClass
def get_vars(self, *args):
return {
k: v.__class__.__name__ for k, v in self.TestScriptClass._get_vars().items()
}

def get_test_script(self, *args):
module = ScriptModule.objects.first()
return module, module.scripts.first()

def setUp(self):
super().setUp()

# Monkey-patch the Script model to return our TestScriptClass above
from extras.api.views import ScriptViewSet
Script.python_class = self.python_class
ScriptViewSet._get_script = self.get_test_script
from extras.api.serializers_.scripts import ScriptSerializer
ScriptSerializer.get_vars = self.get_vars

def test_get_script(self):
module = ScriptModule.objects.get(
file_root=ManagedFileRootPathChoices.SCRIPTS,
file_path='/var/tmp/script.py'
)
script = module.scripts.all().first()
url = reverse('extras-api:script-detail', kwargs={'pk': script.pk})
url = reverse('extras-api:script-detail', kwargs={'pk': None})
response = self.client.get(url, **self.header)

self.assertEqual(response.data['name'], self.TestScriptClass.Meta.name)
Expand Down
Loading