module Actions
  module Pulp3
    module Orchestration
      module ContentViewVersion
        class Export < Actions::EntryAction
          input_format do
            param :smart_proxy_id, Integer
            param :content_view_version_id, Integer
            param :from_content_view_version_id, Integer
            param :export_history_id, Integer
            param :exporter_data, Hash
            param :destination_server, String
            param :format, String
          end

          output_format do
            param :exported_file_checksum, Hash
            param :export_path, String
          end

          def plan(content_view_version:, destination_server: nil,
                   chunk_size: nil, from_history: nil,
                   validate_incremental: true,
                   fail_on_missing_content: false,
                   format: ::Katello::Pulp3::ContentViewVersion::Export::IMPORTABLE)
            smart_proxy = SmartProxy.pulp_primary!
            from_content_view_version = from_history&.content_view_version
            export_service = ::Katello::Pulp3::ContentViewVersion::Export.create(
                smart_proxy: smart_proxy,
                content_view_version: content_view_version,
                destination_server: destination_server,
                from_content_view_version: from_content_view_version,
                format: format)
            export_service.validate!(fail_on_missing_content: fail_on_missing_content,
                                     validate_incremental: validate_incremental,
                                     chunk_size: chunk_size)

            if format == ::Katello::Pulp3::ContentViewVersion::Export::SYNCABLE
              sequence do
                export_output = plan_action(SyncableExport,
                          content_view_version: content_view_version,
                          from_content_view_version: from_history&.content_view_version,
                          smart_proxy: smart_proxy,
                          destination_server: destination_server).output
                plan_self(export_history_id: export_output[:export_history_id],
                          export_path: export_output[:export_path])
              end
              return
            end

            sequence do
              action_output = plan_action(::Actions::Pulp3::ContentViewVersion::CreateExporter,
                                          content_view_version_id: content_view_version.id,
                                          smart_proxy_id: smart_proxy.id,
                                          destination_server: destination_server,
                                          format: format).output

              plan_action(::Actions::Pulp3::ContentViewVersion::Export,
                          content_view_version_id: content_view_version.id,
                          smart_proxy_id: smart_proxy.id,
                          exporter_data: action_output[:exporter_data],
                          chunk_size: chunk_size,
                          from_content_view_version_id: from_content_view_version&.id,
                          format: format)

              history_output = plan_action(
                  ::Actions::Pulp3::ContentViewVersion::CreateExportHistory,
                  smart_proxy_id: smart_proxy.id,
                  exporter_data: action_output[:exporter_data],
                  pulp_href: action_output[:exporter_data][:pulp_href],
                  content_view_version_id: content_view_version.id,
                  from_content_view_version_id: from_content_view_version&.id,
                  destination_server: destination_server,
                  format: format
              ).output

              plan_action(::Actions::Pulp3::ContentViewVersion::DestroyExporter,
                          smart_proxy_id: smart_proxy.id,
                          exporter_data: action_output[:exporter_data],
                          format: format)

              plan_self(export_history_id: history_output[:export_history_id],
                        exported_file_checksum: history_output[:exported_file_checksum],
                        export_path: history_output[:path])
            end
          end

          def run
            output.update(
                export_history_id: input[:export_history_id],
                export_path: input[:export_path],
                exported_file_checksum: input[:exported_file_checksum]
            )
          end

          def rescue_strategy
            Dynflow::Action::Rescue::Skip
          end
        end
      end
    end
  end
end