Module: DDP::Server::Protocol::Data

Included in:
DDP::Server::Protocol
Defined in:
lib/ddp/server/protocol/data.rb

Overview

Protocol regarding handling data subscriptions

Defined Under Namespace

Classes: Subscription

Instance Method Summary collapse

Instance Method Details

#handle_data ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/ddp/server/protocol/data.rb', line 8

def handle_data
  case @message['msg']
  when 'sub'
    handle_sub(@message['id'], @message['name'], @message['params'])
    true
  when 'unsub'
    handle_unsub(@message['id'])
    true
  else
    false
  end
end

#handle_sub(id, name, params) ⇒ Object 



21
22
23
24
25
26
27
28
29
 
# File 'lib/ddp/server/protocol/data.rb', line 21

def handle_sub(id, name, params)
  params ||= []
  query = api.collection_query(name, *params)
  subscription = subscriptions[id] = Subscription.new(self, id, name, query)
  subscription.async.start
  send_ready([id])
rescue => e
  send_error_result(id, e)
end

#handle_unsub(id) ⇒ Object 



40
41
42
43
44
 
# File 'lib/ddp/server/protocol/data.rb', line 40

def handle_unsub(id)
  subscription = @subscriptions.delete(id)
  subscription.stop unless subscription.nil?
  send_nosub(id)
end

#send_added(collection, id, fields = nil) ⇒ Object 



52
53
54
55
56
 
# File 'lib/ddp/server/protocol/data.rb', line 52

def send_added(collection, id, fields = nil)
  message = { msg: 'added', id: id, collection: collection }
  message.merge!(fields: fields) if fields
  write_message message
end

#send_added_before(collection, id, fields = nil, before = nil) ⇒ Object 



73
74
75
76
77
 
# File 'lib/ddp/server/protocol/data.rb', line 73

def send_added_before(collection, id, fields = nil, before = nil)
  message = { msg: 'addedBefore', id: id, collection: collection, before: before }
  message.merge!(fields: fields) if fields
  write_message message
end

#send_changed(collection, id, fields = nil, cleared = nil) ⇒ Object 



58
59
60
61
62
63
 
# File 'lib/ddp/server/protocol/data.rb', line 58

def send_changed(collection, id, fields = nil, cleared = nil)
  message = { msg: 'changed', id: id, collection: collection }
  message.merge!(fields: fields) if fields
  message.merge!(cleared: cleared) if cleared
  write_message message
end

#send_moved_before(collection, id, before = nil) ⇒ Object 



79
80
81
 
# File 'lib/ddp/server/protocol/data.rb', line 79

def send_moved_before(collection, id, before = nil)
  write_message msg: 'movedBefore', id: id, collection: collection, before: before
end

#send_nosub(id, error = nil) ⇒ Object 



46
47
48
49
50
 
# File 'lib/ddp/server/protocol/data.rb', line 46

def send_nosub(id, error = nil)
  message = { msg: 'nosub', id: id }
  message.merge!(error: error) if error
  write_message message
end

#send_ready(subs) ⇒ Object 



69
70
71
 
# File 'lib/ddp/server/protocol/data.rb', line 69

def send_ready(subs)
  write_message msg: 'ready', subs: subs
end

#send_removed(collection, id) ⇒ Object 



65
66
67
 
# File 'lib/ddp/server/protocol/data.rb', line 65

def send_removed(collection, id)
  write_message msg: 'removed', collection: collection, id: id
end

#subscription_update(id, old_value, new_value) ⇒ Object 



31
32
33
34
35
36
37
38
 
# File 'lib/ddp/server/protocol/data.rb', line 31

def subscription_update(id, old_value, new_value)
  subscription_name = @subscriptions[id].name

  return send_added(subscription_name, new_value['id'], new_value) if old_value.nil?
  return send_removed(subscription_name, old_value['id']) if new_value.nil?

  send_changed(subscription_name, old_value['id'], new_value, old_value.keys - new_value.keys)
end