Initial system job implementation

awx/api/serializers.py

@@ -1323,8 +1323,39 @@ class JobSerializer(UnifiedJobSerializer, JobOptionsSerializer):
             ret['job_template'] = None
         return ret
 
-class JobListSerializer(JobSerializer, UnifiedJobListSerializer):
+class SystemJobTemplateSerializer(UnifiedJobTemplateSerializer):
 
+    class Meta:
+        model = SystemJobTemplate
+        fields = ('*', 'job_type',)
+
+    def get_related(self, obj):
+        res = super(SystemJobTemplateSerializer, self).get_related(obj)
+        res.update(dict(
+            jobs = reverse('api:system_job_template_jobs_list', args=(obj.pk,)),
+            schedules = reverse('api:system_job_template_schedules_list', args=(obj.pk,)),
+            launch = reverse('api:system_job_template_launch', args=(obj.pk,)),
+        ))
+        return res
+
+class SystemJobSerializer(UnifiedJobSerializer):
+
+    class Meta:
+        model = SystemJob
+        fields = ('*', 'system_job_template', 'job_type',)
+
+    def get_related(self, obj):
+        res = super(SystemJobSerializer, self).get_related(obj)
+        if obj.job_template and obj.job_template.active:
+            res['system_job_template'] = reverse('api:system_job_template_detail',
+                                                 args=(obj.job_template.pk,))
+        return res
+
+
+class JobListSerializer(JobSerializer, UnifiedJobListSerializer):
+    pass
+
+class SystemJobListSerializer(SystemJobSerializer, UnifiedJobListSerializer):
     pass
 
 
@@ -1391,7 +1422,6 @@ class JobEventSerializer(BaseSerializer):
             pass
         return d
 
-
 class ScheduleSerializer(BaseSerializer):
 
     class Meta:

awx/api/urls.py

@@ -168,6 +168,19 @@ job_event_urls = patterns('awx.api.views',
     url(r'^(?P<pk>[0-9]+)/hosts/$',                     'job_event_hosts_list'),
 )
 
+system_job_template_urls = patterns('awx.api.views',
+    url(r'^$',                                          'system_job_template_list'),
+    url(r'^(?P<pk>[0-9]+)/$',                           'system_job_template_detail'),
+    url(r'^(?P<pk>[0-9]+)/launch/$',                    'system_job_template_launch'),
+    url(r'^(?P<pk>[0-9]+)/jobs/$',                      'system_job_template_jobs_list'),
+    url(r'^(?P<pk>[0-9]+)/schedules/$',                 'system_job_template_schedules_list'),
+)
+
+system_job_urls = patterns('awx.api.views',
+    url(r'^$',                                          'system_job_list'),
+    url(r'^(?P<pk>[0-9]+)/$',                           'system_job_detail'),
+)
+
 schedule_urls = patterns('awx.api.views',
     url(r'^$',                                          'schedule_list'),
     url(r'^(?P<pk>[0-9]+)/$',                           'schedule_detail'),
@@ -205,6 +218,8 @@ v1_urls = patterns('awx.api.views',
     url(r'^jobs/',                  include(job_urls)),
     url(r'^job_host_summaries/',    include(job_host_summary_urls)),
     url(r'^job_events/',            include(job_event_urls)),
+    url(r'^system_job_templates/',  include(system_job_template_urls)),
+    url(r'^system_jobs/',           include(system_job_urls)),
     url(r'^unified_job_templates/$', 'unified_job_template_list'),
     url(r'^unified_jobs/$',         'unified_job_list'),
     url(r'^activity_stream/',       include(activity_stream_urls)),

awx/api/views.py

@@ -1642,6 +1642,50 @@ class JobTemplateJobsList(SubListCreateAPIView):
     relationship = 'jobs'
     parent_key = 'job_template'
 
+class SystemJobTemplateList(ListAPIView):
+
+    model = SystemJobTemplate
+    serializer_class = SystemJobTemplateSerializer
+
+class SystemJobTemplateDetail(RetrieveAPIView):
+
+    model = SystemJobTemplate
+    serializer_class = SystemJobTemplateSerializer
+
+class SystemJobTemplateLaunch(GenericAPIView):
+
+    model = SystemJobTemplate
+
+    def get(self, request, *args, **kwargs):
+        return Response({})
+
+    def post(self, request, *args, **kwargs):
+        obj = self.get_object()
+        if not request.user.can_access(self.model, 'start', obj):
+            raise PermissionDenied()
+        new_job = obj.create_unified_job()
+        result = new_job.signal_start()
+        data = dict(job=new_job.id)
+        return Response(data, status=status.HTTP_202_ACCEPTED)
+
+class SystemJobTemplateSchedulesList(SubListCreateAPIView):
+
+    view_name = "System Job Template Schedules"
+
+    model = Schedule
+    serializer_class = ScheduleSerializer
+    parent_model = SystemJobTemplate
+    relationship = 'schedules'
+    parent_key = 'unified_job_template'
+
+class SystemJobTemplateJobsList(SubListAPIView):
+
+    model = SystemJob
+    serializer_class = SystemJobListSerializer
+    parent_model = SystemJobTemplate
+    relationship = 'jobs'
+    parent_key = 'system_job_template'
+
 class JobList(ListCreateAPIView):
 
     model = Job
@@ -2052,6 +2096,15 @@ class JobJobTasksList(BaseJobEventsList):
         # Done; return the results and count.
         return (results, count, None)
 
+class SystemJobList(ListCreateAPIView):
+
+    model = SystemJob
+    serializer_class = SystemJobListSerializer
+
+class SystemJobDetail(RetrieveAPIView):
+
+    model = SystemJob
+    serializer_class = SystemJobSerializer
 
 class UnifiedJobTemplateList(ListAPIView):