Sha256: 8a725ffd8a7ee03626e0d96c33c84d8c6436771845ff1e3fd498067052470187
Contents?: true
Size: 1.55 KB
Versions: 2
Compression:
Stored size: 1.55 KB
Contents
# frozen_string_literal: true module Telegram module Bot class Client attr_reader :api, :options attr_accessor :logger def self.run(*args, &block) new(*args).run(&block) end def initialize(token, hash = {}) @options = default_options.merge(hash) @api = Api.new(token, url: options.delete(:url)) @logger = options.delete(:logger) end def run yield self end def listen(&block) logger.info('Starting bot') running = true Signal.trap('INT') { running = false } fetch_updates(&block) while running exit end def fetch_updates response = api.getUpdates(options) return unless response['ok'] response['result'].each do |data| yield handle_update(Types::Update.new(data)) end rescue Faraday::TimeoutError, Faraday::ConnectionFailed retry end def handle_update(update) @options[:offset] = update.update_id.next message = update.current_message log_incoming_message(message) message end private def default_options { offset: 0, logger: NullLogger.new, url: 'https://api.telegram.org' } end def log_incoming_message(message) uid = message.respond_to?(:from) && message.from ? message.from.id : nil logger.info( format('Incoming message: text="%<text>s" uid=%<uid>s', message: message, uid: uid) ) end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
telegram-bot-ruby-0.19.1 | lib/telegram/bot/client.rb |
telegram-bot-ruby-0.19.0 | lib/telegram/bot/client.rb |