b1d30aa9cc
move it to Diaspora::Federation::Entities and use it in some tests, but most of the tests can be removed later.
126 lines
4.6 KiB
Ruby
126 lines
4.6 KiB
Ruby
# configure the federation engine
|
|
DiasporaFederation.configure do |config|
|
|
# the pod url
|
|
config.server_uri = AppConfig.pod_uri
|
|
|
|
config.certificate_authorities = AppConfig.environment.certificate_authorities.get
|
|
|
|
config.define_callbacks do
|
|
on :fetch_person_for_webfinger do |handle|
|
|
person = Person.find_local_by_diaspora_handle(handle)
|
|
if person
|
|
DiasporaFederation::Discovery::WebFinger.new(
|
|
acct_uri: "acct:#{person.diaspora_handle}",
|
|
alias_url: AppConfig.url_to("/people/#{person.guid}"),
|
|
hcard_url: AppConfig.url_to(DiasporaFederation::Engine.routes.url_helpers.hcard_path(person.guid)),
|
|
seed_url: AppConfig.pod_uri,
|
|
profile_url: person.profile_url,
|
|
atom_url: person.atom_url,
|
|
salmon_url: person.receive_url,
|
|
subscribe_url: AppConfig.url_to("/people?q={uri}"),
|
|
guid: person.guid,
|
|
public_key: person.serialized_public_key
|
|
)
|
|
end
|
|
end
|
|
|
|
on :fetch_person_for_hcard do |guid|
|
|
person = Person.find_local_by_guid(guid)
|
|
if person
|
|
DiasporaFederation::Discovery::HCard.new(
|
|
guid: person.guid,
|
|
nickname: person.username,
|
|
full_name: "#{person.profile.first_name} #{person.profile.last_name}".strip,
|
|
url: AppConfig.pod_uri,
|
|
photo_large_url: person.image_url,
|
|
photo_medium_url: person.image_url(:thumb_medium),
|
|
photo_small_url: person.image_url(:thumb_small),
|
|
public_key: person.serialized_public_key,
|
|
searchable: person.searchable,
|
|
first_name: person.profile.first_name,
|
|
last_name: person.profile.last_name
|
|
)
|
|
end
|
|
end
|
|
|
|
on :save_person_after_webfinger do |person|
|
|
# find existing person or create a new one
|
|
person_entity = Person.find_by(diaspora_handle: person.diaspora_id) ||
|
|
Person.new(diaspora_handle: person.diaspora_id, guid: person.guid,
|
|
serialized_public_key: person.exported_key, pod: Pod.find_or_create_by(url: person.url))
|
|
|
|
profile = person.profile
|
|
profile_entity = person_entity.profile ||= Profile.new
|
|
|
|
# fill or update profile
|
|
profile_entity.first_name = profile.first_name
|
|
profile_entity.last_name = profile.last_name
|
|
profile_entity.image_url = profile.image_url
|
|
profile_entity.image_url_medium = profile.image_url_medium
|
|
profile_entity.image_url_small = profile.image_url_small
|
|
profile_entity.searchable = profile.searchable
|
|
|
|
person_entity.save!
|
|
end
|
|
|
|
on :fetch_private_key_by_diaspora_id do |diaspora_id|
|
|
key = Person.where(diaspora_handle: diaspora_id).joins(:owner).pluck(:serialized_private_key).first
|
|
OpenSSL::PKey::RSA.new key unless key.nil?
|
|
end
|
|
|
|
on :fetch_author_private_key_by_entity_guid do |entity_type, guid|
|
|
key = entity_type.constantize.where(guid: guid).joins(author: :owner).pluck(:serialized_private_key).first
|
|
OpenSSL::PKey::RSA.new key unless key.nil?
|
|
end
|
|
|
|
on :fetch_public_key_by_diaspora_id do |diaspora_id|
|
|
key = Person.where(diaspora_handle: diaspora_id).pluck(:serialized_public_key).first
|
|
OpenSSL::PKey::RSA.new key unless key.nil?
|
|
end
|
|
|
|
on :fetch_author_public_key_by_entity_guid do |entity_type, guid|
|
|
key = entity_type.constantize.where(guid: guid).joins(:author).pluck(:serialized_public_key).first
|
|
OpenSSL::PKey::RSA.new key unless key.nil?
|
|
end
|
|
|
|
on :entity_author_is_local? do |entity_type, guid|
|
|
entity_type.constantize.where(guid: guid).joins(author: :owner).exists?
|
|
end
|
|
|
|
on :fetch_entity_author_id_by_guid do |entity_type, guid|
|
|
entity_type.constantize.where(guid: guid).joins(:author).pluck(:diaspora_handle).first
|
|
end
|
|
|
|
on :queue_public_receive do |xml|
|
|
Workers::ReceiveUnencryptedSalmon.perform_async(xml)
|
|
end
|
|
|
|
on :queue_private_receive do |guid, xml|
|
|
person = Person.find_by_guid(guid)
|
|
|
|
if person.nil? || person.owner_id.nil?
|
|
false
|
|
else
|
|
Workers::ReceiveEncryptedSalmon.perform_async(person.owner.id, xml)
|
|
true
|
|
end
|
|
end
|
|
|
|
on :receive_entity do
|
|
# TODO
|
|
end
|
|
|
|
on :fetch_public_entity do |entity_type, guid|
|
|
entity = entity_type.constantize.find_by(guid: guid, public: true)
|
|
Diaspora::Federation::Entities.post(entity) if entity.is_a? Post
|
|
end
|
|
|
|
on :fetch_person_url_to do |diaspora_id, path|
|
|
Person.find_by(diaspora_handle: diaspora_id).send(:url_to, path)
|
|
end
|
|
|
|
on :update_pod do
|
|
# TODO
|
|
end
|
|
end
|
|
end
|