зеркало из
https://github.com/glebtv/telegram-bot.git
synced 2026-09-04 02:05:52 +03:00
Сравнить коммиты
2 Коммитов
| Автор | SHA1 | Дата | |
|---|---|---|---|
|
|
17260cb5a9 | ||
|
|
817af95369 |
@@ -1,3 +1,9 @@
|
|||||||
|
# 0.11.0
|
||||||
|
|
||||||
|
- Remove Bot::StaleChat in favor of Bot::Forbidden, as Telegram adds more
|
||||||
|
and more new descriptions.
|
||||||
|
Please open an issue if you face a problem.
|
||||||
|
|
||||||
# 0.10.2
|
# 0.10.2
|
||||||
|
|
||||||
- Support `(edited_)channel_post` updates.
|
- Support `(edited_)channel_post` updates.
|
||||||
|
|||||||
@@ -100,7 +100,7 @@ bot.get_me.class # => Telegram::Bot::Types::User
|
|||||||
```
|
```
|
||||||
|
|
||||||
Any API request error will raise `Telegram::Bot::Error` with description in its message.
|
Any API request error will raise `Telegram::Bot::Error` with description in its message.
|
||||||
Special `Telegram::Bot::StaleChat` is raised when bot can't post messages to the chat anymore.
|
Special `Telegram::Bot::Forbidden` is raised when bot can't post messages to the chat anymore.
|
||||||
|
|
||||||
### Controller
|
### Controller
|
||||||
|
|
||||||
|
|||||||
@@ -6,26 +6,7 @@ module Telegram
|
|||||||
module Bot
|
module Bot
|
||||||
class Error < StandardError; end
|
class Error < StandardError; end
|
||||||
class NotFound < Error; end
|
class NotFound < Error; end
|
||||||
|
class Forbidden < Error; end
|
||||||
# Error class for events when chat is not available anymore for bot.
|
|
||||||
# While Telegram has same error codes for different messages and there is no
|
|
||||||
# official docs for this error codes it uses `description` to
|
|
||||||
# check response.
|
|
||||||
class StaleChat < Error
|
|
||||||
DESCRIPTIONS = [
|
|
||||||
'Bot was blocked',
|
|
||||||
'bot was kicked',
|
|
||||||
"can't write to",
|
|
||||||
'group chat is deactivated',
|
|
||||||
].freeze
|
|
||||||
|
|
||||||
class << self
|
|
||||||
def match_response?(response)
|
|
||||||
description = response['description'].to_s
|
|
||||||
DESCRIPTIONS.any? { |x| description[x] }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
autoload :Async, 'telegram/bot/async'
|
autoload :Async, 'telegram/bot/async'
|
||||||
autoload :Botan, 'telegram/bot/botan'
|
autoload :Botan, 'telegram/bot/botan'
|
||||||
|
|||||||
@@ -46,18 +46,20 @@ module Telegram
|
|||||||
@base_uri = format URL_TEMPLATE, self.token
|
@base_uri = format URL_TEMPLATE, self.token
|
||||||
end
|
end
|
||||||
|
|
||||||
def request(action, body = {}) # rubocop:disable PerceivedComplexity
|
def request(action, body = {})
|
||||||
res = http_request("#{base_uri}#{action}", self.class.prepare_body(body))
|
res = http_request("#{base_uri}#{action}", self.class.prepare_body(body))
|
||||||
status = res.status
|
status = res.status
|
||||||
return JSON.parse(res.body) if 300 > status
|
return JSON.parse(res.body) if 300 > status
|
||||||
result = JSON.parse(res.body) rescue nil # rubocop:disable RescueModifier
|
result = JSON.parse(res.body) rescue nil # rubocop:disable RescueModifier
|
||||||
err_msg = "#{res.reason}: #{result && result['description'] || '-'}"
|
err_msg = result && result['description'] || '-'
|
||||||
if result
|
if result
|
||||||
# NotFound is raised only for valid responses from Telegram
|
# This errors are raised only for valid responses from Telegram
|
||||||
raise NotFound, err_msg if 404 == status
|
case status
|
||||||
raise StaleChat, err_msg if StaleChat.match_response?(result)
|
when 403 then raise Forbidden, err_msg
|
||||||
|
when 404 then raise NotFound, err_msg
|
||||||
|
end
|
||||||
end
|
end
|
||||||
raise Error, err_msg
|
raise Error, "#{res.reason}: #{err_msg}"
|
||||||
end
|
end
|
||||||
|
|
||||||
# Splited to the sections similar to API docs.
|
# Splited to the sections similar to API docs.
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
module Telegram
|
module Telegram
|
||||||
module Bot
|
module Bot
|
||||||
VERSION = '0.10.2'.freeze
|
VERSION = '0.11.0'.freeze
|
||||||
|
|
||||||
def self.gem_version
|
def self.gem_version
|
||||||
Gem::Version.new VERSION
|
Gem::Version.new VERSION
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ RSpec.describe Telegram::Bot::Botan do
|
|||||||
let(:token) { 'token' }
|
let(:token) { 'token' }
|
||||||
|
|
||||||
include_examples 'initializers', :botans
|
include_examples 'initializers', :botans
|
||||||
include_examples 'async', request_args: -> { [double(:method), double(:url)] }
|
it_behaves_like 'async', request_args: -> { [double(:method), double(:url)] }
|
||||||
|
|
||||||
describe '.new' do
|
describe '.new' do
|
||||||
subject { described_class.new(*args) }
|
subject { described_class.new(*args) }
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ RSpec.describe Telegram::Bot::Client do
|
|||||||
let(:botan_token) { double(:botan_token) }
|
let(:botan_token) { double(:botan_token) }
|
||||||
|
|
||||||
include_examples 'initializers'
|
include_examples 'initializers'
|
||||||
include_examples 'async', request_args: -> { [double(:action), {body: :content}] }
|
it_behaves_like 'async', request_args: -> { [double(:action), {body: :content}] }
|
||||||
|
|
||||||
describe '.prepare_body' do
|
describe '.prepare_body' do
|
||||||
subject { described_class.prepare_body(input) }
|
subject { described_class.prepare_body(input) }
|
||||||
@@ -48,4 +48,49 @@ RSpec.describe Telegram::Bot::Client do
|
|||||||
its(:base_uri) { should include args[0][:token] }
|
its(:base_uri) { should include args[0][:token] }
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
describe '#request' do
|
||||||
|
subject { -> { instance.request(action, request_body) } }
|
||||||
|
let(:action) { :some_action }
|
||||||
|
let(:url) { "#{format described_class::URL_TEMPLATE, token}#{action}" }
|
||||||
|
let(:request_body) { double(:body) }
|
||||||
|
let(:prepared_body) { double(:prepared_body) }
|
||||||
|
let(:response) { HTTP::Message.new_response(body).tap { |x| x.status = status } }
|
||||||
|
|
||||||
|
let(:status) { 200 }
|
||||||
|
let(:body) { body_json.to_json }
|
||||||
|
let(:body_json) { {'param' => 'val', 'description' => 'some description'} }
|
||||||
|
before do
|
||||||
|
expect(described_class).to receive(:prepare_body).with(request_body) { prepared_body }
|
||||||
|
expect(instance).to receive(:http_request).with(url, prepared_body) { response }
|
||||||
|
end
|
||||||
|
around { |ex| Telegram::Bot::ClientStub.stub_all!(false) { ex.run } }
|
||||||
|
|
||||||
|
shared_examples 'invalid body' do |error = Telegram::Bot::Error|
|
||||||
|
context 'when body is not json' do
|
||||||
|
let(:body) { '{' }
|
||||||
|
it { should raise_error error }
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
its(:call) { should eq body_json }
|
||||||
|
include_examples 'invalid body', JSON::ParserError
|
||||||
|
|
||||||
|
context 'when status is 403' do
|
||||||
|
let(:status) { 403 }
|
||||||
|
it { should raise_error Telegram::Bot::Forbidden, body_json['description'] }
|
||||||
|
include_examples 'invalid body'
|
||||||
|
end
|
||||||
|
|
||||||
|
context 'when status is 404' do
|
||||||
|
let(:status) { 404 }
|
||||||
|
it { should raise_error Telegram::Bot::NotFound, body_json['description'] }
|
||||||
|
include_examples 'invalid body'
|
||||||
|
end
|
||||||
|
|
||||||
|
context 'when status is other' do
|
||||||
|
let(:status) { 500 }
|
||||||
|
it { should raise_error Telegram::Bot::Error, /#{body_json['description']}/ }
|
||||||
|
end
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@@ -2,25 +2,4 @@ RSpec.describe Telegram::Bot do
|
|||||||
it 'has a version number' do
|
it 'has a version number' do
|
||||||
expect(described_class::VERSION).not_to be nil
|
expect(described_class::VERSION).not_to be nil
|
||||||
end
|
end
|
||||||
|
|
||||||
describe described_class::StaleChat do
|
|
||||||
describe '.match_response?' do
|
|
||||||
subject { ->(val) { described_class.match_response?(val) } }
|
|
||||||
|
|
||||||
it 'returns true for specific errors' do
|
|
||||||
expect(subject.call({})).to eq false
|
|
||||||
expect(subject.call('description' => 'test')).to eq false
|
|
||||||
expect(subject.call('description' => 'Error: bot was kicked from')).to eq true
|
|
||||||
expect(subject.call(
|
|
||||||
'description' => "Forbidden: can't write to private chat with deleted user"
|
|
||||||
)).to eq true
|
|
||||||
expect(subject.call(
|
|
||||||
'description' => 'Bad request: group chat is deactivated'
|
|
||||||
)).to eq true
|
|
||||||
expect(subject.call(
|
|
||||||
'description' => 'Forbidden: Bot was blocked by the user'
|
|
||||||
)).to eq true
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
|
|||||||
Ссылка в новой задаче
Block a user