class RouterInventoryUpdateWorker
  include Sidekiq::Worker
  sidekiq_options queue: :inventory_reindex, retry: 3, backtrace: true

  def perform(params)
    p "[RI-WORKER] Started with params: #{params.inspect}"

    nasid = params['nasid']
    ri = RouterInventory.where(mac_id: nasid).last

    unless ri.present?
      p "[RI-WORKER][#{nasid}] No RouterInventory found with mac_id: #{nasid}"
      return
    end

    firmware_changed = params['current_firmware'].present?
    bn_changed = params['build_number'].present?
    # ip_changed = params['public_ip'].present? && params['current_active_uplink'].present?

    p "[RI-WORKER][#{nasid}] Changes detected - firmware_changed: #{firmware_changed}, bn_changed: #{bn_changed}"
    if firmware_changed || bn_changed
      update_router_inventory_columns(ri, params, firmware_changed, bn_changed)
    else
      p "[RI-WORKER][#{nasid}] No firmware or build number changes to update"
    end

    # if ip_changed
    #   update_uplinks_public_ip(ri.id, params)
    # else
    #   p "[RI-WORKER] No IP changes to update uplinks"
    # end

    p "[RI-WORKER] Finished processing RouterInventoryUpdateWorker for mac_id: #{nasid}"
  end

  def update_router_inventory_columns(router_inventory, params, firmware_changed, bn_changed)
    return unless router_inventory.present?

    update_attributes = {}

    if firmware_changed && params['current_firmware'].present?
      update_attributes[:previous_firmware] = params['previous_firmware'] if params['previous_firmware'].present?
      update_attributes[:current_firmware] = params['current_firmware']
    end

    if bn_changed && params['build_number'].present?
      update_attributes[:build_number] = params['build_number']
    end

    if update_attributes.any?
      p "[RI-WORKER][#{router_inventory.mac_id}] Updating RouterInventory ##{router_inventory.id} with: #{update_attributes.inspect}"
      RouterInventory.where(id: router_inventory.id).update_all(update_attributes)
      router_inventory.reload
      router_inventory.__elasticsearch__.index_document
      p "[RI-WORKER][#{router_inventory.mac_id}] Update complete and document reindexed"
    else
      p "[RI-WORKER][#{router_inventory.mac_id}] No attributes to update for RouterInventory ##{router_inventory.id}"
    end
  end

  def update_uplinks_public_ip(router_inventory_id, params)
    return unless params['public_ip'].present? && params['current_active_uplink'].present?

    public_ip = params['public_ip']
    current_active_uplink_id = params['current_active_uplink'].to_i

    p "[RI-WORKER] Updating uplinks for RouterInventory ##{router_inventory_id} with public IP: #{public_ip} and active uplink ID: #{current_active_uplink_id}"

    uplink_exists = Uplink.exists?(router_inventory_id: router_inventory_id, id: current_active_uplink_id)

    unless uplink_exists
      p "[RI-WORKER] No uplink found for RouterInventory ##{router_inventory_id} with ID: #{current_active_uplink_id}"
      return
    end

    current_pub_ip = Uplink.where(router_inventory_id: router_inventory_id, id: current_active_uplink_id).pluck(:public_ip).first

    if current_pub_ip != public_ip
      p "[RI-WORKER] Public IP changed for Uplink ##{current_active_uplink_id} of RouterInventory ##{router_inventory_id}. Updating to: #{public_ip}"
      Uplink.where(router_inventory_id: router_inventory_id, id: current_active_uplink_id).update_all(public_ip: public_ip)
      p "[RI-WORKER] Uplink public IP updated successfully"
    else
      p "[RI-WORKER] No change in public IP for Uplink ##{current_active_uplink_id} of RouterInventory ##{router_inventory_id}"
    end
  end

end