Class: Redimap::RedisConn

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

Constant Summary collapse

@@RESCUE_QUEUE = 
'redimap'
@@RESCUE_CLASS = 
'RedimapJob'

Instance Method Summary collapse

Constructor Details

#initialize ⇒ RedisConn

Returns a new instance of RedisConn.



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/redimap/redis_conn.rb', line 12

def initialize
  @logger = Redimap.logger
  
  begin
    @redis = Redis.connect(:url => Redimap.config.redis_url)
    
    @redis.ping
  rescue Redis::CannotConnectError => e
    @logger.error { e.to_s }
    
    return
  end
  
  @KEYS = {
    :redimap_mailboxes    => "#{Redimap.config.redis_ns_redimap}:mailboxes",
    :rescue_queues        => "#{Redimap.config.redis_ns_queue}:queues",
    :rescue_queue_redimap => "#{Redimap.config.redis_ns_queue}:queue:#{@@RESCUE_QUEUE}",
  }.freeze
  
  if block_given?
    yield self
    
    close
  end
end

Instance Method Details

#close ⇒ Object 



38
39
40
 
# File 'lib/redimap/redis_conn.rb', line 38

def close
  @redis.quit
end

#get_mailbox_uid(mailbox) ⇒ Object 



42
43
44
 
# File 'lib/redimap/redis_conn.rb', line 42

def get_mailbox_uid(mailbox)
  @redis.hget(@KEYS[:redimap_mailboxes], mailbox).to_i # Also handles nil.
end

#queue_mailbox_uid(mailbox, uid) ⇒ Object 



50
51
52
53
54
 
# File 'lib/redimap/redis_conn.rb', line 50

def queue_mailbox_uid(mailbox, uid)
  @redis.sadd(@KEYS[:rescue_queues], @@RESCUE_QUEUE)
  
  @redis.rpush(@KEYS[:rescue_queue_redimap], payload(mailbox, uid))
end

#set_mailbox_uid(mailbox, uid) ⇒ Object 



46
47
48
 
# File 'lib/redimap/redis_conn.rb', line 46

def set_mailbox_uid(mailbox, uid)
  @redis.hset(@KEYS[:redimap_mailboxes], mailbox, uid)
end