Class: Vines::Storage::CouchDB

Inherits:
Vines::Storage show all
Defined in:
lib/vines/services/roster.rb

Instance Method Summary collapse

Instance Method Details

#_services_find_user ⇒ Object 



6
 
# File 'lib/vines/services/roster.rb', line 6

alias :_services_find_user :find_user

#find_services(jid) ⇒ Object

Return the Service documents to which this JID has permission to access.



70
71
72
73
74
75
76
77
78
79
80
81
 
# File 'lib/vines/services/roster.rb', line 70

def find_services(jid)
  url = "%s/_design/Service/_view/by_user?reduce=false&key=%s" % [@url, escape(jid.to_s).to_json]
  http = EM::HttpRequest.new(url).get
  http.errback { yield [] }
  http.callback do
    doc = if http.response_header.status == 200
      rows = JSON.parse(http.response)['rows'] rescue []
      rows.map {|row| row['value'] }
    end
    yield doc || []
  end
end

#find_systems(services) ⇒ Object

Find the systems that belong to these services. Return a Hash of system name to list of service names to which it belongs.



86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
 
# File 'lib/vines/services/roster.rb', line 86

def find_systems(services)
  keys = services.map {|row| [0, row['_id']] }
  url = "%s/_design/System/_view/memberships?reduce=false" % @url
  http = EM::HttpRequest.new(url).post(
    head: {'Content-Type' => 'application/json'},
    body: {keys: keys}.to_json)
  http.errback { yield [] }
  http.callback do
    doc = if http.response_header.status == 200
      rows = JSON.parse(http.response)['rows'] rescue []
      Hash.new {|h, k| h[k] = [] }.tap do |systems|
        rows.each do |row|
          service = services.find {|s| s['_id'] == row['key'][1] }
          systems[row['value']['name']] << service['name']
        end
      end
    end
    yield doc || []
  end
end

#find_user(jid) ⇒ Object

Override the user’s roster with an auto-populated roster containing the services and systems to which the user has permission to access.



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/vines/services/roster.rb', line 10

def find_user(jid)
  user = _services_find_user(jid)
  return unless user
  user.roster = []

  systems, users = find_users.partition {|u| u['system'] }
  systems.map! {|u| u['_id'].sub('user:', '') }
  return user if systems.include?(user.jid.to_s)
  services = find_services(user.jid)

  users.each do |row|
    id = row['_id'].sub('user:', '')
    user.roster << Contact.new(
      :jid => id,
      :name => row['name'],
      :subscription => 'both',
      :groups => ['People']) unless id == jid.to_s
  end

  services.each do |row|
    user.roster << Contact.new(
      :jid => row['jid'],
      :name => row['name'],
      :subscription => 'to',
      :groups => ['Services'])
  end

  find_systems(services).each do |name, groups|
    id = JID.new(name.dup, user.jid.domain).to_s
    user.roster << Contact.new(
      :jid => id,
      :name => name,
      :subscription => 'to',
      :groups => ['Systems', *groups]) if systems.include?(id)
  end

  user.roster << Contact.new(
    :jid => "vines.#{user.jid.domain}",
    :name => 'Vines',
    :subscription => 'to')
  user
end

#find_users ⇒ Object

Return the User documents for all users and systems.



54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/vines/services/roster.rb', line 54

def find_users
  url = "%s/_design/User/_view/all?reduce=false&include_docs=true" % @url
  http = EM::HttpRequest.new(url).get
  http.errback { yield [] }
  http.callback do
    doc = if http.response_header.status == 200
      rows = JSON.parse(http.response)['rows'] rescue []
      rows.map {|row| row['doc'] }
    end
    yield doc || []
  end
end