1# frozen_string_literal: true
 2
 3require "blather/client/dsl"
 4require "timeout"
 5
 6module BlatherNotify
 7	extend Blather::DSL
 8
 9	@ready = Queue.new
10
11	when_ready { @ready << :ready }
12
13	def self.start(jid, password)
14		# workqueue_count MUST be 0 or else Blather uses threads!
15		setup(jid, password, nil, nil, nil, nil, workqueue_count: 0)
16
17		EM.error_handler { |e| warn e.message }
18		Thread.new do
19			EM.run do
20				client.run
21			end
22		end
23
24		at_exit { shutdown }
25
26		Timeout.timeout(30) { @ready.pop }
27	end
28end