[WIP] feature: add bulk update

app/components/avo/views/resource_edit_component.html.erb

@@ -9,7 +9,7 @@
     **@resource.stimulus_data_attributes
   } do %>
   <%= render_cards_component %>
-  <%= form_with model: @resource.record,
+  <%= form_with model: model,
     scope: @resource.form_scope,
     url: form_url,
     method: form_method,
@@ -23,6 +23,13 @@
     },
     multipart: true do |form| %>
     <%= render Avo::ReferrerParamsComponent.new back_path: back_path %>
+
+    <% if @prefilled_fields.present? %>
+      <% @prefilled_fields.each do |field, value| %>
+        <%= hidden_field_tag "prefilled[#{field}]", value %>
+      <% end %>
+    <% end %>
+
     <%= content_tag :div, class: "space-y-12" do %>
       <% @resource.get_items.each_with_index do |item, index| %>
         <%= render Avo::Items::SwitcherComponent.new(

app/components/avo/views/resource_edit_component.rb

@@ -9,6 +9,14 @@ class Avo::Views::ResourceEditComponent < Avo::ResourceComponent
   prop :view, default: Avo::ViewInquirer.new(:edit).freeze
   prop :display_breadcrumbs, default: true, reader: :public
 
+  attr_reader :query
+
+  def initialize(resource:, query: nil, prefilled_fields: nil, **args)
+    @query = query
+    @prefilled_fields = prefilled_fields
+    super(resource: resource, **args)
+  end
+
   def after_initialize
     @display_breadcrumbs = @reflection.blank? && display_breadcrumbs
   end
@@ -25,6 +33,8 @@ def back_path
     return resource_view_path if via_resource?
     return resources_path if via_index?
 
+    return helpers.resources_path(resource: @resource) if params[:controller] == 'avo/bulk_update'
+
     if is_edit? && Avo.configuration.resource_default_view.show? # via resource show or edit page
       return helpers.resource_path(record: @resource.record, resource: @resource, **keep_referrer_params)
     end
@@ -76,13 +86,19 @@ def is_edit?
   end
 
   def form_method
-    return :put if is_edit?
+    return :put if is_edit? && params[:controller] != 'avo/bulk_update'
 
     :post
   end
 
+  def model
+    @resource.record
+  end
+
   def form_url
-    if is_edit?
+    if params[:controller] == 'avo/bulk_update'
+      helpers.handle_bulk_update_path(resource_name: @resource.name, query: @query)
+    elsif is_edit?
       helpers.resource_path(
         record: @resource.record,
         resource: @resource

app/components/avo/views/resource_index_component.html.erb

@@ -49,6 +49,8 @@
               <%= render Avo::FiltersComponent.new filters: @filters, resource: @resource, applied_filters: @applied_filters, parent_record: @parent_record %>
 
               <%= render partial: "avo/partials/view_toggle_button", locals: { available_view_types: available_view_types, view_type: view_type, turbo_frame: @turbo_frame } %>
+
+              <%= render_bulk_update_button %>
             </div>
           </div>
           <% if has_dynamic_filters? %>

app/components/avo/views/resource_index_component.rb

@@ -3,6 +3,7 @@
 class Avo::Views::ResourceIndexComponent < Avo::ResourceComponent
   include Avo::ResourcesHelper
   include Avo::ApplicationHelper
+  include Avo::Concerns::ChecksShowAuthorization
 
   prop :resource
   prop :resources
@@ -33,6 +34,20 @@ def view_type
     @index_params[:view_type]
   end
 
+  def bulk_edit_path
+    # Add the `view` param to let Avo know where to redirect back when the user clicks the `Cancel` button.
+    args = {via_view: "index"}
+
+    if @parent_record.present?
+      args = {
+        via_resource_class: parent_resource.class.to_s,
+        via_record_id: @parent_record.to_param
+      }
+    end
+
+    helpers.edit_bulk_update_path(resource: @resource, **args)
+  end
+
   def available_view_types
     @index_params[:available_view_types]
   end
@@ -158,6 +173,16 @@ def render_dynamic_filters_button
     end
   end
 
+  def render_bulk_update_button
+    a_link helpers.edit_bulk_update_path(resource_name: @resource.name, id: 4),
+           style: :primary,
+           color: :primary,
+           icon: "avo/edit",
+           form_class: "flex flex-col sm:flex-row sm:inline-flex" do
+      "Bulk update"
+    end
+  end
+
   def scopes_list
     Avo::Advanced::Scopes::ListComponent.new(
       scopes: @scopes,

app/controllers/avo/base_controller.rb

@@ -300,6 +300,7 @@ def cast_nullable(params)
         end
         .to_h
 
+
       params.each do |key, value|
         nullable_values = nullable_fields[key.to_sym]
 

app/controllers/avo/bulk_update_controller.rb

@@ -0,0 +1,134 @@
+module Avo
+  class BulkUpdateController < ResourcesController
+    before_action :set_query, only: [:edit, :handle]
+    before_action :set_fields, only: [:edit, :handle]
+
+    def edit
+      @prefilled_fields = prefill_fields(@query, @fields)
+      @record = @resource.model_class.new(@prefilled_fields.transform_values { |v| v.nil? ? nil : v })
+
+      @resource.record = @record
+      render Avo::Views::ResourceEditComponent.new(
+        resource: @resource,
+        query: @query,
+        prefilled_fields: @prefilled_fields
+      )
+    end
+
+    def handle
+      if params_to_apply.blank?
+        flash[:warning] = t("avo.no_changes_made")
+        redirect_to after_bulk_update_path
+      end
+
+      updated_count, failed_records = update_records
+
+      if failed_records.empty?
+        flash[:notice] = t("avo.bulk_update_success", count: updated_count)
+      else
+        error_messages = failed_records.flat_map { |fr| fr[:errors] }.uniq
+        flash[:error] = t("avo.bulk_update_failure", count: failed_records.count, errors: error_messages.join(", "))
+      end
+
+      redirect_to after_bulk_update_path
+    end
+
+    private
+
+    def params_to_apply
+      prefilled_params = params[:prefilled] || {}
+
+      resource_key = @resource_name.downcase.to_sym
+      current_params = params[resource_key] || {}
+
+      progress_fields = @resource.get_field_definitions
+                                 .select { |field| field.is_a?(Avo::Fields::ProgressBarField) }
+                                 .map(&:id)
+                                 .map(&:to_sym)
+
+
+      params_to_apply = current_params.reject do |key, value|
+        key_sym = key.to_sym
+        prefilled_value = prefilled_params[key_sym]
+
+        next true if progress_fields.include?(key_sym) && prefilled_value == "" && value.to_s == "50"
+
+        prefilled_value.to_s == value.to_s
+      end
+
+      params_to_apply
+    end
+
+    def update_records
+      updated_count = 0
+      failed_records = []
+
+      @query.each do |record|
+        begin
+          params_to_apply.each do |key, value|
+            begin
+              record.public_send("#{key}=", value)
+            rescue => e
+              puts "Błąd przypisywania pola #{key}: #{e.message}"
+            end
+          end
+
+          @resource.fill_record(record, params)
+
+          if record.save
+            updated_count += 1
+          else
+            failed_records << { record: record, errors: record.errors.full_messages }
+          end
+        rescue => e
+          failed_records << { record: record, errors: [e.message] }
+        end
+      end
+
+      return updated_count, failed_records
+    end
+
+    def after_bulk_update_path
+      resources_path(resource: @resource)
+    end
+
+    def prefill_fields(records, fields)
+      prefilled = {}
+      fields.each_key do |field_name|
+        values = records.map { |record| record.public_send(field_name) }
+        prefilled[field_name] = (values.uniq.size == 1 ? values.first : nil)
+      end
+      prefilled
+    end
+
+    def set_query
+      if params[:query].present?
+        @query = @resource.find_record(params[:query], params: params)
+      else
+        resource_ids = action_params[:fields]&.dig(:avo_resource_ids)&.split(",") || []
+        @query = decrypted_query || (resource_ids.any? ? @resource.find_record(resource_ids, params: params) : [])
+      end
+    end
+
+    def set_fields
+      if @query.blank?
+        flash[:error] = "Bulk update cannot be performed without records."
+        redirect_to after_bulk_update_path
+      else
+        @fields = @query.first.attributes.keys.index_with { nil }
+      end
+    end
+
+    def action_params
+      @action_params ||= params.permit(:authenticity_token, fields: {})
+    end
+
+    def decrypted_query
+      encrypted_query = action_params[:fields]&.dig(:avo_selected_query) || params[:query]
+
+      return if encrypted_query.blank?
+
+      Avo::Services::EncryptionService.decrypt(message: encrypted_query, purpose: :select_all, serializer: Marshal)
+    end
+  end
+end

app/helpers/avo/url_helpers.rb

@@ -44,6 +44,14 @@ def edit_resource_path(resource:, record: nil, resource_id: nil, **args)
       avo.send :"edit_resources_#{resource.singular_route_key}_path", record || resource_id, **args
     end
 
+    def edit_bulk_update_path(resource_name:, id:, **args)
+      avo.send :"edit_bulk_update_path", resource_name, id, **args
+    end
+
+    def handle_bulk_update_path(resource_name:, query:, **args)
+      avo.send :"handle_bulk_update_path", resource_name, query, **args
+    end
+
     def resource_attach_path(resource, record_id, related_name, related_id = nil)
       helpers.avo.resources_associations_new_path(resource.singular_route_key, record_id, related_name)
     end

app/javascript/js/controllers/item_select_all_controller.js

@@ -71,6 +71,7 @@ export default class extends Controller {
     }
 
     this.updateLinks('resourceIds')
+    this.updateBulkEditLink('resourceIds')
   }
 
   selectAll(event) {
@@ -82,8 +83,10 @@ export default class extends Controller {
 
     if (this.selectedAllValue) {
       this.updateLinks('selectedQuery')
+      this.updateBulkEditLink('selectedQuery')
     } else {
       this.updateLinks('resourceIds')
+      this.updateBulkEditLink('resourceIds')
     }
   }
 
@@ -118,6 +121,37 @@ export default class extends Controller {
     })
   }
 
+  updateBulkEditLink(param) {
+    let resourceIds = ''
+    let selectedQuery = ''
+
+    if (param === 'resourceIds') {
+      resourceIds = JSON.parse(this.element.dataset.selectedResources).join(',')
+    } else if (param === 'selectedQuery') {
+      selectedQuery = this.element.dataset.itemSelectAllSelectedAllQueryValue
+    }
+
+    document.querySelectorAll('a[href*="/admin/bulk_update/edit"]').forEach((link) => {
+      try {
+        const url = new URL(link.href)
+
+        Array.from(url.searchParams.keys())
+          .filter((key) => key.startsWith('fields['))
+          .forEach((key) => url.searchParams.delete(key))
+
+        if (param === 'resourceIds') {
+          url.searchParams.set('fields[avo_resource_ids]', resourceIds)
+        } else if (param === 'selectedQuery') {
+          url.searchParams.set('fields[avo_selected_query]', selectedQuery)
+        }
+
+        link.href = url.toString()
+      } catch (error) {
+        console.error('Error updating link:', link, error)
+      }
+    })
+  }
+
   resetUnselected() {
     this.selectedAllValue = false
     this.unselectedMessageTarget.classList.remove('hidden')

config/routes.rb

@@ -9,6 +9,9 @@
     instance_exec(&Avo.mount_engines)
   end
 
+  get "/bulk_update/edit", to: "bulk_update#edit", as: "edit_bulk_update"
+  post "/bulk_update/handle", to: "bulk_update#handle", as: "handle_bulk_update"
+
   resources :media_library, only: [:index, :show, :update, :destroy], path: "media-library"
   get "attach-media", to: "media_library#attach"
 

lib/avo/resources/base.rb

@@ -631,6 +631,7 @@ def entity_loader(entity)
       end
 
       def record_param
+        return nil if @record.nil?
         @record_param ||= @record.persisted? ? @record.to_param : nil
       end
 

spec/dummy/config/locales/avo.en.yml

@@ -20,6 +20,8 @@ en:
     attachment_class_detached: "%{attachment_class} detached."
     attachment_failed: "Failed to attach %{attachment_class}"
     attachment_destroyed: Attachment destroyed
+    bulk_update_success: "%{count} records were successfully updated."
+    bulk_update_failure: "Failed to update %{count} records. Errors: %{errors}"
     cancel: Cancel
     choose_a_country: Choose a country
     choose_an_option: Choose an option
@@ -68,6 +70,7 @@ en:
     next_page: Next page
     no_cancel: No, cancel
     no_cards_present: No cards present
+    no_changes_made: No changes were made.
     no_item_found: No record found
     no_options_available: No options available
     no_related_item_found: No related record found