cloudfoundry/cloud_controller_ng

module VCAP::CloudController
  module Jobs
    class AuditEventJob < VCAP::CloudController::Jobs::CCJob
      attr_accessor :job, :event_repository, :event_creation_method, :event_type, :model_class, :model_guid, :params

      def initialize(job, event_repository, event_creation_method, event_type, model_class, model_guid, params={})
        @job = job
        @event_repository = event_repository
        @event_creation_method = event_creation_method
        @event_type = event_type
        @model_class = model_class
        @model_guid = model_guid
        @params = params
      end

      def perform
        model_instance = model_class.first(guid: model_guid)
        job.perform
        return unless model_instance

        event_repository.send(event_creation_method, event_type, model_instance, params)
      end

      def job_name_in_configuration
        :audit_event_job
      end

      def max_attempts
        1
      end

      delegate :reschedule_at, to: :job
    end
  end
end