logo

mastofe

My custom branche(s) on git.pleroma.social/pleroma/mastofe git clone https://anongit.hacktivis.me/git/mastofe.git/

atom_serializer.rb (15984B)

    

  1. # frozen_string_literal: true
  3. class OStatus::AtomSerializer
  4.   include RoutingHelper
  5.   include ActionView::Helpers::SanitizeHelper
  7.   class << self
  8.     def render(element)
  9.       document = Ox::Document.new(version: '1.0')
  10.       document << element
  11.       ('<?xml version="1.0"?>' + Ox.dump(element, effort: :tolerant)).force_encoding('UTF-8')
  12.     end
  13.   end
  15.   def author(account)
  16.     author = Ox::Element.new('author')
  18.     uri = OStatus::TagManager.instance.uri_for(account)
  20.     append_element(author, 'id', uri)
  21.     append_element(author, 'activity:object-type', OStatus::TagManager::TYPES[:person])
  22.     append_element(author, 'uri', uri)
  23.     append_element(author, 'name', account.username)
  24.     append_element(author, 'email', account.local? ? account.local_username_and_domain : account.acct)
  25.     append_element(author, 'summary', Formatter.instance.simplified_format(account).to_str, type: :html) if account.note?
  26.     append_element(author, 'link', nil, rel: :alternate, type: 'text/html', href: ::TagManager.instance.url_for(account))
  27.     append_element(author, 'link', nil, rel: :avatar, type: account.avatar_content_type, 'media:width': 120, 'media:height': 120, href: full_asset_url(account.avatar.url(:original))) if account.avatar?
  28.     append_element(author, 'link', nil, rel: :header, type: account.header_content_type, 'media:width': 700, 'media:height': 335, href: full_asset_url(account.header.url(:original))) if account.header?
  29.     account.emojis.each do |emoji|
  30.       append_element(author, 'link', nil, rel: :emoji, href: full_asset_url(emoji.image.url), name: emoji.shortcode)
  31.     end
  32.     append_element(author, 'poco:preferredUsername', account.username)
  33.     append_element(author, 'poco:displayName', account.display_name) if account.display_name?
  34.     append_element(author, 'poco:note', account.local? ? account.note : strip_tags(account.note)) if account.note?
  35.     append_element(author, 'mastodon:scope', account.locked? ? :private : :public)
  37.     author
  38.   end
  40.   def feed(account, stream_entries)
  41.     feed = Ox::Element.new('feed')
  43.     add_namespaces(feed)
  45.     append_element(feed, 'id', account_url(account, format: 'atom'))
  46.     append_element(feed, 'title', account.display_name.presence || account.username)
  47.     append_element(feed, 'subtitle', account.note)
  48.     append_element(feed, 'updated', account.updated_at.iso8601)
  49.     append_element(feed, 'logo', full_asset_url(account.avatar.url(:original)))
  51.     feed << author(account)
  53.     append_element(feed, 'link', nil, rel: :alternate, type: 'text/html', href: ::TagManager.instance.url_for(account))
  54.     append_element(feed, 'link', nil, rel: :self, type: 'application/atom+xml', href: account_url(account, format: 'atom'))
  55.     append_element(feed, 'link', nil, rel: :next, type: 'application/atom+xml', href: account_url(account, format: 'atom', max_id: stream_entries.last.id)) if stream_entries.size == 20
  56.     append_element(feed, 'link', nil, rel: :hub, href: api_push_url)
  57.     append_element(feed, 'link', nil, rel: :salmon, href: api_salmon_url(account.id))
  59.     stream_entries.each do |stream_entry|
  60.       feed << entry(stream_entry)
  61.     end
  63.     feed
  64.   end
  66.   def entry(stream_entry, root = false)
  67.     entry = Ox::Element.new('entry')
  69.     add_namespaces(entry) if root
  71.     append_element(entry, 'id', OStatus::TagManager.instance.uri_for(stream_entry.status))
  72.     append_element(entry, 'published', stream_entry.created_at.iso8601)
  73.     append_element(entry, 'updated', stream_entry.updated_at.iso8601)
  74.     append_element(entry, 'title', stream_entry&.status&.title || "#{stream_entry.account.acct} deleted status")
  76.     entry << author(stream_entry.account) if root
  78.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[stream_entry.object_type])
  79.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[stream_entry.verb])
  81.     entry << object(stream_entry.target) if stream_entry.targeted?
  83.     if stream_entry.status.nil?
  84.       append_element(entry, 'content', 'Deleted status')
  85.     elsif stream_entry.status.destroyed?
  86.       append_element(entry, 'content', 'Deleted status')
  87.       append_element(entry, 'link', nil, rel: :alternate, type: 'application/activity+json', href: ActivityPub::TagManager.instance.uri_for(stream_entry.status)) if stream_entry.account.local?
  88.     else
  89.       serialize_status_attributes(entry, stream_entry.status)
  90.     end
  92.     append_element(entry, 'link', nil, rel: :alternate, type: 'text/html', href: ::TagManager.instance.url_for(stream_entry.status))
  93.     append_element(entry, 'link', nil, rel: :self, type: 'application/atom+xml', href: account_stream_entry_url(stream_entry.account, stream_entry, format: 'atom'))
  94.     append_element(entry, 'thr:in-reply-to', nil, ref: OStatus::TagManager.instance.uri_for(stream_entry.thread), href: ::TagManager.instance.url_for(stream_entry.thread)) if stream_entry.threaded?
  95.     append_element(entry, 'ostatus:conversation', nil, ref: conversation_uri(stream_entry.status.conversation)) unless stream_entry&.status&.conversation_id.nil?
  97.     entry
  98.   end
  100.   def object(status)
  101.     object = Ox::Element.new('activity:object')
  103.     append_element(object, 'id', OStatus::TagManager.instance.uri_for(status))
  104.     append_element(object, 'published', status.created_at.iso8601)
  105.     append_element(object, 'updated', status.updated_at.iso8601)
  106.     append_element(object, 'title', status.title)
  108.     object << author(status.account)
  110.     append_element(object, 'activity:object-type', OStatus::TagManager::TYPES[status.object_type])
  111.     append_element(object, 'activity:verb', OStatus::TagManager::VERBS[status.verb])
  113.     serialize_status_attributes(object, status)
  115.     append_element(object, 'link', nil, rel: :alternate, type: 'text/html', href: ::TagManager.instance.url_for(status))
  116.     append_element(object, 'thr:in-reply-to', nil, ref: OStatus::TagManager.instance.uri_for(status.thread), href: ::TagManager.instance.url_for(status.thread)) unless status.thread.nil?
  117.     append_element(object, 'ostatus:conversation', nil, ref: conversation_uri(status.conversation)) unless status.conversation_id.nil?
  119.     object
  120.   end
  122.   def follow_salmon(follow)
  123.     entry = Ox::Element.new('entry')
  124.     add_namespaces(entry)
  126.     description = "#{follow.account.acct} started following #{follow.target_account.acct}"
  128.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(follow.created_at, follow.id, 'Follow'))
  129.     append_element(entry, 'title', description)
  130.     append_element(entry, 'content', description, type: :html)
  132.     entry << author(follow.account)
  134.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  135.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:follow])
  137.     object = author(follow.target_account)
  138.     object.value = 'activity:object'
  140.     entry << object
  141.     entry
  142.   end
  144.   def follow_request_salmon(follow_request)
  145.     entry = Ox::Element.new('entry')
  146.     add_namespaces(entry)
  148.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(follow_request.created_at, follow_request.id, 'FollowRequest'))
  149.     append_element(entry, 'title', "#{follow_request.account.acct} requested to follow #{follow_request.target_account.acct}")
  151.     entry << author(follow_request.account)
  153.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  154.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:request_friend])
  156.     object = author(follow_request.target_account)
  157.     object.value = 'activity:object'
  159.     entry << object
  160.     entry
  161.   end
  163.   def authorize_follow_request_salmon(follow_request)
  164.     entry = Ox::Element.new('entry')
  165.     add_namespaces(entry)
  167.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(Time.now.utc, follow_request.id, 'FollowRequest'))
  168.     append_element(entry, 'title', "#{follow_request.target_account.acct} authorizes follow request by #{follow_request.account.acct}")
  170.     entry << author(follow_request.target_account)
  172.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  173.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:authorize])
  175.     object = Ox::Element.new('activity:object')
  176.     object << author(follow_request.account)
  178.     append_element(object, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  179.     append_element(object, 'activity:verb', OStatus::TagManager::VERBS[:request_friend])
  181.     inner_object = author(follow_request.target_account)
  182.     inner_object.value = 'activity:object'
  184.     object << inner_object
  185.     entry  << object
  186.     entry
  187.   end
  189.   def reject_follow_request_salmon(follow_request)
  190.     entry = Ox::Element.new('entry')
  191.     add_namespaces(entry)
  193.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(Time.now.utc, follow_request.id, 'FollowRequest'))
  194.     append_element(entry, 'title', "#{follow_request.target_account.acct} rejects follow request by #{follow_request.account.acct}")
  196.     entry << author(follow_request.target_account)
  198.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  199.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:reject])
  201.     object = Ox::Element.new('activity:object')
  202.     object << author(follow_request.account)
  204.     append_element(object, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  205.     append_element(object, 'activity:verb', OStatus::TagManager::VERBS[:request_friend])
  207.     inner_object = author(follow_request.target_account)
  208.     inner_object.value = 'activity:object'
  210.     object << inner_object
  211.     entry  << object
  212.     entry
  213.   end
  215.   def unfollow_salmon(follow)
  216.     entry = Ox::Element.new('entry')
  217.     add_namespaces(entry)
  219.     description = "#{follow.account.acct} is no longer following #{follow.target_account.acct}"
  221.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(Time.now.utc, follow.id, 'Follow'))
  222.     append_element(entry, 'title', description)
  223.     append_element(entry, 'content', description, type: :html)
  225.     entry << author(follow.account)
  227.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  228.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:unfollow])
  230.     object = author(follow.target_account)
  231.     object.value = 'activity:object'
  233.     entry << object
  234.     entry
  235.   end
  237.   def block_salmon(block)
  238.     entry = Ox::Element.new('entry')
  239.     add_namespaces(entry)
  241.     description = "#{block.account.acct} no longer wishes to interact with #{block.target_account.acct}"
  243.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(Time.now.utc, block.id, 'Block'))
  244.     append_element(entry, 'title', description)
  246.     entry << author(block.account)
  248.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  249.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:block])
  251.     object = author(block.target_account)
  252.     object.value = 'activity:object'
  254.     entry << object
  255.     entry
  256.   end
  258.   def unblock_salmon(block)
  259.     entry = Ox::Element.new('entry')
  260.     add_namespaces(entry)
  262.     description = "#{block.account.acct} no longer blocks #{block.target_account.acct}"
  264.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(Time.now.utc, block.id, 'Block'))
  265.     append_element(entry, 'title', description)
  267.     entry << author(block.account)
  269.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  270.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:unblock])
  272.     object = author(block.target_account)
  273.     object.value = 'activity:object'
  275.     entry << object
  276.     entry
  277.   end
  279.   def favourite_salmon(favourite)
  280.     entry = Ox::Element.new('entry')
  281.     add_namespaces(entry)
  283.     description = "#{favourite.account.acct} favourited a status by #{favourite.status.account.acct}"
  285.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(favourite.created_at, favourite.id, 'Favourite'))
  286.     append_element(entry, 'title', description)
  287.     append_element(entry, 'content', description, type: :html)
  289.     entry << author(favourite.account)
  291.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  292.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:favorite])
  294.     entry << object(favourite.status)
  296.     append_element(entry, 'thr:in-reply-to', nil, ref: OStatus::TagManager.instance.uri_for(favourite.status), href: ::TagManager.instance.url_for(favourite.status))
  298.     entry
  299.   end
  301.   def unfavourite_salmon(favourite)
  302.     entry = Ox::Element.new('entry')
  303.     add_namespaces(entry)
  305.     description = "#{favourite.account.acct} no longer favourites a status by #{favourite.status.account.acct}"
  307.     append_element(entry, 'id', OStatus::TagManager.instance.unique_tag(Time.now.utc, favourite.id, 'Favourite'))
  308.     append_element(entry, 'title', description)
  309.     append_element(entry, 'content', description, type: :html)
  311.     entry << author(favourite.account)
  313.     append_element(entry, 'activity:object-type', OStatus::TagManager::TYPES[:activity])
  314.     append_element(entry, 'activity:verb', OStatus::TagManager::VERBS[:unfavorite])
  316.     entry << object(favourite.status)
  318.     append_element(entry, 'thr:in-reply-to', nil, ref: OStatus::TagManager.instance.uri_for(favourite.status), href: ::TagManager.instance.url_for(favourite.status))
  320.     entry
  321.   end
  323.   private
  325.   def append_element(parent, name, content = nil, **attributes)
  326.     element = Ox::Element.new(name)
  327.     attributes.each { |k, v| element[k] = sanitize_str(v) }
  328.     element << sanitize_str(content) unless content.nil?
  329.     parent  << element
  330.   end
  332.   def sanitize_str(raw_str)
  333.     raw_str.to_s
  334.   end
  336.   def conversation_uri(conversation)
  337.     return conversation.uri if conversation.uri?
  338.     OStatus::TagManager.instance.unique_tag(conversation.created_at, conversation.id, 'Conversation')
  339.   end
  341.   def add_namespaces(parent)
  342.     parent['xmlns']          = OStatus::TagManager::XMLNS
  343.     parent['xmlns:thr']      = OStatus::TagManager::THR_XMLNS
  344.     parent['xmlns:activity'] = OStatus::TagManager::AS_XMLNS
  345.     parent['xmlns:poco']     = OStatus::TagManager::POCO_XMLNS
  346.     parent['xmlns:media']    = OStatus::TagManager::MEDIA_XMLNS
  347.     parent['xmlns:ostatus']  = OStatus::TagManager::OS_XMLNS
  348.     parent['xmlns:mastodon'] = OStatus::TagManager::MTDN_XMLNS
  349.   end
  351.   def serialize_status_attributes(entry, status)
  352.     append_element(entry, 'link', nil, rel: :alternate, type: 'application/activity+json', href: ActivityPub::TagManager.instance.uri_for(status)) if status.account.local?
  354.     append_element(entry, 'summary', status.spoiler_text, 'xml:lang': status.language) if status.spoiler_text?
  355.     append_element(entry, 'content', Formatter.instance.format(status).to_str, type: 'html', 'xml:lang': status.language)
  357.     status.mentions.order(:id).each do |mentioned|
  358.       append_element(entry, 'link', nil, rel: :mentioned, 'ostatus:object-type': OStatus::TagManager::TYPES[:person], href: OStatus::TagManager.instance.uri_for(mentioned.account))
  359.     end
  361.     append_element(entry, 'link', nil, rel: :mentioned, 'ostatus:object-type': OStatus::TagManager::TYPES[:collection], href: OStatus::TagManager::COLLECTIONS[:public]) if status.public_visibility?
  363.     status.tags.each do |tag|
  364.       append_element(entry, 'category', nil, term: tag.name)
  365.     end
  367.     append_element(entry, 'category', nil, term: 'nsfw') if status.sensitive?
  369.     status.media_attachments.each do |media|
  370.       append_element(entry, 'link', nil, rel: :enclosure, type: media.file_content_type, length: media.file_file_size, href: full_asset_url(media.file.url(:original, false)))
  371.     end
  373.     append_element(entry, 'mastodon:scope', status.visibility)
  375.     status.emojis.each do |emoji|
  376.       append_element(entry, 'link', nil, rel: :emoji, href: full_asset_url(emoji.image.url), name: emoji.shortcode)
  377.     end
  378.   end
  379. end