mirror of
https://github.com/discourse/discourse.git
synced 2024-12-12 06:23:41 +08:00
1a7922bea2
This adds a new table UserNotificationSchedules which stores monday-friday start and ends times that each user would like to receive notifications (with a Boolean enabled to remove the use of the schedule). There is then a background job that runs every day and creates do_not_disturb_timings for each user with an enabled notification schedule. The job schedules timings 2 days in advance. The job is designed so that it can be run at any point in time, and it will not create duplicate records. When a users saves their notification schedule, the schedule processing service will run and schedule do_not_disturb_timings. If the user should be in DND due to their schedule, the user will immediately be put in DND (message bus publishes this state). The UI for a user's notification schedule is in user -> preferences -> notifications. By default every day is 8am - 5pm when first enabled.
88 lines
2.6 KiB
Ruby
88 lines
2.6 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class UserNotificationScheduleProcessor
|
|
|
|
attr_accessor :schedule, :user, :timezone_name
|
|
|
|
def initialize(schedule)
|
|
@schedule = schedule
|
|
@user = schedule.user
|
|
@timezone_name = user.user_option.timezone
|
|
end
|
|
|
|
def create_do_not_disturb_timings
|
|
local_time = Time.now.in_time_zone(timezone_name)
|
|
|
|
create_timings_for(local_time, days: 2)
|
|
end
|
|
|
|
def self.create_do_not_disturb_timings_for(schedule)
|
|
processor = UserNotificationScheduleProcessor.new(schedule)
|
|
processor.create_do_not_disturb_timings
|
|
end
|
|
|
|
private
|
|
|
|
def create_timings_for(local_time, days: 0, previous_timing: nil)
|
|
weekday = transform_wday(local_time.wday)
|
|
start_minute = schedule["day_#{weekday}_start_time"]
|
|
end_minute = schedule["day_#{weekday}_end_time"]
|
|
|
|
previous_timing = find_previous_timing(local_time) if previous_timing.nil? && start_minute != 0
|
|
|
|
if start_minute > 0
|
|
previous_timing.ends_at = utc_time_at_minute(local_time, start_minute - 1)
|
|
if previous_timing.id
|
|
previous_timing.save
|
|
else
|
|
user.do_not_disturb_timings.find_or_create_by(previous_timing.attributes.except("id"))
|
|
end
|
|
|
|
next_timing = user.do_not_disturb_timings.new(
|
|
starts_at: utc_time_at_minute(local_time, end_minute),
|
|
scheduled: true
|
|
)
|
|
save_timing_and_continue(local_time, next_timing, days)
|
|
else
|
|
save_timing_and_continue(local_time, previous_timing, days)
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def find_previous_timing(local_time)
|
|
# Try and find a previously scheduled dnd timing that we can extend if the
|
|
# ends_at is at the previous midnight. fallback to a new timing if not.
|
|
previous = user.do_not_disturb_timings.find_by(
|
|
ends_at: (local_time - 1.day).end_of_day.utc,
|
|
scheduled: true
|
|
)
|
|
previous || user.do_not_disturb_timings.new(
|
|
starts_at: local_time.beginning_of_day.utc,
|
|
scheduled: true
|
|
)
|
|
end
|
|
|
|
def save_timing_and_continue(local_time, timing, days)
|
|
if days == 0
|
|
if timing
|
|
timing.ends_at = local_time.end_of_day.utc
|
|
user.do_not_disturb_timings.find_or_create_by(timing.attributes.except("id"))
|
|
end
|
|
user.publish_do_not_disturb(ends_at: user.do_not_disturb_until)
|
|
else
|
|
create_timings_for(local_time + 1.day, days: days - 1, previous_timing: timing)
|
|
end
|
|
end
|
|
|
|
def utc_time_at_minute(base_time, total_minutes)
|
|
hour = total_minutes / 60
|
|
minute = total_minutes % 60
|
|
Time.new(base_time.year, base_time.month, base_time.day, hour, minute, 0, base_time.formatted_offset).utc
|
|
end
|
|
|
|
def transform_wday(wday)
|
|
wday == 0 ? 6 : wday - 1
|
|
end
|
|
end
|