Class: TelegramBot::PollListener

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

Instance Method Summary collapse

Constructor Details

#initialize(client, interval) ⇒ PollListener

Returns a new instance of PollListener.



3
4
5
6
7
8
 
# File 'lib/telegram_bot/poll_listener.rb', line 3

def initialize(client, interval)
  @client    = client
  @interval  = interval
  @offset_id = nil
  @terminate_signal = false
end

Instance Method Details

#get_updates ⇒ Object 



39
40
41
42
43
 
# File 'lib/telegram_bot/poll_listener.rb', line 39

def get_updates
  updates = @client.get_updates(offset: @offset_id,
                                limit: 50)
  updates
end

#message_received(msg) ⇒ Object 



10
11
12
13
 
# File 'lib/telegram_bot/poll_listener.rb', line 10

def message_received(msg)
  @client.append_history(msg)
  @client.handle(msg)
end

#save_offset ⇒ Object 



45
46
47
 
# File 'lib/telegram_bot/poll_listener.rb', line 45

def save_offset
  @client.get_updates(limit: 0, offset: @offset_id)
end

#start! ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/telegram_bot/poll_listener.rb', line 19

def start!
  @terminate_signal = false

  loop do
    get_updates.each do |update|
      message_received(update.message)
      @offset_id = update.id + 1

      if @terminate_signal
        save_offset
        break
      end
    end

    break if @terminate_signal

    sleep @interval
  end
end

#stop! ⇒ Object 



15
16
17
 
# File 'lib/telegram_bot/poll_listener.rb', line 15

def stop!
  @terminate_signal = true
end