зеркало из
https://github.com/glebtv/telegram-bot.git
synced 2026-08-28 15:26:18 +03:00
Сравнить коммиты
62 Коммитов
| Автор | SHA1 | Дата | |
|---|---|---|---|
|
|
cb973d90dc | ||
|
|
7c3002266a | ||
|
|
814c4e7d1a | ||
|
|
42b98dbf40 | ||
|
|
225e02abb4 | ||
|
|
084ff3527b | ||
|
|
533d84c9ce | ||
|
|
7ddebcb1e2 | ||
|
|
e7b7e2a219 | ||
|
|
7a34c0aa88 | ||
|
|
62c3e3c861 | ||
|
|
da22ecbe79 | ||
|
|
ffd17ec933 | ||
|
|
ad1eb5a47f | ||
|
|
b05f17b02b | ||
|
|
6140f7a68a | ||
|
|
57b17f068c | ||
|
|
7bcb0caded | ||
|
|
d048f42c6c | ||
|
|
f54b36d9b7 | ||
|
|
cd2d3d8d87 | ||
|
|
ee666f0e90 | ||
|
|
759b125d82 | ||
|
|
21ca16f613 | ||
|
|
7cfceb7439 | ||
|
|
29603e5b60 | ||
|
|
5822eff988 | ||
|
|
cbe7186c44 | ||
|
|
ca20bb0533 | ||
|
|
6f8565fbd5 | ||
|
|
a16928267a | ||
|
|
83bc13bac6 | ||
|
|
1e1814a26d | ||
|
|
ae9a6a501d | ||
|
|
74c2c28ab5 | ||
|
|
af85966939 | ||
|
|
5145c31d73 | ||
|
|
cbb3a85757 | ||
|
|
f0c5222c8f | ||
|
|
b4e5b056e0 | ||
|
|
be74094c90 | ||
|
|
e53c31b79f | ||
|
|
b40e4b432d | ||
|
|
ef5ec81386 | ||
|
|
7d8a19d3c8 | ||
|
|
380f6686fc | ||
|
|
ea64230eab | ||
|
|
5b9706ed47 | ||
|
|
2d73d1c879 | ||
|
|
88af1152cf | ||
|
|
586217585a | ||
|
|
f83bf92601 | ||
|
|
3049ced903 | ||
|
|
07faf87ed7 | ||
|
|
ac45940937 | ||
|
|
a49ef51da9 | ||
|
|
4f669fccc4 | ||
|
|
e06252907a | ||
|
|
af229c8bcc | ||
|
|
a7cf3754be | ||
|
|
783d9c13e9 | ||
|
|
5417511f06 |
@@ -2,7 +2,3 @@ checks:
|
||||
method-complexity:
|
||||
config:
|
||||
threshold: 6 # should be just fine
|
||||
|
||||
plugins:
|
||||
rubocop:
|
||||
enabled: true
|
||||
|
||||
47
.github/workflows/ci.yml
поставляемый
Обычный файл
47
.github/workflows/ci.yml
поставляемый
Обычный файл
@@ -0,0 +1,47 @@
|
||||
name: Lint & Test
|
||||
|
||||
on: [push, pull_request]
|
||||
|
||||
jobs:
|
||||
lint:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- uses: actions/checkout@v3
|
||||
- uses: ruby/setup-ruby@v1
|
||||
with:
|
||||
ruby-version: '3.2'
|
||||
bundler-cache: true
|
||||
- run: bundle exec rubocop
|
||||
|
||||
test:
|
||||
runs-on: ubuntu-latest
|
||||
strategy:
|
||||
matrix:
|
||||
ruby:
|
||||
- '2.7'
|
||||
gemfile:
|
||||
- gemfiles/rails_61.gemfile
|
||||
- gemfiles/rails_60.gemfile
|
||||
- gemfiles/rails_52.gemfile
|
||||
- gemfiles/rails_51.gemfile
|
||||
include:
|
||||
# ruby 3.x
|
||||
- ruby: '3.2'
|
||||
gemfile: gemfiles/rails_80.gemfile
|
||||
- ruby: '3.2'
|
||||
gemfile: gemfiles/rails_72.gemfile
|
||||
- ruby: '3.2'
|
||||
gemfile: gemfiles/rails_71.gemfile
|
||||
- ruby: '3.0'
|
||||
gemfile: gemfiles/rails_61.gemfile
|
||||
- ruby: '3.0'
|
||||
gemfile: gemfiles/rails_60.gemfile
|
||||
env:
|
||||
BUNDLE_GEMFILE: ${{ github.workspace }}/${{ matrix.gemfile }}
|
||||
steps:
|
||||
- uses: actions/checkout@v3
|
||||
- uses: ruby/setup-ruby@v1
|
||||
with:
|
||||
ruby-version: ${{ matrix.ruby }}
|
||||
bundler-cache: true
|
||||
- run: bundle exec rake spec
|
||||
43
.rubocop.yml
43
.rubocop.yml
@@ -1,15 +1,18 @@
|
||||
# Rubocop does not support 2.0
|
||||
Gemspec/RequiredRubyVersion: {Enabled: false}
|
||||
require: rubocop-rails
|
||||
|
||||
Rails: {Enabled: true}
|
||||
AllCops:
|
||||
TargetRubyVersion: 2.4
|
||||
NewCops: enable
|
||||
SuggestExtensions: false
|
||||
Exclude:
|
||||
- gemfiles/*
|
||||
- tmp/*
|
||||
- vendor/**/* # for github actions
|
||||
|
||||
Layout/AlignParameters:
|
||||
# Disable, till rubocop supports combination of styles.
|
||||
# Use one of this styles where appropriate, keep it clean, compact and readable.
|
||||
Enabled: false
|
||||
# EnforcedStyle:
|
||||
# - with_first_parameter
|
||||
# - with_fixed_indentation
|
||||
Gemspec/DevelopmentDependencies: {Enabled: false}
|
||||
|
||||
Layout/ArgumentAlignment: {EnforcedStyle: with_fixed_indentation}
|
||||
Layout/ParameterAlignment: {EnforcedStyle: with_fixed_indentation}
|
||||
|
||||
# Breaks
|
||||
#
|
||||
@@ -19,7 +22,11 @@ Layout/AlignParameters:
|
||||
# )
|
||||
Layout/ClosingParenthesisIndentation: {Enabled: false}
|
||||
Layout/DotPosition: {EnforcedStyle: trailing}
|
||||
Layout/EmptyLineAfterGuardClause: {Enabled: false}
|
||||
Layout/FirstParameterIndentation: {EnforcedStyle: consistent}
|
||||
Layout/LineContinuationLeadingSpace: {Enabled: false}
|
||||
Layout/LineEndStringConcatenationIndentation: {EnforcedStyle: indented}
|
||||
Layout/LineLength: {Max: 100}
|
||||
# Same as Layout/ClosingParenthesisIndentation
|
||||
Layout/MultilineMethodCallBraceLayout: {Enabled: false}
|
||||
Layout/MultilineMethodCallIndentation: {EnforcedStyle: indented}
|
||||
@@ -28,8 +35,16 @@ Layout/SpaceInsideHashLiteralBraces: {EnforcedStyle: no_space}
|
||||
|
||||
# Offences named scopes and `expect {}.to change {}`.
|
||||
Lint/AmbiguousBlockAssociation: {Enabled: false}
|
||||
Lint/EmptyBlock:
|
||||
Exclude:
|
||||
- spec/**/*
|
||||
|
||||
Naming/FileName:
|
||||
Exclude:
|
||||
- lib/tasks/telegram-bot.rake
|
||||
Naming/MethodParameterName: {MinNameLength: 2}
|
||||
Naming/PredicateName: {Enabled: false}
|
||||
Naming/RescuedExceptionsVariableName: {PreferredName: exception}
|
||||
Naming/VariableNumber: {EnforcedStyle: snake_case}
|
||||
|
||||
Style/Alias: {Enabled: false}
|
||||
@@ -45,12 +60,16 @@ Style/ModuleFunction: {Enabled: false}
|
||||
Style/NestedParenthesizedCalls: {Enabled: false}
|
||||
Style/SignalException: {EnforcedStyle: only_raise}
|
||||
Style/TrailingCommaInArguments: {Enabled: false}
|
||||
Style/TrailingCommaInLiteral: {EnforcedStyleForMultiline: comma}
|
||||
Style/TrailingCommaInArrayLiteral: {EnforcedStyleForMultiline: comma}
|
||||
Style/TrailingCommaInHashLiteral: {EnforcedStyleForMultiline: comma}
|
||||
|
||||
Metrics/AbcSize: {Max: 21}
|
||||
# Other metrics are just enough.
|
||||
# This one offences all specs, routes and some initializers.
|
||||
Metrics/BlockLength: {Enabled: false}
|
||||
Metrics/LineLength: {Max: 100}
|
||||
Metrics/MethodLength: {Max: 30}
|
||||
Metrics/CyclomaticComplexity: {Max: 8}
|
||||
|
||||
Rails/IndexWith: {Enabled: false}
|
||||
Rails/RakeEnvironment: {Enabled: false}
|
||||
Rails/ShortI18n: {Enabled: false}
|
||||
|
||||
30
.travis.yml
30
.travis.yml
@@ -1,30 +0,0 @@
|
||||
os: linux
|
||||
dist: xenial
|
||||
language: ruby
|
||||
cache: bundler
|
||||
rvm:
|
||||
- 2.6
|
||||
- 2.5
|
||||
gemfile:
|
||||
- gemfiles/rails_61.gemfile
|
||||
- gemfiles/rails_60.gemfile
|
||||
- gemfiles/rails_52.gemfile
|
||||
jobs:
|
||||
include:
|
||||
# ruby 3.x
|
||||
- rvm: 3.0
|
||||
gemfile: gemfiles/rails_61.gemfile
|
||||
- rvm: 3.0
|
||||
gemfile: gemfiles/rails_60.gemfile
|
||||
# old rails
|
||||
- rvm: 2.5
|
||||
gemfile: gemfiles/rails_51.gemfile
|
||||
- rvm: 2.5
|
||||
gemfile: gemfiles/rails_50.gemfile
|
||||
- rvm: 2.5
|
||||
gemfile: gemfiles/rails_42.gemfile
|
||||
# old rubies
|
||||
- rvm: 2.4
|
||||
gemfile: gemfiles/rails_52.gemfile
|
||||
notifications:
|
||||
email: false
|
||||
32
Appraisals
32
Appraisals
@@ -1,3 +1,25 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
appraise 'rails-80' do
|
||||
gem 'actionpack', '~> 8.0.0'
|
||||
gem 'railties', '~> 8.0.0'
|
||||
end
|
||||
|
||||
appraise 'rails-72' do
|
||||
gem 'actionpack', '~> 7.2.0'
|
||||
gem 'railties', '~> 7.2.0'
|
||||
end
|
||||
|
||||
appraise 'rails-71' do
|
||||
gem 'actionpack', '~> 7.1.0'
|
||||
gem 'railties', '~> 7.1.0'
|
||||
end
|
||||
|
||||
appraise 'rails-70' do
|
||||
gem 'actionpack', '~> 7.0.0'
|
||||
gem 'railties', '~> 7.0.0'
|
||||
end
|
||||
|
||||
appraise 'rails-61' do
|
||||
gem 'actionpack', '~> 6.1.0'
|
||||
gem 'railties', '~> 6.1.0'
|
||||
@@ -17,13 +39,3 @@ appraise 'rails-51' do
|
||||
gem 'actionpack', '~> 5.1.0'
|
||||
gem 'railties', '~> 5.1.0'
|
||||
end
|
||||
|
||||
appraise 'rails-50' do
|
||||
gem 'actionpack', '~> 5.0.0'
|
||||
gem 'railties', '~> 5.0.0'
|
||||
end
|
||||
|
||||
appraise 'rails-42' do
|
||||
gem 'actionpack', '~> 4.2.0'
|
||||
gem 'railties', '~> 4.2.0'
|
||||
end
|
||||
|
||||
57
CHANGELOG.md
57
CHANGELOG.md
@@ -1,5 +1,62 @@
|
||||
# Unreleased
|
||||
|
||||
# 0.16.7
|
||||
|
||||
- Update to Bot API 8.2
|
||||
|
||||
# 0.16.6
|
||||
|
||||
- Fix poller rake task for Rails 8.0
|
||||
|
||||
# 0.16.5
|
||||
|
||||
- Rails 8.0 support
|
||||
- Update to Bot API 8.0
|
||||
|
||||
# 0.16.4
|
||||
|
||||
- Rails 7.2 support
|
||||
- Update to Bot API 7.9
|
||||
|
||||
# 0.16.3
|
||||
|
||||
- Update to Bot API 7.7
|
||||
- Added `pre_checkout_query` to PAYLOAD_TYPES
|
||||
|
||||
# 0.16.2
|
||||
|
||||
- Update to Bot API 7.3
|
||||
- Add `# frozen_string_literal: true` to all source files.
|
||||
|
||||
# 0.16.1
|
||||
|
||||
- Fix logger in poller mode in rails 7.1
|
||||
|
||||
# 0.16.0
|
||||
|
||||
- Add `UpdatesController#webhook_request` that is set to `ActionDispatch::Request`
|
||||
in webhook mode.
|
||||
- Update to Bot API 6.8
|
||||
- Added `chat_join_request` to PAYLOAD_TYPES
|
||||
|
||||
# 0.15.7
|
||||
|
||||
- Add support for editMessageMedia similar to sendMediaGroup.
|
||||
|
||||
# 0.15.6
|
||||
|
||||
- Rails 7.0 support.
|
||||
- Fix sending File objects in nested objects in sendMediaGroup.
|
||||
- Update to Bot API 5.7
|
||||
|
||||
# 0.15.4
|
||||
|
||||
- Update to Bot API 5.3
|
||||
|
||||
# 0.15.3
|
||||
|
||||
- Ruby 3.0 support: fix translation helpers.
|
||||
|
||||
# 0.15.2
|
||||
|
||||
- Ruby 3.0 support. Drop support for Ruby < 2.4.
|
||||
|
||||
12
Gemfile
12
Gemfile
@@ -1,20 +1,22 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
source 'https://rubygems.org'
|
||||
gemspec
|
||||
|
||||
group :development do
|
||||
gem 'appraisal', '~> 2.2'
|
||||
|
||||
gem 'pry', '~> 0.13.1'
|
||||
gem 'pry-byebug', '~> 3.9.0'
|
||||
gem 'debug', '~> 1.9.2'
|
||||
gem 'sdoc', '~> 2.0.3'
|
||||
|
||||
gem 'telegram-bot-types', '~> 0.6.2'
|
||||
gem 'telegram-bot-types', '~> 0.6.3'
|
||||
|
||||
gem 'rspec', '~> 3.10.0'
|
||||
gem 'rspec', '~> 3.12.0'
|
||||
gem 'rspec-its', '~> 1.3.0'
|
||||
gem 'rspec-rails', '~> 4.0.2'
|
||||
|
||||
gem 'rubocop', '~> 0.52.1'
|
||||
gem 'rubocop', '~> 1.59.0'
|
||||
gem 'rubocop-rails', '~> 2.23.1'
|
||||
|
||||
gem 'coveralls', '~> 0.8.23', require: false
|
||||
end
|
||||
|
||||
74
README.md
74
README.md
@@ -2,7 +2,7 @@
|
||||
|
||||
[](http://badge.fury.io/rb/telegram-bot)
|
||||
[](https://codeclimate.com/github/telegram-bot-rb/telegram-bot)
|
||||
[](https://travis-ci.org/telegram-bot-rb/telegram-bot)
|
||||
[](https://github.com/telegram-bot-rb/telegram-bot/actions/workflows/ci.yml)
|
||||
|
||||
Tools for developing Telegram bots. Best used with Rails, but can be used in
|
||||
[standalone app](https://github.com/telegram-bot-rb/telegram-bot/wiki/Not-rails-application).
|
||||
@@ -25,9 +25,33 @@ with session, keyboards and inline queries.
|
||||
Run it on your local machine in 1 minute!
|
||||
|
||||
And here is [app template](https://github.com/telegram-bot-rb/rails_template)
|
||||
to generate clean app in seconds.
|
||||
to generate new rails app in seconds.
|
||||
|
||||
Examples and cookbook in [wiki](https://github.com/telegram-bot-rb/telegram-bot/wiki).
|
||||
See examples and cookbook in [the wiki](https://github.com/telegram-bot-rb/telegram-bot/wiki).
|
||||
|
||||
## Table of Contents
|
||||
|
||||
* [Installation](#installation)
|
||||
* [Usage](#usage)
|
||||
* [Configuration](#configuration)
|
||||
* [Configuration in Rails app](#configuration-in-rails-app)
|
||||
* [Client](#client)
|
||||
* [Typed responses](#typed-responses)
|
||||
* [Controller](#controller)
|
||||
* [Reply helpers](#reply-helpers)
|
||||
* [Optional typecasting](#optional-typecasting)
|
||||
* [Session](#session)
|
||||
* [Message context](#message-context)
|
||||
* [Callback queries](#callback-queries)
|
||||
* [Routes in Rails app](#routes-in-rails-app)
|
||||
* [Processing updates](#processing-updates)
|
||||
* [Development & Debugging](#development--debugging)
|
||||
* [Testing](#testing)
|
||||
* [Deployment](#deployment)
|
||||
* [Async mode](#async-mode)
|
||||
* [Limitations](#limitations)
|
||||
* [Development](#development)
|
||||
* [Contributing](#contributing)
|
||||
|
||||
## Installation
|
||||
|
||||
@@ -39,11 +63,15 @@ gem 'telegram-bot'
|
||||
|
||||
And then execute:
|
||||
|
||||
$ bundle
|
||||
```
|
||||
bundle
|
||||
```
|
||||
|
||||
Or install it yourself as:
|
||||
|
||||
$ gem install telegram-bot
|
||||
```
|
||||
gem install telegram-bot
|
||||
```
|
||||
|
||||
Require if necessary:
|
||||
|
||||
@@ -170,19 +198,18 @@ Bot controllers like usual rails controllers provides features like callbacks,
|
||||
|
||||
```ruby
|
||||
class Telegram::WebhookController < Telegram::Bot::UpdatesController
|
||||
# use callbacks like in any other controllers
|
||||
# use callbacks like in any other controller
|
||||
around_action :with_locale
|
||||
|
||||
# Every update can have one of: message, inline_query, chosen_inline_result,
|
||||
# Every update has one of: message, inline_query, chosen_inline_result,
|
||||
# callback_query, etc.
|
||||
# Define method with same name to respond to this updates.
|
||||
# Define method with the same name to handle this type of update.
|
||||
def message(message)
|
||||
# message can be also accessed via instance method
|
||||
message == self.payload # true
|
||||
# store_message(message['text'])
|
||||
end
|
||||
|
||||
# This basic methods receives commonly used params:
|
||||
# For the following types of updates commonly used params are passed as arguments,
|
||||
# full payload object is available with `payload` instance method.
|
||||
#
|
||||
# message(payload)
|
||||
# inline_query(query, offset)
|
||||
@@ -193,14 +220,19 @@ class Telegram::WebhookController < Telegram::Bot::UpdatesController
|
||||
# Command arguments will be parsed and passed to the method.
|
||||
# Be sure to use splat args and default values to not get errors when
|
||||
# someone passed more or less arguments in the message.
|
||||
def start!(data = nil, *)
|
||||
# do_smth_with(data)
|
||||
def start!(word = nil, *other_words)
|
||||
# do_smth_with(word)
|
||||
|
||||
# full message object is also available via `payload` instance method:
|
||||
# process_raw_message(payload['text'])
|
||||
|
||||
# There are `chat` & `from` shortcut methods.
|
||||
# For callback queries `chat` if taken from `message` when it's available.
|
||||
# For callback queries `chat` is taken from `message` when it's available.
|
||||
response = from ? "Hello #{from['username']}!" : 'Hi there!'
|
||||
|
||||
# There is `respond_with` helper to set `chat_id` from received message:
|
||||
respond_with :message, text: response
|
||||
|
||||
# `reply_with` also sets `reply_to_message_id`:
|
||||
reply_with :photo, photo: File.open('party.jpg')
|
||||
end
|
||||
@@ -223,10 +255,10 @@ end
|
||||
|
||||
#### Reply helpers
|
||||
|
||||
There are helpers to respond for basic actions. They just set chat/message/query
|
||||
identifiers from update. See
|
||||
There are helpers for basic responses. They just set chat/message/query
|
||||
identifiers from the update. See
|
||||
[`ReplyHelpers`](https://github.com/telegram-bot-rb/telegram-bot/blob/master/lib/telegram/bot/updates_controller/reply_helpers.rb)
|
||||
module for more information. Here are this methods signatures:
|
||||
module for more information. Here are these methods signatures:
|
||||
|
||||
```ruby
|
||||
def respond_with(type, params); end
|
||||
@@ -389,7 +421,7 @@ telegram_webhook TelegramAuctionController, :auction
|
||||
telegram_webhook TelegramController, as: :custom_telegram_webhook
|
||||
```
|
||||
|
||||
#### Processesing updates
|
||||
#### Processing updates
|
||||
|
||||
To process update with controller call `.dispatch(bot, update)` on it.
|
||||
There are several options to run it automatically:
|
||||
@@ -398,6 +430,10 @@ There are several options to run it automatically:
|
||||
- Use `Telegram::Bot::Middleware` with rack ([example in wiki](https://github.com/telegram-bot-rb/telegram-bot/wiki/Not-rails-application)).
|
||||
- Use poller (described in the next section).
|
||||
|
||||
When controller runs in webhook mode `Telegram::Bot::Middleware` passes
|
||||
`ActionDispatch::Request` object to the `.dispatch` method.
|
||||
It's available via `#webhook_request` controller method.
|
||||
|
||||
To run action without update (ex., send notifications from jobs),
|
||||
you can call `#process` directly. In this case controller can be initialized
|
||||
with `:from` and/or `:chat` options instead of `update` object:
|
||||
@@ -507,7 +543,7 @@ end
|
||||
|
||||
There is a context for testing bot controller in the way similar to Rails controller tests.
|
||||
It's supposed to be a low-level alternative for integration tests. Among the differences is
|
||||
that controller tests use a single controller instance for all dispatches in specific exaple,
|
||||
that controller tests use a single controller instance for all dispatches in specific example,
|
||||
session is stubbed (does not use configured store engine), and update is not serialized
|
||||
so it also supports mocks. This can be useful for unit testing, but should not be used as
|
||||
the default way to test the bot.
|
||||
|
||||
2
Rakefile
2
Rakefile
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'bundler/gem_tasks'
|
||||
require 'rspec/core/rake_task'
|
||||
|
||||
|
||||
@@ -1,7 +1,11 @@
|
||||
#!/usr/bin/env ruby
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'bundler/setup'
|
||||
require 'telegram/bot'
|
||||
|
||||
require 'pry'
|
||||
Pry.start
|
||||
require 'irb'
|
||||
require 'irb/completion'
|
||||
|
||||
IRB.setup(nil)
|
||||
IRB::Irb.new.run(IRB.conf)
|
||||
|
||||
@@ -1,4 +1,6 @@
|
||||
#!/usr/bin/env ruby
|
||||
# frozen_string_literal: true
|
||||
|
||||
#
|
||||
# Fetch list of methods from Telegram docs.
|
||||
# Use it to update client.rb.
|
||||
@@ -6,7 +8,7 @@
|
||||
require 'net/http'
|
||||
require 'nokogiri'
|
||||
|
||||
DOCS_URL = 'https://core.telegram.org/bots/api'.freeze
|
||||
DOCS_URL = 'https://core.telegram.org/bots/api'
|
||||
|
||||
page_html = Net::HTTP.get(URI(DOCS_URL))
|
||||
doc = Nokogiri::HTML(page_html)
|
||||
@@ -18,11 +20,11 @@ headers = doc.css('h3, h4').
|
||||
map { |g| g.map(&:text) }
|
||||
|
||||
# Method starts with lowercase and does not have spaces.
|
||||
NOT_METHOD_REGEXP = /(\A[^a-z])|\s/
|
||||
NOT_METHOD_REGEXP = /(\A[^a-z])|\s/.freeze
|
||||
|
||||
# Filter method names.
|
||||
method_list = headers.
|
||||
map { |g| g.reject { |x| x.match?(NOT_METHOD_REGEXP) } }.
|
||||
map { |g| g.grep_v(NOT_METHOD_REGEXP) }.
|
||||
reject(&:empty?)
|
||||
|
||||
api_version = doc.text.match(/^(?:Introducing )?(Bot API ([\d\.]+))\.?$/)
|
||||
@@ -39,3 +41,24 @@ puts result_txt
|
||||
API_METHODS_FILE = File.expand_path('../lib/telegram/bot/client/api_methods.txt', __dir__).freeze
|
||||
File.write(API_METHODS_FILE, result_txt)
|
||||
puts '', "Updated #{API_METHODS_FILE}"
|
||||
|
||||
|
||||
puts '', 'Payload types:'
|
||||
update_tbody = doc.css('tbody').
|
||||
find { |tbody| tbody.css('td').any? { |td| td.text == 'update_id' } }
|
||||
payload_types = update_tbody.css('td:first-child').map(&:text).reject { |x| x == 'update_id' }
|
||||
|
||||
result = ['# Generated with bin/fetch-telegram-methods']
|
||||
result << "# #{api_version[1]}" if api_version
|
||||
result << payload_types.join("\n")
|
||||
result << ''
|
||||
result_txt = result.join("\n")
|
||||
|
||||
puts result_txt
|
||||
|
||||
PAYLOAD_TYPES_FILE = File.expand_path(
|
||||
'../lib/telegram/bot/updates_controller/payload_types.txt',
|
||||
__dir__,
|
||||
).freeze
|
||||
File.write(PAYLOAD_TYPES_FILE, result_txt)
|
||||
puts '', "Updated #{PAYLOAD_TYPES_FILE}"
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
#!/usr/bin/env ruby
|
||||
# frozen_string_literal: true
|
||||
|
||||
root = File.expand_path('../../', __FILE__)
|
||||
root = File.expand_path('..', __dir__)
|
||||
hooks_dir = "#{root}/bin/git-hooks"
|
||||
|
||||
`ls -1 #{hooks_dir}`.each_line.map(&:strip).each do |file|
|
||||
|
||||
@@ -7,14 +7,14 @@ gem "railties", "~> 5.1.0"
|
||||
|
||||
group :development do
|
||||
gem "appraisal", "~> 2.2"
|
||||
gem "pry", "~> 0.13.1"
|
||||
gem "pry-byebug", "~> 3.9.0"
|
||||
gem "debug", "~> 1.9.2"
|
||||
gem "sdoc", "~> 2.0.3"
|
||||
gem "telegram-bot-types", "~> 0.6.2"
|
||||
gem "rspec", "~> 3.10.0"
|
||||
gem "telegram-bot-types", "~> 0.6.3"
|
||||
gem "rspec", "~> 3.12.0"
|
||||
gem "rspec-its", "~> 1.3.0"
|
||||
gem "rspec-rails", "~> 4.0.2"
|
||||
gem "rubocop", "~> 0.52.1"
|
||||
gem "rubocop", "~> 1.59.0"
|
||||
gem "rubocop-rails", "~> 2.23.1"
|
||||
gem "coveralls", "~> 0.8.23", require: false
|
||||
end
|
||||
|
||||
|
||||
@@ -7,14 +7,14 @@ gem "railties", "~> 5.2.0"
|
||||
|
||||
group :development do
|
||||
gem "appraisal", "~> 2.2"
|
||||
gem "pry", "~> 0.13.1"
|
||||
gem "pry-byebug", "~> 3.9.0"
|
||||
gem "debug", "~> 1.9.2"
|
||||
gem "sdoc", "~> 2.0.3"
|
||||
gem "telegram-bot-types", "~> 0.6.2"
|
||||
gem "rspec", "~> 3.10.0"
|
||||
gem "telegram-bot-types", "~> 0.6.3"
|
||||
gem "rspec", "~> 3.12.0"
|
||||
gem "rspec-its", "~> 1.3.0"
|
||||
gem "rspec-rails", "~> 4.0.2"
|
||||
gem "rubocop", "~> 0.52.1"
|
||||
gem "rubocop", "~> 1.59.0"
|
||||
gem "rubocop-rails", "~> 2.23.1"
|
||||
gem "coveralls", "~> 0.8.23", require: false
|
||||
end
|
||||
|
||||
|
||||
@@ -7,14 +7,14 @@ gem "railties", "~> 6.0.0"
|
||||
|
||||
group :development do
|
||||
gem "appraisal", "~> 2.2"
|
||||
gem "pry", "~> 0.13.1"
|
||||
gem "pry-byebug", "~> 3.9.0"
|
||||
gem "debug", "~> 1.9.2"
|
||||
gem "sdoc", "~> 2.0.3"
|
||||
gem "telegram-bot-types", "~> 0.6.2"
|
||||
gem "rspec", "~> 3.10.0"
|
||||
gem "telegram-bot-types", "~> 0.6.3"
|
||||
gem "rspec", "~> 3.12.0"
|
||||
gem "rspec-its", "~> 1.3.0"
|
||||
gem "rspec-rails", "~> 4.0.2"
|
||||
gem "rubocop", "~> 0.52.1"
|
||||
gem "rubocop", "~> 1.59.0"
|
||||
gem "rubocop-rails", "~> 2.23.1"
|
||||
gem "coveralls", "~> 0.8.23", require: false
|
||||
end
|
||||
|
||||
|
||||
@@ -7,14 +7,14 @@ gem "railties", "~> 6.1.0"
|
||||
|
||||
group :development do
|
||||
gem "appraisal", "~> 2.2"
|
||||
gem "pry", "~> 0.13.1"
|
||||
gem "pry-byebug", "~> 3.9.0"
|
||||
gem "debug", "~> 1.9.2"
|
||||
gem "sdoc", "~> 2.0.3"
|
||||
gem "telegram-bot-types", "~> 0.6.2"
|
||||
gem "rspec", "~> 3.10.0"
|
||||
gem "telegram-bot-types", "~> 0.6.3"
|
||||
gem "rspec", "~> 3.12.0"
|
||||
gem "rspec-its", "~> 1.3.0"
|
||||
gem "rspec-rails", "~> 4.0.2"
|
||||
gem "rubocop", "~> 0.52.1"
|
||||
gem "rubocop", "~> 1.59.0"
|
||||
gem "rubocop-rails", "~> 2.23.1"
|
||||
gem "coveralls", "~> 0.8.23", require: false
|
||||
end
|
||||
|
||||
|
||||
@@ -2,19 +2,19 @@
|
||||
|
||||
source "https://rubygems.org"
|
||||
|
||||
gem "actionpack", "~> 4.2.0"
|
||||
gem "railties", "~> 4.2.0"
|
||||
gem "actionpack", "~> 7.0.0"
|
||||
gem "railties", "~> 7.0.0"
|
||||
|
||||
group :development do
|
||||
gem "appraisal", "~> 2.2"
|
||||
gem "pry", "~> 0.13.1"
|
||||
gem "pry-byebug", "~> 3.9.0"
|
||||
gem "debug", "~> 1.9.2"
|
||||
gem "sdoc", "~> 2.0.3"
|
||||
gem "telegram-bot-types", "~> 0.6.2"
|
||||
gem "rspec", "~> 3.10.0"
|
||||
gem "telegram-bot-types", "~> 0.6.3"
|
||||
gem "rspec", "~> 3.12.0"
|
||||
gem "rspec-its", "~> 1.3.0"
|
||||
gem "rspec-rails", "~> 4.0.2"
|
||||
gem "rubocop", "~> 0.52.1"
|
||||
gem "rubocop", "~> 1.59.0"
|
||||
gem "rubocop-rails", "~> 2.23.1"
|
||||
gem "coveralls", "~> 0.8.23", require: false
|
||||
end
|
||||
|
||||
@@ -2,19 +2,19 @@
|
||||
|
||||
source "https://rubygems.org"
|
||||
|
||||
gem "actionpack", "~> 5.0.0"
|
||||
gem "railties", "~> 5.0.0"
|
||||
gem "actionpack", "~> 7.1.0"
|
||||
gem "railties", "~> 7.1.0"
|
||||
|
||||
group :development do
|
||||
gem "appraisal", "~> 2.2"
|
||||
gem "pry", "~> 0.13.1"
|
||||
gem "pry-byebug", "~> 3.9.0"
|
||||
gem "debug", "~> 1.9.2"
|
||||
gem "sdoc", "~> 2.0.3"
|
||||
gem "telegram-bot-types", "~> 0.6.2"
|
||||
gem "rspec", "~> 3.10.0"
|
||||
gem "telegram-bot-types", "~> 0.6.3"
|
||||
gem "rspec", "~> 3.12.0"
|
||||
gem "rspec-its", "~> 1.3.0"
|
||||
gem "rspec-rails", "~> 4.0.2"
|
||||
gem "rubocop", "~> 0.52.1"
|
||||
gem "rubocop", "~> 1.59.0"
|
||||
gem "rubocop-rails", "~> 2.23.1"
|
||||
gem "coveralls", "~> 0.8.23", require: false
|
||||
end
|
||||
|
||||
21
gemfiles/rails_72.gemfile
Обычный файл
21
gemfiles/rails_72.gemfile
Обычный файл
@@ -0,0 +1,21 @@
|
||||
# This file was generated by Appraisal
|
||||
|
||||
source "https://rubygems.org"
|
||||
|
||||
gem "actionpack", "~> 7.2.0"
|
||||
gem "railties", "~> 7.2.0"
|
||||
|
||||
group :development do
|
||||
gem "appraisal", "~> 2.2"
|
||||
gem "debug", "~> 1.9.2"
|
||||
gem "sdoc", "~> 2.0.3"
|
||||
gem "telegram-bot-types", "~> 0.6.3"
|
||||
gem "rspec", "~> 3.12.0"
|
||||
gem "rspec-its", "~> 1.3.0"
|
||||
gem "rspec-rails", "~> 4.0.2"
|
||||
gem "rubocop", "~> 1.59.0"
|
||||
gem "rubocop-rails", "~> 2.23.1"
|
||||
gem "coveralls", "~> 0.8.23", require: false
|
||||
end
|
||||
|
||||
gemspec path: "../"
|
||||
21
gemfiles/rails_80.gemfile
Обычный файл
21
gemfiles/rails_80.gemfile
Обычный файл
@@ -0,0 +1,21 @@
|
||||
# This file was generated by Appraisal
|
||||
|
||||
source "https://rubygems.org"
|
||||
|
||||
gem "actionpack", "~> 8.0.0"
|
||||
gem "railties", "~> 8.0.0"
|
||||
|
||||
group :development do
|
||||
gem "appraisal", "~> 2.2"
|
||||
gem "debug", "~> 1.9.2"
|
||||
gem "sdoc", "~> 2.0.3"
|
||||
gem "telegram-bot-types", "~> 0.6.3"
|
||||
gem "rspec", "~> 3.12.0"
|
||||
gem "rspec-its", "~> 1.3.0"
|
||||
gem "rspec-rails", "~> 4.0.2"
|
||||
gem "rubocop", "~> 1.59.0"
|
||||
gem "rubocop-rails", "~> 2.23.1"
|
||||
gem "coveralls", "~> 0.8.23", require: false
|
||||
end
|
||||
|
||||
gemspec path: "../"
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
namespace :telegram do
|
||||
namespace :bot do
|
||||
desc 'Run poller. It broadcasts Rails.logger to STDOUT in dev like `rails s` do. ' \
|
||||
@@ -6,10 +8,17 @@ namespace :telegram do
|
||||
ENV['BOT_POLLER_MODE'] = 'true'
|
||||
Rake::Task['environment'].invoke
|
||||
if ENV.fetch('LOG_TO_STDOUT') { Rails.env.development? }.present?
|
||||
console = ActiveSupport::Logger.new(STDERR)
|
||||
Rails.logger.extend ActiveSupport::Logger.broadcast console
|
||||
console = ActiveSupport::Logger.new($stderr)
|
||||
if Rails.logger.respond_to?(:broadcast_to)
|
||||
Rails.logger.broadcast_to(console)
|
||||
else
|
||||
Rails.logger.extend ActiveSupport::Logger.broadcast console
|
||||
end
|
||||
end
|
||||
Telegram::Bot::UpdatesPoller.start(ENV['BOT'].try!(:to_sym) || :default)
|
||||
# Routes are not loaded by default in Rails >= 8.0.
|
||||
# Load them explicitly to identify a controller for a bot.
|
||||
Rails.application.try(:reload_routes_unless_loaded)
|
||||
Telegram::Bot::UpdatesPoller.start(ENV['BOT']&.to_sym || :default)
|
||||
end
|
||||
|
||||
desc 'Set webhook urls for all bots'
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/config_methods'
|
||||
|
||||
module Telegram
|
||||
@@ -12,15 +14,6 @@ module Telegram
|
||||
# Raised for valid telegram response with 404 status code.
|
||||
class NotFound < Error; end
|
||||
|
||||
module_function
|
||||
|
||||
def deprecation_0_16
|
||||
@deprecation ||= begin
|
||||
require 'active_support/deprecation'
|
||||
ActiveSupport::Deprecation.new('0.16', 'Telegram::Bot')
|
||||
end
|
||||
end
|
||||
|
||||
autoload :Async, 'telegram/bot/async'
|
||||
autoload :Client, 'telegram/bot/client'
|
||||
autoload :ClientStub, 'telegram/bot/client_stub'
|
||||
@@ -30,6 +23,7 @@ module Telegram
|
||||
autoload :Tasks, 'telegram/bot/tasks'
|
||||
autoload :UpdatesController, 'telegram/bot/updates_controller'
|
||||
autoload :UpdatesPoller, 'telegram/bot/updates_poller'
|
||||
autoload :VERSION, 'telegram/bot/version'
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
# Telegram clients can perform requests in async way with
|
||||
@@ -128,7 +130,7 @@ module Telegram
|
||||
#
|
||||
# If no block is given returns previously set value or the global one,
|
||||
# set by #async=.
|
||||
def async(val = true)
|
||||
def async(val = true) # rubocop:disable Style/OptionalBooleanParameter
|
||||
thread_key = object_id
|
||||
thread_store = Async.thread_store
|
||||
return thread_store.fetch(thread_key) { @async } unless block_given?
|
||||
@@ -137,7 +139,7 @@ module Telegram
|
||||
thread_store[thread_key] = self.class.prepare_async_val(val)
|
||||
yield
|
||||
ensure
|
||||
if MISSING_VALUE == old_val
|
||||
if old_val == MISSING_VALUE
|
||||
thread_store.delete(thread_key)
|
||||
else
|
||||
thread_store[thread_key] = old_val
|
||||
|
||||
@@ -1,14 +1,17 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'active_support/core_ext/hash/keys'
|
||||
require 'json'
|
||||
require 'httpclient'
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class Client
|
||||
SERVER = 'https://api.telegram.org'.freeze
|
||||
URL_TEMPLATE = '%<server>s/bot%<token>s/'.freeze
|
||||
SERVER = 'https://api.telegram.org'
|
||||
URL_TEMPLATE = '%<server>s/bot%<token>s/'
|
||||
|
||||
autoload :RequestBodyFormatter, 'telegram/bot/client/request_body_formatter'
|
||||
autoload :TypedResponse, 'telegram/bot/client/typed_response'
|
||||
|
||||
prepend Async
|
||||
include DebugClient
|
||||
|
||||
@@ -35,20 +38,12 @@ module Telegram
|
||||
prepend TypedResponse
|
||||
end
|
||||
|
||||
# Encodes nested hashes as json.
|
||||
def prepare_body(body)
|
||||
body = body.dup
|
||||
body.each do |k, val|
|
||||
body[k] = val.to_json if val.is_a?(Hash) || val.is_a?(Array)
|
||||
end
|
||||
end
|
||||
|
||||
def prepare_async_args(action, body = {})
|
||||
[action.to_s, Async.prepare_hash(prepare_body(body))]
|
||||
[action.to_s, Async.prepare_hash(RequestBodyFormatter.format(body, action))]
|
||||
end
|
||||
|
||||
def error_for_response(response)
|
||||
result = JSON.parse(response.body) rescue nil # rubocop:disable RescueModifier
|
||||
result = JSON.parse(response.body) rescue nil # rubocop:disable Style/RescueModifier
|
||||
return Error.new(response.reason) unless result
|
||||
message = result['description'] || '-'
|
||||
# This errors are raised only for valid responses from Telegram
|
||||
@@ -70,7 +65,7 @@ module Telegram
|
||||
end
|
||||
|
||||
def request(action, body = {})
|
||||
response = http_request("#{base_uri}#{action}", self.class.prepare_body(body))
|
||||
response = http_request("#{base_uri}#{action}", RequestBodyFormatter.format(body, action))
|
||||
raise self.class.error_for_response(response) if response.status >= 300
|
||||
JSON.parse(response.body)
|
||||
end
|
||||
|
||||
@@ -1,10 +1,12 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'active_support/core_ext/string/inflections'
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class Client
|
||||
module ApiHelper
|
||||
METHODS_LIST_FILE = File.expand_path('../api_methods.txt', __FILE__)
|
||||
METHODS_LIST_FILE = File.expand_path('api_methods.txt', __dir__)
|
||||
|
||||
class << self
|
||||
def methods_list(file = METHODS_LIST_FILE)
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
# Generated with bin/fetch-telegram-methods
|
||||
# Bot API 5.0
|
||||
# Bot API 8.2
|
||||
|
||||
getUpdates
|
||||
setWebhook
|
||||
@@ -11,7 +11,9 @@ logOut
|
||||
close
|
||||
sendMessage
|
||||
forwardMessage
|
||||
forwardMessages
|
||||
copyMessage
|
||||
copyMessages
|
||||
sendPhoto
|
||||
sendAudio
|
||||
sendDocument
|
||||
@@ -19,24 +21,34 @@ sendVideo
|
||||
sendAnimation
|
||||
sendVoice
|
||||
sendVideoNote
|
||||
sendPaidMedia
|
||||
sendMediaGroup
|
||||
sendLocation
|
||||
editMessageLiveLocation
|
||||
stopMessageLiveLocation
|
||||
sendVenue
|
||||
sendContact
|
||||
sendPoll
|
||||
sendDice
|
||||
sendChatAction
|
||||
setMessageReaction
|
||||
getUserProfilePhotos
|
||||
setUserEmojiStatus
|
||||
getFile
|
||||
kickChatMember
|
||||
banChatMember
|
||||
unbanChatMember
|
||||
restrictChatMember
|
||||
promoteChatMember
|
||||
setChatAdministratorCustomTitle
|
||||
banChatSenderChat
|
||||
unbanChatSenderChat
|
||||
setChatPermissions
|
||||
exportChatInviteLink
|
||||
createChatInviteLink
|
||||
editChatInviteLink
|
||||
createChatSubscriptionInviteLink
|
||||
editChatSubscriptionInviteLink
|
||||
revokeChatInviteLink
|
||||
approveChatJoinRequest
|
||||
declineChatJoinRequest
|
||||
setChatPhoto
|
||||
deleteChatPhoto
|
||||
setChatTitle
|
||||
@@ -47,35 +59,84 @@ unpinAllChatMessages
|
||||
leaveChat
|
||||
getChat
|
||||
getChatAdministrators
|
||||
getChatMembersCount
|
||||
getChatMemberCount
|
||||
getChatMember
|
||||
setChatStickerSet
|
||||
deleteChatStickerSet
|
||||
getForumTopicIconStickers
|
||||
createForumTopic
|
||||
editForumTopic
|
||||
closeForumTopic
|
||||
reopenForumTopic
|
||||
deleteForumTopic
|
||||
unpinAllForumTopicMessages
|
||||
editGeneralForumTopic
|
||||
closeGeneralForumTopic
|
||||
reopenGeneralForumTopic
|
||||
hideGeneralForumTopic
|
||||
unhideGeneralForumTopic
|
||||
unpinAllGeneralForumTopicMessages
|
||||
answerCallbackQuery
|
||||
getUserChatBoosts
|
||||
getBusinessConnection
|
||||
setMyCommands
|
||||
deleteMyCommands
|
||||
getMyCommands
|
||||
setMyName
|
||||
getMyName
|
||||
setMyDescription
|
||||
getMyDescription
|
||||
setMyShortDescription
|
||||
getMyShortDescription
|
||||
setChatMenuButton
|
||||
getChatMenuButton
|
||||
setMyDefaultAdministratorRights
|
||||
getMyDefaultAdministratorRights
|
||||
|
||||
editMessageText
|
||||
editMessageCaption
|
||||
editMessageMedia
|
||||
editMessageLiveLocation
|
||||
stopMessageLiveLocation
|
||||
editMessageReplyMarkup
|
||||
stopPoll
|
||||
deleteMessage
|
||||
deleteMessages
|
||||
|
||||
sendSticker
|
||||
getStickerSet
|
||||
getCustomEmojiStickers
|
||||
uploadStickerFile
|
||||
createNewStickerSet
|
||||
addStickerToSet
|
||||
setStickerPositionInSet
|
||||
deleteStickerFromSet
|
||||
setStickerSetThumb
|
||||
replaceStickerInSet
|
||||
setStickerEmojiList
|
||||
setStickerKeywords
|
||||
setStickerMaskPosition
|
||||
setStickerSetTitle
|
||||
setStickerSetThumbnail
|
||||
setCustomEmojiStickerSetThumbnail
|
||||
deleteStickerSet
|
||||
getAvailableGifts
|
||||
sendGift
|
||||
verifyUser
|
||||
verifyChat
|
||||
removeUserVerification
|
||||
removeChatVerification
|
||||
|
||||
answerInlineQuery
|
||||
answerWebAppQuery
|
||||
savePreparedInlineMessage
|
||||
|
||||
sendInvoice
|
||||
createInvoiceLink
|
||||
answerShippingQuery
|
||||
answerPreCheckoutQuery
|
||||
getStarTransactions
|
||||
refundStarPayment
|
||||
editUserStarSubscription
|
||||
|
||||
setPassportDataErrors
|
||||
|
||||
|
||||
63
lib/telegram/bot/client/request_body_formatter.rb
Обычный файл
63
lib/telegram/bot/client/request_body_formatter.rb
Обычный файл
@@ -0,0 +1,63 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'json'
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class Client
|
||||
# Encodes nested hashes and arrays as json and extract File objects from them
|
||||
# to the top level. Top-level File objects are handled by httpclient.
|
||||
# More details: https://core.telegram.org/bots/api#sending-files
|
||||
module RequestBodyFormatter
|
||||
extend self
|
||||
|
||||
def format(body, action)
|
||||
body = body.dup
|
||||
case action.to_s
|
||||
when 'sendMediaGroup'
|
||||
extract_files_from_array!(body, :media)
|
||||
when 'editMessageMedia'
|
||||
replace_field(body, :media) do |value|
|
||||
files = {}
|
||||
extract_files_from_hash(value, files).tap { body.merge!(files) }
|
||||
end
|
||||
end
|
||||
body.each do |key, val|
|
||||
body[key] = val.to_json if val.is_a?(Hash) || val.is_a?(Array)
|
||||
end
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
# Detects field by symbol or string name and replaces it with mapped value.
|
||||
def replace_field(hash, field_name)
|
||||
field_name = [field_name.to_sym, field_name.to_s].find { |x| hash.key?(x) }
|
||||
hash[field_name] = yield hash[field_name] if field_name
|
||||
end
|
||||
|
||||
def extract_files_from_array!(hash, field_name)
|
||||
replace_field(hash, field_name) do |value|
|
||||
break value unless value.is_a?(Array)
|
||||
files = {}
|
||||
value.map { |x| extract_files_from_hash(x, files) }.
|
||||
tap { hash.merge!(files) }
|
||||
end
|
||||
end
|
||||
|
||||
# Replace File objects with `attach` URIs. File objects are added into `files` hash.
|
||||
def extract_files_from_hash(hash, files)
|
||||
return hash unless hash.is_a?(Hash)
|
||||
hash.transform_values do |value|
|
||||
if value.is_a?(File)
|
||||
arg_name = "_file#{files.size}"
|
||||
files[arg_name] = value
|
||||
"attach://#{arg_name}"
|
||||
else
|
||||
value
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/client/api_helper'
|
||||
require 'active_support/core_ext/string/inflections'
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
# Stubbed client for tests. Saves all requests into #requests hash.
|
||||
@@ -17,7 +19,7 @@ module Telegram
|
||||
class << self
|
||||
# Any call to Client.new will return ClientStub instance when `enabled` is true.
|
||||
# Can be used with a block.
|
||||
def stub_all!(enabled = true)
|
||||
def stub_all!(enabled = true) # rubocop:disable Style/OptionalBooleanParameter
|
||||
Client.extend(StubbedConstructor) unless Client < StubbedConstructor
|
||||
return @_stub_all = enabled unless block_given?
|
||||
begin
|
||||
@@ -34,7 +36,7 @@ module Telegram
|
||||
end
|
||||
end
|
||||
|
||||
def initialize(token = nil, username = nil, **options)
|
||||
def initialize(token = nil, username = nil, **options) # rubocop:disable Lint/MissingSuper
|
||||
@token = token || options[:token]
|
||||
@username = username || options[:username] || token
|
||||
reset
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'active_support/core_ext/hash/keys'
|
||||
require 'active_support/core_ext/hash/indifferent_access'
|
||||
|
||||
@@ -44,7 +46,7 @@ module Telegram
|
||||
# from `secrets.yml` merging `telegram['bot']` at `:default` key.
|
||||
#
|
||||
# Can be overwritten with .bots_config=
|
||||
def bots_config
|
||||
def bots_config # rubocop:disable Metrics/PerceivedComplexity
|
||||
@bots_config ||=
|
||||
if defined?(Rails.application)
|
||||
app = Rails.application
|
||||
|
||||
@@ -1,7 +1,9 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
module DebugClient
|
||||
def debug!(dev = STDOUT)
|
||||
def debug!(dev = $stdout)
|
||||
if block_given?
|
||||
begin
|
||||
old_dev = client.debug_dev
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'active_support/concern'
|
||||
require 'active_support/core_ext/hash/indifferent_access'
|
||||
require 'active_support/json'
|
||||
@@ -16,12 +18,12 @@ module Telegram
|
||||
def call(env)
|
||||
request = ActionDispatch::Request.new(env)
|
||||
update = request.request_parameters
|
||||
controller.dispatch(bot, update)
|
||||
controller.dispatch(bot, update, request)
|
||||
[200, {}, ['']]
|
||||
end
|
||||
|
||||
def inspect
|
||||
"#<#{self.class.name}(#{controller.try!(:name)})>"
|
||||
"#<#{self.class.name}(#{controller&.name})>"
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/routes_helper'
|
||||
|
||||
module Telegram
|
||||
@@ -10,7 +12,7 @@ module Telegram
|
||||
end
|
||||
|
||||
config.before_initialize do
|
||||
::ActionDispatch::Routing::Mapper.send(:include, RoutesHelper)
|
||||
::ActionDispatch::Routing::Mapper.include RoutesHelper
|
||||
end
|
||||
|
||||
initializer 'telegram.bot.updates_controller.set_config' do |app|
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'base64'
|
||||
require 'openssl'
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
module RSpec
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec'
|
||||
require 'telegram/bot/rspec/message_helpers'
|
||||
|
||||
@@ -7,7 +9,7 @@ RSpec.shared_context 'telegram/bot/callback_query' do
|
||||
|
||||
subject { -> { dispatch callback_query: payload } }
|
||||
let(:payload) { {id: callback_query_id, from: from, message: message, data: data} }
|
||||
let(:callback_query_id) { 11 }
|
||||
let(:callback_query_id) { '11' }
|
||||
let(:message_id) { 22 }
|
||||
let(:message) { {message_id: message_id, chat: chat, text: 'message text'} }
|
||||
let(:data) { raise '`let(:data) { "callback query data here" }` is required' }
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
module RSpec
|
||||
@@ -61,14 +63,14 @@ module Telegram
|
||||
|
||||
attr_reader :performed_requests, :description
|
||||
|
||||
def initialize(bot, action, description: nil)
|
||||
def initialize(bot, action, description: nil) # rubocop:disable Lint/MissingSuper
|
||||
@bot = bot
|
||||
@action = action
|
||||
@description = description || "make #{action} telegram request"
|
||||
exactly(1)
|
||||
end
|
||||
|
||||
def matches?(proc) # rubocop:disable AbcSize
|
||||
def matches?(proc) # rubocop:disable Metrics/AbcSize
|
||||
raise ArgumentError, 'matcher only supports block expectations' unless proc.is_a?(Proc)
|
||||
original_requests_count = bot.requests[action].count
|
||||
proc.call
|
||||
@@ -115,15 +117,15 @@ module Telegram
|
||||
:arg_list_matcher, :matching_requests_count
|
||||
|
||||
def base_message
|
||||
"make #{expectation_type.to_s.tr('_', ' ')} #{expected_number} " \
|
||||
"#{bot.inspect}.#{action} requests,".tap do |msg|
|
||||
msg << " with #{arg_list_matcher}," if arg_list_matcher
|
||||
msg << " but made #{matching_requests_count}"
|
||||
if performed_requests
|
||||
actual_args = performed_requests.map(&:inspect).join(', ')
|
||||
msg << ", and #{performed_requests.count} with #{actual_args}"
|
||||
end
|
||||
msg = "make #{expectation_type.to_s.tr('_', ' ')} #{expected_number} " \
|
||||
"#{bot.inspect}.#{action} requests,"
|
||||
msg += " with #{arg_list_matcher}," if arg_list_matcher
|
||||
msg += " but made #{matching_requests_count}"
|
||||
if performed_requests
|
||||
actual_args = performed_requests.map(&:inspect).join(', ')
|
||||
msg += ", and #{performed_requests.count} with #{actual_args}"
|
||||
end
|
||||
msg
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec/integration/shared'
|
||||
|
||||
RSpec.shared_context 'telegram/bot/integration/poller' do
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec/integration/shared'
|
||||
require 'rack/test'
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec/integration/shared'
|
||||
|
||||
RSpec.shared_context 'telegram/bot/integration/rails', type: :request do
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'active_support/json'
|
||||
require 'telegram/bot'
|
||||
require 'telegram/bot/rspec/message_helpers'
|
||||
@@ -10,5 +12,5 @@ RSpec.shared_context 'telegram/bot/integration/shared' do
|
||||
|
||||
let(:bot) { Telegram.bot }
|
||||
let(:clear_session?) { described_class.respond_to?(:session_store) }
|
||||
before { described_class.session_store.try!(:clear) if clear_session? }
|
||||
before { described_class.session_store&.clear if clear_session? }
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
# Shared helpers for testing message updates.
|
||||
RSpec.shared_context 'telegram/bot/message_helpers' do
|
||||
let(:default_message_options) { {from: from, chat: chat} }
|
||||
|
||||
@@ -7,7 +7,7 @@ module Telegram
|
||||
|
||||
def set_webhook
|
||||
routes = Rails.application.routes.url_helpers
|
||||
cert_file = ENV['CERT']
|
||||
cert_file = ENV.fetch('CERT', nil)
|
||||
cert = File.open(cert_file) if cert_file
|
||||
each_bot do |key, bot|
|
||||
route_name = RoutesHelper.route_name_for_bot(bot)
|
||||
@@ -16,7 +16,7 @@ module Telegram
|
||||
bot.set_webhook(
|
||||
url: url,
|
||||
certificate: cert,
|
||||
ip_address: ENV['IP_ADDRESS'],
|
||||
ip_address: ENV.fetch('IP_ADDRESS', nil),
|
||||
drop_pending_updates: drop_pending_updates,
|
||||
)
|
||||
end
|
||||
@@ -50,13 +50,13 @@ module Telegram
|
||||
end
|
||||
|
||||
def each_bot(&block)
|
||||
id = ENV['BOT'].try!(:to_sym)
|
||||
id = ENV['BOT']&.to_sym
|
||||
bots = id ? {id => Client.by_id(id)} : Telegram.bots
|
||||
bots.each { |key, bot| bot.async(false) { block[key, bot] } }
|
||||
end
|
||||
|
||||
def drop_pending_updates
|
||||
ENV['DROP_PENDING_UPDATES'].try!(:downcase) == 'true'
|
||||
ENV['DROP_PENDING_UPDATES']&.downcase == 'true'
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'abstract_controller'
|
||||
require 'active_support/core_ext/string/inflections'
|
||||
require 'active_support/callbacks'
|
||||
@@ -47,7 +49,7 @@ module Telegram
|
||||
# ControllerClass.new(bot, from: telegram_user, chat: telegram_chat).
|
||||
# process(:help, *args)
|
||||
#
|
||||
class UpdatesController < AbstractController::Base # rubocop:disable ClassLength
|
||||
class UpdatesController < AbstractController::Base # rubocop:disable Metrics/ClassLength
|
||||
abstract!
|
||||
|
||||
%w[
|
||||
@@ -69,12 +71,12 @@ module Telegram
|
||||
include AbstractController::Callbacks
|
||||
# Redefine callbacks with default terminator.
|
||||
if ActiveSupport::VERSION::MAJOR >= 5
|
||||
define_callbacks :process_action,
|
||||
skip_after_callbacks_if_terminated: true
|
||||
define_callbacks :process_action,
|
||||
skip_after_callbacks_if_terminated: true
|
||||
else
|
||||
define_callbacks :process_action,
|
||||
terminator: ->(_, result) { result == false },
|
||||
skip_after_callbacks_if_terminated: true
|
||||
define_callbacks :process_action,
|
||||
terminator: ->(_, result) { result == false },
|
||||
skip_after_callbacks_if_terminated: true
|
||||
end
|
||||
|
||||
include Commands
|
||||
@@ -87,19 +89,13 @@ module Telegram
|
||||
|
||||
extend Session::ConfigMethods
|
||||
|
||||
PAYLOAD_TYPES = %w[
|
||||
message
|
||||
edited_message
|
||||
channel_post
|
||||
edited_channel_post
|
||||
inline_query
|
||||
chosen_inline_result
|
||||
callback_query
|
||||
shipping_query
|
||||
pre_checkout_query
|
||||
poll
|
||||
poll_answer
|
||||
].freeze
|
||||
PAYLOAD_TYPES_FILE = File.expand_path('updates_controller/payload_types.txt', __dir__)
|
||||
PAYLOAD_TYPES = File.read(PAYLOAD_TYPES_FILE).
|
||||
lines.
|
||||
map(&:strip).
|
||||
reject { |x| x.empty? || x.start_with?('#') }.
|
||||
to_set.
|
||||
freeze
|
||||
|
||||
class << self
|
||||
# Initialize controller and process update.
|
||||
@@ -108,41 +104,63 @@ module Telegram
|
||||
end
|
||||
|
||||
def payload_from_update(update)
|
||||
update && PAYLOAD_TYPES.find do |type|
|
||||
item = update[type]
|
||||
return [item, type] if item
|
||||
case update
|
||||
when nil then nil
|
||||
when Hash
|
||||
# faster lookup for the case when telegram-bot-types is not used
|
||||
update.find do |type, item|
|
||||
return [item, type] if PAYLOAD_TYPES.include?(type)
|
||||
end
|
||||
else
|
||||
payload_from_typed_update(update)
|
||||
end
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
def payload_from_typed_update(update)
|
||||
PAYLOAD_TYPES.find do |type|
|
||||
begin
|
||||
item = update[type]
|
||||
return [item, type] if item
|
||||
rescue Exception # rubocop:disable Lint/RescueException
|
||||
# dry-rb raises exception if field is not defined in schema
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
attr_internal_reader :update, :bot, :payload, :payload_type
|
||||
attr_internal_reader :bot, :payload, :payload_type, :update, :webhook_request
|
||||
delegate :username, to: :bot, prefix: true, allow_nil: true
|
||||
|
||||
# Second argument can be either update object with hash access & string
|
||||
# `update` can be either update object with hash access & string
|
||||
# keys or Hash with `:from` or `:chat` to override this values and assume
|
||||
# that update is nil.
|
||||
def initialize(bot = nil, update = nil)
|
||||
# ActionDispatch::Request object is passed in `webhook_request` when bot running
|
||||
# in webhook mode.
|
||||
def initialize(bot = nil, update = nil, webhook_request = nil) # rubocop:disable Lint/MissingSuper
|
||||
if update.is_a?(Hash) && (update.key?(:from) || update.key?(:chat))
|
||||
options = update
|
||||
update = nil
|
||||
end
|
||||
@_update = update
|
||||
@_bot = bot
|
||||
@_chat, @_from = options && options.values_at(:chat, :from)
|
||||
@_update = update
|
||||
@_chat, @_from = options&.values_at(:chat, :from)
|
||||
@_payload, @_payload_type = self.class.payload_from_update(update)
|
||||
@_webhook_request = webhook_request
|
||||
end
|
||||
|
||||
# Accessor to `'chat'` field of payload. Also tries `'chat'` in `'message'`
|
||||
# when there is no such field in payload.
|
||||
#
|
||||
# Can be overriden with `chat` option for #initialize.
|
||||
def chat
|
||||
@_chat ||=
|
||||
def chat # rubocop:disable Metrics/PerceivedComplexity
|
||||
@_chat ||= # rubocop:disable Naming/MemoizedInstanceVariableName
|
||||
if payload
|
||||
if payload.is_a?(Hash)
|
||||
payload['chat'] || payload['message'] && payload['message']['chat']
|
||||
payload['chat'] || (payload['message'] && payload['message']['chat'])
|
||||
else
|
||||
payload.try(:chat) || payload.try(:message).try!(:chat)
|
||||
payload.try(:chat) || payload.try(:message)&.chat
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -150,7 +168,8 @@ module Telegram
|
||||
# Accessor to `'from'` field of payload. Can be overriden with `from` option
|
||||
# for #initialize.
|
||||
def from
|
||||
@_from ||= payload.is_a?(Hash) ? payload['from'] : payload.try(:from)
|
||||
@_from ||= # rubocop:disable Naming/MemoizedInstanceVariableName
|
||||
payload.is_a?(Hash) ? payload['from'] : payload.try(:from)
|
||||
end
|
||||
|
||||
# Processes current update.
|
||||
@@ -215,7 +234,7 @@ module Telegram
|
||||
# Silently ignore unsupported messages to not fail when user crafts
|
||||
# an update with usupported command, callback query context, etc.
|
||||
def action_missing(action, *_args)
|
||||
logger.debug { "The action '#{action}' is not defined in #{self.class.name}" } if logger
|
||||
logger&.debug { "The action '#{action}' is not defined in #{self.class.name}" }
|
||||
nil
|
||||
end
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class UpdatesController
|
||||
|
||||
@@ -1,9 +1,11 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class UpdatesController
|
||||
# Support for parsing commands
|
||||
module Commands
|
||||
CMD_REGEX = %r{\A/([a-z\d_]{,31})(@(\S+))?(\s|$)}i
|
||||
CMD_REGEX = %r{\A/([a-z\d_]{,31})(@(\S+))?(\s|$)}i.freeze
|
||||
|
||||
class << self
|
||||
# Fetches command from text message. All subsequent words are returned
|
||||
@@ -34,7 +36,7 @@ module Telegram
|
||||
def action_for_message
|
||||
cmd, args = Commands.command_from_text(payload['text'], bot_username)
|
||||
return unless cmd
|
||||
[[action_for_command(cmd), type: :command, command: cmd], args]
|
||||
[[action_for_command(cmd), {type: :command, command: cmd}], args]
|
||||
end
|
||||
|
||||
alias_method :action_for_channel_post, :action_for_message
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class UpdatesController
|
||||
@@ -23,8 +25,8 @@ module Telegram
|
||||
def process_action(*args)
|
||||
raw_payload = {
|
||||
controller: self.class.name,
|
||||
action: action_name,
|
||||
update: update,
|
||||
action: action_name,
|
||||
update: update,
|
||||
}
|
||||
Instrumentation.instrument(:start_processing, raw_payload.dup)
|
||||
Instrumentation.instrument(:process_action, raw_payload) do |payload|
|
||||
@@ -61,14 +63,14 @@ module Telegram
|
||||
# end
|
||||
#
|
||||
# :api: plugin
|
||||
def cleanup_view_runtime #:nodoc:
|
||||
def cleanup_view_runtime # :nodoc:
|
||||
yield
|
||||
end
|
||||
|
||||
# Every time after an action is processed, this method is invoked
|
||||
# with the payload, so you can add more information.
|
||||
# :api: plugin
|
||||
def append_info_to_payload(_payload) #:nodoc:
|
||||
def append_info_to_payload(_payload) # :nodoc:
|
||||
end
|
||||
|
||||
module ClassMethods
|
||||
@@ -76,7 +78,7 @@ module Telegram
|
||||
# controller process action. This method should return an array
|
||||
# with the messages to be added.
|
||||
# :api: plugin
|
||||
def log_process_action(_payload) #:nodoc:
|
||||
def log_process_action(_payload) # :nodoc:
|
||||
[]
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'active_support/log_subscriber'
|
||||
|
||||
module Telegram
|
||||
@@ -8,7 +10,7 @@ module Telegram
|
||||
info do
|
||||
payload = event.payload
|
||||
"Processing by #{payload[:controller]}##{payload[:action]}\n" \
|
||||
" Update: #{payload[:update].to_json}"
|
||||
" Update: #{payload[:update].to_json}"
|
||||
end
|
||||
end
|
||||
|
||||
@@ -17,7 +19,7 @@ module Telegram
|
||||
payload = event.payload
|
||||
additions = UpdatesController.log_process_action(payload)
|
||||
message = "Completed in #{event.duration.round}ms"
|
||||
message << " (#{additions.join(' | ')})" if additions.present?
|
||||
message += " (#{additions.join(' | ')})" if additions.present?
|
||||
message
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class UpdatesController
|
||||
@@ -11,7 +13,7 @@ module Telegram
|
||||
# respond_with :message, text: 'Where are you?'
|
||||
# end
|
||||
#
|
||||
# def set_location_from_messge(city = nil, *)
|
||||
# def set_location_from_message(city = nil, *)
|
||||
# # update
|
||||
# end
|
||||
#
|
||||
@@ -48,12 +50,12 @@ module Telegram
|
||||
# it has higher priority than contextual action.
|
||||
def action_for_message
|
||||
val = message_context_session.delete(:context)
|
||||
context = val && val.to_s
|
||||
super || context && begin
|
||||
args = payload['text'].try!(:split) || []
|
||||
context = val&.to_s
|
||||
super || (context && begin
|
||||
args = payload['text']&.split || []
|
||||
action = action_for_message_context(context)
|
||||
[[action, type: :message_context, context: context], args]
|
||||
end
|
||||
[[action, {type: :message_context, context: context}], args]
|
||||
end)
|
||||
end
|
||||
|
||||
# Save context for the next request.
|
||||
|
||||
25
lib/telegram/bot/updates_controller/payload_types.txt
Обычный файл
25
lib/telegram/bot/updates_controller/payload_types.txt
Обычный файл
@@ -0,0 +1,25 @@
|
||||
# Generated with bin/fetch-telegram-methods
|
||||
# Bot API 8.2
|
||||
message
|
||||
edited_message
|
||||
channel_post
|
||||
edited_channel_post
|
||||
business_connection
|
||||
business_message
|
||||
edited_business_message
|
||||
deleted_business_messages
|
||||
message_reaction
|
||||
message_reaction_count
|
||||
inline_query
|
||||
chosen_inline_result
|
||||
callback_query
|
||||
shipping_query
|
||||
pre_checkout_query
|
||||
purchased_paid_media
|
||||
poll
|
||||
poll_answer
|
||||
my_chat_member
|
||||
chat_member
|
||||
chat_join_request
|
||||
chat_boost
|
||||
removed_chat_boost
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class UpdatesController
|
||||
@@ -59,9 +61,9 @@ module Telegram
|
||||
# Edit message from callback query.
|
||||
def edit_message(type, params = {})
|
||||
params =
|
||||
if message_id = payload['inline_message_id'] # rubocop:disable AssignmentInCondition
|
||||
if message_id = payload['inline_message_id'] # rubocop:disable Lint/AssignmentInCondition
|
||||
params.merge(inline_message_id: message_id)
|
||||
elsif message = payload['message'] # rubocop:disable AssignmentInCondition
|
||||
elsif message = payload['message'] # rubocop:disable Lint/AssignmentInCondition
|
||||
params.merge(chat_id: message['chat']['id'], message_id: message['message_id'])
|
||||
else
|
||||
raise 'Can not edit message without `inline_message_id` or `message`'
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'active_support/rescuable'
|
||||
|
||||
module Telegram
|
||||
@@ -11,7 +13,7 @@ module Telegram
|
||||
|
||||
def process_action(*)
|
||||
super
|
||||
rescue Exception => exception # rubocop:disable RescueException
|
||||
rescue Exception => exception # rubocop:disable Lint/RescueException
|
||||
rescue_with_handler(exception) || raise
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/updates_controller/testing'
|
||||
require 'telegram/bot/rspec/message_helpers'
|
||||
require 'telegram/bot/rspec/callback_query_helpers'
|
||||
@@ -13,8 +15,9 @@ RSpec.shared_context 'telegram/bot/updates_controller' do
|
||||
x.extend Telegram::Bot::UpdatesController::Testing
|
||||
end
|
||||
end
|
||||
let(:controller_args) { [bot, deep_stringify(update)] }
|
||||
let(:controller_args) { [bot, deep_stringify(update), webhook_request] }
|
||||
let(:update) { {payload_type => payload} }
|
||||
let(:webhook_request) { nil }
|
||||
let(:payload_type) { :some_type }
|
||||
let(:payload) { double(:payload) }
|
||||
let(:bot) { Telegram::Bot::ClientStub.new(bot_name) }
|
||||
@@ -22,8 +25,8 @@ RSpec.shared_context 'telegram/bot/updates_controller' do
|
||||
let(:session) { controller.send(:session) }
|
||||
|
||||
# Process update.
|
||||
def dispatch(update = self.update, bot = self.bot)
|
||||
controller.dispatch_again(bot, deep_stringify(update))
|
||||
def dispatch(update = self.update, bot = self.bot, webhook_request = self.webhook_request)
|
||||
controller.dispatch_again(bot, deep_stringify(update), webhook_request)
|
||||
end
|
||||
|
||||
# Same as `.as_json` but mocks-friendly.
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'rack/session/abstract/id'
|
||||
require 'active_support/cache'
|
||||
|
||||
@@ -27,7 +29,8 @@ module Telegram
|
||||
protected
|
||||
|
||||
def session
|
||||
@_session ||= self.class.build_session(session_key)
|
||||
@_session ||= # rubocop:disable Naming/MemoizedInstanceVariableName
|
||||
self.class.build_session(session_key)
|
||||
end
|
||||
|
||||
def session_key
|
||||
@@ -41,7 +44,7 @@ module Telegram
|
||||
class SessionHash < Rack::Session::Abstract::SessionHash
|
||||
attr_reader :id
|
||||
|
||||
def initialize(store, id)
|
||||
def initialize(store, id) # rubocop:disable Lint/MissingSuper
|
||||
@store = store
|
||||
@id = id
|
||||
end
|
||||
@@ -65,13 +68,13 @@ module Telegram
|
||||
|
||||
def commit
|
||||
return unless loaded?
|
||||
data = to_hash.delete_if { |_, v| v.nil? }
|
||||
data = to_hash.compact
|
||||
@store.write(id, data)
|
||||
end
|
||||
end
|
||||
|
||||
class NullSessionHash < Session::SessionHash
|
||||
def initialize
|
||||
def initialize # rubocop:disable Lint/MissingSuper
|
||||
@data = {}
|
||||
@loaded = true
|
||||
@exists = true
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class UpdatesController
|
||||
@@ -5,9 +7,9 @@ module Telegram
|
||||
IVARS_TO_KEEP = %i[@_session].freeze
|
||||
|
||||
# Perform multiple dispatches on same instance.
|
||||
def dispatch_again(bot = nil, update = nil)
|
||||
def dispatch_again(bot = nil, update = nil, webhook_request = nil)
|
||||
recycle!
|
||||
initialize(bot, update)
|
||||
initialize(bot, update, webhook_request)
|
||||
dispatch
|
||||
end
|
||||
|
||||
@@ -16,7 +18,7 @@ module Telegram
|
||||
# everything will be rewriten with #initialize.
|
||||
#
|
||||
# With `full` set to `true` it'll clear all cached instance variables.
|
||||
def recycle!(full = false)
|
||||
def recycle!(full = false) # rubocop:disable Style/OptionalBooleanParameter
|
||||
return unless full
|
||||
(instance_variables - IVARS_TO_KEEP).each do |ivar|
|
||||
remove_instance_variable(ivar)
|
||||
@@ -27,7 +29,8 @@ module Telegram
|
||||
|
||||
# Stubs session.
|
||||
def session
|
||||
@_session ||= Session::NullSessionHash.new
|
||||
@_session ||= # rubocop:disable Naming/MemoizedInstanceVariableName
|
||||
Session::NullSessionHash.new
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class UpdatesController
|
||||
@@ -12,15 +14,15 @@ module Telegram
|
||||
|
||||
module ClassMethods
|
||||
# Class-level helper for lazy translations.
|
||||
def translate(key, options = {})
|
||||
def translate(key, **options)
|
||||
key = "#{controller_path.tr('/', '.')}#{key}" if key.to_s.start_with?('.')
|
||||
I18n.translate(key, options)
|
||||
I18n.translate(key, **options)
|
||||
end
|
||||
alias :t :translate
|
||||
end
|
||||
|
||||
# See toplevel description.
|
||||
def translate(key, options = {})
|
||||
def translate(key, **options)
|
||||
if key.to_s.start_with?('.')
|
||||
path = controller_path.tr('/', '.')
|
||||
defaults = [:"#{path}#{key}"]
|
||||
@@ -28,7 +30,7 @@ module Telegram
|
||||
options[:default] = defaults.flatten
|
||||
key = "#{path}.#{action_name_i18n_key}#{key}"
|
||||
end
|
||||
I18n.translate(key, options)
|
||||
I18n.translate(key, **options)
|
||||
end
|
||||
alias :t :translate
|
||||
|
||||
|
||||
@@ -1,10 +1,12 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
class UpdatesController
|
||||
# Include this module to type cast update to Virtus model
|
||||
# using `telegram-bot-types` gem (install this gem first).
|
||||
module TypedUpdate
|
||||
def initialize(bot = nil, update = nil)
|
||||
def initialize(bot = nil, update = nil, webhook_request = nil)
|
||||
update = Types::Update.new(update) if update && !update.is_a?(Types::Update)
|
||||
super
|
||||
end
|
||||
|
||||
@@ -1,9 +1,11 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
# Supposed to be used in development environments only.
|
||||
class UpdatesPoller
|
||||
class << self
|
||||
@@instances = {} # rubocop:disable ClassVars
|
||||
@@instances = {} # rubocop:disable Style/ClassVars
|
||||
|
||||
def instances
|
||||
@@instances
|
||||
@@ -36,7 +38,7 @@ module Telegram
|
||||
end
|
||||
|
||||
def log(&block)
|
||||
logger.info(&block) if logger
|
||||
logger&.info(&block)
|
||||
end
|
||||
|
||||
def start
|
||||
@@ -56,7 +58,7 @@ module Telegram
|
||||
def run
|
||||
while running
|
||||
updates = fetch_updates
|
||||
process_updates(updates) if updates && updates.any?
|
||||
process_updates(updates) if updates&.any?
|
||||
end
|
||||
end
|
||||
|
||||
@@ -82,8 +84,8 @@ module Telegram
|
||||
process_update(update)
|
||||
end
|
||||
end
|
||||
rescue StandardError => e
|
||||
logger.error { ([e.message] + e.backtrace).join("\n") } if logger
|
||||
rescue StandardError => exception
|
||||
logger&.error { ([exception.message] + exception.backtrace).join("\n") }
|
||||
end
|
||||
|
||||
# Override this method to setup custom error collector.
|
||||
@@ -102,10 +104,8 @@ module Telegram
|
||||
end
|
||||
|
||||
if defined?(Rails.application) && Rails.application.respond_to?(:reloader)
|
||||
def reloading_code
|
||||
Rails.application.reloader.wrap do
|
||||
yield
|
||||
end
|
||||
def reloading_code(&block)
|
||||
Rails.application.reloader.wrap(&block)
|
||||
end
|
||||
else
|
||||
def reloading_code
|
||||
|
||||
@@ -1,6 +1,8 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
module Telegram
|
||||
module Bot
|
||||
VERSION = '0.15.2'.freeze
|
||||
VERSION = '0.16.7'
|
||||
|
||||
def self.gem_version
|
||||
Gem::Version.new VERSION
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'integration_helper'
|
||||
|
||||
RSpec.describe DefaultBotController, telegram_bot: :rails do
|
||||
@@ -10,4 +12,13 @@ RSpec.describe DefaultBotController, telegram_bot: :rails do
|
||||
subject { -> { dispatch_command :load_session } }
|
||||
it { should_not raise_error }
|
||||
end
|
||||
|
||||
describe '#dispatch' do
|
||||
it 'provides webhook_request' do
|
||||
expect(described_class).to receive(:dispatch).
|
||||
with(bot, hash_including('message'), instance_of(ActionDispatch::Request)).
|
||||
and_call_original
|
||||
dispatch_message :test
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'integration_helper'
|
||||
|
||||
RSpec.describe NamedBotController, telegram_bot: :rails do
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'integration_helper'
|
||||
|
||||
RSpec.describe OtherBotController, telegram_bot: :rails do
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec/integration/rails'
|
||||
require 'action_controller'
|
||||
require 'action_dispatch'
|
||||
@@ -13,7 +15,12 @@ ENV['RAILS_ENV'] = 'test'
|
||||
class TestApplication < Rails::Application
|
||||
config.eager_load = false
|
||||
config.log_level = :debug
|
||||
config.action_dispatch.show_exceptions = false
|
||||
if (ActionPack::VERSION::MAJOR >= 8) ||
|
||||
(ActionPack::VERSION::MAJOR == 7 && ActionPack::VERSION::MINOR >= 2)
|
||||
config.action_dispatch.show_exceptions = :none
|
||||
else
|
||||
config.action_dispatch.show_exceptions = false
|
||||
end
|
||||
routes.default_url_options = {host: 'test.rpsec'}
|
||||
|
||||
telegram_config = {
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'pathname'
|
||||
require 'pry'
|
||||
require 'debug'
|
||||
require 'rspec/its'
|
||||
|
||||
if ENV['CI']
|
||||
@@ -10,7 +12,7 @@ elsif ENV.key?('COV')
|
||||
SimpleCov.start
|
||||
end
|
||||
|
||||
GEM_ROOT = Pathname.new File.expand_path('../..', __FILE__)
|
||||
GEM_ROOT = Pathname.new File.expand_path('..', __dir__)
|
||||
|
||||
$LOAD_PATH.unshift GEM_ROOT.join('lib')
|
||||
require 'telegram/bot'
|
||||
@@ -18,7 +20,7 @@ require 'telegram/bot/updates_controller/rspec_helpers'
|
||||
require 'telegram/bot/types'
|
||||
require 'active_support/json'
|
||||
|
||||
Dir[GEM_ROOT.join('spec/support/**/*.rb')].each { |f| require f }
|
||||
Dir[GEM_ROOT.join('spec/support/**/*.rb')].sort.each { |f| require f }
|
||||
|
||||
RSpec.configure do |config|
|
||||
config.expect_with :rspec do |expectations|
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.shared_examples 'async' do |request_args:|
|
||||
let(:instance) { described_class.new(token: token, id: id, async: async) }
|
||||
let(:id) { :default_bot }
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.shared_examples 'shared integration examples' do
|
||||
let(:bot) { Telegram::Bot::ClientStub.new('token') }
|
||||
let(:controller_class) do
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::Async::Job do
|
||||
let(:job_class) do
|
||||
described_class = self.described_class
|
||||
|
||||
94
spec/telegram/bot/client/request_body_formatter_spec.rb
Обычный файл
94
spec/telegram/bot/client/request_body_formatter_spec.rb
Обычный файл
@@ -0,0 +1,94 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::Client::RequestBodyFormatter do
|
||||
describe '.format' do
|
||||
subject { described_class.format(input, action) }
|
||||
let(:action) { :sendMessage }
|
||||
|
||||
context 'when plain hash is given' do
|
||||
let(:input) { {a: 1, b: '2', c: nil} }
|
||||
it { should eq input }
|
||||
end
|
||||
|
||||
context 'when nested hash is given' do
|
||||
let(:input) { {a: 1, b: '2', c: [1, 2], d: {a: 1}, e: {b: []}} }
|
||||
|
||||
it 'encodes nested hashes to json' do
|
||||
expected = input.dup
|
||||
%i[c d e].each { |x| expected[x] = expected[x].to_json }
|
||||
should eq expected
|
||||
end
|
||||
end
|
||||
|
||||
context 'with sendMediaGroup action' do
|
||||
let(:action) { :sendMediaGroup }
|
||||
let(:input) { {media: [{a: file_1}, {'b' => file_2, c: 123}, {d: 456}], x: 789} }
|
||||
let(:file_1) { File.new(__FILE__) }
|
||||
let(:file_2) { File.new(__FILE__) }
|
||||
|
||||
it 'extracts files to the top-level' do
|
||||
should eq(
|
||||
media: [
|
||||
{a: 'attach://_file0'},
|
||||
{b: 'attach://_file1', c: 123},
|
||||
{d: 456},
|
||||
].to_json,
|
||||
x: 789,
|
||||
'_file0' => file_1,
|
||||
'_file1' => file_2,
|
||||
)
|
||||
end
|
||||
|
||||
context 'and input has string keys' do
|
||||
let(:input) { super().stringify_keys }
|
||||
it 'extracts files to the top-level' do
|
||||
should eq(
|
||||
'media' => [
|
||||
{a: 'attach://_file0'},
|
||||
{b: 'attach://_file1', c: 123},
|
||||
{d: 456},
|
||||
].to_json,
|
||||
'x' => 789,
|
||||
'_file0' => file_1,
|
||||
'_file1' => file_2,
|
||||
)
|
||||
end
|
||||
end
|
||||
|
||||
context 'without media' do
|
||||
let(:input) { {a: 1, b: '2', c: nil} }
|
||||
it { should eq input }
|
||||
end
|
||||
end
|
||||
|
||||
context 'with editMessageMedia action' do
|
||||
let(:action) { :editMessageMedia }
|
||||
let(:input) { {media: {a: file, b: 123}, x: 789} }
|
||||
let(:file) { File.new(__FILE__) }
|
||||
|
||||
it 'extracts files to the top-level' do
|
||||
should eq(
|
||||
media: {a: 'attach://_file0', b: 123}.to_json,
|
||||
x: 789,
|
||||
'_file0' => file,
|
||||
)
|
||||
end
|
||||
|
||||
context 'and input has string keys' do
|
||||
let(:input) { super().stringify_keys }
|
||||
it 'extracts files to the top-level' do
|
||||
should eq(
|
||||
'media' => {a: 'attach://_file0', b: 123}.to_json,
|
||||
'x' => 789,
|
||||
'_file0' => file,
|
||||
)
|
||||
end
|
||||
end
|
||||
|
||||
context 'without media' do
|
||||
let(:input) { {a: 1, b: '2', c: nil} }
|
||||
it { should eq input }
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::Client::TypedResponse do
|
||||
let(:bot) { Telegram::Bot::Client.new('token').tap { |x| x.extend described_class } }
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::Client do
|
||||
let(:instance) { described_class.new 'token' }
|
||||
let(:token) { 'token' }
|
||||
@@ -71,29 +73,10 @@ RSpec.describe Telegram::Bot::Client do
|
||||
end
|
||||
end
|
||||
|
||||
describe '.prepare_body' do
|
||||
subject { described_class.prepare_body(input) }
|
||||
|
||||
context 'when plain hash is given' do
|
||||
let(:input) { {a: 1, b: '2', c: nil} }
|
||||
it { should eq input }
|
||||
end
|
||||
|
||||
context 'when nested hash is given' do
|
||||
let(:input) { {a: 1, b: '2', c: [1, 2], d: {a: 1}, e: {b: []}} }
|
||||
|
||||
it 'encodes nested hashes to json' do
|
||||
expected = input.dup
|
||||
%i[c d e].each { |x| expected[x] = expected[x].to_json }
|
||||
should eq expected
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
describe '.prepare_async_args' do
|
||||
subject { described_class.prepare_async_args(*input) }
|
||||
let(:input) { [:action, a: 1, b: :sym, c: [:other], 'd' => 'str'] }
|
||||
it { should eq ['action', a: 1, b: 'sym', c: '["other"]', 'd' => 'str'] }
|
||||
let(:input) { [:action, {a: 1, b: :sym, c: [:other], 'd' => 'str'}] }
|
||||
it { should eq ['action', {a: 1, b: 'sym', c: '["other"]', 'd' => 'str'}] }
|
||||
end
|
||||
|
||||
describe '.new' do
|
||||
@@ -148,7 +131,8 @@ RSpec.describe Telegram::Bot::Client do
|
||||
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(Telegram::Bot::Client::RequestBodyFormatter).
|
||||
to receive(:format).with(request_body, action) { prepared_body }
|
||||
expect(instance).to receive(:http_request).with(url, prepared_body) { response }
|
||||
end
|
||||
around { |ex| Telegram::Bot::ClientStub.stub_all!(false) { ex.run } }
|
||||
|
||||
@@ -1,7 +1,9 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::ClientStub do
|
||||
describe '#stub_all!' do
|
||||
let(:client) { Telegram::Bot::Client.new('token', 'bot_name') }
|
||||
let(:clients) { ['token', token: 'token2'].map(&Telegram::Bot::Client.method(:wrap)) }
|
||||
let(:clients) { ['token', {token: 'token2'}].map(&Telegram::Bot::Client.method(:wrap)) }
|
||||
|
||||
shared_examples 'constructors' do |expected_class|
|
||||
it 'makes Client.new return ClientStub' do
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::ConfigMethods do
|
||||
let(:registry) do
|
||||
Object.new.tap do |x|
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'rack/mock'
|
||||
|
||||
RSpec.describe Telegram::Bot::Middleware do
|
||||
@@ -11,7 +13,7 @@ RSpec.describe Telegram::Bot::Middleware do
|
||||
let(:env) do
|
||||
Rack::MockRequest.env_for('/',
|
||||
method: :post,
|
||||
input: JSON.dump(update),
|
||||
input: JSON.dump(update),
|
||||
'CONTENT_TYPE' => 'application/json',
|
||||
)
|
||||
end
|
||||
@@ -24,7 +26,8 @@ RSpec.describe Telegram::Bot::Middleware do
|
||||
end
|
||||
|
||||
it 'calls dispatch on controller' do
|
||||
expect(controller).to receive(:dispatch).with(bot, update)
|
||||
expect(controller).to receive(:dispatch).
|
||||
with(bot, update, instance_of(ActionDispatch::Request))
|
||||
subject
|
||||
end
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/routes_helper'
|
||||
|
||||
RSpec.describe Telegram::Bot::RoutesHelper do
|
||||
@@ -46,7 +48,7 @@ RSpec.describe Telegram::Bot::RoutesHelper do
|
||||
let(:controller) { double(:controller, name: :controller) }
|
||||
before { allow(Telegram).to receive(:bots) { bots } }
|
||||
|
||||
def assert_route(bot, controller, path: nil, **expected_options) # rubocop:disable AbcSize
|
||||
def assert_route(bot, controller, path: nil, **expected_options) # rubocop:disable Metrics/AbcSize
|
||||
path ||= "telegram/#{described_class.token_hash(bot.token)}"
|
||||
expect(mapper).to receive(:post) do |actual_path, actual_options|
|
||||
expect(actual_path).to eq(path)
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec/integration/poller'
|
||||
|
||||
RSpec.describe 'Integration spec helpers', telegram_bot: :poller do
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::RSpec::ClientMatchers do
|
||||
let(:bot) { Telegram::Bot::ClientStub.new('TestBot') }
|
||||
let(:other_bot) { Telegram::Bot::ClientStub.new('OtherTestBot') }
|
||||
@@ -31,6 +33,9 @@ RSpec.describe Telegram::Bot::RSpec::ClientMatchers do
|
||||
args = {text: 'test', parseMode: :Markdown}
|
||||
block = ->(*) { bot.send_message(args) }
|
||||
expect(&block).to make_telegram_request(bot, :sendMessage).with(args)
|
||||
expect do
|
||||
expect(&block).to make_telegram_request(bot, :sendMessage).with(args.merge(extra: 1))
|
||||
end.to raise_error RSpec::Expectations::ExpectationNotMetError
|
||||
expect(&block).to_not make_telegram_request(bot, :sendMessage).with(args.except(:text))
|
||||
expect { 3.times(&block) }.to make_telegram_request(bot, :sendMessage).
|
||||
with(args).exactly(3).times
|
||||
|
||||
@@ -1,5 +1,16 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec/integration/poller'
|
||||
|
||||
RSpec.describe 'Poller integration spec', telegram_bot: :poller do
|
||||
include_examples 'shared integration examples'
|
||||
|
||||
describe '#dispatch' do
|
||||
it 'doesn`t provide webhook_request' do
|
||||
expect(controller_class).to receive(:dispatch).
|
||||
with(bot, hash_including('message')).
|
||||
and_call_original
|
||||
dispatch_message :test
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec/integration/rack'
|
||||
|
||||
RSpec.describe 'Rack integration spec', telegram_bot: :rack do
|
||||
@@ -17,4 +19,13 @@ RSpec.describe 'Rack integration spec', telegram_bot: :rack do
|
||||
ActionDispatch::ParamsParser.new(app)
|
||||
end
|
||||
end
|
||||
|
||||
describe '#dispatch' do
|
||||
it 'provides webhook_request' do
|
||||
expect(controller_class).to receive(:dispatch).
|
||||
with(bot, hash_including('message'), instance_of(ActionDispatch::Request)).
|
||||
and_call_original
|
||||
dispatch_message :test
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1 +1,2 @@
|
||||
# frozen_string_literal: true
|
||||
# Tested in spec/integration
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'telegram/bot/rspec/integration/poller'
|
||||
|
||||
RSpec.describe 'Integration: message helpers', telegram_bot: :poller do
|
||||
@@ -108,7 +110,7 @@ RSpec.describe 'Integration: message helpers', telegram_bot: :poller do
|
||||
end
|
||||
|
||||
context 'with options' do
|
||||
let(:args) { ['asd', 'qwe', option: 1] }
|
||||
let(:args) { ['asd', 'qwe', {option: 1}] }
|
||||
it { should respond_with_message "Start: #{args[0...-1].inspect}, option: 1" }
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::CallbackQueryContext do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
let(:controller_class) do
|
||||
@@ -6,7 +8,8 @@ RSpec.describe Telegram::Bot::UpdatesController::CallbackQueryContext do
|
||||
include described_class
|
||||
|
||||
attr_accessor :filter_done
|
||||
before_action only: :ctx2_callback_query do
|
||||
|
||||
before_action only: :ctx_2_callback_query do
|
||||
self.filter_done = true
|
||||
end
|
||||
|
||||
@@ -14,12 +17,12 @@ RSpec.describe Telegram::Bot::UpdatesController::CallbackQueryContext do
|
||||
[:no_context, data]
|
||||
end
|
||||
|
||||
def ctx1_callback_query(data)
|
||||
[:ctx1, data]
|
||||
def ctx_1_callback_query(data)
|
||||
[:ctx_1, data]
|
||||
end
|
||||
|
||||
def ctx2_callback_query(data)
|
||||
[:ctx2, data]
|
||||
def ctx_2_callback_query(data)
|
||||
[:ctx_2, data]
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -40,19 +43,19 @@ RSpec.describe Telegram::Bot::UpdatesController::CallbackQueryContext do
|
||||
let(:data) { "#{ctx}:#{text}" }
|
||||
|
||||
context 'and valid' do
|
||||
let(:ctx) { 'ctx1' }
|
||||
its(:call) { should eq [:ctx1, text] }
|
||||
let(:ctx) { 'ctx_1' }
|
||||
its(:call) { should eq [:ctx_1, text] }
|
||||
it { should_not change(controller, :filter_done) }
|
||||
|
||||
context 'and context has callback' do
|
||||
let(:ctx) { 'ctx2' }
|
||||
its(:call) { should eq [:ctx2, text] }
|
||||
let(:ctx) { 'ctx_2' }
|
||||
its(:call) { should eq [:ctx_2, text] }
|
||||
it { should change(controller, :filter_done) }
|
||||
end
|
||||
|
||||
context 'and data has multiple colons' do
|
||||
let(:text) { super().tr(' ', ':') }
|
||||
its(:call) { should eq [:ctx1, text] }
|
||||
its(:call) { should eq [:ctx_1, text] }
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::Commands do
|
||||
describe '#action_for_command' do
|
||||
subject { ->(*args) { object.action_for_command(*args) } }
|
||||
@@ -88,11 +90,11 @@ RSpec.describe Telegram::Bot::UpdatesController::Commands do
|
||||
context 'with command' do
|
||||
let(:text) { "/test#{"@#{mention}" if mention} arg 1 2" }
|
||||
let(:mention) {}
|
||||
it { should eq [['test!', type: :command, command: 'test'], %w[arg 1 2]] }
|
||||
it { should eq [['test!', {type: :command, command: 'test'}], %w[arg 1 2]] }
|
||||
|
||||
context 'with mention' do
|
||||
let(:mention) { bot.username }
|
||||
it { should eq [['test!', type: :command, command: 'test'], %w[arg 1 2]] }
|
||||
it { should eq [['test!', {type: :command, command: 'test'}], %w[arg 1 2]] }
|
||||
end
|
||||
|
||||
context 'with mention for other bot' do
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::Instrumentation do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::MessageContext do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
let(:controller_class) do
|
||||
@@ -6,11 +8,13 @@ RSpec.describe Telegram::Bot::UpdatesController::MessageContext do
|
||||
include described_class
|
||||
|
||||
attr_accessor :filter_done
|
||||
|
||||
before_action only: :context_with_filter do
|
||||
self.filter_done = true
|
||||
end
|
||||
|
||||
attr_reader :callbacks_runs
|
||||
|
||||
before_action { @callbacks_runs = (@callbacks_runs || 0) + 1 }
|
||||
|
||||
def message(*args)
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
let(:params) { {arg: 1, 'other_arg' => 2} }
|
||||
@@ -38,7 +40,7 @@ RSpec.describe Telegram::Bot::UpdatesController do
|
||||
end
|
||||
|
||||
context 'when update is not set' do
|
||||
let(:controller_args) { [bot, chat: deep_stringify(chat)] }
|
||||
let(:controller_args) { [bot, {chat: deep_stringify(chat)}] }
|
||||
it 'sets chat_id' do
|
||||
expect(bot).to receive("send_#{respond_type}").
|
||||
with(params.merge(chat_id: chat[:id])) { result }
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::Rescue do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::Session do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
let(:controller_class) do
|
||||
|
||||
@@ -1,3 +1,7 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
require 'action_dispatch'
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::Testing do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
let(:controller_class) do
|
||||
@@ -24,4 +28,27 @@ RSpec.describe Telegram::Bot::UpdatesController::Testing do
|
||||
it { should_not change { controller.send(:session)[:key] }.from 'sval' }
|
||||
end
|
||||
end
|
||||
|
||||
describe '#dispatch' do
|
||||
it 'doesn`t provide webhook_request' do
|
||||
dispatch
|
||||
expect(controller.webhook_request).to eq nil
|
||||
end
|
||||
|
||||
context 'when webhook_request is set' do
|
||||
let(:webhook_request) { ActionDispatch::Request.new({}) }
|
||||
it 'passes it to controller' do
|
||||
dispatch
|
||||
expect(controller.webhook_request).to eq webhook_request
|
||||
end
|
||||
end
|
||||
|
||||
context 'when webhook_request is given' do
|
||||
it 'passes it to controller' do
|
||||
webhook_request = ActionDispatch::Request.new({})
|
||||
dispatch(update, bot, webhook_request)
|
||||
expect(controller.webhook_request).to eq webhook_request
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,5 +1,28 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::Translation do
|
||||
def self.stub_translations(translations)
|
||||
around do |ex|
|
||||
backend = I18n.backend
|
||||
I18n.backend = I18n::Backend::Simple.new
|
||||
begin
|
||||
I18n.backend.store_translations 'en', telegram: {webhooks: translations}
|
||||
ex.run
|
||||
ensure
|
||||
I18n.backend = backend
|
||||
end
|
||||
end
|
||||
end
|
||||
let(:result) { double(:result) }
|
||||
|
||||
describe '#translate' do
|
||||
stub_translations(
|
||||
start: {
|
||||
hello: 'Hello from start!',
|
||||
hi: 'Hi %{name} from start', # rubocop:disable Style/FormatStringToken
|
||||
},
|
||||
)
|
||||
|
||||
let(:controller) do
|
||||
double(
|
||||
controller_path: 'telegram/webhooks',
|
||||
@@ -10,12 +33,28 @@ RSpec.describe Telegram::Bot::UpdatesController::Translation do
|
||||
it 'uses action_name without ! for lazy translations' do
|
||||
expect(I18n).to receive(:translate).with('telegram.webhooks.start.hello',
|
||||
default: [:'telegram.webhooks.hello'],
|
||||
)
|
||||
controller.t('.hello')
|
||||
) { result }
|
||||
expect(controller.t('.hello')).to eq(result)
|
||||
|
||||
expect(I18n).to receive(:translate).with('telegram.webhooks.start.hi',
|
||||
default: [:'telegram.webhooks.hi'],
|
||||
name: 'Dude',
|
||||
) { result }
|
||||
expect(controller.t('.hi', name: 'Dude')).to eq(result)
|
||||
end
|
||||
|
||||
it 'translates' do
|
||||
expect(controller.t('.hello')).to eq('Hello from start!')
|
||||
expect(controller.t('.hi', name: 'Dude')).to eq('Hi Dude from start')
|
||||
end
|
||||
end
|
||||
|
||||
describe described_class::ClassMethods do
|
||||
stub_translations(
|
||||
hello: 'Hello!',
|
||||
hi: 'Hi %{name}', # rubocop:disable Style/FormatStringToken
|
||||
)
|
||||
|
||||
describe '#translate' do
|
||||
let(:controller_class) do
|
||||
double(controller_path: 'telegram/webhooks').
|
||||
@@ -23,8 +62,20 @@ RSpec.describe Telegram::Bot::UpdatesController::Translation do
|
||||
end
|
||||
|
||||
it 'uses controller_path for lazy translations' do
|
||||
expect(I18n).to receive(:translate).with('telegram.webhooks.hello', {})
|
||||
controller_class.t('.hello')
|
||||
expect(I18n).to receive(:translate) do |*args, **kwargs|
|
||||
# not using .with to support ruby 2.x and 3.x
|
||||
expect([*args, kwargs]).to eq(['telegram.webhooks.hello', {}])
|
||||
result
|
||||
end
|
||||
expect(controller_class.t('.hello')).to eq(result)
|
||||
|
||||
expect(I18n).to receive(:translate).with('telegram.webhooks.hi', name: 'Dude') { result }
|
||||
expect(controller_class.t('.hi', name: 'Dude')).to eq(result)
|
||||
end
|
||||
|
||||
it 'translates' do
|
||||
expect(controller_class.t('.hello')).to eq('Hello!')
|
||||
expect(controller_class.t('.hi', name: 'Dude')).to eq('Hi Dude')
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController::TypedUpdate do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
let(:controller_class) do
|
||||
@@ -9,14 +11,32 @@ RSpec.describe Telegram::Bot::UpdatesController::TypedUpdate do
|
||||
|
||||
context 'when `update` is a virtus model' do
|
||||
subject { controller }
|
||||
unique_types = Telegram::Bot::UpdatesController::PAYLOAD_TYPES - %w[
|
||||
unique_types = (Telegram::Bot::UpdatesController::PAYLOAD_TYPES - %w[
|
||||
edited_message
|
||||
channel_post
|
||||
edited_channel_post
|
||||
]
|
||||
unique_types.each do |type|
|
||||
my_chat_member
|
||||
chat_member
|
||||
chat_join_request
|
||||
|
||||
# TODO: remove when added to telegram-bot-types
|
||||
business_connection
|
||||
business_message
|
||||
edited_business_message
|
||||
deleted_business_messages
|
||||
message_reaction
|
||||
message_reaction_count
|
||||
chat_boost
|
||||
removed_chat_boost
|
||||
purchased_paid_media
|
||||
pre_checkout_query
|
||||
]).
|
||||
map { |x| [x, Telegram::Bot::Types.const_get(x.camelize)] }.to_h.
|
||||
merge(
|
||||
'chat_member' => Telegram::Bot::Types::ChatMemberUpdated
|
||||
)
|
||||
unique_types.each do |type, type_class|
|
||||
context "with #{type}" do
|
||||
type_class = Telegram::Bot::Types.const_get(type.camelize)
|
||||
let(:payload_type) { type }
|
||||
let(:payload) do
|
||||
{}.tap do |result|
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesController do
|
||||
include_context 'telegram/bot/updates_controller'
|
||||
|
||||
@@ -5,7 +7,7 @@ RSpec.describe Telegram::Bot::UpdatesController do
|
||||
subject { controller.action_for_payload }
|
||||
|
||||
def stub_payload(*fields)
|
||||
Hash[fields.map { |x| [x, double(x)] }]
|
||||
fields.map { |x| [x, double(x)] }.to_h
|
||||
end
|
||||
|
||||
context 'when payload is inline_query' do
|
||||
@@ -46,6 +48,8 @@ RSpec.describe Telegram::Bot::UpdatesController do
|
||||
chosen_inline_result
|
||||
callback_query
|
||||
poll_answer
|
||||
chat_join_request
|
||||
pre_checkout_query
|
||||
]
|
||||
(described_class::PAYLOAD_TYPES - custom_payload_types).each do |type|
|
||||
context "when payload is #{type}" do
|
||||
@@ -89,7 +93,7 @@ RSpec.describe Telegram::Bot::UpdatesController do
|
||||
|
||||
describe '#process' do
|
||||
subject { -> { controller.process(:action, *args) } }
|
||||
let(:args) { %i[arg1 arg2] }
|
||||
let(:args) { %i[arg_1 arg_2] }
|
||||
let(:controller_class) do
|
||||
Class.new(described_class) do
|
||||
attr_reader :acted, :hooked
|
||||
@@ -197,7 +201,7 @@ RSpec.describe Telegram::Bot::UpdatesController do
|
||||
end
|
||||
|
||||
context 'when options hash is given' do
|
||||
let(:controller_args) { [bot, from: from, chat: chat] }
|
||||
let(:controller_args) { [bot, {from: from, chat: chat}] }
|
||||
with_reinitialize do
|
||||
its(:bot) { should eq bot }
|
||||
its(:update) { should eq nil }
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot::UpdatesPoller do
|
||||
let(:instance) { described_class.new(bot, controller) }
|
||||
let(:bot) { Telegram::Bot::Client.new('token') }
|
||||
|
||||
@@ -1,3 +1,5 @@
|
||||
# frozen_string_literal: true
|
||||
|
||||
RSpec.describe Telegram::Bot do
|
||||
it 'has a version number' do
|
||||
expect(described_class::VERSION).not_to be nil
|
||||
|
||||
@@ -1,4 +1,6 @@
|
||||
lib = File.expand_path('../lib', __FILE__)
|
||||
# frozen_string_literal: true
|
||||
|
||||
lib = File.expand_path('lib', __dir__)
|
||||
$LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
|
||||
require 'telegram/bot/version'
|
||||
|
||||
@@ -12,6 +14,10 @@ Gem::Specification.new do |spec|
|
||||
spec.homepage = 'https://github.com/telegram-bot-rb/telegram-bot'
|
||||
spec.license = 'MIT'
|
||||
|
||||
spec.metadata = {
|
||||
'rubygems_mfa_required' => 'true',
|
||||
}
|
||||
|
||||
spec.files = `git ls-files -z`.split("\x0").reject { |f| f.match(%r{^spec/}) }
|
||||
spec.bindir = 'exe'
|
||||
spec.executables = spec.files.grep(%r{^exe/}) { |f| File.basename(f) }
|
||||
@@ -19,8 +25,8 @@ Gem::Specification.new do |spec|
|
||||
|
||||
spec.required_ruby_version = '>= 2.4'
|
||||
|
||||
spec.add_dependency 'actionpack', '>= 4.0', '< 6.2'
|
||||
spec.add_dependency 'activesupport', '>= 4.0', '< 6.2'
|
||||
spec.add_dependency 'actionpack', '>= 4.0', '< 8.1'
|
||||
spec.add_dependency 'activesupport', '>= 4.0', '< 8.1'
|
||||
spec.add_dependency 'httpclient', '~> 2.7'
|
||||
|
||||
spec.add_development_dependency 'bundler', '> 1.16'
|
||||
|
||||
Ссылка в новой задаче
Block a user