375cbfe946
* Refresh an individual user's segmentation * Refresh segment if creating a published article * Quick refactor * Refresh segment if update publishing * Quick refactor * Refresh segment if update user settings * Refresh segments after user update + role change * Using latest_article_updated_at * Sidekiq uses JSON for arguments, needs basic types * Fix test issues with last_updated_at and sidekiq params * Tests update continues * Consolidate dependencies * Method names acknowledging manual exclusive * Fix test name copypasta * Rubocop * Try to clarify Creator#series * Try to avoid naming predicate * Remove erroneously included helper
71 lines
1.8 KiB
Ruby
71 lines
1.8 KiB
Ruby
module Articles
|
|
class Creator
|
|
def self.call(...)
|
|
new(...).call
|
|
end
|
|
|
|
def initialize(user, article_params)
|
|
@user = user
|
|
@article_params = normalize_params(article_params)
|
|
end
|
|
|
|
def call
|
|
rate_limit!
|
|
|
|
create_article.tap do
|
|
subscribe_author if article.persisted?
|
|
refresh_auto_audience_segments if article.published?
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
attr_reader :article, :user, :article_params
|
|
|
|
def normalize_params(original_params)
|
|
original_params.except(:tags).tap do |params|
|
|
# convert tags from array to a string
|
|
if (tags = original_params[:tags]).present?
|
|
params[:tag_list] = tags.join(", ")
|
|
end
|
|
end
|
|
end
|
|
|
|
def rate_limit!
|
|
rate_limit_to_use = if user.decorate.considered_new?
|
|
:published_article_antispam_creation
|
|
else
|
|
:published_article_creation
|
|
end
|
|
|
|
user.rate_limiter.check_limit!(rate_limit_to_use)
|
|
end
|
|
|
|
def refresh_auto_audience_segments
|
|
user.refresh_auto_audience_segments
|
|
end
|
|
|
|
def create_article
|
|
@article = Article.create(article_params) do |article|
|
|
article.user_id = user.id
|
|
article.show_comments = true
|
|
article.collection = series if series.present?
|
|
end
|
|
end
|
|
|
|
def series
|
|
@series ||= if article_params[:series].blank?
|
|
[]
|
|
else
|
|
Collection.find_series(article_params[:series], user)
|
|
end
|
|
end
|
|
|
|
# Subscribe author to notifications for all comments on their article.
|
|
def subscribe_author
|
|
NotificationSubscription.create(user: user,
|
|
notifiable: article,
|
|
config: "all_comments")
|
|
end
|
|
end
|
|
end
|