2016-11-15 09:56:29 -06:00
|
|
|
# frozen_string_literal: true
|
2017-05-01 19:14:47 -05: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
|
|
|
|
#
|
2016-11-15 09:56:29 -06:00
|
|
|
|
2016-08-17 10:56:23 -05:00
|
|
|
class Account < ApplicationRecord
|
2017-05-10 20:47:38 -05:00
|
|
|
MENTION_RE = /(?:^|[^\/[:word:]])@([a-z0-9_]+(?:@[a-z0-9\.\-]+[a-z0-9]+)?)/i
|
2017-05-05 14:37:02 -05:00
|
|
|
|
|
|
|
include AccountAvatar
|
2017-05-31 13:28:45 -05:00
|
|
|
include AccountFinderConcern
|
2017-05-05 14:37:02 -05: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 18:14:30 -05:00
|
|
|
include AccountInteractions
|
2017-05-05 14:37:02 -05:00
|
|
|
include Attachmentable
|
2017-05-18 08:43:10 -05:00
|
|
|
include Remotable
|
2016-09-12 11:22:43 -05:00
|
|
|
|
2016-02-22 09:00:20 -06:00
|
|
|
# Local users
|
|
|
|
has_one :user, inverse_of: :account
|
|
|
|
|
2017-05-07 09:40:57 -05:00
|
|
|
validates :username, presence: true
|
2017-05-18 20:11:23 -05:00
|
|
|
validates :username, uniqueness: { scope: :domain, case_sensitive: true }, unless: :local?
|
2017-05-07 09:40:57 -05:00
|
|
|
|
|
|
|
# Local user validations
|
2017-05-18 20:11:23 -05:00
|
|
|
with_options if: :local? do
|
2017-06-04 18:03:45 -05:00
|
|
|
validates :username, format: { with: /\A[a-z0-9_]+\z/i }, uniqueness: { scope: :domain, case_sensitive: false }, length: { maximum: 30 }, unreserved: true
|
2017-05-07 09:40:57 -05:00
|
|
|
validates :display_name, length: { maximum: 30 }
|
|
|
|
validates :note, length: { maximum: 160 }
|
|
|
|
end
|
2016-03-16 05:18:09 -05:00
|
|
|
|
2016-02-22 09:00:20 -06:00
|
|
|
# Timelines
|
2016-10-09 07:48:43 -05: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 07:59:13 -06:00
|
|
|
has_many :notifications, inverse_of: :account, dependent: :destroy
|
2016-02-20 15:53:20 -06:00
|
|
|
|
2016-11-28 06:36:47 -06:00
|
|
|
# Media
|
2016-09-05 10:46:36 -05:00
|
|
|
has_many :media_attachments, dependent: :destroy
|
|
|
|
|
2016-11-28 06:36:47 -06:00
|
|
|
# PuSH subscriptions
|
|
|
|
has_many :subscriptions, dependent: :destroy
|
|
|
|
|
2017-04-18 12:36:18 -05:00
|
|
|
# Report relationships
|
|
|
|
has_many :reports
|
|
|
|
has_many :targeted_reports, class_name: 'Report', foreign_key: :target_account_id
|
|
|
|
|
2016-09-19 17:39:03 -05:00
|
|
|
scope :remote, -> { where.not(domain: nil) }
|
|
|
|
scope :local, -> { where(domain: nil) }
|
2017-05-04 19:23:01 -05:00
|
|
|
scope :without_followers, -> { where(followers_count: 0) }
|
|
|
|
scope :with_followers, -> { where('followers_count > 0') }
|
2016-12-02 07:14:49 -06:00
|
|
|
scope :expiring, ->(time) { where(subscription_expires_at: nil).or(where('subscription_expires_at < ?', time)).remote.with_followers }
|
2017-05-04 19:23:01 -05:00
|
|
|
scope :partitioned, -> { order('row_number() over (partition by domain)') }
|
2016-12-06 11:22:59 -06:00
|
|
|
scope :silenced, -> { where(silenced: true) }
|
|
|
|
scope :suspended, -> { where(suspended: true) }
|
2017-01-07 19:55:40 -06:00
|
|
|
scope :recent, -> { reorder(id: :desc) }
|
|
|
|
scope :alphabetic, -> { order(domain: :asc, username: :asc) }
|
2017-04-18 14:09:07 -05:00
|
|
|
scope :by_domain_accounts, -> { group(:domain).select(:domain, 'COUNT(*) AS accounts_count').order('accounts_count desc') }
|
2017-05-22 14:50:58 -05:00
|
|
|
scope :matches_username, ->(value) { where(arel_table[:username].matches("#{value}%")) }
|
|
|
|
scope :matches_display_name, ->(value) { where(arel_table[:display_name].matches("#{value}%")) }
|
2016-10-16 11:57:54 -05:00
|
|
|
|
2017-04-28 08:12:37 -05:00
|
|
|
delegate :email,
|
2017-05-01 09:31:02 -05:00
|
|
|
:current_sign_in_ip,
|
|
|
|
:current_sign_in_at,
|
|
|
|
:confirmed?,
|
2017-05-08 16:10:50 -05:00
|
|
|
:locale,
|
2017-05-01 09:31:02 -05:00
|
|
|
to: :user,
|
|
|
|
prefix: true,
|
|
|
|
allow_nil: true
|
2017-04-28 08:12:37 -05:00
|
|
|
|
2017-05-20 10:32:44 -05:00
|
|
|
delegate :filtered_languages, to: :user, prefix: false, allow_nil: true
|
2017-05-01 10:42:13 -05:00
|
|
|
|
2016-02-22 09:00:20 -06:00
|
|
|
def local?
|
2016-09-29 14:28:21 -05:00
|
|
|
domain.nil?
|
2016-02-22 09:00:20 -06:00
|
|
|
end
|
|
|
|
|
2016-02-22 11:10:30 -06:00
|
|
|
def acct
|
2016-09-29 14:28:21 -05:00
|
|
|
local? ? username : "#{username}@#{domain}"
|
2016-02-22 11:10:30 -06:00
|
|
|
end
|
|
|
|
|
2017-04-10 15:58:06 -05: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 11:10:30 -06:00
|
|
|
def subscribed?
|
2017-05-03 12:13:04 -05:00
|
|
|
subscription_expires_at.present?
|
2016-02-22 11:10:30 -06:00
|
|
|
end
|
|
|
|
|
2017-04-23 17:38:37 -05:00
|
|
|
def followers_domains
|
|
|
|
followers.reorder(nil).pluck('distinct accounts.domain')
|
|
|
|
end
|
|
|
|
|
2016-02-22 09:00:20 -06:00
|
|
|
def keypair
|
2017-05-07 09:40:57 -05:00
|
|
|
OpenSSL::PKey::RSA.new(private_key || public_key)
|
2016-02-22 09:00:20 -06:00
|
|
|
end
|
|
|
|
|
2016-02-20 15:53:20 -06:00
|
|
|
def subscription(webhook_url)
|
2016-09-29 14:28:21 -05:00
|
|
|
OStatus2::Subscription.new(remote_url, secret: secret, lease_seconds: 86_400 * 30, webhook: webhook_url, hub: hub_url)
|
2016-02-20 15:53:20 -06:00
|
|
|
end
|
2016-02-26 08:28:08 -06:00
|
|
|
|
2017-05-05 14:37:02 -05:00
|
|
|
def save_with_optional_media!
|
2016-12-02 07:14:49 -06:00
|
|
|
save!
|
2017-01-18 19:14:57 -06:00
|
|
|
rescue ActiveRecord::RecordInvalid
|
2017-01-19 02:37:07 -06:00
|
|
|
self.avatar = nil
|
2017-03-18 16:51:20 -05:00
|
|
|
self.header = nil
|
2017-01-19 02:37:07 -06:00
|
|
|
self[:avatar_remote_url] = ''
|
2017-03-18 16:51:20 -05:00
|
|
|
self[:header_remote_url] = ''
|
2017-01-18 19:14:57 -06:00
|
|
|
save!
|
2016-02-28 07:33:13 -06:00
|
|
|
end
|
|
|
|
|
2016-03-24 20:13:30 -05:00
|
|
|
def object_type
|
|
|
|
:person
|
|
|
|
end
|
|
|
|
|
2016-02-29 12:42:08 -06:00
|
|
|
def to_param
|
2016-09-29 14:28:21 -05:00
|
|
|
username
|
2016-02-29 12:42:08 -06:00
|
|
|
end
|
|
|
|
|
2017-04-28 08:10:41 -05: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 18:14:30 -05:00
|
|
|
def excluded_from_timeline_domains
|
|
|
|
Rails.cache.fetch("exclude_domains_for:#{id}") { domain_blocks.pluck(:domain) }
|
|
|
|
end
|
|
|
|
|
2016-11-09 10:48:44 -06:00
|
|
|
class << self
|
2017-05-16 05:06:38 -05:00
|
|
|
def triadic_closures(account, limit: 5, offset: 0)
|
2017-04-09 07:45:01 -05:00
|
|
|
sql = <<-SQL.squish
|
2017-03-16 14:10:51 -05:00
|
|
|
WITH first_degree AS (
|
2017-05-16 05:06:38 -05:00
|
|
|
SELECT target_account_id
|
|
|
|
FROM follows
|
|
|
|
WHERE account_id = :account_id
|
|
|
|
)
|
2017-03-16 14:10:51 -05:00
|
|
|
SELECT accounts.*
|
|
|
|
FROM follows
|
|
|
|
INNER JOIN accounts ON follows.target_account_id = accounts.id
|
2017-05-16 05:06:38 -05: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-03-16 14:10:51 -05:00
|
|
|
GROUP BY target_account_id, accounts.id
|
|
|
|
ORDER BY count(account_id) DESC
|
2017-05-16 05:06:38 -05:00
|
|
|
OFFSET :offset
|
2017-04-17 18:21:55 -05:00
|
|
|
LIMIT :limit
|
2017-04-09 07:45:01 -05:00
|
|
|
SQL
|
2017-03-16 14:10:51 -05:00
|
|
|
|
2017-05-16 05:06:38 -05:00
|
|
|
excluded_account_ids = account.excluded_from_timeline_account_ids + [account.id]
|
|
|
|
|
2017-04-17 18:21:55 -05:00
|
|
|
find_by_sql(
|
2017-05-16 05:06:38 -05:00
|
|
|
[sql, { account_id: account.id, excluded_account_ids: excluded_account_ids, limit: limit, offset: offset }]
|
2017-04-17 18:21:55 -05:00
|
|
|
)
|
2017-03-16 14:10:51 -05:00
|
|
|
end
|
|
|
|
|
2017-03-17 14:47:38 -05:00
|
|
|
def search_for(terms, limit = 10)
|
2017-05-07 09:40:57 -05:00
|
|
|
textsearch, query = generate_query_for_search(terms)
|
2017-03-17 14:47:38 -05:00
|
|
|
|
2017-04-09 07:45:01 -05:00
|
|
|
sql = <<-SQL.squish
|
2017-03-17 14:47:38 -05:00
|
|
|
SELECT
|
|
|
|
accounts.*,
|
|
|
|
ts_rank_cd(#{textsearch}, #{query}, 32) AS rank
|
|
|
|
FROM accounts
|
|
|
|
WHERE #{query} @@ #{textsearch}
|
|
|
|
ORDER BY rank DESC
|
|
|
|
LIMIT ?
|
2017-04-09 07:45:01 -05:00
|
|
|
SQL
|
2017-03-17 14:47:38 -05:00
|
|
|
|
2017-05-07 09:40:57 -05:00
|
|
|
find_by_sql([sql, limit])
|
2017-03-17 14:47:38 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def advanced_search_for(terms, account, limit = 10)
|
2017-05-07 09:40:57 -05:00
|
|
|
textsearch, query = generate_query_for_search(terms)
|
2017-03-17 14:47:38 -05:00
|
|
|
|
2017-04-09 07:45:01 -05:00
|
|
|
sql = <<-SQL.squish
|
2017-03-17 14:47:38 -05: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}
|
|
|
|
GROUP BY accounts.id
|
|
|
|
ORDER BY rank DESC
|
|
|
|
LIMIT ?
|
2017-04-09 07:45:01 -05:00
|
|
|
SQL
|
2017-03-17 14:47:38 -05:00
|
|
|
|
2017-05-07 09:40:57 -05:00
|
|
|
find_by_sql([sql, account.id, account.id, limit])
|
2017-03-17 14:47:38 -05:00
|
|
|
end
|
|
|
|
|
2017-01-08 12:12:54 -06:00
|
|
|
private
|
|
|
|
|
2017-05-07 09:40:57 -05: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
|
|
|
|
|
2017-01-08 12:12:54 -06:00
|
|
|
def follow_mapping(query, field)
|
2017-05-01 09:31:02 -05:00
|
|
|
query.pluck(field).each_with_object({}) { |id, mapping| mapping[id] = true }
|
2016-12-22 16:03:57 -06:00
|
|
|
end
|
2016-10-03 10:16:58 -05:00
|
|
|
end
|
|
|
|
|
2017-04-24 19:47:31 -05:00
|
|
|
before_create :generate_keys
|
|
|
|
before_validation :normalize_domain
|
2017-04-18 16:15:44 -05:00
|
|
|
|
|
|
|
private
|
|
|
|
|
2017-04-24 19:47:31 -05:00
|
|
|
def generate_keys
|
|
|
|
return unless local?
|
|
|
|
|
|
|
|
keypair = OpenSSL::PKey::RSA.new(Rails.env.test? ? 1024 : 2048)
|
|
|
|
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 15:53:20 -06:00
|
|
|
end
|