warp_engine/app/admin/pipelines.rb

ActiveAdmin.register WarpEngine::Pipeline, as: "Pipeline" do
  actions :index, :show, :edit, :update

  permit_params :platform, :software_id

  menu parent: "🌀 WarpEngine", priority: 10, label: "🚀 Pipelines"

  config.sort_order = "repo_name_asc"
  config.batch_actions = false

  scope :all, default: true
  scope("Active")   { |s| s.where(active: true) }
  scope("Inactive") { |s| s.where(active: false) }

  WarpEngine::PlatformLink::SUPPORTED_PLATFORMS.each do |p|
    scope(p.capitalize) { |s| s.where(platform: p) }
  end

  index do
    id_column
    column :repo_owner
    column :repo_name
    column :platform
    column("Software") { |r| r.software ? link_to(r.software.title, admin_software_path(r.software)) : "-" }
    column(:active) { |r| status_tag(r.active ? "active" : "inactive", class: r.active ? "yes" : "no") }
    column("Pipeline") { |r|
      if r.last_pipeline_status
        status_tag r.last_pipeline_status,
                   class: r.last_pipeline_status == "success" ? "yes" : "no"
      else
        "-"
      end
    }
    column :last_pipeline_at
    actions defaults: true do |pipeline|
      if pipeline.active && WarpEngine.ci.configured?
        item "Trigger", trigger_admin_pipeline_path(pipeline), method: :post, class: "member_link"
      end
    end
  end

  filter :repo_name
  filter :platform, as: :select, collection: WarpEngine::PlatformLink::SUPPORTED_PLATFORMS
  filter :active

  form do |f|
    f.inputs do
      f.input :platform, as: :select, collection: WarpEngine::PlatformLink::SUPPORTED_PLATFORMS
      f.input :software_id, as: :select,
              collection: WarpEngine::Software.order(:title).map { |s| [ s.title, s.id ] },
              include_blank: "- none -",
              hint: "One pipeline per software. Picking one that another pipeline already " \
                    "has moves the link here — that pipeline is left without a software, " \
                    "and the move is written to the log."
    end
    f.actions
  end

  sidebar "Details", only: :show do
    attributes_table_for resource do
      row :id
      row("Repo id") { |r| r.remote_repo_id }
      row :repo_owner
      row :repo_name
      row :platform
      row("Software") { |r| r.software ? link_to(r.software.title, admin_software_path(r.software)) : "-" }
      row(:active) { |r| status_tag(r.active ? "active" : "inactive", class: r.active ? "yes" : "no") }
      row :last_pipeline_status
      row :last_pipeline_at
      row :created_at
      row :updated_at
    end
  end

  show do
    panel "Pipelines" do
      if !WarpEngine.ci.configured?
        para "No CI provider is configured. Set c.ci_adapter in the WarpEngine initializer.",
             style: "color:#999;"
      elsif !resource.active
        para "This repository is inactive.", style: "color:#999;"
      else
        begin
          runs = WarpEngine::PipelineService.new.runs(resource, page: 1)
          if runs.any?
            table_for runs.first(10) do
              column("Number") { |r| r.number }
              column("Status") { |r| status_tag r.status, class: r.success? ? "yes" : "no" }
              column("Branch") { |r| r.branch }
              column("Message") { |r| r.message&.truncate(60) }
              column("Created") { |r| r.created_at ? r.created_at.strftime("%Y-%m-%d %H:%M") : "-" }
            end
          else
            para "No pipelines found.", style: "color:#999;"
          end
        rescue => e
          para "Error fetching pipelines: #{e.message}", style: "color:red;"
        end
      end
    end
  end

  member_action :trigger, method: :post do
    pipeline = WarpEngine::Pipeline.find(params[:id])
    WarpEngine::PipelineService.new.trigger(pipeline)
    redirect_to resource_path(pipeline), notice: "Pipeline triggered for #{pipeline.full_name}"
  rescue => e
    redirect_to resource_path(pipeline), alert: "Trigger failed: #{e.message}"
  end

  collection_action :sync, method: :post do
    result = WarpEngine::PipelineSyncService.new.sync_all
    redirect_to collection_path,
      notice: "Synced: #{result[:created].size} new, #{result[:updated].size} updated, #{result[:deactivated].size} deactivated"
  rescue => e
    redirect_to collection_path, alert: "Sync failed: #{e.message}"
  end

  action_item :sync_repos, only: :index do
    if WarpEngine.ci.configured?
      link_to "Sync from #{WarpEngine.ci.name}", sync_admin_pipelines_path, method: :post
    end
  end

  controller do
    def scoped_collection
      super.includes(:software)
    end
  end
end