私は新しいバージョンの Discourse に対応できるように、私の側で plugin.rb ファイルを変更しました。
# frozen_string_literal: true
# name: discourse-calendar-rsvp-posts
# about: Create short topic replies for RSVP events
# version: 0.9
# authors: Mario Santana, gilles
after_initialize do
module ::CalendarRsvpPosts
PLUGIN_NAME = "discourse-calendar-rsvp-posts"
def self.event_class
"DiscourseEvents::Events::Event".safe_constantize ||
"DiscourseEvents::Event".safe_constantize ||
"DiscourseCalendar::Event".safe_constantize ||
"DiscoursePostEvent::Event".safe_constantize
end
def self.invitee_class
"DiscourseEvents::Events::Invitee".safe_constantize ||
"DiscourseEvents::Invitee".safe_constantize ||
"DiscourseCalendar::Invitee".safe_constantize ||
"DiscoursePostEvent::Invitee".safe_constantize
end
def self.history_marker
I18n.t('calendar_rsvp_posts.markers.history')
end
def self.notification_marker
I18n.t('calendar_rsvp_posts.markers.notification')
end
# このイベントを無視すべきかどうかを判断するヘルパー
def self.should_post_for_event?(event)
return false if event.nil?
return true if SiteSetting.calendar_rsvp_posts_allow_past_events
return false if event.starts_at.nil?
event.starts_at >= Time.current
end
# イベントの RSVP 投稿（履歴または単なる通知）を検索する
def self.find_rsvp_posts(event)
return [] if event.nil? || event.post.nil? || event.post.topic.nil?
event.post.topic.posts
.where(user_id: Discourse.system_user.id)
.where("raw LIKE ? OR raw LIKE ?",
"%#{history_marker}%",
"%#{notification_marker}%")
.order(created_at: :asc)
end
# 履歴投稿を特定して検索する
def self.find_history_post(event)
return nil if event.nil? || event.post.nil? || event.post.topic.nil?
event.post.topic.posts
.where(user_id: Discourse.system_user.id)
.where("raw LIKE ?", "%#{history_marker}%")
.order(created_at: :asc)
.first
end
# すべての通知投稿を検索して削除する（履歴投稿は除く）
def self.delete_notification_posts(event)
return if event.nil? || event.post.nil? || event.post.topic.nil?
notification_posts = event.post.topic.posts
.where(user_id: Discourse.system_user.id)
.where("raw LIKE ?", "%#{notification_marker}%")
notification_posts.each do |post|
begin
PostDestroyer.new(Discourse.system_user, post, context: "calendar-rsvp-posts cleanup").destroy
rescue StandardError => e
Rails.logger.warn("calendar-rsvp-posts: failed to delete notification post #{post.id}: #{e}")
end
end
end
# タイムスタンプ付きの履歴エントリ行を構築する
def self.build_history_entry(username, action_label, extra_text = nil)
timestamp = Time.current.strftime("%Y-%m-%d %H:%M UTC")
entry = "- **#{timestamp}** - #{username} #{action_label}"
entry += " (#{extra_text})" if extra_text.present?
entry
end
# 履歴投稿の内容を構築または更新する
def self.build_history_raw(event, new_entry)
event_title = (event.name.presence || event.post.topic.title).to_s
parts = []
parts << history_marker
parts << "### #{I18n.t('calendar_rsvp_posts.history.header', event_title: event_title)}"
parts << ""
parts << new_entry
parts.join("\n")
end
# 既存の履歴に新しいエントリを追加する
def self.append_to_history(existing_raw, new_entry)
lines = existing_raw.split("\n")
header_end_idx = lines.index { |line| line.start_with?("### RSVP History") }
if header_end_idx
insert_idx = header_end_idx + 2
lines.insert(insert_idx, new_entry)
else
lines << new_entry
end
lines.join("\n")
end
# 単なる通知投稿を履歴形式に変換する
def self.convert_to_history(simple_post, event)
raw = simple_post.raw
going_label = I18n.t('calendar_rsvp_posts.actions.going').gsub('(', '\\(').gsub(')', '\\)')
interested_label = I18n.t('calendar_rsvp_posts.actions.interested').gsub('(', '\\(').gsub(')', '\\)')
not_going_label = I18n.t('calendar_rsvp_posts.actions.not_going').gsub('(', '\\(').gsub(')', '\\)')
removed_label = I18n.t('calendar_rsvp_posts.actions.removed').gsub('(', '\\(').gsub(')', '\\)')
pattern = /\*\*([^\*]+)\s+(#{Regexp.escape(going_label)}|#{Regexp.escape(interested_label)}|#{Regexp.escape(not_going_label)}|#{Regexp.escape(removed_label)})\*\*/
match = raw.match(pattern)
if match
username = match[1]
action = match[2]
extra_match = raw.match(/\.\s+([^.]+)\.$/)
extra_text = extra_match ? extra_match[1] : nil
timestamp = simple_post.created_at.strftime("%Y-%m-%d %H:%M UTC")
first_entry = "- **#{timestamp}** - #{username} #{action}"
first_entry += " (#{extra_text})" if extra_text.present?
event_title = (event.name.presence || event.post.topic.title).to_s
parts = []
parts << history_marker
parts << "### #{I18n.t('calendar_rsvp_posts.history.header', event_title: event_title)}"
parts << ""
parts << first_entry
parts.join("\n")
else
event_title = (event.name.presence || event.post.topic.title).to_s
history_marker + "\n### #{I18n.t('calendar_rsvp_posts.history.header', event_title: event_title)}\n\n" + raw
end
end
# 通知投稿を構築する
def self.build_notification_raw(username, action_label, event, extra_text = nil)
event_title = (event.name.presence || event.post.topic.title).to_s
extra_text_formatted = extra_text.present? ? "#{extra_text} " : ""
notification_raw = notification_marker + "\n"
notification_raw += I18n.t('calendar_rsvp_posts.notification.template',
event_title: event_title,
extra: extra_text_formatted,
username: username,
action: action_label)
notification_raw
end
# 投稿の作成/更新を処理するための中央ロジックメソッド
def self.publish_rsvp_update(event, username, action_label, extra_text = nil)
if SiteSetting.calendar_rsvp_posts_enable_history
history_post = find_history_post(event)
all_rsvp_posts = find_rsvp_posts(event)
new_entry = build_history_entry(username, action_label, extra_text)
if all_rsvp_posts.empty?
notification_raw = build_notification_raw(username, action_label, event, extra_text)
PostCreator.create!(
Discourse.system_user,
topic_id: event.post.topic_id,
raw: notification_raw,
skip_validations: true
)
elsif history_post.nil?
first_post = all_rsvp_posts.first
history_raw = convert_to_history(first_post, event)
history_raw = append_to_history(history_raw, new_entry)
PostRevisor.new(first_post, event.post.topic).revise!(
Discourse.system_user,
raw: history_raw,
skip_validations: true,
skip_revision: false
)
notification_raw = build_notification_raw(username, action_label, event, extra_text)
PostCreator.create!(
Discourse.system_user,
topic_id: event.post.topic_id,
raw: notification_raw,
skip_validations: true
)
else
updated_raw = append_to_history(history_post.raw, new_entry)
PostRevisor.new(history_post, event.post.topic).revise!(
Discourse.system_user,
raw: updated_raw,
skip_validations: true,
skip_revision: false
)
delete_notification_posts(event)
notification_raw = build_notification_raw(username, action_label, event, extra_text)
PostCreator.create!(
Discourse.system_user,
topic_id: event.post.topic_id,
raw: notification_raw,
skip_validations: true
)
end
else
all_rsvp_posts = find_rsvp_posts(event)
all_rsvp_posts.each do |post|
begin
PostDestroyer.new(Discourse.system_user, post, context: "calendar-rsvp-posts cleanup").destroy
rescue StandardError => e
Rails.logger.warn("calendar-rsvp-posts: failed to delete post #{post.id}: #{e}")
end
end
notification_raw = build_notification_raw(username, action_label, event, extra_text)
PostCreator.create!(
Discourse.system_user,
topic_id: event.post.topic_id,
raw: notification_raw,
skip_validations: true
)
end
end
end
# ==========================================
# バックグラウンドジョブの定義
# ==========================================
module ::Jobs
class ProcessCalendarRsvpPost < ::Jobs::Base
def execute(args)
event_id = args[:event_id]
username = args[:username]
action_label = args[:action_label]
extra_text = args[:extra_text]
event_cls = ::CalendarRsvpPosts.event_class
return unless event_cls
event = event_cls.find_by(id: event_id)
return unless event
::CalendarRsvpPosts.publish_rsvp_update(event, username, action_label, extra_text)
end
end
end
# ==========================================
# イベントハンドラー
# ==========================================
# 出席の作成/更新用のハンドラー
proc_handler = proc do |invitee|
begin
event = invitee&.event
next if event.nil?
next unless CalendarRsvpPosts.should_post_for_event?(event)
invitee_cls = CalendarRsvpPosts.invitee_class
next unless invitee_cls
going_val = invitee_cls.statuses[:going]
interested_val = invitee_cls.statuses[:interested]
not_going_val = invitee_cls.statuses[:not_going]
new_status = invitee.status
prev_status =
if invitee.respond_to?(:previous_changes) && invitee.previous_changes["status"]
invitee.previous_changes["status"][0]
else
nil
end
next if prev_status && prev_status == new_status
username = invitee.user&.username || "someone"
action_label = nil
if new_status == going_val && SiteSetting.calendar_rsvp_posts_on_new_going
action_label = I18n.t('calendar_rsvp_posts.actions.going')
elsif new_status == interested_val && SiteSetting.calendar_rsvp_posts_on_new_interested
action_label = I18n.t('calendar_rsvp_posts.actions.interested')
elsif new_status == not_going_val && SiteSetting.calendar_rsvp_posts_on_new_not_going
action_label = I18n.t('calendar_rsvp_posts.actions.not_going')
end
next if action_label.nil?
extra_text = nil
if event.max_attendees.present?
current_going = event.going_count
prev_going =
if prev_status == going_val && new_status != going_val
current_going + 1
elsif prev_status != going_val && new_status == going_val
current_going - 1
else
current_going
end
was_full = prev_going >= event.max_attendees
is_full = current_going >= event.max_attendees
if was_full && !is_full
extra_text = I18n.t('calendar_rsvp_posts.capacity.spots_available')
elsif !was_full && is_full
extra_text = I18n.t('calendar_rsvp_posts.capacity.now_full')
end
end
# リクエストをブロックする代わりにジョブをキューに投入する
Jobs.enqueue(:process_calendar_rsvp_post,
event_id: event.id,
username: username,
action_label: action_label,
extra_text: extra_text
)
rescue StandardError => e
Rails.logger.warn("calendar-rsvp-posts: handler error: #{e}")
Rails.logger.warn(e.backtrace.join("\n"))
end
end
on(:discourse_calendar_post_event_invitee_status_changed, &proc_handler)
# 招待者の明示的な削除（RSVP の削除）用のハンドラー
invitee_cls = CalendarRsvpPosts.invitee_class
if invitee_cls
invitee_cls.class_eval do
after_destroy do
event = self.event
should_process = event.present? &&
SiteSetting.calendar_rsvp_posts_on_removed_rsvp &&
(SiteSetting.calendar_rsvp_posts_allow_past_events || event.starts_at.nil? || event.starts_at >= Time.current)
if should_process
begin
username = self.user&.username || "someone"
action_label = I18n.t('calendar_rsvp_posts.actions.removed')
# リクエストをブロックする代わりにジョブをキューに投入する
Jobs.enqueue(:process_calendar_rsvp_post,
event_id: event.id,
username: username,
action_label: action_label,
extra_text: nil
)
rescue StandardError => e
Rails.logger.warn("calendar-rsvp-posts: after_destroy handler error: #{e}")
Rails.logger.warn(e.backtrace.join("\n"))
end
end
end
end
end
end
