Class: ActiveJabber::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/activejabber.rb

Defined Under Namespace

Classes: Request

Instance Method Summary collapse

Constructor Details

#initialize(username, password) ⇒ Base

Returns a new instance of Base.



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

def initialize(username, password)
  @username = username
  @password = password
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(method, *args) ⇒ Object

Used to initiate the smart chaining logic.



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

def method_missing(method, *args)
  request_parts = []
  Base::Request.new(self, nil, request_parts).send(method, *args)
end

Instance Method Details

#generate_hash ⇒ Object

Creates a random hash used to uniquely identify each method.



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

def generate_hash
  ActiveSupport::SecureRandom.hex(8) # Generates 16 character hexdecimal string.
end

#jabber ⇒ Object

Returns memoizes and returns a Jabber object, will try to reconnect if disconnected.



4
5
6
7
8
9
10
11
12
13
14
15
 
# File 'lib/activejabber.rb', line 4

def jabber
  if @jabber
    if @jabber.connected?
      return @jabber
    else
      @jabber.reconnect
    end
  else
    @jabber = Jabber::Simple.new(@username, @password)
  end
  return @jabber
end

#request(path, opts) ⇒ Object

Sends a request to the client, path should be formatted like “/users” and @opts@ may include a @:args@ (a string) and @:timeout@ (in seconds) keys.



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
52
 
# File 'lib/activejabber.rb', line 26

def request(path, opts)
  hash = self.generate_hash
  message = hash + ':' + path.gsub(/\?$/, '')
  if opts[:args]
    message += ('?' + opts[:args])
  end
  
  self.jabber.deliver(Jabber::JID.new('[email protected]'), message)
  start = Time.now
  while (Time.now - start) < opts[:timeout]
    self.jabber.received_messages do |msg|
      if msg.body.strip.starts_with?(hash) and msg.from.to_s.strip.starts_with?('[email protected]')
        parts = msg.body.strip.split(':', 3)
        data = (parts[2].nil? ? '' : parts[2].strip)
        if opts[:format] == :json
          data = ActiveSupport::JSON.decode(data)
        end
        response = {:status => parts[1].to_i, :data => data}
        response[:latency] = (Time.now - start)
        return response
      end
    end
  end
  if (Time.now - start) >= opts[:timeout]
    return {:status => 408, :data => '', :latency => (Time.now - start)} # Request timeout
  end
end