mirror of
https://github.com/basecamp/once-campfire.git
synced 2026-10-08 15:50:08 +09:00
78a84a6ab7
Boosting and unboosting touch the message, so after_update_commit rewrote its row in the full-text index with the same text, loading the rich text again to rebuild it, on every boost. The index only needs a new row when the rich text body was saved. Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_0142qgjggdJ2KDdGk7RF9Xm9
42 lines
1.4 KiB
Ruby
42 lines
1.4 KiB
Ruby
module Message::Searchable
|
|
extend ActiveSupport::Concern
|
|
|
|
included do
|
|
after_create_commit :create_in_index
|
|
after_update_commit :update_in_index, if: :body_saved?
|
|
after_destroy_commit :remove_from_index
|
|
|
|
scope :search, ->(query) { joins("join message_search_index idx on messages.id = idx.rowid").where("idx.body match ?", match_terms(query)).ordered }
|
|
end
|
|
|
|
class_methods do
|
|
# Quotes each word, so that FTS5 searches for AND, OR, NOT and NEAR rather than
|
|
# parsing them as operators, which fails on a query like "AND" or "salt AND".
|
|
def match_terms(query)
|
|
query.split.map { |word| %("#{word.gsub('"', '""')}") }.join(" ")
|
|
end
|
|
end
|
|
|
|
private
|
|
def create_in_index
|
|
execute_sql_with_binds "insert into message_search_index(rowid, body) values (?, ?)", id, plain_text_body
|
|
end
|
|
|
|
# Boosts touch their message too: rewrite the index only when the body was saved.
|
|
def body_saved?
|
|
association(:rich_text_body).target&.saved_change_to_body?
|
|
end
|
|
|
|
def update_in_index
|
|
execute_sql_with_binds "update message_search_index set body = ? where rowid = ?", plain_text_body, id
|
|
end
|
|
|
|
def remove_from_index
|
|
execute_sql_with_binds "delete from message_search_index where rowid = ?", id
|
|
end
|
|
|
|
def execute_sql_with_binds(*statement)
|
|
self.class.connection.execute self.class.sanitize_sql(statement)
|
|
end
|
|
end
|