2016-11-15 10:56:29 -05:00
|
|
|
# frozen_string_literal: true
|
2017-05-01 20:14:47 -04:00
|
|
|
# == Schema Information
|
|
|
|
#
|
|
|
|
# Table name: accounts
|
|
|
|
#
|
|
|
|
# id :integer not null, primary key
|
|
|
|
# username :string default(""), not null
|
|
|
|
# domain :string
|
|
|
|
# secret :string default(""), not null
|
|
|
|
# private_key :text
|
|
|
|
# public_key :text default(""), not null
|
|
|
|
# remote_url :string default(""), not null
|
|
|
|
# salmon_url :string default(""), not null
|
|
|
|
# hub_url :string default(""), not null
|
|
|
|
# created_at :datetime not null
|
|
|
|
# updated_at :datetime not null
|
|
|
|
# note :text default(""), not null
|
|
|
|
# display_name :string default(""), not null
|
|
|
|
# uri :string default(""), not null
|
|
|
|
# url :string
|
|
|
|
# avatar_file_name :string
|
|
|
|
# avatar_content_type :string
|
|
|
|
# avatar_file_size :integer
|
|
|
|
# avatar_updated_at :datetime
|
|
|
|
# header_file_name :string
|
|
|
|
# header_content_type :string
|
|
|
|
# header_file_size :integer
|
|
|
|
# header_updated_at :datetime
|
|
|
|
# avatar_remote_url :string
|
|
|
|
# subscription_expires_at :datetime
|
|
|
|
# silenced :boolean default(FALSE), not null
|
|
|
|
# suspended :boolean default(FALSE), not null
|
|
|
|
# locked :boolean default(FALSE), not null
|
|
|
|
# header_remote_url :string default(""), not null
|
|
|
|
# statuses_count :integer default(0), not null
|
|
|
|
# followers_count :integer default(0), not null
|
|
|
|
# following_count :integer default(0), not null
|
|
|
|
# last_webfingered_at :datetime
|
2017-07-19 11:06:46 -04:00
|
|
|
# inbox_url :string default(""), not null
|
|
|
|
# outbox_url :string default(""), not null
|
|
|
|
# shared_inbox_url :string default(""), not null
|
|
|
|
# followers_url :string default(""), not null
|
|
|
|
# protocol :integer default("ostatus"), not null
|
2017-11-07 13:06:44 -05:00
|
|
|
# memorial :boolean default(FALSE), not null
|
2017-05-01 20:14:47 -04:00
|
|
|
#
|
2016-11-15 10:56:29 -05:00
|
|
|
|
2016-08-17 11:56:23 -04:00
|
|
|
class Account < ApplicationRecord
|
2017-11-07 13:08:14 -05:00
|
|
|
MENTION_RE = /(?<=^|[^\/[:word:]])@(([a-z0-9_]+)(?:@[a-z0-9\.\-]+[a-z0-9]+)?)/i
|
2017-05-05 15:37:02 -04:00
|
|
|
|
|
|
|
include AccountAvatar
|
2017-05-31 14:28:45 -04:00
|
|
|
include AccountFinderConcern
|
2017-05-05 15:37:02 -04:00
|
|
|
include AccountHeader
|
Account domain blocks (#2381)
* Add <ostatus:conversation /> tag to Atom input/output
Only uses ref attribute (not href) because href would be
the alternate link that's always included also.
Creates new conversation for every non-reply status. Carries
over conversation for every reply. Keeps remote URIs verbatim,
generates local URIs on the fly like the rest of them.
* Conversation muting - prevents notifications that reference a conversation
(including replies, favourites, reblogs) from being created. API endpoints
/api/v1/statuses/:id/mute and /api/v1/statuses/:id/unmute
Currently no way to tell when a status/conversation is muted, so the web UI
only has a "disable notifications" button, doesn't work as a toggle
* Display "Dismiss notifications" on all statuses in notifications column, not just own
* Add "muted" as a boolean attribute on statuses JSON
For now always false on contained reblogs, since it's only relevant for
statuses returned from the notifications endpoint, which are not nested
Remove "Disable notifications" from detailed status view, since it's
only relevant in the notifications column
* Up max class length
* Remove pending test for conversation mute
* Add tests, clean up
* Rename to "mute conversation" and "unmute conversation"
* Raise validation error when trying to mute/unmute status without conversation
* Adding account domain blocks that filter notifications and public timelines
* Add tests for domain blocks in notifications, public timelines
Filter reblogs of blocked domains from home
* Add API for listing and creating account domain blocks
* API for creating/deleting domain blocks, tests for Status#ancestors
and Status#descendants, filter domain blocks from them
* Filter domains in streaming API
* Update account_domain_block_spec.rb
2017-05-18 19:14:30 -04:00
|
|
|
include AccountInteractions
|
2017-05-05 15:37:02 -04:00
|
|
|
include Attachmentable
|
2017-05-18 09:43:10 -04:00
|
|
|
include Remotable
|
2016-09-12 12:22:43 -04:00
|
|
|
|
2017-07-19 11:06:46 -04:00
|
|
|
enum protocol: [:ostatus, :activitypub]
|
|
|
|
|
2016-02-22 10:00:20 -05:00
|
|
|
# Local users
|
|
|
|
has_one :user, inverse_of: :account
|
|
|
|
|
2017-05-07 10:40:57 -04:00
|
|
|
validates :username, presence: true
|
2017-06-08 09:22:01 -04:00
|
|
|
|
|
|
|
# Remote user validations
|
2017-06-11 11:01:32 -04:00
|
|
|
validates :username, uniqueness: { scope: :domain, case_sensitive: true }, if: -> { !local? && will_save_change_to_username? }
|
2017-05-07 10:40:57 -04:00
|
|
|
|
|
|
|
# Local user validations
|
2017-06-11 11:01:32 -04:00
|
|
|
validates :username, format: { with: /\A[a-z0-9_]+\z/i }, uniqueness: { scope: :domain, case_sensitive: false }, length: { maximum: 30 }, if: -> { local? && will_save_change_to_username? }
|
|
|
|
validates_with UnreservedUsernameValidator, if: -> { local? && will_save_change_to_username? }
|
|
|
|
validates :display_name, length: { maximum: 30 }, if: -> { local? && will_save_change_to_display_name? }
|
|
|
|
validates :note, length: { maximum: 160 }, if: -> { local? && will_save_change_to_note? }
|
2016-03-16 06:18:09 -04:00
|
|
|
|
2016-02-22 10:00:20 -05:00
|
|
|
# Timelines
|
2016-10-09 08:48:43 -04:00
|
|
|
has_many :stream_entries, inverse_of: :account, dependent: :destroy
|
|
|
|
has_many :statuses, inverse_of: :account, dependent: :destroy
|
|
|
|
has_many :favourites, inverse_of: :account, dependent: :destroy
|
|
|
|
has_many :mentions, inverse_of: :account, dependent: :destroy
|
2016-11-21 08:59:13 -05:00
|
|
|
has_many :notifications, inverse_of: :account, dependent: :destroy
|
2016-02-20 16:53:20 -05:00
|
|
|
|
2017-08-24 19:41:18 -04:00
|
|
|
# Pinned statuses
|
|
|
|
has_many :status_pins, inverse_of: :account, dependent: :destroy
|
2017-08-25 12:50:52 -04:00
|
|
|
has_many :pinned_statuses, -> { reorder('status_pins.created_at DESC') }, through: :status_pins, class_name: 'Status', source: :status
|
2017-08-24 19:41:18 -04:00
|
|
|
|
2016-11-28 07:36:47 -05:00
|
|
|
# Media
|
2016-09-05 11:46:36 -04:00
|
|
|
has_many :media_attachments, dependent: :destroy
|
|
|
|
|
2016-11-28 07:36:47 -05:00
|
|
|
# PuSH subscriptions
|
|
|
|
has_many :subscriptions, dependent: :destroy
|
|
|
|
|
2017-04-18 13:36:18 -04:00
|
|
|
# Report relationships
|
|
|
|
has_many :reports
|
|
|
|
has_many :targeted_reports, class_name: 'Report', foreign_key: :target_account_id
|
|
|
|
|
2017-10-07 14:26:43 -04:00
|
|
|
# Moderation notes
|
2017-10-10 07:12:17 -04:00
|
|
|
has_many :account_moderation_notes, dependent: :destroy
|
|
|
|
has_many :targeted_moderation_notes, class_name: 'AccountModerationNote', foreign_key: :target_account_id, dependent: :destroy
|
2017-10-07 14:26:43 -04:00
|
|
|
|
2016-09-19 18:39:03 -04:00
|
|
|
scope :remote, -> { where.not(domain: nil) }
|
|
|
|
scope :local, -> { where(domain: nil) }
|
2017-05-04 20:23:01 -04:00
|
|
|
scope :without_followers, -> { where(followers_count: 0) }
|
|
|
|
scope :with_followers, -> { where('followers_count > 0') }
|
2017-08-21 11:32:41 -04:00
|
|
|
scope :expiring, ->(time) { remote.where.not(subscription_expires_at: nil).where('subscription_expires_at < ?', time) }
|
2017-05-04 20:23:01 -04:00
|
|
|
scope :partitioned, -> { order('row_number() over (partition by domain)') }
|
2016-12-06 12:22:59 -05:00
|
|
|
scope :silenced, -> { where(silenced: true) }
|
|
|
|
scope :suspended, -> { where(suspended: true) }
|
2017-01-07 20:55:40 -05:00
|
|
|
scope :recent, -> { reorder(id: :desc) }
|
|
|
|
scope :alphabetic, -> { order(domain: :asc, username: :asc) }
|
2017-04-18 15:09:07 -04:00
|
|
|
scope :by_domain_accounts, -> { group(:domain).select(:domain, 'COUNT(*) AS accounts_count').order('accounts_count desc') }
|
2017-05-22 15:50:58 -04:00
|
|
|
scope :matches_username, ->(value) { where(arel_table[:username].matches("#{value}%")) }
|
|
|
|
scope :matches_display_name, ->(value) { where(arel_table[:display_name].matches("#{value}%")) }
|
2017-09-13 06:30:07 -04:00
|
|
|
scope :matches_domain, ->(value) { where(arel_table[:domain].matches("%#{value}%")) }
|
2016-10-16 12:57:54 -04:00
|
|
|
|
2017-04-28 09:12:37 -04:00
|
|
|
delegate :email,
|
2017-05-01 10:31:02 -04:00
|
|
|
:current_sign_in_ip,
|
|
|
|
:current_sign_in_at,
|
|
|
|
:confirmed?,
|
2017-08-16 11:12:58 -04:00
|
|
|
:admin?,
|
2017-05-08 17:10:50 -04:00
|
|
|
:locale,
|
2017-05-01 10:31:02 -04:00
|
|
|
to: :user,
|
|
|
|
prefix: true,
|
|
|
|
allow_nil: true
|
2017-04-28 09:12:37 -04:00
|
|
|
|
2017-05-20 11:32:44 -04:00
|
|
|
delegate :filtered_languages, to: :user, prefix: false, allow_nil: true
|
2017-05-01 11:42:13 -04:00
|
|
|
|
2016-02-22 10:00:20 -05:00
|
|
|
def local?
|
2016-09-29 15:28:21 -04:00
|
|
|
domain.nil?
|
2016-02-22 10:00:20 -05:00
|
|
|
end
|
|
|
|
|
2016-02-22 12:10:30 -05:00
|
|
|
def acct
|
2016-09-29 15:28:21 -04:00
|
|
|
local? ? username : "#{username}@#{domain}"
|
2016-02-22 12:10:30 -05:00
|
|
|
end
|
|
|
|
|
2017-04-10 16:58:06 -04:00
|
|
|
def local_username_and_domain
|
|
|
|
"#{username}@#{Rails.configuration.x.local_domain}"
|
|
|
|
end
|
|
|
|
|
|
|
|
def to_webfinger_s
|
|
|
|
"acct:#{local_username_and_domain}"
|
|
|
|
end
|
|
|
|
|
2016-02-22 12:10:30 -05:00
|
|
|
def subscribed?
|
2017-05-03 13:13:04 -04:00
|
|
|
subscription_expires_at.present?
|
2016-02-22 12:10:30 -05:00
|
|
|
end
|
|
|
|
|
2017-09-28 11:50:14 -04:00
|
|
|
def possibly_stale?
|
|
|
|
last_webfingered_at.nil? || last_webfingered_at <= 1.day.ago
|
|
|
|
end
|
|
|
|
|
|
|
|
def refresh!
|
|
|
|
return if local?
|
|
|
|
ResolveRemoteAccountService.new.call(acct)
|
|
|
|
end
|
|
|
|
|
2017-11-07 13:06:44 -05:00
|
|
|
def unsuspend!
|
|
|
|
transaction do
|
|
|
|
user&.enable! if local?
|
|
|
|
update!(suspended: false)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def memorialize!
|
|
|
|
transaction do
|
|
|
|
user&.disable! if local?
|
|
|
|
update!(memorial: true)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2016-02-22 10:00:20 -05:00
|
|
|
def keypair
|
2017-08-21 11:32:41 -04:00
|
|
|
@keypair ||= OpenSSL::PKey::RSA.new(private_key || public_key)
|
2016-02-22 10:00:20 -05:00
|
|
|
end
|
|
|
|
|
2016-02-20 16:53:20 -05:00
|
|
|
def subscription(webhook_url)
|
2017-08-21 11:32:41 -04:00
|
|
|
@subscription ||= OStatus2::Subscription.new(remote_url, secret: secret, webhook: webhook_url, hub: hub_url)
|
2016-02-20 16:53:20 -05:00
|
|
|
end
|
2016-02-26 09:28:08 -05:00
|
|
|
|
2017-05-05 15:37:02 -04:00
|
|
|
def save_with_optional_media!
|
2016-12-02 08:14:49 -05:00
|
|
|
save!
|
2017-01-18 20:14:57 -05:00
|
|
|
rescue ActiveRecord::RecordInvalid
|
2017-01-19 03:37:07 -05:00
|
|
|
self.avatar = nil
|
2017-03-18 17:51:20 -04:00
|
|
|
self.header = nil
|
2017-01-19 03:37:07 -05:00
|
|
|
self[:avatar_remote_url] = ''
|
2017-03-18 17:51:20 -04:00
|
|
|
self[:header_remote_url] = ''
|
2017-01-18 20:14:57 -05:00
|
|
|
save!
|
2016-02-28 08:33:13 -05:00
|
|
|
end
|
|
|
|
|
2016-03-24 21:13:30 -04:00
|
|
|
def object_type
|
|
|
|
:person
|
|
|
|
end
|
|
|
|
|
2016-02-29 13:42:08 -05:00
|
|
|
def to_param
|
2016-09-29 15:28:21 -04:00
|
|
|
username
|
2016-02-29 13:42:08 -05:00
|
|
|
end
|
|
|
|
|
2017-04-28 09:10:41 -04:00
|
|
|
def excluded_from_timeline_account_ids
|
|
|
|
Rails.cache.fetch("exclude_account_ids_for:#{id}") { blocking.pluck(:target_account_id) + blocked_by.pluck(:account_id) + muting.pluck(:target_account_id) }
|
|
|
|
end
|
|
|
|
|
Account domain blocks (#2381)
* Add <ostatus:conversation /> tag to Atom input/output
Only uses ref attribute (not href) because href would be
the alternate link that's always included also.
Creates new conversation for every non-reply status. Carries
over conversation for every reply. Keeps remote URIs verbatim,
generates local URIs on the fly like the rest of them.
* Conversation muting - prevents notifications that reference a conversation
(including replies, favourites, reblogs) from being created. API endpoints
/api/v1/statuses/:id/mute and /api/v1/statuses/:id/unmute
Currently no way to tell when a status/conversation is muted, so the web UI
only has a "disable notifications" button, doesn't work as a toggle
* Display "Dismiss notifications" on all statuses in notifications column, not just own
* Add "muted" as a boolean attribute on statuses JSON
For now always false on contained reblogs, since it's only relevant for
statuses returned from the notifications endpoint, which are not nested
Remove "Disable notifications" from detailed status view, since it's
only relevant in the notifications column
* Up max class length
* Remove pending test for conversation mute
* Add tests, clean up
* Rename to "mute conversation" and "unmute conversation"
* Raise validation error when trying to mute/unmute status without conversation
* Adding account domain blocks that filter notifications and public timelines
* Add tests for domain blocks in notifications, public timelines
Filter reblogs of blocked domains from home
* Add API for listing and creating account domain blocks
* API for creating/deleting domain blocks, tests for Status#ancestors
and Status#descendants, filter domain blocks from them
* Filter domains in streaming API
* Update account_domain_block_spec.rb
2017-05-18 19:14:30 -04:00
|
|
|
def excluded_from_timeline_domains
|
|
|
|
Rails.cache.fetch("exclude_domains_for:#{id}") { domain_blocks.pluck(:domain) }
|
|
|
|
end
|
|
|
|
|
2016-11-09 11:48:44 -05:00
|
|
|
class << self
|
2017-09-11 18:16:03 -04:00
|
|
|
def readonly_attributes
|
|
|
|
super - %w(statuses_count following_count followers_count)
|
|
|
|
end
|
|
|
|
|
2017-06-22 12:34:27 -04:00
|
|
|
def domains
|
|
|
|
reorder(nil).pluck('distinct accounts.domain')
|
|
|
|
end
|
|
|
|
|
2017-08-12 18:44:41 -04:00
|
|
|
def inboxes
|
2017-09-28 21:16:20 -04:00
|
|
|
urls = reorder(nil).where(protocol: :activitypub).pluck("distinct coalesce(nullif(accounts.shared_inbox_url, ''), accounts.inbox_url)")
|
|
|
|
DeliveryFailureTracker.filter(urls)
|
2017-08-12 18:44:41 -04:00
|
|
|
end
|
|
|
|
|
2017-05-16 06:06:38 -04:00
|
|
|
def triadic_closures(account, limit: 5, offset: 0)
|
2017-04-09 08:45:01 -04:00
|
|
|
sql = <<-SQL.squish
|
2017-03-16 15:10:51 -04:00
|
|
|
WITH first_degree AS (
|
2017-05-16 06:06:38 -04:00
|
|
|
SELECT target_account_id
|
|
|
|
FROM follows
|
|
|
|
WHERE account_id = :account_id
|
|
|
|
)
|
2017-03-16 15:10:51 -04:00
|
|
|
SELECT accounts.*
|
|
|
|
FROM follows
|
|
|
|
INNER JOIN accounts ON follows.target_account_id = accounts.id
|
2017-05-16 06:06:38 -04:00
|
|
|
WHERE
|
|
|
|
account_id IN (SELECT * FROM first_degree)
|
|
|
|
AND target_account_id NOT IN (SELECT * FROM first_degree)
|
|
|
|
AND target_account_id NOT IN (:excluded_account_ids)
|
2017-06-14 12:01:27 -04:00
|
|
|
AND accounts.suspended = false
|
2017-03-16 15:10:51 -04:00
|
|
|
GROUP BY target_account_id, accounts.id
|
|
|
|
ORDER BY count(account_id) DESC
|
2017-05-16 06:06:38 -04:00
|
|
|
OFFSET :offset
|
2017-04-17 19:21:55 -04:00
|
|
|
LIMIT :limit
|
2017-04-09 08:45:01 -04:00
|
|
|
SQL
|
2017-03-16 15:10:51 -04:00
|
|
|
|
2017-05-16 06:06:38 -04:00
|
|
|
excluded_account_ids = account.excluded_from_timeline_account_ids + [account.id]
|
|
|
|
|
2017-04-17 19:21:55 -04:00
|
|
|
find_by_sql(
|
2017-05-16 06:06:38 -04:00
|
|
|
[sql, { account_id: account.id, excluded_account_ids: excluded_account_ids, limit: limit, offset: offset }]
|
2017-04-17 19:21:55 -04:00
|
|
|
)
|
2017-03-16 15:10:51 -04:00
|
|
|
end
|
|
|
|
|
2017-03-17 15:47:38 -04:00
|
|
|
def search_for(terms, limit = 10)
|
2017-05-07 10:40:57 -04:00
|
|
|
textsearch, query = generate_query_for_search(terms)
|
2017-03-17 15:47:38 -04:00
|
|
|
|
2017-04-09 08:45:01 -04:00
|
|
|
sql = <<-SQL.squish
|
2017-03-17 15:47:38 -04:00
|
|
|
SELECT
|
|
|
|
accounts.*,
|
|
|
|
ts_rank_cd(#{textsearch}, #{query}, 32) AS rank
|
|
|
|
FROM accounts
|
|
|
|
WHERE #{query} @@ #{textsearch}
|
2017-06-14 12:01:27 -04:00
|
|
|
AND accounts.suspended = false
|
2017-03-17 15:47:38 -04:00
|
|
|
ORDER BY rank DESC
|
|
|
|
LIMIT ?
|
2017-04-09 08:45:01 -04:00
|
|
|
SQL
|
2017-03-17 15:47:38 -04:00
|
|
|
|
2017-05-07 10:40:57 -04:00
|
|
|
find_by_sql([sql, limit])
|
2017-03-17 15:47:38 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def advanced_search_for(terms, account, limit = 10)
|
2017-05-07 10:40:57 -04:00
|
|
|
textsearch, query = generate_query_for_search(terms)
|
2017-03-17 15:47:38 -04:00
|
|
|
|
2017-04-09 08:45:01 -04:00
|
|
|
sql = <<-SQL.squish
|
2017-03-17 15:47:38 -04:00
|
|
|
SELECT
|
|
|
|
accounts.*,
|
|
|
|
(count(f.id) + 1) * ts_rank_cd(#{textsearch}, #{query}, 32) AS rank
|
|
|
|
FROM accounts
|
|
|
|
LEFT OUTER JOIN follows AS f ON (accounts.id = f.account_id AND f.target_account_id = ?) OR (accounts.id = f.target_account_id AND f.account_id = ?)
|
|
|
|
WHERE #{query} @@ #{textsearch}
|
2017-06-14 12:01:27 -04:00
|
|
|
AND accounts.suspended = false
|
2017-03-17 15:47:38 -04:00
|
|
|
GROUP BY accounts.id
|
|
|
|
ORDER BY rank DESC
|
|
|
|
LIMIT ?
|
2017-04-09 08:45:01 -04:00
|
|
|
SQL
|
2017-03-17 15:47:38 -04:00
|
|
|
|
2017-05-07 10:40:57 -04:00
|
|
|
find_by_sql([sql, account.id, account.id, limit])
|
2017-03-17 15:47:38 -04:00
|
|
|
end
|
|
|
|
|
2017-01-08 13:12:54 -05:00
|
|
|
private
|
|
|
|
|
2017-05-07 10:40:57 -04:00
|
|
|
def generate_query_for_search(terms)
|
|
|
|
terms = Arel.sql(connection.quote(terms.gsub(/['?\\:]/, ' ')))
|
|
|
|
textsearch = "(setweight(to_tsvector('simple', accounts.display_name), 'A') || setweight(to_tsvector('simple', accounts.username), 'B') || setweight(to_tsvector('simple', coalesce(accounts.domain, '')), 'C'))"
|
|
|
|
query = "to_tsquery('simple', ''' ' || #{terms} || ' ''' || ':*')"
|
|
|
|
|
|
|
|
[textsearch, query]
|
|
|
|
end
|
2016-10-03 11:16:58 -04:00
|
|
|
end
|
|
|
|
|
2017-04-24 20:47:31 -04:00
|
|
|
before_create :generate_keys
|
|
|
|
before_validation :normalize_domain
|
2017-07-14 13:47:53 -04:00
|
|
|
before_validation :prepare_contents, if: :local?
|
2017-04-18 17:15:44 -04:00
|
|
|
|
|
|
|
private
|
|
|
|
|
2017-07-14 13:47:53 -04:00
|
|
|
def prepare_contents
|
|
|
|
display_name&.strip!
|
|
|
|
note&.strip!
|
|
|
|
end
|
|
|
|
|
2017-04-24 20:47:31 -04:00
|
|
|
def generate_keys
|
|
|
|
return unless local?
|
|
|
|
|
2017-08-24 07:31:55 -04:00
|
|
|
keypair = OpenSSL::PKey::RSA.new(Rails.env.test? ? 512 : 2048)
|
2017-04-24 20:47:31 -04:00
|
|
|
self.private_key = keypair.to_pem
|
|
|
|
self.public_key = keypair.public_key.to_pem
|
|
|
|
end
|
|
|
|
|
|
|
|
def normalize_domain
|
|
|
|
return if local?
|
|
|
|
|
|
|
|
self.domain = TagManager.instance.normalize_domain(domain)
|
|
|
|
end
|
2016-02-20 16:53:20 -05:00
|
|
|
end
|