Sha256: c46c3927f5e84f34d547974cc69580eed4fb533e7693695c5d9bcd9118eeb05c
Contents?: true
Size: 1.23 KB
Versions: 43
Compression:
Stored size: 1.23 KB
Contents
module SocialStream
module Ostatus
module Models
module Activity
extend ActiveSupport::Concern
included do
after_commit :send_salmon
end
private
# Send Salmon notification to remote subject
def send_salmon
return if sender.subject_type == "RemoteSubject" ||
receiver.subject_type != "RemoteSubject"
entry =
Proudhon::Entry.new id: "tag:#{ SocialStream::Ostatus.activity_feed_host },2005:activity-#{ id }",
title: stream_title,
content: stream_content,
verb: SocialStream::ActivityStreams.verb(verb),
author: Proudhon::Author.new(name: sender.name,
uri: sender.webfinger_uri)
salmon = entry.to_salmon
if SocialStream::Ostatus.debug_requests
logger.info entry.to_xml
end
# FIXME: Rails 4 queues
Thread.new do
salmon.deliver receiver_subject.salmon_url, sender.rsa_key
ActiveRecord::Base.connection.close
end
end
end
end
end
end
Version data entries
43 entries across 43 versions & 2 rubygems