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

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

Overview

Protocol regarding handling data subscriptions

Instance Method Summary collapse

Instance Method Details

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



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

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

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



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

def 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

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



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

def 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

#handle_data ⇒ Object 



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

def handle_data
  case @message['msg']
  when 'sub'
    handle_sub
    true
  when 'unsub'
    handle_unsub
    true
  else
    false
  end
end

#handle_sub ⇒ Object 



19
20
21
 
# File 'lib/ddp/server/protocol/data.rb', line 19

def handle_sub
  raise 'Must be overridden'
end

#handle_unsub ⇒ Object 



23
24
25
 
# File 'lib/ddp/server/protocol/data.rb', line 23

def handle_unsub
  raise 'Must be overridden'
end

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



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

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

#nosub(id, error = nil) ⇒ Object 



27
28
29
30
31
 
# File 'lib/ddp/server/protocol/data.rb', line 27

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

#ready(subs) ⇒ Object 



50
51
52
 
# File 'lib/ddp/server/protocol/data.rb', line 50

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

#removed(collection, id) ⇒ Object 



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

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