mirror of
https://github.com/discourse/discourse.git
synced 2026-08-06 13:08:40 +08:00
249ae0009aThis commit removes the `include_expired` param and its associated site setting `include_expired_events_on_calendar`. Since recent changes this performance optimisation doesn’t make sense anymore as we only load the events needed for a specific before/after range. The rules are the following: Non recurring events: - They have to have a start date between before/after range Recurring events: - they don't have event_dates, so we don't rely on it for them - what's important for recurring_event, is the recurring_until property and the original starts at - we want to return recurring events when their start date is is after the after param and the before param is before the recurring_until - if recurring_until is NULL we just look at the start date It's done this way as the serializer only sends the rrule to the front, and this is the frontend which will compute the recurring events, but if you want to have all the events of august, and your recurring event is starting in june, you need to also fetch this june event. This commit ensures we can now deal properly with nil dates as it makes no sense to have dates for an expired recurring event.
111 lines
3.5 KiB
Ruby
Vendored
111 lines
3.5 KiB
Ruby
Vendored
# frozen_string_literal: true
|
|
|
|
module Jobs
|
|
class DiscoursePostEventSendReminder < ::Jobs::Base
|
|
sidekiq_options retry: false
|
|
|
|
def execute(args)
|
|
raise Discourse::InvalidParameters.new(:event_id) if args[:event_id].blank?
|
|
raise Discourse::InvalidParameters.new(:reminder) if args[:reminder].blank?
|
|
|
|
event =
|
|
DiscoursePostEvent::Event.includes(post: [:topic], invitees: [:user]).find(args[:event_id])
|
|
|
|
return unless event.post
|
|
|
|
invitees =
|
|
event.invitees.where(
|
|
status: [
|
|
DiscoursePostEvent::Invitee.statuses[:going],
|
|
DiscoursePostEvent::Invitee.statuses[:interested],
|
|
],
|
|
)
|
|
|
|
already_notified_users =
|
|
Notification.where(
|
|
read: false,
|
|
notification_type: Notification.types[:event_reminder] || Notification.types[:custom],
|
|
topic_id: event.post.topic_id,
|
|
post_number: 1,
|
|
)
|
|
|
|
return if event.starts_at.nil?
|
|
|
|
# Convert both times to UTC for proper comparison
|
|
current_time = Time.current
|
|
event_start_time =
|
|
(
|
|
if event.starts_at.is_a?(ActiveSupport::TimeWithZone)
|
|
event.starts_at
|
|
else
|
|
event.starts_at.in_time_zone(event.timezone || "UTC")
|
|
end
|
|
)
|
|
|
|
event_started = current_time > event_start_time
|
|
|
|
# we remove users who have been visiting the topic since event started
|
|
if event_started
|
|
invitees =
|
|
invitees.where.not(
|
|
user_id:
|
|
TopicUser
|
|
.where(
|
|
"topic_users.topic_id = ? AND topic_users.last_visited_at >= ? AND topic_users.last_read_post_number >= ?",
|
|
event.post.topic_id,
|
|
event_start_time,
|
|
1,
|
|
)
|
|
.pluck(:user_id)
|
|
.concat(already_notified_users.pluck(:user_id)),
|
|
)
|
|
else
|
|
invitees = invitees.where.not(user_id: already_notified_users.pluck(:user_id))
|
|
end
|
|
|
|
event_end_time =
|
|
(
|
|
if event.ends_at.is_a?(ActiveSupport::TimeWithZone)
|
|
event.ends_at
|
|
else
|
|
event.ends_at&.in_time_zone(event.timezone || "UTC")
|
|
end
|
|
)
|
|
event_ended = event_end_time && current_time > event_end_time
|
|
prefix = "before"
|
|
if event_ended
|
|
prefix = "after"
|
|
elsif event_started && !event_ended
|
|
prefix = "ongoing"
|
|
end
|
|
|
|
invitees.find_each do |invitee|
|
|
attrs = {
|
|
notification_type: Notification.types[:event_reminder] || Notification.types[:custom],
|
|
topic_id: event.post.topic_id,
|
|
post_number: event.post.post_number,
|
|
data: {
|
|
topic_title: event.name || event.post.topic.title,
|
|
display_username: invitee.user.username,
|
|
message: "discourse_post_event.notifications.#{prefix}_event_reminder",
|
|
}.to_json,
|
|
}
|
|
|
|
invitee.user.notifications.consolidate_or_create!(attrs)
|
|
|
|
PostAlerter.new(event.post).create_notification_alert(
|
|
user: invitee.user,
|
|
post: event.post,
|
|
username: invitee.user.username,
|
|
notification_type: Notification.types[:event_reminder] || Notification.types[:custom],
|
|
excerpt:
|
|
I18n.t(
|
|
"discourse_post_event.notifications.#{prefix}_event_reminder",
|
|
title: event.name || event.post.topic.title,
|
|
locale: invitee.user.effective_locale,
|
|
),
|
|
)
|
|
end
|
|
end
|
|
end
|
|
end
|
