Module: WhereIsWaldo

Defined in:
lib/where_is_waldo.rb,
lib/where_is_waldo/engine.rb,
lib/where_is_waldo/version.rb,
lib/where_is_waldo/configuration.rb,
app/models/where_is_waldo/presence.rb,
app/services/where_is_waldo/roster.rb,
app/jobs/where_is_waldo/application_job.rb,
app/services/where_is_waldo/broadcaster.rb,
app/channels/where_is_waldo/jwt_connection.rb,
app/channels/where_is_waldo/roster_channel.rb,
app/services/where_is_waldo/roster_delivery.rb,
app/channels/where_is_waldo/presence_channel.rb,
app/jobs/where_is_waldo/presence_cleanup_job.rb,
app/models/where_is_waldo/application_record.rb,
app/services/where_is_waldo/presence_service.rb,
app/models/concerns/where_is_waldo/broadcastable.rb,
app/services/where_is_waldo/adapters/base_adapter.rb,
app/services/where_is_waldo/adapters/redis_adapter.rb,
app/channels/where_is_waldo/application_cable/channel.rb,
app/services/where_is_waldo/adapters/database_adapter.rb,
lib/generators/where_is_waldo/install/install_generator.rb,
app/channels/where_is_waldo/application_cable/connection.rb

Defined Under Namespace

Modules: Adapters, ApplicationCable, Broadcastable, Generators, JwtConnection, RosterDelivery Classes: ApplicationJob, ApplicationRecord, Broadcaster, Configuration, Engine, Presence, PresenceChannel, PresenceCleanupJob, PresenceService, Roster, RosterChannel

Constant Summary collapse

VERSION = 
File.read(File.expand_path("../../VERSION", __dir__)).strip

Class Method Summary collapse

Class Method Details

.all_online_ids(timeout: nil) ⇒ Object

Get all online subject IDs (no scope filtering)



54
55
56
 
# File 'lib/where_is_waldo.rb', line 54

def all_online_ids(timeout: nil)
  PresenceService.all_online_ids(timeout: timeout)
end

.broadcast_to(scope, message_type, data = {}) ⇒ Object

Broadcast to subjects in a scope

Examples:

WhereIsWaldo.broadcast_to(org.members, :notification, { message: "Hello" })



101
102
103
 
# File 'lib/where_is_waldo.rb', line 101

def broadcast_to(scope, message_type, data = {})
  Broadcaster.broadcast_to(scope, message_type, data)
end

.broadcast_to_online(scope, message_type, data = {}) ⇒ Object

Broadcast only to online subjects in a scope

Examples:

WhereIsWaldo.broadcast_to_online(org.members, :alert, { message: "Urgent" })



107
108
109
 
# File 'lib/where_is_waldo.rb', line 107

def broadcast_to_online(scope, message_type, data = {})
  Broadcaster.broadcast_to_online(scope, message_type, data)
end

.broadcast_to_session(session_id, message_type, data = {}) ⇒ Object

Broadcast to a specific session

Examples:

WhereIsWaldo.broadcast_to_session(session_id, :force_logout, { reason: "..." })



113
114
115
 
# File 'lib/where_is_waldo.rb', line 113

def broadcast_to_session(session_id, message_type, data = {})
  Broadcaster.broadcast_to_session(session_id, message_type, data)
end

.cleanup(timeout: nil) ⇒ Object 



64
65
66
 
# File 'lib/where_is_waldo.rb', line 64

def cleanup(timeout: nil)
  PresenceService.cleanup(timeout: timeout)
end

.config ⇒ Object 



17
18
19
 
# File 'lib/where_is_waldo.rb', line 17

def config
  configuration
end

.configuration ⇒ Object 



9
10
11
 
# File 'lib/where_is_waldo.rb', line 9

def configuration
  @configuration ||= Configuration.new
end

.configure {|configuration| ... } ⇒ Object

Yields:



13
14
15
 
# File 'lib/where_is_waldo.rb', line 13

def configure
  yield(configuration)
end

.connect ⇒ Object

Presence Management ===



27
28
29
 
# File 'lib/where_is_waldo.rb', line 27

def connect(...)
  PresenceService.connect(...)
end

.disconnect ⇒ Object 



31
32
33
 
# File 'lib/where_is_waldo.rb', line 31

def disconnect(...)
  PresenceService.disconnect(...)
end

.heartbeat ⇒ Object 



35
36
37
 
# File 'lib/where_is_waldo.rb', line 35

def heartbeat(...)
  PresenceService.heartbeat(...)
end

.online(scope, timeout: nil) ⇒ Object

Get online subjects from a scope

Examples:

WhereIsWaldo.online(org.members) => AR relation of online members



43
44
45
 
# File 'lib/where_is_waldo.rb', line 43

def online(scope, timeout: nil)
  PresenceService.online(scope, timeout: timeout)
end

.online_ids(scope, timeout: nil) ⇒ Object

Get online subject IDs from a scope

Examples:

WhereIsWaldo.online_ids(org.members.admin)



49
50
51
 
# File 'lib/where_is_waldo.rb', line 49

def online_ids(scope, timeout: nil)
  PresenceService.online_ids(scope, timeout: timeout)
end

.presence_on(subject_id, platform, timeout: nil) ⇒ Object

Presence status for a subject on a specific device/platform.

Examples:

WhereIsWaldo.presence_on(user.id, :mobile) # => "idle"



82
83
84
 
# File 'lib/where_is_waldo.rb', line 82

def presence_on(subject_id, platform, timeout: nil)
  Roster.device_status(subject_id, platform, timeout: timeout)
end

.publish_presence(subject_id, timeout: nil) ⇒ Object

Broadcast a compact presence delta for a subject to their org's roster stream. Call on transitions only (usually automatic via PresenceChannel).



88
89
90
 
# File 'lib/where_is_waldo.rb', line 88

def publish_presence(subject_id, timeout: nil)
  Roster.publish(subject_id, timeout: timeout)
end

.reset_configuration! ⇒ Object 



21
22
23
 
# File 'lib/where_is_waldo.rb', line 21

def reset_configuration!
  @configuration = Configuration.new
end

.roster_snapshot(org, timeout: nil) ⇒ Object

Full roster state for an org record (every member + current presence).



71
72
73
 
# File 'lib/where_is_waldo.rb', line 71

def roster_snapshot(org, timeout: nil)
  Roster.snapshot(org, timeout: timeout)
end

.roster_state_for(subject_id, timeout: nil) ⇒ Object

Aggregate presence state ({ status:, devices: }) for one subject.



76
77
78
 
# File 'lib/where_is_waldo.rb', line 76

def roster_state_for(subject_id, timeout: nil)
  Roster.state_for(subject_id, timeout: timeout)
end

.roster_stream_for(subject) ⇒ Object

Shared roster stream name for the org a subject belongs to.



93
94
95
 
# File 'lib/where_is_waldo.rb', line 93

def roster_stream_for(subject)
  Roster.stream_for_subject(subject)
end