ActiveAdmin.register WarpEngine::CiRepository, as: "CI Repository" do
  actions :index, :show, :edit, :update

  menu parent: "🌀 WarpEngine", priority: 10, label: "🔧 CI Repos"

  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 ? "ok" : "warning") }
    column("Pipeline") { |r|
      if r.last_pipeline_status
        status_tag r.last_pipeline_status,
                   class: r.last_pipeline_status == "success" ? "ok" : "error"
      else
        "-"
      end
    }
    column :last_pipeline_at
    actions defaults: true do |repo|
      if repo.active && WarpEngine.woodpecker_configured?
        item "Trigger", trigger_admin_ci_repository_path(repo), 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 -"
    end
    f.actions
  end

  show do
    attributes_table do
      row :id
      row :woodpecker_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") }
      row :last_pipeline_status
      row :last_pipeline_at
      row :created_at
      row :updated_at
    end

    if WarpEngine.woodpecker_configured? && resource.active
      panel "Recent Pipelines" do
        begin
          pipelines = WarpEngine::CiPipelineService.new.list_pipelines(resource, page: 1)
          if pipelines.is_a?(Array) && pipelines.any?
            table_for pipelines.first(10) do
              column("Number") { |p| p["number"] }
              column("Status") { |p| status_tag p["status"], class: p["status"] == "success" ? "ok" : "error" }
              column("Branch") { |p| p["branch"] }
              column("Message") { |p| p["message"]&.truncate(60) }
              column("Created") { |p| p["created_at"] }
            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
    repo = WarpEngine::CiRepository.find(params[:id])
    WarpEngine::CiPipelineService.new.trigger(repo)
    redirect_to resource_path(repo), notice: "Pipeline triggered for #{repo.full_name}"
  rescue => e
    redirect_to resource_path(repo), alert: "Trigger failed: #{e.message}"
  end

  collection_action :sync, method: :post do
    result = WarpEngine::CiRepoSyncService.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.woodpecker_configured?
      link_to "Sync from Woodpecker", sync_admin_ci_repositories_path, method: :post
    end
  end

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