Merge pull request #409 from chrismeyersfsu/replay_job_events

add job event replay awx-manage command

awx/api/serializers.py

@@ -3138,6 +3138,26 @@ class JobEventSerializer(BaseSerializer):
         return ret
 
 
+class JobEventWebSocketSerializer(JobEventSerializer):
+    created = serializers.SerializerMethodField()
+    modified = serializers.SerializerMethodField()
+    event_name = serializers.CharField(source='event')
+    group_name = serializers.SerializerMethodField()
+
+    class Meta:
+        model = JobEvent
+        fields = ('*', 'event_name', 'group_name',)
+
+    def get_created(self, obj):
+        return obj.created.isoformat()
+
+    def get_modified(self, obj):
+        return obj.modified.isoformat()
+
+    def get_group_name(self, obj):
+        return 'job_events'
+
+
 class AdHocCommandEventSerializer(BaseSerializer):
 
     event_display = serializers.CharField(source='get_event_display', read_only=True)
@@ -3177,6 +3197,26 @@ class AdHocCommandEventSerializer(BaseSerializer):
         return ret
 
 
+class AdHocCommandEventWebSocketSerializer(AdHocCommandEventSerializer):
+    created = serializers.SerializerMethodField()
+    modified = serializers.SerializerMethodField()
+    event_name = serializers.CharField(source='event')
+    group_name = serializers.SerializerMethodField()
+
+    class Meta:
+        model = AdHocCommandEvent
+        fields = ('*', 'event_name', 'group_name',)
+
+    def get_created(self, obj):
+        return obj.created.isoformat()
+
+    def get_modified(self, obj):
+        return obj.modified.isoformat()
+
+    def get_group_name(self, obj):
+        return 'ad_hoc_command_events'
+
+
 class JobLaunchSerializer(BaseSerializer):
 
     passwords_needed_to_start = serializers.ReadOnlyField()