af83/chouette-core

module Query
  class NotificationRule < Base
        def email(value)
      change_scope(if: value.present?) do |scope|
                scope
                    .joins(workbench: :organisation)
                    .left_joins(organisation: :users)
                    .where(
                        %{
                            CASE
                                WHEN notification_rules.target_type = 'external_email' THEN notification_rules.external_email LIKE :value
                                WHEN notification_rules.target_type = 'user' THEN notification_rules.user_ids @> ARRAY[users.id] AND users.email LIKE :value
                                WHEN notification_rules.target_type = 'workbench' THEN users.email LIKE :value
                            END
                        },
                        value: "%#{value.downcase}%"
                    )
                    .distinct
            end
        end

        def in_period(period)
            change_scope(if: period.present?) do |scope|
                scope.where('period::daterange && daterange(:begin, :end)', begin: period.min, end: period.max + 1.day) #Need to add one day because of PostgreSQL behaviour with daterange (exclusvive end)
            end
        end

        def notification_type(value)
            change_scope(if: value.present?) do |scope|
                scope.where('ARRAY[?]::text[] @> ARRAY[notification_rules.notification_type]::text[]', value)
            end
        end

        def rule_type(value)
            change_scope(if: value.present?) do |scope|
                scope.where('ARRAY[?]::text[] @> ARRAY[notification_rules.rule_type]::text[]', value)
            end
        end

        def operation_statuses(value)
            change_scope(if: value.present?) do |scope|
                scope.where(operation_statuses: []).or(scope.where('operation_statuses::text[] && ARRAY[?]', value))
            end
        end

        def lines(value)
            value = (value || []).reject(&:blank?).map(&:to_i)
            change_scope(if: value.present?) do |scope|
                scope.where(line_ids: []).or(scope.where('line_ids::integer[] && ARRAY[?]', value))
            end
        end
  end
end