pulibrary / pdc_describe / 4e4e59fc-9df4-4838-9fd4-6c7ea33cdb7c

class WorkList

  class << self

    def unfinished_works(user, search_terms = nil)

      works_by_user_state(user, ["none", "draft", "awaiting_approval"], search_terms)

    end

    def completed_works(user, search_terms = nil)

      works_by_user_state(user, "approved", search_terms)

    end

    def withdrawn_works(user, search_terms = nil)

      works_by_user_state(user, "withdrawn", search_terms)

    end

    private

      def search_terms_where_clause(search_terms)

        if search_terms.nil?

          Work.all

        else

          Work.where("CAST(metadata AS VARCHAR) ILIKE :search_terms", search_terms: "%" + search_terms.strip + "%")

        end

      end

      def works_by_user_state(user, state, search_terms)

        search_context = search_terms_where_clause(search_terms)

        works = search_context.where(created_by_user_id: user, state:).to_a

        if user.admin_groups.count > 0

          user.admin_groups.each do |group|

            works += search_context.where(group_id: group.id, state:)

          end

        end

        works_mentioned_by_user_state(user, state, search_context).each do |work|

          already_included = !works.find { |existing_work| existing_work[:id] == work.id }.nil?

          works << work unless already_included

        end

        works.uniq(&:id).sort_by(&:updated_at).reverse

      end

      def works_mentioned_by_user_state(user, state, search_context)

        search_context.joins(:work_activity)

                      .joins('INNER JOIN "work_activity_notifications" ON "work_activities"."id" = "work_activity_notifications"."work_activity_id"')

                      .where(state:)

                      .where('"work_activity_notifications"."user_id" = ?', user.id)

      end

  end

end