gitcoinco/code_fund_ads

class PropertiesController < ApplicationController
  include Scopable
  include Sortable
  include Properties::Stashable

  before_action :authenticate_user!
  before_action :set_property, except: [:create, :index]
  before_action :set_user, only: [:index], if: -> { params[:user_id].present? }
  before_action :set_assignable_fallback_campaigns, only: [:edit]
  after_action -> { stash_property @property }, only: [:new, :edit]

  set_default_sorted_by :name

  def index
    properties = scope_list(Property).order(order_by).includes(:user, :property_traffic_estimates)

    if authorized_user.can_admin_system?
      properties = properties.where(user: @user) if @user
    else
      properties = properties.where(user: current_user)
    end

    @pagy, @properties = pagy(properties, page: @page)
  end

  def new
    if params[:clone].present?
      cloned_property = current_user.properties.find(params[:clone])
      if cloned_property.present?
        @property.attributes = cloned_property.attributes
        @property.status = "pending"
      end
    end

    set_assignable_fallback_campaigns
  end

  def show
    payload = {
      resource: {dashboard: ENV["METABASE_PROPERTY_DASHBOARD_ID"].to_i},
      params: {
        "property_id" => @property.id,
        "start_date" => @start_date.strftime("%F"),
        "end_date" => @end_date.strftime("%F")
      }
    }
    token = JWT.encode payload, ENV["METABASE_SECRET_KEY"]

    @iframe_url = ENV["METABASE_SITE_URL"] + "/embed/dashboard/" + token + "#bordered=false&titled=false"
  end

  def create
    @property = current_user.properties.build(property_params)
    @property.status = "pending"
    authorize_assigned_fallback_campaign_ids @property

    respond_to do |format|
      if @property.save
        CreateNewPropertyNotificationJob.perform_later @property
        format.html { redirect_to @property, notice: "Property was successfully created." }
        format.json { render :show, status: :created, location: @property }
      else
        format.html { render :new }
        format.json { render json: @property.errors, status: :unprocessable_entity }
      end
    end
  end

  def update
    @property.assign_attributes(property_params)
    authorize_assigned_fallback_campaign_ids @property

    respond_to do |format|
      if @property.save
        format.html { redirect_to @property, notice: "Property was successfully updated." }
        format.json { render :show, status: :ok, location: @property }
      else
        format.html { render :edit }
        format.json { render json: @property.errors, status: :unprocessable_entity }
      end
    end
  end

  def destroy
    @property.update(status: ENUMS::PROPERTY_STATUSES::ARCHIVED)
    redirect_url = params[:redir] || properties_url

    respond_to do |format|
      format.html { redirect_to redirect_url, notice: "Property was successfully archived." }
      format.json { head :no_content }
    end
  end

  protected

  def set_property
    return @property ||= stashed_property if action_name == "new"
    @property ||= if authorized_user.can_admin_system?
      Property.find(params[:id])
    else
      current_user.properties.find(params[:id])
    end
    @property.audience = @audience if @audience
    @property.validate
    @property
  end

  def set_user
    @user = if authorized_user.can_admin_system?
      User.find(params[:user_id])
    else
      current_user
    end
  end

  def set_assignable_fallback_campaigns
    @assignable_fallback_campaigns = if authorized_user.can_admin_system?
      Campaign.active.fallback
    else
      Current.organization&.campaigns&.active&.fallback
    end
  end

  def set_sortable_columns
    @sortable_columns ||= %w[
      created_at
      name
      status
      updated_at
    ]
  end

  def set_scopable_values
    @scopable_values ||= ["all", ENUMS::PROPERTY_STATUSES.values].flatten
  end

  private

  def property_params
    params.require(:property).permit(
      :ad_template,
      :ad_theme,
      :description,
      :fallback_ad_template,
      :fallback_ad_theme,
      :language,
      :name,
      :prohibit_fallback_campaigns,
      :property_type,
      :responsive_behavior,
      :screenshot,
      :url,
      keywords: [],
      assigned_fallback_campaign_ids: []
    ).tap do |whitelisted|
      if authorized_user.can_admin_system?
        whitelisted.merge! params.require(:property).permit(
          :audience_id,
          :restrict_to_assigner_campaigns,
          :revenue_percentage,
          :status,
          prohibited_organization_ids: []
        )
      end
    end
  end

  def authorize_assigned_fallback_campaign_ids(property)
    return unless property.assigned_fallback_campaign_ids.present?
    campaigns = Campaign.where(id: property.assigned_fallback_campaign_ids)
    property.assigned_fallback_campaign_ids = campaigns.each_with_object([]) { |campaign, memo|
      next unless authorized_user.can_assign_property_to_campaign?(property, campaign)
      memo << campaign.id
    }
  end
end