Sha256: f87ffc3bc66528a5baad0e7278aad09cf959222fdb1bf16ae83315a0cb1e6742
Contents?: true
Size: 1.5 KB
Versions: 25
Compression:
Stored size: 1.5 KB
Contents
# encoding: UTF-8
module Vines
class Stanza
class Presence
class Subscribed < Presence
register "/presence[@type='subscribed']"
def process
stamp_from
inbound? ? process_inbound : process_outbound
end
def process_outbound
to = stamp_to
stream.user.add_subscription_from(to)
storage.save_user(stream.user)
stream.update_user_streams(stream.user)
local? ? process_inbound : route
send_roster_push(to)
send_known_presence(to)
end
def process_inbound
to = stamp_to
user = storage(to.domain).find_user(to)
contact = user.contact(stream.user.jid) if user
return unless contact && contact.can_subscribe?
contact.subscribe_to
storage(to.domain).save_user(user)
stream.update_user_streams(user)
broadcast_subscription_change(contact)
end
private
# After approving a contact's subscription to this user's presence,
# broadcast this user's most recent presence stanzas to the contact.
def send_known_presence(to)
stanzas = stream.available_resources(stream.user.jid).map do |stream|
stream.last_broadcast_presence.clone.tap do |node|
node['from'] = stream.user.jid.to_s
node['id'] = Kit.uuid
end
end
broadcast_to_available_resources(stanzas, to)
end
end
end
end
end
Version data entries
25 entries across 25 versions & 3 rubygems